aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_tcp.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2011-07-14 12:27:17 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2011-07-14 12:27:17 +0000
commit66add8aa9a02a01b1ffa94b9f111b6a3a6ca1cec (patch)
treee783cc79c7e83efc9e9a913e7c24f9ccc2b1ddb2 /src/transport/plugin_transport_tcp.c
parentd3c70c3bfde07f93c72effebbfd11436a5a9590c (diff)
downloadgnunet-66add8aa9a02a01b1ffa94b9f111b6a3a6ca1cec.tar.gz
gnunet-66add8aa9a02a01b1ffa94b9f111b6a3a6ca1cec.zip
addiional checks
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
-rw-r--r--src/transport/plugin_transport_tcp.c10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c
index 168a2b344..6ad6f979e 100644
--- a/src/transport/plugin_transport_tcp.c
+++ b/src/transport/plugin_transport_tcp.c
@@ -1113,6 +1113,7 @@ tcp_plugin_send (void *cls,
1113 target, 1113 target,
1114 NULL, 1114 NULL,
1115 GNUNET_YES); 1115 GNUNET_YES);
1116 GNUNET_assert (session != NULL);
1116 1117
1117 /* create new message entry */ 1118 /* create new message entry */
1118 pm = GNUNET_malloc (sizeof (struct PendingMessage) + msgbuf_size); 1119 pm = GNUNET_malloc (sizeof (struct PendingMessage) + msgbuf_size);
@@ -1189,9 +1190,18 @@ tcp_plugin_send (void *cls,
1189 addrlen); 1190 addrlen);
1190 session->connect_alen = addrlen; 1191 session->connect_alen = addrlen;
1191 } 1192 }
1193 else /* session != NULL */
1194 {
1195 /* check if session is valid */
1196 struct Session * ses = plugin->sessions;
1197 while ((ses != NULL) && (ses != session))
1198 ses = ses->next;
1199 GNUNET_assert (ses != NULL);
1200 }
1192 GNUNET_assert (session != NULL); 1201 GNUNET_assert (session != NULL);
1193 GNUNET_assert (session->client != NULL); 1202 GNUNET_assert (session->client != NULL);
1194 1203
1204
1195 GNUNET_SERVER_client_set_timeout(session->client, GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT); 1205 GNUNET_SERVER_client_set_timeout(session->client, GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT);
1196 GNUNET_STATISTICS_update (plugin->env->stats, 1206 GNUNET_STATISTICS_update (plugin->env->stats,
1197 gettext_noop ("# bytes currently in TCP buffers"), 1207 gettext_noop ("# bytes currently in TCP buffers"),