diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-03-11 12:44:06 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-03-11 12:44:06 +0000 |
commit | 914ec7ef9e59b69868b92fced96d6693b2097e13 (patch) | |
tree | 9891a3f70dd894a2af1582baf1a3c9ccd53beb43 /src/chat | |
parent | 69d9f80b83053162a38a292fc8a024acb6a463a9 (diff) | |
download | gnunet-914ec7ef9e59b69868b92fced96d6693b2097e13.tar.gz gnunet-914ec7ef9e59b69868b92fced96d6693b2097e13.zip |
add cork option to core api:
Diffstat (limited to 'src/chat')
-rw-r--r-- | src/chat/gnunet-service-chat.c | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/chat/gnunet-service-chat.c b/src/chat/gnunet-service-chat.c index bbf4dd8f1..a1e180009 100644 --- a/src/chat/gnunet-service-chat.c +++ b/src/chat/gnunet-service-chat.c | |||
@@ -262,6 +262,7 @@ send_message_noficiation (void *cls, | |||
262 | #endif | 262 | #endif |
263 | my_msg = GNUNET_memdup (msg, ntohs (msg->header.size)); | 263 | my_msg = GNUNET_memdup (msg, ntohs (msg->header.size)); |
264 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, | 264 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, |
265 | GNUNET_NO, | ||
265 | 1, | 266 | 1, |
266 | MAX_TRANSMIT_DELAY, | 267 | MAX_TRANSMIT_DELAY, |
267 | &pid, | 268 | &pid, |
@@ -553,6 +554,7 @@ send_join_noficiation (void *cls, | |||
553 | strlen (entry->room) + | 554 | strlen (entry->room) + |
554 | entry->meta_len; | 555 | entry->meta_len; |
555 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, | 556 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, |
557 | GNUNET_NO, | ||
556 | 1, | 558 | 1, |
557 | MAX_TRANSMIT_DELAY, | 559 | MAX_TRANSMIT_DELAY, |
558 | &pid, | 560 | &pid, |
@@ -750,6 +752,7 @@ send_confirmation_receipt (void *cls, | |||
750 | my_receipt = GNUNET_memdup (receipt, | 752 | my_receipt = GNUNET_memdup (receipt, |
751 | sizeof (struct P2PConfirmationReceiptMessage)); | 753 | sizeof (struct P2PConfirmationReceiptMessage)); |
752 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, | 754 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, |
755 | GNUNET_YES, | ||
753 | 1, | 756 | 1, |
754 | MAX_TRANSMIT_DELAY, | 757 | MAX_TRANSMIT_DELAY, |
755 | &pid, | 758 | &pid, |
@@ -936,6 +939,7 @@ send_leave_noficiation (void *cls, | |||
936 | public_key = GNUNET_memdup (&entry->public_key, | 939 | public_key = GNUNET_memdup (&entry->public_key, |
937 | sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); | 940 | sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); |
938 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, | 941 | if (NULL == GNUNET_CORE_notify_transmit_ready (core, |
942 | GNUNET_YES, | ||
939 | 1, | 943 | 1, |
940 | MAX_TRANSMIT_DELAY, | 944 | MAX_TRANSMIT_DELAY, |
941 | &pid, | 945 | &pid, |
@@ -1408,6 +1412,7 @@ handle_p2p_sync_request (void *cls, | |||
1408 | strlen (entry->room) + | 1412 | strlen (entry->room) + |
1409 | entry->meta_len; | 1413 | entry->meta_len; |
1410 | th = GNUNET_CORE_notify_transmit_ready (core, | 1414 | th = GNUNET_CORE_notify_transmit_ready (core, |
1415 | GNUNET_NO, | ||
1411 | 1, | 1416 | 1, |
1412 | MAX_TRANSMIT_DELAY, | 1417 | MAX_TRANSMIT_DELAY, |
1413 | other, | 1418 | other, |
@@ -1589,6 +1594,7 @@ peer_connect_handler (void *cls, | |||
1589 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | 1594 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, |
1590 | "Peer connected: %s\n", GNUNET_i2s (peer)); | 1595 | "Peer connected: %s\n", GNUNET_i2s (peer)); |
1591 | th = GNUNET_CORE_notify_transmit_ready (core, | 1596 | th = GNUNET_CORE_notify_transmit_ready (core, |
1597 | GNUNET_YES, | ||
1592 | 1, | 1598 | 1, |
1593 | MAX_TRANSMIT_DELAY, | 1599 | MAX_TRANSMIT_DELAY, |
1594 | peer, | 1600 | peer, |