diff options
Diffstat (limited to 'src/transport/plugin_transport_http_server.c')
-rw-r--r-- | src/transport/plugin_transport_http_server.c | 19 |
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 | ||