target,
NULL,
GNUNET_YES);
+ GNUNET_assert (session != NULL);
/* create new message entry */
pm = GNUNET_malloc (sizeof (struct PendingMessage) + msgbuf_size);
addrlen);
session->connect_alen = addrlen;
}
+ else /* session != NULL */
+ {
+ /* check if session is valid */
+ struct Session * ses = plugin->sessions;
+ while ((ses != NULL) && (ses != session))
+ ses = ses->next;
+ if (ses == NULL)
+ {
+ GNUNET_break (0);
+ return -1;
+ }
+ }
GNUNET_assert (session != NULL);
GNUNET_assert (session->client != NULL);
+
GNUNET_SERVER_client_set_timeout(session->client, GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT);
GNUNET_STATISTICS_update (plugin->env->stats,
gettext_noop ("# bytes currently in TCP buffers"),