diff options
author | LRN <lrn1986@gmail.com> | 2013-03-13 17:49:26 +0000 |
---|---|---|
committer | LRN <lrn1986@gmail.com> | 2013-03-13 17:49:26 +0000 |
commit | 405f776bc08486af4edb80e18149c0829732b347 (patch) | |
tree | d5fc635a51641dec6b53cb2540276f34ae8f6210 /src/util/connection.c | |
parent | 3ceae682287492ecc768aea5c4c463216a35774d (diff) | |
download | gnunet-405f776bc08486af4edb80e18149c0829732b347.tar.gz gnunet-405f776bc08486af4edb80e18149c0829732b347.zip |
All-encompassing ARM update
Diffstat (limited to 'src/util/connection.c')
-rw-r--r-- | src/util/connection.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/util/connection.c b/src/util/connection.c index c4795cebe..ea35b04e1 100644 --- a/src/util/connection.c +++ b/src/util/connection.c | |||
@@ -1153,14 +1153,22 @@ process_notify (struct GNUNET_CONNECTION_Handle *connection) | |||
1153 | size_t size; | 1153 | size_t size; |
1154 | GNUNET_CONNECTION_TransmitReadyNotify notify; | 1154 | GNUNET_CONNECTION_TransmitReadyNotify notify; |
1155 | 1155 | ||
1156 | LOG (GNUNET_ERROR_TYPE_DEBUG, "process_notify is running\n"); | ||
1157 | |||
1156 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == connection->write_task); | 1158 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == connection->write_task); |
1157 | if (NULL == (notify = connection->nth.notify_ready)) | 1159 | if (NULL == (notify = connection->nth.notify_ready)) |
1160 | { | ||
1161 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Noone to notify\n"); | ||
1158 | return GNUNET_NO; | 1162 | return GNUNET_NO; |
1163 | } | ||
1159 | used = connection->write_buffer_off - connection->write_buffer_pos; | 1164 | used = connection->write_buffer_off - connection->write_buffer_pos; |
1160 | avail = connection->write_buffer_size - used; | 1165 | avail = connection->write_buffer_size - used; |
1161 | size = connection->nth.notify_size; | 1166 | size = connection->nth.notify_size; |
1162 | if (size > avail) | 1167 | if (size > avail) |
1168 | { | ||
1169 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Not enough buffer\n"); | ||
1163 | return GNUNET_NO; | 1170 | return GNUNET_NO; |
1171 | } | ||
1164 | connection->nth.notify_ready = NULL; | 1172 | connection->nth.notify_ready = NULL; |
1165 | if (connection->write_buffer_size - connection->write_buffer_off < size) | 1173 | if (connection->write_buffer_size - connection->write_buffer_off < size) |
1166 | { | 1174 | { |