aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_http_server.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_http_server.c')
-rw-r--r--src/transport/plugin_transport_http_server.c19
1 files changed, 15 insertions, 4 deletions
diff --git a/src/transport/plugin_transport_http_server.c b/src/transport/plugin_transport_http_server.c
index c7a1bfe7a..47b0bda7f 100644
--- a/src/transport/plugin_transport_http_server.c
+++ b/src/transport/plugin_transport_http_server.c
@@ -598,11 +598,13 @@ server_delete_session (struct Session *s)
598 } 598 }
599 notify_session_monitor (plugin, 599 notify_session_monitor (plugin,
600 s, 600 s,
601 GNUNET_TRANSPORT_SS_DOWN); 601 GNUNET_TRANSPORT_SS_DONE);
602 if (GNUNET_YES == s->known_to_service) 602 if (GNUNET_YES == s->known_to_service)
603 {
603 plugin->env->session_end (plugin->env->cls, 604 plugin->env->session_end (plugin->env->cls,
604 s->address, 605 s->address,
605 s); 606 s);
607 }
606 if (NULL != s->msg_tk) 608 if (NULL != s->msg_tk)
607 { 609 {
608 GNUNET_SERVER_mst_destroy (s->msg_tk); 610 GNUNET_SERVER_mst_destroy (s->msg_tk);
@@ -1461,6 +1463,9 @@ server_lookup_connection (struct HTTP_Server_Plugin *plugin,
1461 GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE); 1463 GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
1462 notify_session_monitor (plugin, 1464 notify_session_monitor (plugin,
1463 s, 1465 s,
1466 GNUNET_TRANSPORT_SS_INIT);
1467 notify_session_monitor (plugin,
1468 s,
1464 GNUNET_TRANSPORT_SS_HANDSHAKE); 1469 GNUNET_TRANSPORT_SS_HANDSHAKE);
1465 LOG (GNUNET_ERROR_TYPE_DEBUG, 1470 LOG (GNUNET_ERROR_TYPE_DEBUG,
1466 "Creating new session %p for peer `%s' connecting from `%s'\n", 1471 "Creating new session %p for peer `%s' connecting from `%s'\n",
@@ -1512,7 +1517,13 @@ server_lookup_connection (struct HTTP_Server_Plugin *plugin,
1512 (NULL != s->server_recv) ) 1517 (NULL != s->server_recv) )
1513 { 1518 {
1514 s->known_to_service = GNUNET_YES; 1519 s->known_to_service = GNUNET_YES;
1515 plugin->env->session_start (NULL, s->address ,s, NULL, 0); 1520 notify_session_monitor (plugin,
1521 s,
1522 GNUNET_TRANSPORT_SS_UP);
1523 plugin->env->session_start (NULL,
1524 s->address,
1525 s,
1526 NULL, 0);
1516 } 1527 }
1517 1528
1518 if ( (NULL == s->server_recv) || 1529 if ( (NULL == s->server_recv) ||
@@ -1592,7 +1603,7 @@ server_send_callback (void *cls,
1592 GNUNET_free (msg); 1603 GNUNET_free (msg);
1593 notify_session_monitor (s->plugin, 1604 notify_session_monitor (s->plugin,
1594 s, 1605 s,
1595 GNUNET_TRANSPORT_SS_UP); 1606 GNUNET_TRANSPORT_SS_UPDATE);
1596 } 1607 }
1597 } 1608 }
1598 if (0 < bytes_read) 1609 if (0 < bytes_read)
@@ -3298,7 +3309,7 @@ send_session_info_iter (void *cls,
3298 3309
3299 notify_session_monitor (plugin, 3310 notify_session_monitor (plugin,
3300 session, 3311 session,
3301 GNUNET_TRANSPORT_SS_UP); 3312 GNUNET_TRANSPORT_SS_INIT);
3302 return GNUNET_OK; 3313 return GNUNET_OK;
3303} 3314}
3304 3315