}
ce = GNUNET_malloc (sizeof (struct ClientEntry));
ce->client = client;
- GNUNET_SERVER_client_keep (client);
GNUNET_CONTAINER_DLL_insert (client_head, client_tail, ce);
GNUNET_SERVER_notification_context_add (nc, client);
return ce;
we = GNUNET_malloc (sizeof (struct WatchEntry));
we->client = client;
we->last_value_set = GNUNET_NO;
- GNUNET_SERVER_client_keep (client);
we->wid = ce->max_wid++;
GNUNET_CONTAINER_DLL_insert (pos->we_head, pos->we_tail, we);
if (pos->value != 0)
start = se->next;
while (NULL != (we = se->we_head))
{
- GNUNET_SERVER_client_drop (we->client);
GNUNET_CONTAINER_DLL_remove (se->we_head, se->we_tail, we);
GNUNET_free (we);
}
{
if (ce->client == client)
{
- GNUNET_SERVER_client_drop (ce->client);
GNUNET_CONTAINER_DLL_remove (client_head, client_tail, ce);
GNUNET_free (ce);
break;
wen = we->next;
if (we->client != client)
continue;
- GNUNET_SERVER_client_drop (we->client);
GNUNET_CONTAINER_DLL_remove (se->we_head, se->we_tail, we);
GNUNET_free (we);
}