diff options
Diffstat (limited to 'src/transport/plugin_transport_udp.c')
-rw-r--r-- | src/transport/plugin_transport_udp.c | 18 |
1 files changed, 13 insertions, 5 deletions
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c index 0a8c3cab4..f185c8738 100644 --- a/src/transport/plugin_transport_udp.c +++ b/src/transport/plugin_transport_udp.c | |||
@@ -2265,13 +2265,17 @@ process_udp_message (struct Plugin *plugin, | |||
2265 | udp_addr, | 2265 | udp_addr, |
2266 | udp_addr_len, | 2266 | udp_addr_len, |
2267 | GNUNET_HELLO_ADDRESS_INFO_NONE); | 2267 | GNUNET_HELLO_ADDRESS_INFO_NONE); |
2268 | if (NULL == (s = udp_plugin_lookup_session (plugin, address))) | 2268 | if (NULL == |
2269 | (s = udp_plugin_lookup_session (plugin, address))) | ||
2269 | { | 2270 | { |
2270 | s = udp_plugin_create_session (plugin, | 2271 | s = udp_plugin_create_session (plugin, |
2271 | address, | 2272 | address, |
2272 | network_type); | 2273 | network_type); |
2273 | plugin->env->session_start (plugin->env->cls, | 2274 | plugin->env->session_start (plugin->env->cls, |
2274 | address, s, NULL, 0); | 2275 | address, |
2276 | s, | ||
2277 | NULL, | ||
2278 | 0); | ||
2275 | notify_session_monitor (s->plugin, | 2279 | notify_session_monitor (s->plugin, |
2276 | s, | 2280 | s, |
2277 | GNUNET_TRANSPORT_SS_INIT); | 2281 | GNUNET_TRANSPORT_SS_INIT); |
@@ -3566,9 +3570,13 @@ libgnunet_plugin_transport_udp_init (void *cls) | |||
3566 | p->sessions = GNUNET_CONTAINER_multipeermap_create (10, GNUNET_NO); | 3570 | p->sessions = GNUNET_CONTAINER_multipeermap_create (10, GNUNET_NO); |
3567 | p->defrag_ctxs = GNUNET_CONTAINER_heap_create ( | 3571 | p->defrag_ctxs = GNUNET_CONTAINER_heap_create ( |
3568 | GNUNET_CONTAINER_HEAP_ORDER_MIN); | 3572 | GNUNET_CONTAINER_HEAP_ORDER_MIN); |
3569 | p->mst = GNUNET_SERVER_mst_create (&process_inbound_tokenized_messages, p); | 3573 | p->mst = GNUNET_SERVER_mst_create (&process_inbound_tokenized_messages, |
3570 | GNUNET_BANDWIDTH_tracker_init (&p->tracker, NULL, NULL, | 3574 | p); |
3571 | GNUNET_BANDWIDTH_value_init ((uint32_t) udp_max_bps), 30); | 3575 | GNUNET_BANDWIDTH_tracker_init (&p->tracker, |
3576 | NULL, | ||
3577 | NULL, | ||
3578 | GNUNET_BANDWIDTH_value_init ((uint32_t) udp_max_bps), | ||
3579 | 30); | ||
3572 | LOG(GNUNET_ERROR_TYPE_DEBUG, | 3580 | LOG(GNUNET_ERROR_TYPE_DEBUG, |
3573 | "Setting up sockets\n"); | 3581 | "Setting up sockets\n"); |
3574 | res = setup_sockets (p, | 3582 | res = setup_sockets (p, |