diff options
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
| -rw-r--r-- | src/transport/plugin_transport_tcp.c | 20 |
1 files changed, 11 insertions, 9 deletions
diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c index d877a7f5b..9221f7e49 100644 --- a/src/transport/plugin_transport_tcp.c +++ b/src/transport/plugin_transport_tcp.c | |||
| @@ -624,14 +624,16 @@ process_pending_messages (struct Session *session) | |||
| 624 | return; | 624 | return; |
| 625 | session->transmit_handle | 625 | session->transmit_handle |
| 626 | = GNUNET_SERVER_notify_transmit_ready (session->client, | 626 | = GNUNET_SERVER_notify_transmit_ready (session->client, |
| 627 | ntohs (session->pending_messages-> | 627 | ntohs (session-> |
| 628 | msg->size) + | 628 | pending_messages->msg-> |
| 629 | (session->pending_messages-> | 629 | size) + |
| 630 | is_welcome ? 0 : sizeof (struct | 630 | (session-> |
| 631 | DataMessage)), | 631 | pending_messages->is_welcome ? 0 : |
| 632 | sizeof (struct DataMessage)), | ||
| 632 | GNUNET_TIME_absolute_get_remaining | 633 | GNUNET_TIME_absolute_get_remaining |
| 633 | (session->pending_messages[0]. | 634 | (session-> |
| 634 | timeout), &do_transmit, session); | 635 | pending_messages[0].timeout), |
| 636 | &do_transmit, session); | ||
| 635 | } | 637 | } |
| 636 | 638 | ||
| 637 | 639 | ||
| @@ -803,8 +805,8 @@ disconnect_session (struct Session *session) | |||
| 803 | } | 805 | } |
| 804 | if (session->transmit_handle != NULL) | 806 | if (session->transmit_handle != NULL) |
| 805 | { | 807 | { |
| 806 | GNUNET_CONNECTION_notify_transmit_ready_cancel (session-> | 808 | GNUNET_CONNECTION_notify_transmit_ready_cancel |
| 807 | transmit_handle); | 809 | (session->transmit_handle); |
| 808 | session->transmit_handle = NULL; | 810 | session->transmit_handle = NULL; |
| 809 | } | 811 | } |
| 810 | while (NULL != (pm = session->pending_messages)) | 812 | while (NULL != (pm = session->pending_messages)) |