Author: Pekka Riikonen <priikone@silcnet.org>
- Copyright (C) 2001 - 2006 Pekka Riikonen
+ Copyright (C) 2001 - 2007 Pekka Riikonen
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
#include "silcclient.h"
#include "client_internal.h"
-/* XXX locking */
-
/************************ Client Searching Locally **************************/
/* Finds entry for client by the client's ID. Returns the entry or NULL
/* Find ID from cache */
if (!silc_idcache_find_by_id_one(conn->internal->client_cache, client_id,
- &id_cache))
+ &id_cache)) {
+ silc_mutex_unlock(conn->internal->lock);
return NULL;
+ }
client_entry = id_cache->context;
/* Reference */
silc_client_ref_client(client, conn, client_entry);
- silc_mutex_lock(conn->internal->lock);
+ silc_mutex_unlock(conn->internal->lock);
SILC_LOG_DEBUG(("Found"));
/* Finds clients by nickname from local cache. */
-SilcDList silc_client_get_clients_local(SilcClient client,
- SilcClientConnection conn,
- const char *nickname,
- const char *format)
+SilcDList silc_client_get_clients_local_ext(SilcClient client,
+ SilcClientConnection conn,
+ const char *nickname,
+ SilcBool get_all,
+ SilcBool get_valid)
{
SilcIDCacheEntry id_cache;
SilcList list;
SilcDList clients;
SilcClientEntry entry;
- char *nicknamec;
+ char nick[128 + 1], *nicknamec, *parsed = NULL, *format = NULL;
+ char server[256 + 1];
if (!client || !conn || !nickname)
return NULL;
+ /* Get nickname from nickname@server string */
+ silc_parse_userfqdn(nickname, nick, sizeof(nick), server, sizeof(server));
+
+ /* Parse nickname in case it is formatted */
+ if (!silc_client_nickname_parse(client, conn, (char *)nick, &parsed))
+ return NULL;
+
+ if (!get_all)
+ format = (char *)nick;
+
+ SILC_LOG_DEBUG(("Find clients by nickname %s", parsed));
+
/* Normalize nickname for search */
- nicknamec = silc_identifier_check(nickname, strlen(nickname),
+ nicknamec = silc_identifier_check(parsed, strlen(parsed),
SILC_STRING_UTF8, 128, NULL);
- if (!nicknamec)
- silc_free(nicknamec);
+ if (!nicknamec) {
+ silc_free(parsed);
return NULL;
+ }
clients = silc_dlist_init();
if (!clients) {
silc_free(nicknamec);
+ silc_free(parsed);
return NULL;
}
silc_mutex_lock(conn->internal->lock);
/* Find from cache */
+ silc_list_init(list, struct SilcIDCacheEntryStruct, next);
if (!silc_idcache_find_by_name(conn->internal->client_cache, nicknamec,
&list)) {
silc_mutex_unlock(conn->internal->lock);
silc_free(nicknamec);
+ silc_free(parsed);
silc_dlist_uninit(clients);
return NULL;
}
+ silc_list_start(list);
- if (!format) {
+ if (get_all) {
/* Take all without any further checking */
- silc_list_start(list);
while ((id_cache = silc_list_get(list))) {
- silc_client_ref_client(client, conn, entry);
- silc_dlist_add(clients, id_cache->context);
+ entry = id_cache->context;
+ if (!get_valid || entry->internal.valid) {
+ silc_client_ref_client(client, conn, id_cache->context);
+ silc_dlist_add(clients, id_cache->context);
+ }
}
} else {
/* Check multiple cache entries for exact match */
- silc_list_start(list);
while ((id_cache = silc_list_get(list))) {
entry = id_cache->context;
- if (silc_utf8_strcasecmp(entry->nickname, format)) {
+
+ /* If server was provided, find entries that either have no server
+ set or have the same server. Ignore those that have different
+ server. */
+ if (server[0] && entry->server &&
+ !silc_utf8_strcasecmp(entry->server, server))
+ continue;
+
+ if (silc_utf8_strcasecmp(entry->nickname,
+ format ? format : parsed) &&
+ (!get_valid || entry->internal.valid)) {
silc_client_ref_client(client, conn, entry);
silc_dlist_add(clients, entry);
+
+ /* If format is NULL, we find one exact match with the base
+ nickname (parsed). */
+ if (!format)
+ break;
}
}
}
silc_mutex_unlock(conn->internal->lock);
- silc_dlist_start(clients);
-
silc_free(nicknamec);
+ silc_free(parsed);
+
+ if (!silc_dlist_count(clients)) {
+ silc_dlist_uninit(clients);
+ return NULL;
+ }
+
+ SILC_LOG_DEBUG(("Found %d clients", silc_dlist_count(clients)));
+
+ silc_dlist_start(clients);
return clients;
}
+/* Finds clients by nickname from local cache. */
+
+SilcDList silc_client_get_clients_local(SilcClient client,
+ SilcClientConnection conn,
+ const char *nickname,
+ SilcBool return_all)
+{
+ return silc_client_get_clients_local_ext(client, conn, nickname, return_all,
+ TRUE);
+}
+
/********************** Client Resolving from Server ************************/
/* Resolving context */
SilcDList clients;
SilcGetClientCallback completion;
void *context;
+ SilcClientEntry client_entry;
} *SilcClientGetClientInternal;
/* Resolving command callback */
if (error != SILC_STATUS_OK) {
SILC_LOG_DEBUG(("Resolving failed: %s", silc_get_status_message(error)));
+
+ if (i->client_entry) {
+ i->client_entry->internal.resolve_cmd_ident = 0;
+ silc_client_unref_client(client, conn, i->client_entry);
+ }
+
if (i->completion)
i->completion(client, conn, error, NULL, i->context);
goto out;
client_entry = va_arg(ap, SilcClientEntry);
silc_client_ref_client(client, conn, client_entry);
silc_dlist_add(i->clients, client_entry);
+ client_entry->internal.resolve_cmd_ident = 0;
}
if (status == SILC_STATUS_OK || status == SILC_STATUS_LIST_END) {
/* Deliver the clients to the caller */
if (i->completion) {
SILC_LOG_DEBUG(("Resolved %d clients", silc_dlist_count(i->clients)));
+
+ if (i->client_entry) {
+ i->client_entry->internal.resolve_cmd_ident = 0;
+ silc_client_unref_client(client, conn, i->client_entry);
+ }
+
silc_dlist_start(i->clients);
i->completion(client, conn, SILC_STATUS_OK, i->clients, i->context);
}
/* Resolves client information from server by the client ID. */
-void silc_client_get_client_by_id_resolve(SilcClient client,
- SilcClientConnection conn,
- SilcClientID *client_id,
- SilcBuffer attributes,
- SilcGetClientCallback completion,
- void *context)
+SilcUInt16
+silc_client_get_client_by_id_resolve(SilcClient client,
+ SilcClientConnection conn,
+ SilcClientID *client_id,
+ SilcBuffer attributes,
+ SilcGetClientCallback completion,
+ void *context)
{
SilcClientGetClientInternal i;
+ SilcClientEntry client_entry;
SilcBuffer idp;
+ SilcUInt16 cmd_ident;
- if (!client || !conn | !client_id)
- return;
+ if (!client || !conn | !client_id) {
+ SILC_LOG_ERROR(("Missing arguments to "
+ "silc_client_get_clients_by_id_resolve call"));
+ return 0;
+ }
SILC_LOG_DEBUG(("Resolve client by ID (%s)",
silc_id_render(client_id, SILC_ID_CLIENT)));
i = silc_calloc(1, sizeof(*i));
if (!i)
- return;
+ return 0;
i->completion = completion;
i->context = context;
+ i->clients = silc_dlist_init();
+ if (!i->clients) {
+ silc_free(i);
+ return 0;
+ }
+
+ /* Attach to resolving, if on going */
+ client_entry = silc_client_get_client_by_id(client, conn, client_id);
+ if (client_entry && client_entry->internal.resolve_cmd_ident) {
+ SILC_LOG_DEBUG(("Attach to existing resolving"));
+ silc_client_unref_client(client, conn, client_entry);
+ silc_client_command_pending(conn, SILC_COMMAND_NONE,
+ client_entry->internal.resolve_cmd_ident,
+ silc_client_get_clients_cb, i);
+ return client_entry->internal.resolve_cmd_ident;
+ }
/* Send the command */
idp = silc_id_payload_encode(client_id, SILC_ID_CLIENT);
- silc_client_command_send(client, conn, SILC_COMMAND_WHOIS,
- silc_client_get_clients_cb, i,
- 2, 3, silc_buffer_datalen(attributes),
- 4, silc_buffer_datalen(idp));
+ cmd_ident = silc_client_command_send(client, conn, SILC_COMMAND_WHOIS,
+ silc_client_get_clients_cb, i,
+ 2, 3, silc_buffer_datalen(attributes),
+ 4, silc_buffer_datalen(idp));
+ if (!cmd_ident && completion)
+ completion(client, conn, SILC_STATUS_ERR_RESOURCE_LIMIT, NULL, context);
+
+ if (client_entry && cmd_ident) {
+ client_entry->internal.resolve_cmd_ident = cmd_ident;
+ i->client_entry = client_entry;
+ } else {
+ silc_client_unref_client(client, conn, client_entry);
+ }
+
silc_buffer_free(idp);
+
+ return cmd_ident;
}
/* Finds client entry or entries by the `nickname' and `server'. The
void *context)
{
SilcClientGetClientInternal i;
- char userhost[768 + 1];
+ char nick[128 + 1], serv[256 + 1], userhost[768 + 1], *parsed = NULL;
int len;
SILC_LOG_DEBUG(("Resolve client by %s command",
silc_get_command_name(command)));
- if (!client || !conn)
+ if (!client || !conn) {
+ SILC_LOG_ERROR(("Missing arguments to silc_client_get_clients call"));
return 0;
- if (!nickname && !attributes)
+ }
+ if (!nickname && !attributes) {
+ SILC_LOG_ERROR(("Missing arguments to silc_client_get_clients call"));
return 0;
+ }
+
+ /* Parse server name from the nickname if set */
+ if (silc_parse_userfqdn(nickname, nick, sizeof(nick),
+ serv, sizeof(serv)) == 2)
+ server = (const char *)serv;
+ nickname = (const char *)nick;
+
+ /* Parse nickname in case it is formatted */
+ if (silc_client_nickname_parse(client, conn, (char *)nickname, &parsed))
+ nickname = (const char *)parsed;
i = silc_calloc(1, sizeof(*i));
- if (!i)
+ if (!i) {
+ silc_free(parsed);
return 0;
+ }
i->clients = silc_dlist_init();
- if (!i->clients)
+ if (!i->clients) {
+ silc_free(parsed);
+ silc_free(i);
return 0;
+ }
i->completion = completion;
i->context = context;
} else if (nickname) {
silc_strncat(userhost, sizeof(userhost) - 1, nickname, strlen(nickname));
}
+ silc_free(parsed);
/* Send the command */
if (command == SILC_COMMAND_IDENTIFY)
/* Get client entry */
client_entry = silc_client_get_client_by_id(client, conn, &id.u.client_id);
- if (client_entry) {
- silc_client_ref_client(client, conn, client_entry);
+ if (client_entry)
silc_dlist_add(clients, client_entry);
- }
if (!silc_buffer_pull(i->client_id_list, idp_len)) {
status = SILC_STATUS_ERR_BAD_CLIENT_ID;
out:
if (status != SILC_STATUS_OK && i->completion)
i->completion(client, conn, status, NULL, i->context);
+
silc_client_list_free(client, conn, clients);
+ silc_buffer_free(i->client_id_list);
silc_free(i);
+
return FALSE;
}
command reply for example returns this sort of list. The `completion'
will be called after the entries are available. */
-void silc_client_get_clients_by_list(SilcClient client,
- SilcClientConnection conn,
- SilcUInt32 list_count,
- SilcBuffer client_id_list,
- SilcGetClientCallback completion,
- void *context)
+SilcUInt16 silc_client_get_clients_by_list(SilcClient client,
+ SilcClientConnection conn,
+ SilcUInt32 list_count,
+ SilcBuffer client_id_list,
+ SilcGetClientCallback completion,
+ void *context)
{
GetClientsByListInternal in;
SilcClientEntry entry;
unsigned char **res_argv = NULL;
SilcUInt32 *res_argv_lens = NULL, *res_argv_types = NULL, res_argc = 0;
- SilcUInt16 idp_len;
+ SilcUInt16 idp_len, cmd_ident;
SilcID id;
int i;
SILC_LOG_DEBUG(("Resolve clients from Client ID list"));
if (!client || !conn || !client_id_list)
- return;
+ return 0;
in = silc_calloc(1, sizeof(*in));
if (!in)
- return;
+ return 0;
in->completion = completion;
in->context = context;
in->list_count = list_count;
/* Check if we have this client cached already. If we don't have the
entry or it has incomplete info, then resolve it from the server. */
entry = silc_client_get_client_by_id(client, conn, &id.u.client_id);
- if (!entry || !entry->nickname || !entry->username || !entry->realname) {
+ if (!entry || !entry->nickname[0] || !entry->username[0] ||
+ !entry->realname) {
if (!res_argv) {
res_argv = silc_calloc(list_count, sizeof(*res_argv));
res_argv_lens = silc_calloc(list_count, sizeof(*res_argv_lens));
res_argv_types = silc_calloc(list_count, sizeof(*res_argv_types));
- if (!res_argv || !res_argv_lens || !res_argv_types)
+ if (!res_argv || !res_argv_lens || !res_argv_types) {
+ silc_client_unref_client(client, conn, entry);
goto err;
+ }
}
res_argv[res_argc] = client_id_list->data;
res_argv_lens[res_argc] = idp_len;
- res_argv_types[res_argc] = res_argc + 5;
+ res_argv_types[res_argc] = res_argc + 4;
res_argc++;
}
+ silc_client_unref_client(client, conn, entry);
if (!silc_buffer_pull(client_id_list, idp_len))
goto err;
/* Query the unknown client information from server */
if (res_argc) {
- silc_client_command_send_argv(client, conn, SILC_COMMAND_WHOIS,
- silc_client_get_clients_list_cb,
- in, res_argc, res_argv, res_argv_lens,
- res_argv_types);
+ cmd_ident = silc_client_command_send_argv(client,
+ conn, SILC_COMMAND_WHOIS,
+ silc_client_get_clients_list_cb,
+ in, res_argc, res_argv,
+ res_argv_lens,
+ res_argv_types);
silc_free(res_argv);
silc_free(res_argv_lens);
silc_free(res_argv_types);
- return;
+ return cmd_ident;
}
/* We have the clients in cache, get them and call the completion */
silc_client_get_clients_list_cb(client, conn, SILC_COMMAND_WHOIS,
SILC_STATUS_OK, SILC_STATUS_OK, in, NULL);
- return;
+ return 0;
err:
silc_buffer_free(in->client_id_list);
silc_free(res_argv);
silc_free(res_argv_lens);
silc_free(res_argv_types);
+ return 0;
}
#if 0
entry = chu->client;
/* If the entry has incomplete info, then resolve it from the server. */
- if (!entry->nickname || !entry->realname) {
+ if (!entry->nickname[0] || !entry->realname) {
if (entry->status & SILC_CLIENT_STATUS_RESOLVING) {
/* Attach to this resolving and wait until it finishes */
silc_client_command_pending(
SilcUInt32 mode)
{
SilcClientEntry client_entry;
- char *nick = NULL;
+ char *nick = NULL, parsed[128 + 1];
SILC_LOG_DEBUG(("Adding new client entry"));
if (!client_entry)
return NULL;
+ silc_rwlock_alloc(&client_entry->internal.lock);
+ silc_atomic_init32(&client_entry->internal.refcnt, 0);
+ silc_atomic_init32(&client_entry->internal.deleted, 1);
client_entry->id = *id;
- client_entry->internal.valid = TRUE;
client_entry->mode = mode;
client_entry->realname = userinfo ? strdup(userinfo) : NULL;
- silc_parse_userfqdn(nickname, client_entry->nickname,
- sizeof(client_entry->nickname),
- client_entry->server,
- sizeof(client_entry->server));
+
+ silc_parse_userfqdn(nickname, parsed, sizeof(parsed),
+ client_entry->server, sizeof(client_entry->server));
+ if (nickname && client->internal->params->full_nicknames)
+ silc_snprintf(client_entry->nickname, sizeof(client_entry->nickname),
+ nickname);
+ else if (nickname)
+ silc_snprintf(client_entry->nickname, sizeof(client_entry->nickname),
+ parsed);
+
silc_parse_userfqdn(username, client_entry->username,
sizeof(client_entry->username),
client_entry->hostname,
sizeof(client_entry->hostname));
- client_entry->channels = silc_hash_table_alloc(1, silc_hash_ptr, NULL, NULL,
- NULL, NULL, NULL, TRUE);
+
+ client_entry->channels = silc_hash_table_alloc(NULL, 1, silc_hash_ptr, NULL,
+ NULL, NULL, NULL, NULL, TRUE);
if (!client_entry->channels) {
silc_free(client_entry->realname);
silc_free(client_entry);
/* Normalize nickname */
if (client_entry->nickname[0]) {
- nick = silc_identifier_check(client_entry->nickname,
- strlen(client_entry->nickname),
+ nick = silc_identifier_check(parsed, strlen(parsed),
SILC_STRING_UTF8, 128, NULL);
if (!nick) {
silc_free(client_entry->realname);
}
}
- /* Format the nickname */
- silc_client_nickname_format(client, conn, client_entry);
+ silc_mutex_lock(conn->internal->lock);
/* Add client to cache, the normalized nickname is saved to cache */
if (!silc_idcache_add(conn->internal->client_cache, nick,
silc_free(client_entry->realname);
silc_hash_table_free(client_entry->channels);
silc_free(client_entry);
+ silc_mutex_unlock(conn->internal->lock);
return NULL;
}
client_entry->nickname_normalized = nick;
+ silc_mutex_unlock(conn->internal->lock);
+ silc_client_ref_client(client, conn, client_entry);
+
+ /* Format the nickname */
+ silc_client_nickname_format(client, conn, client_entry, FALSE);
+
+ if (client_entry->nickname[0])
+ client_entry->internal.valid = TRUE;
+
+ SILC_LOG_DEBUG(("Added %p", client_entry));
+
return client_entry;
}
-/* Updates the `client_entry' with the new information sent as argument. */
+/* Updates the `client_entry' with the new information sent as argument.
+ This handles entry locking internally. */
void silc_client_update_client(SilcClient client,
SilcClientConnection conn,
const char *userinfo,
SilcUInt32 mode)
{
- char *nick = NULL;
+ char *nick = NULL, parsed[128 + 1];
SILC_LOG_DEBUG(("Update client entry"));
+ silc_rwlock_wrlock(client_entry->internal.lock);
+
if (!client_entry->realname && userinfo)
client_entry->realname = strdup(userinfo);
+
if ((!client_entry->username[0] || !client_entry->hostname[0]) && username)
silc_parse_userfqdn(username, client_entry->username,
sizeof(client_entry->username),
client_entry->hostname,
sizeof(client_entry->username));
+
if (!client_entry->nickname[0] && nickname) {
- silc_parse_userfqdn(nickname, client_entry->nickname,
- sizeof(client_entry->nickname),
- client_entry->server,
- sizeof(client_entry->server));
+ silc_parse_userfqdn(nickname, parsed, sizeof(parsed),
+ client_entry->server, sizeof(client_entry->server));
+ if (client->internal->params->full_nicknames)
+ silc_snprintf(client_entry->nickname, sizeof(client_entry->nickname),
+ nickname);
+ else
+ silc_snprintf(client_entry->nickname, sizeof(client_entry->nickname),
+ parsed);
/* Normalize nickname */
- nick = silc_identifier_check(client_entry->nickname,
- strlen(client_entry->nickname),
+ nick = silc_identifier_check(parsed, strlen(parsed),
SILC_STRING_UTF8, 128, NULL);
- if (!nick)
+ if (!nick) {
+ silc_rwlock_unlock(client_entry->internal.lock);
return;
+ }
/* Format nickname */
- silc_client_nickname_format(client, conn, client_entry);
+ silc_client_nickname_format(client, conn, client_entry,
+ client_entry == conn->local_entry);
- /* Remove the old cache entry and create a new one */
- silc_idcache_del_by_context(conn->internal->client_cache, client_entry,
- NULL);
- silc_idcache_add(conn->internal->client_cache, nick, &client_entry->id,
- client_entry);
+ /* Update cache entry */
+ silc_mutex_lock(conn->internal->lock);
+ silc_idcache_update_by_context(conn->internal->client_cache,
+ client_entry, NULL, nick, TRUE);
+ silc_mutex_unlock(conn->internal->lock);
+ client_entry->nickname_normalized = nick;
+ client_entry->internal.valid = TRUE;
}
client_entry->mode = mode;
+
+ silc_rwlock_unlock(client_entry->internal.lock);
+}
+
+/* Change a client's nickname. Must be called with `client_entry' locked. */
+
+SilcBool silc_client_change_nickname(SilcClient client,
+ SilcClientConnection conn,
+ SilcClientEntry client_entry,
+ const char *new_nick,
+ SilcClientID *new_id,
+ const unsigned char *idp,
+ SilcUInt32 idp_len)
+{
+ char *tmp;
+
+ SILC_LOG_DEBUG(("Change nickname %s to %s", client_entry->nickname,
+ new_nick));
+
+ /* Normalize nickname */
+ tmp = silc_identifier_check(new_nick, strlen(new_nick),
+ SILC_STRING_UTF8, 128, NULL);
+ if (!tmp)
+ return FALSE;
+
+ /* Update the client entry */
+ silc_mutex_lock(conn->internal->lock);
+ if (!silc_idcache_update_by_context(conn->internal->client_cache,
+ client_entry, new_id, tmp, TRUE)) {
+ silc_free(tmp);
+ silc_mutex_unlock(conn->internal->lock);
+ return FALSE;
+ }
+ silc_mutex_unlock(conn->internal->lock);
+
+ memset(client_entry->nickname, 0, sizeof(client_entry->nickname));
+ memcpy(client_entry->nickname, new_nick, strlen(new_nick));
+ client_entry->nickname_normalized = tmp;
+ silc_client_nickname_format(client, conn, client_entry,
+ client_entry == conn->local_entry);
+
+ /* For my client entry, update ID and set new ID to packet stream */
+ if (client_entry == conn->local_entry) {
+ if (idp && idp_len) {
+ silc_buffer_enlarge(conn->internal->local_idp, idp_len);
+ silc_buffer_put(conn->internal->local_idp, idp, idp_len);
+ }
+ if (new_id)
+ silc_packet_set_ids(conn->stream, SILC_ID_CLIENT, conn->local_id,
+ 0, NULL);
+ }
+
+ client_entry->internal.valid = TRUE;
+ return TRUE;
}
/* Deletes the client entry and frees all memory. */
SilcClientConnection conn,
SilcClientEntry client_entry)
{
- SILC_LOG_DEBUG(("Start"));
-
silc_free(client_entry->realname);
+ silc_free(client_entry->nickname_normalized);
+ silc_free(client_entry->internal.key);
if (client_entry->public_key)
silc_pkcs_public_key_free(client_entry->public_key);
silc_hash_table_free(client_entry->channels);
silc_cipher_free(client_entry->internal.send_key);
if (client_entry->internal.receive_key)
silc_cipher_free(client_entry->internal.receive_key);
- silc_free(client_entry->internal.key);
-#if 0
- silc_client_ftp_session_free_client(conn, client_entry);
- if (client_entry->internal->ke)
+ if (client_entry->internal.hmac_send)
+ silc_hmac_free(client_entry->internal.hmac_send);
+ if (client_entry->internal.hmac_receive)
+ silc_hmac_free(client_entry->internal.hmac_receive);
+ silc_client_ftp_session_free_client(client, client_entry);
+ if (client_entry->internal.ke)
silc_client_abort_key_agreement(client, conn, client_entry);
-#endif /* 0 */
+ silc_atomic_uninit32(&client_entry->internal.deleted);
+ silc_atomic_uninit32(&client_entry->internal.refcnt);
+ silc_rwlock_free(client_entry->internal.lock);
silc_free(client_entry);
}
SilcBool silc_client_del_client(SilcClient client, SilcClientConnection conn,
SilcClientEntry client_entry)
{
- SilcBool ret = silc_idcache_del_by_context(conn->internal->client_cache,
- client_entry, NULL);
-#if 0
- if (ret) {
- /* Remove from channels */
- silc_client_remove_from_channels(client, conn, client_entry);
+ if (!client_entry)
+ return FALSE;
- /* Free the client entry data */
- silc_client_del_client_entry(client, conn, client_entry);
+ SILC_LOG_DEBUG(("Marking client entry %p deleted"));
+
+ if (silc_atomic_sub_int32(&client_entry->internal.deleted, 1) != 0) {
+ SILC_LOG_DEBUG(("Client entry %p already marked deleted"));
+ return FALSE;
}
-#endif
- return ret;
+ silc_client_unref_client(client, conn, client_entry);
+ return TRUE;
+}
+
+/* Internal routine used to find client by ID and if not found this creates
+ new client entry and returns it. */
+
+SilcClientEntry silc_client_get_client(SilcClient client,
+ SilcClientConnection conn,
+ SilcClientID *client_id)
+{
+ SilcClientEntry client_entry;
+
+ client_entry = silc_client_get_client_by_id(client, conn, client_id);
+ if (!client_entry) {
+ client_entry = silc_client_add_client(client, conn, NULL, NULL, NULL,
+ client_id, 0);
+ if (!client_entry)
+ return NULL;
+ silc_client_ref_client(client, conn, client_entry);
+ }
+
+ return client_entry;
+}
+
+/* Lock client */
+
+void silc_client_lock_client(SilcClientEntry client_entry)
+{
+ silc_rwlock_rdlock(client_entry->internal.lock);
+}
+
+/* Unlock client */
+
+void silc_client_unlock_client(SilcClientEntry client_entry)
+{
+ silc_rwlock_unlock(client_entry->internal.lock);
}
/* Take reference of client entry */
-void silc_client_ref_client(SilcClient client, SilcClientConnection conn,
- SilcClientEntry client_entry)
+SilcClientEntry silc_client_ref_client(SilcClient client,
+ SilcClientConnection conn,
+ SilcClientEntry client_entry)
{
- silc_atomic_add_int8(&client_entry->internal.refcnt, 1);
+ silc_atomic_add_int32(&client_entry->internal.refcnt, 1);
+ SILC_LOG_DEBUG(("Client %p refcnt %d->%d", client_entry,
+ silc_atomic_get_int32(&client_entry->internal.refcnt) - 1,
+ silc_atomic_get_int32(&client_entry->internal.refcnt)));
+ return client_entry;
}
/* Release reference of client entry */
void silc_client_unref_client(SilcClient client, SilcClientConnection conn,
SilcClientEntry client_entry)
{
- if (silc_atomic_sub_int8(&client_entry->internal.refcnt, 1) == 0) {
- silc_client_del_client(client, conn, client_entry);
+ SilcBool ret;
+
+ if (!client_entry)
return;
+
+ SILC_LOG_DEBUG(("Client %p refcnt %d->%d", client_entry,
+ silc_atomic_get_int32(&client_entry->internal.refcnt),
+ silc_atomic_get_int32(&client_entry->internal.refcnt) - 1));
+
+ if (silc_atomic_sub_int32(&client_entry->internal.refcnt, 1) > 0)
+ return;
+
+ SILC_LOG_DEBUG(("Deleting client %p (%d)", client_entry,
+ silc_atomic_get_int32(&client_entry->internal.deleted)));
+
+ silc_mutex_lock(conn->internal->lock);
+ ret = silc_idcache_del_by_context(conn->internal->client_cache,
+ client_entry, NULL);
+ silc_mutex_unlock(conn->internal->lock);
+
+ if (ret) {
+ /* Remove from channels */
+ silc_client_remove_from_channels(client, conn, client_entry);
+
+ /* Free the client entry data */
+ silc_client_del_client_entry(client, conn, client_entry);
}
}
{
SilcClientEntry client_entry;
- silc_dlist_start(client_list);
- while ((client_entry = silc_dlist_get(client_list)))
- silc_client_unref_client(client, conn, client_entry);
+ if (client_list) {
+ silc_dlist_start(client_list);
+ while ((client_entry = silc_dlist_get(client_list)))
+ silc_client_unref_client(client, conn, client_entry);
- silc_dlist_uninit(client_list);
+ silc_dlist_uninit(client_list);
+ }
}
+/* Formats the nickname of the client specified by the `client_entry'.
+ If the format is specified by the application this will format the
+ nickname and replace the old nickname in the client entry. If the
+ format string is not specified then this function has no effect.
+ Returns the client entry that was formatted. */
-/************************* Channel Entry Routines ***************************/
-
-/* Add new channel entry to the ID Cache */
-
-SilcChannelEntry silc_client_add_channel(SilcClient client,
- SilcClientConnection conn,
- const char *channel_name,
- SilcUInt32 mode,
- SilcChannelID *channel_id)
+SilcClientEntry silc_client_nickname_format(SilcClient client,
+ SilcClientConnection conn,
+ SilcClientEntry client_entry,
+ SilcBool priority)
{
- SilcChannelEntry channel;
- char *channel_namec;
+ char *cp;
+ char newnick[128 + 1];
+ int i, off = 0, len;
+ SilcDList clients;
+ SilcClientEntry entry, unformatted = NULL;
+ SilcBool formatted = FALSE;
- SILC_LOG_DEBUG(("Start"));
+ if (!client->internal->params->nickname_format[0])
+ return client_entry;
+ if (!client_entry->nickname[0])
+ return NULL;
- channel = silc_calloc(1, sizeof(*channel));
- channel->channel_name = strdup(channel_name);
- channel->id = channel_id;
- channel->mode = mode;
- channel->user_list = silc_hash_table_alloc(1, silc_hash_ptr, NULL, NULL,
- NULL, NULL, NULL, TRUE);
+ SILC_LOG_DEBUG(("Format nickname"));
- /* Normalize channel name */
- channel_namec = silc_channel_name_check(channel_name, strlen(channel_name),
- SILC_STRING_UTF8, 256, NULL);
- if (!channel_namec) {
- silc_free(channel->channel_name);
- silc_hash_table_free(channel->user_list);
- silc_free(channel);
+ /* Get all clients with same nickname. Do not perform the formatting
+ if there aren't any clients with same nickname unless the application
+ is forcing us to do so. */
+ clients = silc_client_get_clients_local_ext(client, conn,
+ client_entry->nickname,
+ TRUE, FALSE);
+ if (!clients)
return NULL;
+ if (silc_dlist_count(clients) == 1 && !priority &&
+ !client->internal->params->nickname_force_format) {
+ silc_client_list_free(client, conn, clients);
+ return client_entry;
}
- /* Put it to the ID cache */
- if (!silc_idcache_add(conn->internal->channel_cache, channel_namec,
- (void *)channel->id, (void *)channel)) {
- silc_free(channel_namec);
- silc_free(channel->channel_name);
- silc_hash_table_free(channel->user_list);
- silc_free(channel);
- return NULL;
- }
+ /* Is the requested client formatted already */
+ if (client_entry->nickname_normalized &&
+ !silc_utf8_strcasecmp(client_entry->nickname,
+ client_entry->nickname_normalized))
+ formatted = TRUE;
- return channel;
-}
+ if (client->internal->params->nickname_force_format)
+ formatted = FALSE;
-/* Foreach callbcak to free all users from the channel when deleting a
- channel entry. */
+ /* Find unformatted client entry */
+ while ((entry = silc_dlist_get(clients))) {
+ if (!entry->internal.valid)
+ continue;
+ if (entry == client_entry)
+ continue;
+ if (silc_utf8_strcasecmp(entry->nickname, entry->nickname_normalized)) {
+ unformatted = entry;
+ break;
+ }
+ }
-static void silc_client_del_channel_foreach(void *key, void *context,
- void *user_context)
-{
- SilcChannelUser chu = (SilcChannelUser)context;
+ /* If there are no other unformatted clients and the requested client is
+ unformatted, just return it. */
+ if (!unformatted && !formatted) {
+ silc_client_list_free(client, conn, clients);
+ return client_entry;
+ }
- SILC_LOG_DEBUG(("Start"));
+ /* If priority formatting then the requested client will get the
+ unformatted nickname, and the unformatted client will get a new
+ formatted nickname. */
+ if (priority) {
+ if (formatted) {
+ /* Simply change the client's nickname to unformatted */
+ if (!silc_client_nickname_parse(client, conn, client_entry->nickname,
+ &cp))
+ return NULL;
+
+ silc_snprintf(client_entry->nickname, sizeof(client_entry->nickname),
+ cp);
+ silc_free(cp);
+ }
- /* Remove the context from the client's channel hash table as that
- table and channel's user_list hash table share this same context. */
- silc_hash_table_del(chu->client->channels, chu->channel);
- silc_free(chu);
-}
+ if (!unformatted) {
+ /* There was no other unformatted client */
+ silc_client_list_free(client, conn, clients);
+ return client_entry;
+ }
-/* Removes channel from the cache by the channel entry. */
+ /* Now format the previously unformatted client */
+ client_entry = unformatted;
+ formatted = FALSE;
+ }
-SilcBool silc_client_del_channel(SilcClient client, SilcClientConnection conn,
- SilcChannelEntry channel)
-{
- SilcBool ret = silc_idcache_del_by_context(conn->internal->channel_cache,
- channel, NULL);
+ /* If already formatted just return it */
+ if (formatted) {
+ silc_client_list_free(client, conn, clients);
+ return client_entry;
+ }
- SILC_LOG_DEBUG(("Start"));
+ memset(newnick, 0, sizeof(newnick));
+ cp = client->internal->params->nickname_format;
+ while (cp && *cp) {
+ if (*cp == '%') {
+ cp++;
+ continue;
+ }
- /* Free all client entrys from the users list. The silc_hash_table_free
- will free all the entries so they are not freed at the foreach
- callback. */
- silc_hash_table_foreach(channel->user_list, silc_client_del_channel_foreach,
- NULL);
- silc_hash_table_free(channel->user_list);
-
- silc_free(channel->channel_name);
- silc_free(channel->topic);
- silc_free(channel->id);
- if (channel->founder_key)
- silc_pkcs_public_key_free(channel->founder_key);
- silc_free(channel->key);
- if (channel->channel_key)
- silc_cipher_free(channel->channel_key);
- if (channel->hmac)
- silc_hmac_free(channel->hmac);
- if (channel->old_channel_keys) {
- SilcCipher key;
- silc_dlist_start(channel->old_channel_keys);
- while ((key = silc_dlist_get(channel->old_channel_keys)) != SILC_LIST_END)
- silc_cipher_free(key);
- silc_dlist_uninit(channel->old_channel_keys);
- }
- if (channel->old_hmacs) {
- SilcHmac hmac;
- silc_dlist_start(channel->old_hmacs);
- while ((hmac = silc_dlist_get(channel->old_hmacs)) != SILC_LIST_END)
- silc_hmac_free(hmac);
- silc_dlist_uninit(channel->old_hmacs);
+ switch(*cp) {
+ case 'n':
+ /* Nickname */
+ if (!client_entry->nickname[0])
+ break;
+ len = strlen(client_entry->nickname);
+ memcpy(&newnick[off], client_entry->nickname, len);
+ off += len;
+ break;
+ case 'h':
+ /* Stripped hostname */
+ if (!client_entry->hostname[0])
+ break;
+ len = strcspn(client_entry->hostname, ".");
+ i = strcspn(client_entry->hostname, "-");
+ if (i < len)
+ len = i;
+ memcpy(&newnick[off], client_entry->hostname, len);
+ off += len;
+ break;
+ case 'H':
+ /* Full hostname */
+ if (!client_entry->hostname[0])
+ break;
+ len = strlen(client_entry->hostname);
+ memcpy(&newnick[off], client_entry->hostname, len);
+ off += len;
+ break;
+ case 'a':
+ /* Ascending number */
+ {
+ char tmp[6];
+ int num, max = 1;
+
+ if (silc_dlist_count(clients) == 1)
+ break;
+
+ silc_dlist_start(clients);
+ while ((entry = silc_dlist_get(clients))) {
+ if (!silc_utf8_strncasecmp(entry->nickname, newnick, off))
+ continue;
+ if (strlen(entry->nickname) <= off)
+ continue;
+ num = atoi(&entry->nickname[off]);
+ if (num > max)
+ max = num;
+ }
+
+ memset(tmp, 0, sizeof(tmp));
+ silc_snprintf(tmp, sizeof(tmp) - 1, "%d", ++max);
+ len = strlen(tmp);
+ memcpy(&newnick[off], tmp, len);
+ off += len;
+ }
+ break;
+ default:
+ /* Some other character in the string */
+ memcpy(&newnick[off], cp, 1);
+ off++;
+ break;
+ }
+
+ cp++;
}
- silc_schedule_task_del_by_context(conn->client->schedule, channel);
- silc_client_del_channel_private_keys(client, conn, channel);
- silc_free(channel);
- return ret;
+
+ newnick[off] = 0;
+ memset(client_entry->nickname, 0, sizeof(client_entry->nickname));
+ memcpy(client_entry->nickname, newnick, strlen(newnick));
+ silc_client_list_free(client, conn, clients);
+
+ return client_entry;
}
-/* Replaces the channel ID of the `channel' to `new_id'. Returns FALSE
- if the ID could not be changed. */
+/* Parses nickname according to nickname format string */
-SilcBool silc_client_replace_channel_id(SilcClient client,
- SilcClientConnection conn,
- SilcChannelEntry channel,
- SilcChannelID *new_id)
+SilcBool silc_client_nickname_parse(SilcClient client,
+ SilcClientConnection conn,
+ char *nickname,
+ char **ret_nick)
{
- char *channel_namec;
+ char *cp, s = 0, e = 0, *nick;
+ SilcBool n = FALSE;
+ int len;
- if (!new_id)
+ if (!client->internal->params->nickname_format[0]) {
+ *ret_nick = silc_strdup(nickname);
+ return TRUE;
+ }
+
+ if (!nickname || !nickname[0])
return FALSE;
- SILC_LOG_DEBUG(("Old Channel ID id(%s)",
- silc_id_render(channel->id, SILC_ID_CHANNEL)));
- SILC_LOG_DEBUG(("New Channel ID id(%s)",
- silc_id_render(new_id, SILC_ID_CHANNEL)));
+ cp = client->internal->params->nickname_format;
+ while (cp && *cp) {
+ if (*cp == '%') {
+ cp++;
+ continue;
+ }
- silc_idcache_del_by_id(conn->internal->channel_cache, channel->id, NULL);
- silc_free(channel->id);
- channel->id = new_id;
+ switch(*cp) {
+ case 'n':
+ n = TRUE;
+ break;
- /* Normalize channel name */
- channel_namec = silc_channel_name_check(channel->channel_name,
- strlen(channel->channel_name),
- SILC_STRING_UTF8, 256, NULL);
- if (!channel_namec)
+ case 'h':
+ case 'H':
+ case 'a':
+ break;
+
+ default:
+ /* Get separator character */
+ if (n)
+ e = *cp;
+ else
+ s = *cp;
+ break;
+ }
+
+ cp++;
+ }
+ if (!n)
return FALSE;
- return silc_idcache_add(conn->internal->channel_cache, channel_namec,
- channel->id, channel) != NULL;
+ /* Parse the nickname */
+ nick = nickname;
+ len = strlen(nick);
+ if (s)
+ if (strchr(nickname, s))
+ nick = strchr(nickname, s) + 1;
+ if (e)
+ if (strchr(nick, e))
+ len = strchr(nick, e) - nick;
+ if (!len)
+ return FALSE;
+
+ *ret_nick = silc_memdup(nick, len);
+ if (!(*ret_nick))
+ return FALSE;
+
+ SILC_LOG_DEBUG(("Parsed nickname: %s", *ret_nick));
+
+ return TRUE;
}
+/************************ Channel Searching Locally *************************/
+
/* Finds entry for channel by the channel name. Returns the entry or NULL
if the entry was not found. It is found only if the client is joined
to the channel. */
SilcClientConnection conn,
char *channel)
{
+ SilcList list;
SilcIDCacheEntry id_cache;
- SilcChannelEntry entry;
+ SilcChannelEntry entry = NULL;
+ char chname[256 + 1], server[256 + 1];
- assert(client && conn);
- if (!channel)
+ if (!client || !conn || !channel)
return NULL;
- SILC_LOG_DEBUG(("Start"));
+ SILC_LOG_DEBUG(("Find channel %s", channel));
+
+ /* Parse server name from channel name */
+ silc_parse_userfqdn(channel, chname, sizeof(chname), server, sizeof(server));
/* Normalize name for search */
- channel = silc_channel_name_check(channel, strlen(channel), SILC_STRING_UTF8,
+ channel = silc_channel_name_check(chname, strlen(chname), SILC_STRING_UTF8,
256, NULL);
if (!channel)
return NULL;
- if (!silc_idcache_find_by_name_one(conn->internal->channel_cache, channel,
- &id_cache)) {
+ silc_mutex_lock(conn->internal->lock);
+
+ if (!silc_idcache_find_by_name(conn->internal->channel_cache, channel,
+ &list)) {
+ silc_mutex_unlock(conn->internal->lock);
silc_free(channel);
return NULL;
}
- entry = (SilcChannelEntry)id_cache->context;
+ /* If server name was specified with channel name, find the correct
+ channel entry with the server name. There can only be one channel
+ with same name on same server. */
+ silc_list_start(list);
+ if (server[0]) {
+ while ((id_cache = silc_list_get(list))) {
+ entry = id_cache->context;
+ if (!entry->server[0])
+ continue;
+ if (silc_utf8_strcasecmp(entry->server, server))
+ break;
+ }
+ } else {
+ /* Get first channel without server name specified or one with our
+ current server connection name */
+ while ((id_cache = silc_list_get(list))) {
+ entry = id_cache->context;
+ if (!entry->server[0])
+ break;
+ if (silc_utf8_strcasecmp(entry->server, conn->remote_host))
+ break;
+ }
+ }
- SILC_LOG_DEBUG(("Found"));
+ if (!id_cache) {
+ silc_mutex_unlock(conn->internal->lock);
+ silc_free(channel);
+ return NULL;
+ }
+
+ SILC_LOG_DEBUG(("Found channel %s%s%s", entry->channel_name,
+ entry->server[0] ? "@" : "", entry->server));
+
+ /* Reference */
+ silc_client_ref_channel(client, conn, entry);
+ silc_mutex_unlock(conn->internal->lock);
silc_free(channel);
SilcIDCacheEntry id_cache;
SilcChannelEntry entry;
- assert(client && conn);
- if (!channel_id)
+ if (!client || !conn || !channel_id)
return NULL;
- SILC_LOG_DEBUG(("Start"));
+ SILC_LOG_DEBUG(("Find channel by id %s",
+ silc_id_render(channel_id, SILC_ID_CHANNEL)));
+
+ silc_mutex_lock(conn->internal->lock);
if (!silc_idcache_find_by_id_one(conn->internal->channel_cache, channel_id,
- &id_cache))
+ &id_cache)) {
+ silc_mutex_unlock(conn->internal->lock);
return NULL;
-
- entry = (SilcChannelEntry)id_cache->context;
+ }
SILC_LOG_DEBUG(("Found"));
+ entry = id_cache->context;
+
+ /* Reference */
+ silc_client_ref_channel(client, conn, entry);
+ silc_mutex_unlock(conn->internal->lock);
+
return entry;
}
-#if 0
+/********************** Channel Resolving from Server ***********************/
+
+/* Channel resolving context */
typedef struct {
- SilcClient client;
- SilcClientConnection conn;
- union {
- SilcChannelID *channel_id;
- char *channel_name;
- } u;
+ SilcDList channels;
SilcGetChannelCallback completion;
void *context;
-} *GetChannelInternal;
+} *SilcClientGetChannelInternal;
-SILC_CLIENT_CMD_FUNC(get_channel_resolve_callback)
+/* Resolving command callback */
+
+static SilcBool silc_client_get_channel_cb(SilcClient client,
+ SilcClientConnection conn,
+ SilcCommand command,
+ SilcStatus status,
+ SilcStatus error,
+ void *context,
+ va_list ap)
{
- GetChannelInternal i = (GetChannelInternal)context;
+ SilcClientGetChannelInternal i = context;
SilcChannelEntry entry;
- SILC_LOG_DEBUG(("Start"));
+ if (error != SILC_STATUS_OK) {
+ SILC_LOG_DEBUG(("Resolving failed: %s", silc_get_status_message(error)));
+ if (i->completion)
+ i->completion(client, conn, error, NULL, i->context);
+ goto out;
+ }
- /* Get the channel */
- entry = silc_client_get_channel(i->client, i->conn, i->u.channel_name);
- if (entry) {
- i->completion(i->client, i->conn, &entry, 1, i->context);
- } else {
- i->completion(i->client, i->conn, NULL, 0, i->context);
+ /* Add the returned channel to list */
+ if (i->completion) {
+ entry = va_arg(ap, SilcChannelEntry);
+ silc_client_ref_channel(client, conn, entry);
+ silc_dlist_add(i->channels, entry);
+ }
+
+ if (status == SILC_STATUS_OK || status == SILC_STATUS_LIST_END) {
+ /* Deliver the channels to the caller */
+ if (i->completion) {
+ SILC_LOG_DEBUG(("Resolved %d channels", silc_dlist_count(i->channels)));
+ silc_dlist_start(i->channels);
+ i->completion(client, conn, SILC_STATUS_OK, i->channels, i->context);
+ }
+ goto out;
}
- silc_free(i->u.channel_name);
+ return TRUE;
+
+ out:
+ silc_client_list_free_channels(client, conn, i->channels);
silc_free(i);
+ return FALSE;
}
/* Resolves channel entry from the server by the channel name. */
SilcGetChannelCallback completion,
void *context)
{
- GetChannelInternal i = silc_calloc(1, sizeof(*i));
+ SilcClientGetChannelInternal i;
- assert(client && conn && channel_name);
+ if (!client || !conn || !channel_name || !completion)
+ return;
- SILC_LOG_DEBUG(("Start"));
+ SILC_LOG_DEBUG(("Resolve channel %s", channel_name));
- i->client = client;
- i->conn = conn;
- i->u.channel_name = strdup(channel_name);
+ i = silc_calloc(1, sizeof(*i));
+ if (!i)
+ return;
i->completion = completion;
i->context = context;
+ i->channels = silc_dlist_init();
+ if (!i->channels) {
+ silc_free(i);
+ return;
+ }
+
+ /* Send the command */
+ if (!silc_client_command_send(client, conn, SILC_COMMAND_IDENTIFY,
+ silc_client_get_channel_cb, i, 1,
+ 3, channel_name, strlen(channel_name))) {
+ if (completion)
+ completion(client, conn, SILC_STATUS_ERR_RESOURCE_LIMIT, NULL, context);
+ }
+}
+
+/* Resolves channel information from the server by the channel ID. */
- /* Register our own command reply for this command */
- silc_client_command_register(client, SILC_COMMAND_IDENTIFY, NULL, NULL,
- silc_client_command_reply_identify_i, 0,
- ++conn->cmd_ident);
+SilcUInt16
+silc_client_get_channel_by_id_resolve(SilcClient client,
+ SilcClientConnection conn,
+ SilcChannelID *channel_id,
+ SilcGetChannelCallback completion,
+ void *context)
+{
+ SilcClientGetChannelInternal i;
+ SilcBuffer idp;
+ SilcUInt16 cmd_ident;
+
+ if (!client || !conn || !channel_id || !completion)
+ return 0;
+
+ SILC_LOG_DEBUG(("Resolve channel by id %s",
+ silc_id_render(channel_id, SILC_ID_CHANNEL)));
+
+ i = silc_calloc(1, sizeof(*i));
+ if (!i)
+ return 0;
+ i->completion = completion;
+ i->context = context;
+ i->channels = silc_dlist_init();
+ if (!i->channels) {
+ silc_free(i);
+ return 0;
+ }
/* Send the command */
- silc_client_command_send(client, conn, SILC_COMMAND_IDENTIFY,
- conn->cmd_ident,
- 1, 3, channel_name, strlen(channel_name));
-
- /* Add pending callback */
- silc_client_command_pending(conn, SILC_COMMAND_IDENTIFY, conn->cmd_ident,
- silc_client_command_get_channel_resolve_callback,
- (void *)i);
+ idp = silc_id_payload_encode(channel_id, SILC_ID_CHANNEL);
+ cmd_ident = silc_client_command_send(client, conn, SILC_COMMAND_IDENTIFY,
+ silc_client_get_channel_cb, i, 1,
+ 5, silc_buffer_datalen(idp));
+ silc_buffer_free(idp);
+ if (!cmd_ident && completion)
+ completion(client, conn, SILC_STATUS_ERR_RESOURCE_LIMIT, NULL, context);
+
+ return cmd_ident;
}
-SILC_CLIENT_CMD_FUNC(get_channel_by_id_callback)
+/************************* Channel Entry Routines ***************************/
+
+/* Add new channel entry to the ID Cache */
+
+SilcChannelEntry silc_client_add_channel(SilcClient client,
+ SilcClientConnection conn,
+ const char *channel_name,
+ SilcUInt32 mode,
+ SilcChannelID *channel_id)
+{
+ SilcChannelEntry channel;
+ char *channel_namec, name[256 + 1];
+
+ SILC_LOG_DEBUG(("Adding channel %s", channel_name));
+
+ channel = silc_calloc(1, sizeof(*channel));
+ if (!channel)
+ return NULL;
+
+ silc_rwlock_alloc(&channel->internal.lock);
+ silc_atomic_init32(&channel->internal.refcnt, 0);
+ silc_atomic_init32(&channel->internal.deleted, 1);
+ channel->id = *channel_id;
+ channel->mode = mode;
+
+ silc_parse_userfqdn(channel_name, name, sizeof(name),
+ channel->server, sizeof(channel->server));
+ if (client->internal->params->full_channel_names)
+ channel->channel_name = strdup(channel_name);
+ else
+ channel->channel_name = strdup(name);
+
+ if (!channel->channel_name) {
+ silc_rwlock_free(channel->internal.lock);
+ silc_atomic_uninit32(&channel->internal.refcnt);
+ silc_free(channel);
+ return NULL;
+ }
+
+ channel->user_list = silc_hash_table_alloc(NULL, 1, silc_hash_ptr, NULL, NULL,
+ NULL, NULL, NULL, TRUE);
+ if (!channel->user_list) {
+ silc_rwlock_free(channel->internal.lock);
+ silc_atomic_uninit32(&channel->internal.refcnt);
+ silc_free(channel->channel_name);
+ silc_free(channel);
+ return NULL;
+ }
+
+ /* Normalize channel name */
+ channel_namec = silc_channel_name_check(name, strlen(name),
+ SILC_STRING_UTF8, 256, NULL);
+ if (!channel_namec) {
+ silc_rwlock_free(channel->internal.lock);
+ silc_atomic_uninit32(&channel->internal.refcnt);
+ silc_free(channel->channel_name);
+ silc_hash_table_free(channel->user_list);
+ silc_free(channel);
+ return NULL;
+ }
+
+ silc_mutex_lock(conn->internal->lock);
+
+ /* Add channel to cache, the normalized channel name is saved to cache */
+ if (!silc_idcache_add(conn->internal->channel_cache, channel_namec,
+ &channel->id, channel)) {
+ silc_rwlock_free(channel->internal.lock);
+ silc_atomic_uninit32(&channel->internal.refcnt);
+ silc_free(channel_namec);
+ silc_free(channel->channel_name);
+ silc_hash_table_free(channel->user_list);
+ silc_free(channel);
+ silc_mutex_unlock(conn->internal->lock);
+ return NULL;
+ }
+
+ silc_mutex_unlock(conn->internal->lock);
+ silc_client_ref_channel(client, conn, channel);
+
+ SILC_LOG_DEBUG(("Added %p", channel));
+
+ return channel;
+}
+
+/* Removes channel from the cache by the channel entry. */
+
+SilcBool silc_client_del_channel(SilcClient client, SilcClientConnection conn,
+ SilcChannelEntry channel)
+{
+
+ if (!channel)
+ return FALSE;
+
+ SILC_LOG_DEBUG(("Marking channel entry %p deleted"));
+
+
+ if (silc_atomic_sub_int32(&channel->internal.deleted, 1) != 0) {
+ SILC_LOG_DEBUG(("Channel entry %p already marked deleted"));
+ return FALSE;
+ silc_client_del_channel_private_keys(client, conn, channel);
+ }
+
+ silc_client_unref_channel(client, conn, channel);
+ return TRUE;
+}
+
+/* Replaces the channel ID of the `channel' to `new_id'. Returns FALSE
+ if the ID could not be changed. This handles entry locking internally. */
+
+SilcBool silc_client_replace_channel_id(SilcClient client,
+ SilcClientConnection conn,
+ SilcChannelEntry channel,
+ SilcChannelID *new_id)
+{
+ SilcBool ret = FALSE;
+
+ if (!new_id)
+ return FALSE;
+
+ SILC_LOG_DEBUG(("Old Channel ID id(%s)",
+ silc_id_render(&channel->id, SILC_ID_CHANNEL)));
+ SILC_LOG_DEBUG(("New Channel ID id(%s)",
+ silc_id_render(new_id, SILC_ID_CHANNEL)));
+
+ /* Update the ID */
+ silc_rwlock_wrlock(channel->internal.lock);
+ silc_mutex_lock(conn->internal->lock);
+ silc_idcache_update_by_context(conn->internal->channel_cache, channel,
+ new_id, NULL, FALSE);
+ silc_mutex_unlock(conn->internal->lock);
+ silc_rwlock_unlock(channel->internal.lock);
+
+ return ret;
+}
+
+/* Lock channel */
+
+void silc_client_lock_channel(SilcChannelEntry channel_entry)
+{
+ silc_rwlock_rdlock(channel_entry->internal.lock);
+}
+
+/* Unlock channel */
+
+void silc_client_unlock_channel(SilcChannelEntry channel_entry)
+{
+ silc_rwlock_unlock(channel_entry->internal.lock);
+}
+
+/* Take reference of channel entry */
+
+SilcChannelEntry silc_client_ref_channel(SilcClient client,
+ SilcClientConnection conn,
+ SilcChannelEntry channel_entry)
+{
+ silc_atomic_add_int32(&channel_entry->internal.refcnt, 1);
+ SILC_LOG_DEBUG(("Channel %p refcnt %d->%d", channel_entry,
+ silc_atomic_get_int32(&channel_entry->internal.refcnt) - 1,
+ silc_atomic_get_int32(&channel_entry->internal.refcnt)));
+ return channel_entry;
+}
+
+/* Release reference of channel entry */
+
+void silc_client_unref_channel(SilcClient client, SilcClientConnection conn,
+ SilcChannelEntry channel_entry)
{
- GetChannelInternal i = (GetChannelInternal)context;
- SilcChannelEntry entry;
+ SilcIDCacheEntry id_cache;
+ SilcBool ret = TRUE;
+ SilcCipher key;
+ SilcHmac hmac;
+ char *namec;
- SILC_LOG_DEBUG(("Start"));
+ if (!channel_entry)
+ return;
- /* Get the channel */
- entry = silc_client_get_channel_by_id(i->client, i->conn, i->u.channel_id);
- if (entry) {
- i->completion(i->client, i->conn, &entry, 1, i->context);
- } else {
- i->completion(i->client, i->conn, NULL, 0, i->context);
- }
+ SILC_LOG_DEBUG(("Channel %p refcnt %d->%d", channel_entry,
+ silc_atomic_get_int32(&channel_entry->internal.refcnt),
+ silc_atomic_get_int32(&channel_entry->internal.refcnt)
+ - 1));
- silc_free(i->u.channel_id);
- silc_free(i);
-}
+ if (silc_atomic_sub_int32(&channel_entry->internal.refcnt, 1) > 0)
+ return;
-/* Resolves channel information from the server by the channel ID. */
+ SILC_LOG_DEBUG(("Deleting channel %p", channel_entry));
-void silc_client_get_channel_by_id_resolve(SilcClient client,
- SilcClientConnection conn,
- SilcChannelID *channel_id,
- SilcGetChannelCallback completion,
- void *context)
-{
- SilcBuffer idp;
- GetChannelInternal i = silc_calloc(1, sizeof(*i));
+ silc_mutex_lock(conn->internal->lock);
+ if (silc_idcache_find_by_context(conn->internal->channel_cache, channel_entry,
+ &id_cache)) {
+ namec = id_cache->name;
+ ret = silc_idcache_del_by_context(conn->internal->channel_cache,
+ channel_entry, NULL);
+ silc_free(namec);
+ }
+ silc_mutex_unlock(conn->internal->lock);
- assert(client && conn && channel_id);
+ if (!ret)
+ return;
- SILC_LOG_DEBUG(("Start"));
+ silc_client_empty_channel(client, conn, channel_entry);
+ silc_client_del_channel_private_keys(client, conn, channel_entry);
+ silc_hash_table_free(channel_entry->user_list);
+ silc_free(channel_entry->channel_name);
+ silc_free(channel_entry->topic);
+ if (channel_entry->founder_key)
+ silc_pkcs_public_key_free(channel_entry->founder_key);
+ if (channel_entry->internal.send_key)
+ silc_cipher_free(channel_entry->internal.send_key);
+ if (channel_entry->internal.receive_key)
+ silc_cipher_free(channel_entry->internal.receive_key);
+ if (channel_entry->internal.hmac)
+ silc_hmac_free(channel_entry->internal.hmac);
+ if (channel_entry->internal.old_channel_keys) {
+ silc_dlist_start(channel_entry->internal.old_channel_keys);
+ while ((key = silc_dlist_get(channel_entry->internal.old_channel_keys)))
+ silc_cipher_free(key);
+ silc_dlist_uninit(channel_entry->internal.old_channel_keys);
+ }
+ if (channel_entry->internal.old_hmacs) {
+ silc_dlist_start(channel_entry->internal.old_hmacs);
+ while ((hmac = silc_dlist_get(channel_entry->internal.old_hmacs)))
+ silc_hmac_free(hmac);
+ silc_dlist_uninit(channel_entry->internal.old_hmacs);
+ }
+ if (channel_entry->channel_pubkeys)
+ silc_argument_list_free(channel_entry->channel_pubkeys,
+ SILC_ARGUMENT_PUBLIC_KEY);
+ silc_atomic_uninit32(&channel_entry->internal.deleted);
+ silc_atomic_uninit32(&channel_entry->internal.refcnt);
+ silc_rwlock_free(channel_entry->internal.lock);
+ silc_schedule_task_del_by_context(conn->client->schedule, channel_entry);
+ silc_free(channel_entry);
+}
- i->client = client;
- i->conn = conn;
- i->u.channel_id = silc_id_dup(channel_id, SILC_ID_CHANNEL);
- i->completion = completion;
- i->context = context;
+/* Free channel entry list */
- /* Register our own command reply for this command */
- silc_client_command_register(client, SILC_COMMAND_IDENTIFY, NULL, NULL,
- silc_client_command_reply_identify_i, 0,
- ++conn->cmd_ident);
+void silc_client_list_free_channels(SilcClient client,
+ SilcClientConnection conn,
+ SilcDList channel_list)
+{
+ SilcChannelEntry channel_entry;
- /* Send the command */
- idp = silc_id_payload_encode(channel_id, SILC_ID_CHANNEL);
- silc_client_command_send(client, conn, SILC_COMMAND_IDENTIFY,
- conn->cmd_ident,
- 1, 5, idp->data, idp->len);
- silc_buffer_free(idp);
+ if (channel_list) {
+ silc_dlist_start(channel_list);
+ while ((channel_entry = silc_dlist_get(channel_list)))
+ silc_client_unref_channel(client, conn, channel_entry);
- /* Add pending callback */
- silc_client_command_pending(conn, SILC_COMMAND_IDENTIFY, conn->cmd_ident,
- silc_client_command_get_channel_by_id_callback,
- (void *)i);
+ silc_dlist_uninit(channel_list);
+ }
}
-#endif /* 0 */
+
+/************************* Server Searching Locally *************************/
/* Finds entry for server by the server name. */
SilcIDCacheEntry id_cache;
SilcServerEntry entry;
- assert(client && conn);
- if (!server_name)
+ if (!client || !conn || !server_name)
return NULL;
- SILC_LOG_DEBUG(("Start"));
+ SILC_LOG_DEBUG(("Find server by name %s", server_name));
/* Normalize server name for search */
server_name = silc_identifier_check(server_name, strlen(server_name),
if (!server_name)
return NULL;
+ silc_mutex_lock(conn->internal->lock);
+
if (!silc_idcache_find_by_name_one(conn->internal->server_cache,
server_name, &id_cache)) {
silc_free(server_name);
+ silc_mutex_unlock(conn->internal->lock);
return NULL;
}
- entry = (SilcServerEntry)id_cache->context;
+ SILC_LOG_DEBUG(("Found"));
+
+ /* Reference */
+ entry = id_cache->context;
+ silc_client_ref_server(client, conn, entry);
+
+ silc_mutex_unlock(conn->internal->lock);
silc_free(server_name);
SilcIDCacheEntry id_cache;
SilcServerEntry entry;
- assert(client && conn);
- if (!server_id)
+ if (!client || !conn || !server_id)
return NULL;
- SILC_LOG_DEBUG(("Start"));
+ SILC_LOG_DEBUG(("Find server by id %s",
+ silc_id_render(server_id, SILC_ID_SERVER)));
+
+ silc_mutex_lock(conn->internal->lock);
if (!silc_idcache_find_by_id_one(conn->internal->server_cache,
- (void *)server_id, &id_cache))
+ server_id, &id_cache)) {
+ silc_mutex_unlock(conn->internal->lock);
return NULL;
+ }
+
+ SILC_LOG_DEBUG(("Found"));
- entry = (SilcServerEntry)id_cache->context;
+ /* Reference */
+ entry = id_cache->context;
+ silc_client_ref_server(client, conn, entry);
+
+ silc_mutex_unlock(conn->internal->lock);
return entry;
}
+/*********************** Server Resolving from Server ***********************/
+
+/* Resolving context */
+typedef struct {
+ SilcDList servers;
+ SilcGetServerCallback completion;
+ void *context;
+} *SilcClientGetServerInternal;
+
+/* Resolving command callback */
+
+static SilcBool silc_client_get_server_cb(SilcClient client,
+ SilcClientConnection conn,
+ SilcCommand command,
+ SilcStatus status,
+ SilcStatus error,
+ void *context,
+ va_list ap)
+{
+ SilcClientGetServerInternal i = context;
+ SilcServerEntry server;
+
+ if (error != SILC_STATUS_OK) {
+ SILC_LOG_DEBUG(("Resolving failed: %s", silc_get_status_message(error)));
+ if (i->completion)
+ i->completion(client, conn, error, NULL, i->context);
+ goto out;
+ }
+
+ /* Add the returned servers to list */
+ if (i->completion) {
+ server = va_arg(ap, SilcServerEntry);
+ silc_client_ref_server(client, conn, server);
+ silc_dlist_add(i->servers, server);
+ server->internal.resolve_cmd_ident = 0;
+ }
+
+ if (status == SILC_STATUS_OK || status == SILC_STATUS_LIST_END) {
+ /* Deliver the servers to the caller */
+ if (i->completion) {
+ SILC_LOG_DEBUG(("Resolved %d servers", silc_dlist_count(i->servers)));
+ silc_dlist_start(i->servers);
+ i->completion(client, conn, SILC_STATUS_OK, i->servers, i->context);
+ }
+ goto out;
+ }
+
+ return TRUE;
+
+ out:
+ silc_client_list_free_servers(client, conn, i->servers);
+ silc_free(i);
+ return FALSE;
+}
+
+/* Resolve server by server ID */
+
+SilcUInt16
+silc_client_get_server_by_id_resolve(SilcClient client,
+ SilcClientConnection conn,
+ SilcServerID *server_id,
+ SilcGetServerCallback completion,
+ void *context)
+{
+ SilcClientGetServerInternal i;
+ SilcServerEntry server;
+ SilcBuffer idp;
+ SilcUInt16 cmd_ident;
+
+ if (!client || !conn || !server_id || !completion)
+ return 0;
+
+ SILC_LOG_DEBUG(("Resolve server by id %s",
+ silc_id_render(server_id, SILC_ID_SERVER)));
+
+ i = silc_calloc(1, sizeof(*i));
+ if (!i)
+ return 0;
+ i->completion = completion;
+ i->context = context;
+ i->servers = silc_dlist_init();
+ if (!i->servers) {
+ silc_free(i);
+ return 0;
+ }
+
+ /* Attach to resolving, if on going */
+ server = silc_client_get_server_by_id(client, conn, server_id);
+ if (server && server->internal.resolve_cmd_ident) {
+ SILC_LOG_DEBUG(("Attach to existing resolving"));
+ silc_client_unref_server(client, conn, server);
+ silc_client_command_pending(conn, SILC_COMMAND_NONE,
+ server->internal.resolve_cmd_ident,
+ silc_client_get_server_cb, i);
+ return server->internal.resolve_cmd_ident;
+ }
+
+ /* Send the command */
+ idp = silc_id_payload_encode(server_id, SILC_ID_SERVER);
+ cmd_ident = silc_client_command_send(client, conn, SILC_COMMAND_IDENTIFY,
+ silc_client_get_server_cb, i, 1,
+ 5, silc_buffer_datalen(idp));
+ silc_buffer_free(idp);
+ if (!cmd_ident && completion)
+ completion(client, conn, SILC_STATUS_ERR_RESOURCE_LIMIT, NULL, context);
+
+ if (server && cmd_ident)
+ server->internal.resolve_cmd_ident = cmd_ident;
+
+ silc_client_unref_server(client, conn, server);
+
+ return cmd_ident;
+}
+
+/************************** Server Entry Routines ***************************/
+
/* Add new server entry */
SilcServerEntry silc_client_add_server(SilcClient client,
SilcServerEntry server_entry;
char *server_namec = NULL;
- SILC_LOG_DEBUG(("Start"));
+ if (!server_id)
+ return NULL;
+
+ SILC_LOG_DEBUG(("Adding new server %s", server_name));
server_entry = silc_calloc(1, sizeof(*server_entry));
- if (!server_entry || !server_id)
+ if (!server_entry)
return NULL;
- server_entry->server_id = server_id;
+ silc_rwlock_alloc(&server_entry->internal.lock);
+ silc_atomic_init32(&server_entry->internal.refcnt, 0);
+ server_entry->id = *server_id;
if (server_name)
server_entry->server_name = strdup(server_name);
if (server_info)
server_namec = silc_identifier_check(server_name, strlen(server_name),
SILC_STRING_UTF8, 256, NULL);
if (!server_namec) {
- silc_free(server_entry->server_id);
silc_free(server_entry->server_name);
silc_free(server_entry->server_info);
silc_free(server_entry);
}
}
+ silc_mutex_lock(conn->internal->lock);
+
/* Add server to cache */
if (!silc_idcache_add(conn->internal->server_cache, server_namec,
- server_entry->server_id, server_entry)) {
+ &server_entry->id, server_entry)) {
silc_free(server_namec);
- silc_free(server_entry->server_id);
silc_free(server_entry->server_name);
silc_free(server_entry->server_info);
silc_free(server_entry);
+ silc_mutex_unlock(conn->internal->lock);
return NULL;
}
+ silc_mutex_unlock(conn->internal->lock);
+ silc_client_ref_server(client, conn, server_entry);
+
+ SILC_LOG_DEBUG(("Added %p", server_entry));
+
return server_entry;
}
/* Removes server from the cache by the server entry. */
SilcBool silc_client_del_server(SilcClient client, SilcClientConnection conn,
- SilcServerEntry server)
+ SilcServerEntry server)
{
- SilcBool ret = silc_idcache_del_by_context(conn->internal->server_cache,
- server, NULL);
+ SilcIDCacheEntry id_cache;
+ SilcBool ret = TRUE;
+ char *namec;
+
+ if (!server)
+ return FALSE;
+
+ if (silc_atomic_sub_int32(&server->internal.refcnt, 1) > 0)
+ return FALSE;
+
+ SILC_LOG_DEBUG(("Deleting server %p", server));
+
+ silc_mutex_lock(conn->internal->lock);
+ if (silc_idcache_find_by_context(conn->internal->server_cache, server,
+ &id_cache)) {
+ namec = id_cache->name;
+ ret = silc_idcache_del_by_context(conn->internal->server_cache,
+ server, NULL);
+ silc_free(namec);
+ }
+ silc_mutex_unlock(conn->internal->lock);
+
silc_free(server->server_name);
silc_free(server->server_info);
- silc_free(server->server_id);
+ if (server->public_key)
+ silc_pkcs_public_key_free(server->public_key);
+ silc_atomic_uninit32(&server->internal.refcnt);
+ silc_rwlock_free(server->internal.lock);
silc_free(server);
+
return ret;
}
{
char *server_namec = NULL;
- SILC_LOG_DEBUG(("Start"));
+ SILC_LOG_DEBUG(("Updating server %p", server_entry));
if (server_name &&
(!server_entry->server_name ||
!silc_utf8_strcasecmp(server_entry->server_name, server_name))) {
- silc_idcache_del_by_context(conn->internal->server_cache,
- server_entry, NULL);
+ server_namec = silc_identifier_check(server_name, strlen(server_name),
+ SILC_STRING_UTF8, 256, NULL);
+ if (!server_namec)
+ return;
+
silc_free(server_entry->server_name);
server_entry->server_name = strdup(server_name);
+ if (!server_entry->server_name)
+ return;
- /* Normalize server name */
- if (server_name) {
- server_namec = silc_identifier_check(server_name, strlen(server_name),
- SILC_STRING_UTF8, 256, NULL);
- if (!server_namec)
- return;
-
- silc_idcache_add(conn->internal->server_cache, server_namec,
- server_entry->server_id, server_entry);
- }
+ /* Update cache entry */
+ silc_mutex_lock(conn->internal->lock);
+ silc_idcache_update_by_context(conn->internal->server_cache, server_entry,
+ NULL, server_namec, TRUE);
+ silc_mutex_unlock(conn->internal->lock);
}
if (server_info &&
}
}
-/* Formats the nickname of the client specified by the `client_entry'.
- If the format is specified by the application this will format the
- nickname and replace the old nickname in the client entry. If the
- format string is not specified then this function has no effect. */
+/* Lock server */
-void silc_client_nickname_format(SilcClient client,
- SilcClientConnection conn,
- SilcClientEntry client_entry)
+void silc_client_lock_server(SilcServerEntry server_entry)
{
- char *cp;
- char newnick[128 + 1];
- int i, off = 0, len;
- SilcBool freebase;
- SilcDList clients;
- SilcClientEntry entry, unformatted = NULL;
-
- SILC_LOG_DEBUG(("Start"));
-
- if (!client->internal->params->nickname_format[0])
- return;
+ silc_rwlock_rdlock(server_entry->internal.lock);
+}
- if (!client_entry->nickname)
- return;
+/* Unlock server */
- /* Get all clients with same nickname. Do not perform the formatting
- if there aren't any clients with same nickname unless the application
- is forcing us to do so. */
- clients = silc_client_get_clients_local(client, conn,
- client_entry->nickname, NULL);
- if (!clients && !client->internal->params->nickname_force_format)
- return;
+void silc_client_unlock_server(SilcServerEntry server_entry)
+{
+ silc_rwlock_unlock(server_entry->internal.lock);
+}
- len = 0;
- freebase = TRUE;
- while ((entry = silc_dlist_get(clients))) {
- if (entry->internal.valid && entry != client_entry)
- len++;
- if (entry->internal.valid && entry != client_entry &&
- silc_utf8_strcasecmp(entry->nickname, client_entry->nickname)) {
- freebase = FALSE;
- unformatted = entry;
- }
- }
- if (!len || freebase)
- return;
+/* Take reference of server entry */
- /* If we are changing nickname of our local entry we'll enforce
- that we will always get the unformatted nickname. Give our
- format number to the one that is not formatted now. */
- if (unformatted && client_entry == conn->local_entry)
- client_entry = unformatted;
+SilcServerEntry silc_client_ref_server(SilcClient client,
+ SilcClientConnection conn,
+ SilcServerEntry server_entry)
+{
+ silc_atomic_add_int32(&server_entry->internal.refcnt, 1);
+ SILC_LOG_DEBUG(("Server %p refcnt %d->%d", server_entry,
+ silc_atomic_get_int32(&server_entry->internal.refcnt) - 1,
+ silc_atomic_get_int32(&server_entry->internal.refcnt)));
+ return server_entry;
+}
- memset(newnick, 0, sizeof(newnick));
- cp = client->internal->params->nickname_format;
- while (*cp) {
- if (*cp == '%') {
- cp++;
- continue;
- }
+/* Release reference of server entry */
- switch(*cp) {
- case 'n':
- /* Nickname */
- if (!client_entry->nickname[0])
- break;
- len = strlen(client_entry->nickname);
- memcpy(&newnick[off], client_entry->nickname, len);
- off += len;
- break;
- case 'h':
- /* Stripped hostname */
- if (!client_entry->hostname[0])
- break;
- len = strcspn(client_entry->hostname, ".");
- i = strcspn(client_entry->hostname, "-");
- if (i < len)
- len = i;
- memcpy(&newnick[off], client_entry->hostname, len);
- off += len;
- break;
- case 'H':
- /* Full hostname */
- if (!client_entry->hostname[0])
- break;
- len = strlen(client_entry->hostname);
- memcpy(&newnick[off], client_entry->hostname, len);
- off += len;
- break;
- case 's':
- /* Stripped server name */
- if (!client_entry->server)
- break;
- len = strcspn(client_entry->server, ".");
- memcpy(&newnick[off], client_entry->server, len);
- off += len;
- break;
- case 'S':
- /* Full server name */
- if (!client_entry->server)
- break;
- len = strlen(client_entry->server);
- memcpy(&newnick[off], client_entry->server, len);
- off += len;
- break;
- case 'a':
- /* Ascending number */
- {
- char tmp[6];
- int num, max = 1;
+void silc_client_unref_server(SilcClient client, SilcClientConnection conn,
+ SilcServerEntry server_entry)
+{
+ if (server_entry) {
+ SILC_LOG_DEBUG(("Server %p refcnt %d->%d", server_entry,
+ silc_atomic_get_int32(&server_entry->internal.refcnt),
+ silc_atomic_get_int32(&server_entry->internal.refcnt)
+ - 1));
+ silc_client_del_server(client, conn, server_entry);
+ }
+}
- if (silc_dlist_count(clients) == 1)
- break;
+/* Free server entry list */
- silc_dlist_start(clients);
- while ((entry = silc_dlist_get(clients))) {
- if (!silc_utf8_strncasecmp(entry->nickname, newnick, off))
- continue;
- if (strlen(entry->nickname) <= off)
- continue;
- num = atoi(&entry->nickname[off]);
- if (num > max)
- max = num;
- }
+void silc_client_list_free_servers(SilcClient client,
+ SilcClientConnection conn,
+ SilcDList server_list)
+{
+ SilcServerEntry server_entry;
- memset(tmp, 0, sizeof(tmp));
- snprintf(tmp, sizeof(tmp) - 1, "%d", ++max);
- len = strlen(tmp);
- memcpy(&newnick[off], tmp, len);
- off += len;
- }
- break;
- default:
- /* Some other character in the string */
- memcpy(&newnick[off], cp, 1);
- off++;
- break;
- }
+ if (server_list) {
+ silc_dlist_start(server_list);
+ while ((server_entry = silc_dlist_get(server_list)))
+ silc_client_unref_server(client, conn, server_entry);
- cp++;
+ silc_dlist_uninit(server_list);
}
-
- newnick[off] = 0;
- memcpy(client_entry->nickname, newnick, strlen(newnick));
- silc_dlist_uninit(clients);
}
projects / silc.git / blobdiff