aboutsummaryrefslogtreecommitdiff
path: root/src/util/connection.c
diff options
context:
space:
mode:
authorLRN <lrn1986@gmail.com>2013-03-13 17:49:26 +0000
committerLRN <lrn1986@gmail.com>2013-03-13 17:49:26 +0000
commit405f776bc08486af4edb80e18149c0829732b347 (patch)
treed5fc635a51641dec6b53cb2540276f34ae8f6210 /src/util/connection.c
parent3ceae682287492ecc768aea5c4c463216a35774d (diff)
downloadgnunet-405f776bc08486af4edb80e18149c0829732b347.tar.gz
gnunet-405f776bc08486af4edb80e18149c0829732b347.zip
All-encompassing ARM update
Diffstat (limited to 'src/util/connection.c')
-rw-r--r--src/util/connection.c8
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 {