aboutsummaryrefslogtreecommitdiff
path: root/src/core/core_api.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2014-01-30 19:22:23 +0000
committerChristian Grothoff <christian@grothoff.org>2014-01-30 19:22:23 +0000
commit6daf13eaa64b5b041edce219f30ab8dcfe38cdf5 (patch)
treec56e4517a0ee08cfb013e296b7d7cf33f2ab49d8 /src/core/core_api.c
parent6fd0a7efde08115b568b99b7755861a50f1b6c2e (diff)
downloadgnunet-6daf13eaa64b5b041edce219f30ab8dcfe38cdf5.tar.gz
gnunet-6daf13eaa64b5b041edce219f30ab8dcfe38cdf5.zip
-towards fixing #3295 (core traffic prioritization)
Diffstat (limited to 'src/core/core_api.c')
-rw-r--r--src/core/core_api.c11
1 files changed, 7 insertions, 4 deletions
diff --git a/src/core/core_api.c b/src/core/core_api.c
index 56bd29df3..7818a60a3 100644
--- a/src/core/core_api.c
+++ b/src/core/core_api.c
@@ -700,7 +700,8 @@ transmit_message (void *cls, size_t size, void *buf)
700 * @param ignore_currently_down transmit message even if not initialized? 700 * @param ignore_currently_down transmit message even if not initialized?
701 */ 701 */
702static void 702static void
703trigger_next_request (struct GNUNET_CORE_Handle *h, int ignore_currently_down) 703trigger_next_request (struct GNUNET_CORE_Handle *h,
704 int ignore_currently_down)
704{ 705{
705 uint16_t msize; 706 uint16_t msize;
706 707
@@ -742,7 +743,8 @@ trigger_next_request (struct GNUNET_CORE_Handle *h, int ignore_currently_down)
742 * @param msg the message received from the core service 743 * @param msg the message received from the core service
743 */ 744 */
744static void 745static void
745main_notify_handler (void *cls, const struct GNUNET_MessageHeader *msg) 746main_notify_handler (void *cls,
747 const struct GNUNET_MessageHeader *msg)
746{ 748{
747 struct GNUNET_CORE_Handle *h = cls; 749 struct GNUNET_CORE_Handle *h = cls;
748 const struct InitReplyMessage *m; 750 const struct InitReplyMessage *m;
@@ -1265,7 +1267,7 @@ run_request_next_transmission (void *cls,
1265 * @param handle connection to core service 1267 * @param handle connection to core service
1266 * @param cork is corking allowed for this transmission? 1268 * @param cork is corking allowed for this transmission?
1267 * @param priority how important is the message? 1269 * @param priority how important is the message?
1268 * @param maxdelay how long can the message wait? 1270 * @param maxdelay how long can the message wait? Only effective if @a cork is #GNUNET_YES
1269 * @param target who should receive the message, never NULL (can be this peer's identity for loopback) 1271 * @param target who should receive the message, never NULL (can be this peer's identity for loopback)
1270 * @param notify_size how many bytes of buffer space does @a notify want? 1272 * @param notify_size how many bytes of buffer space does @a notify want?
1271 * @param notify function to call when buffer space is available; 1273 * @param notify function to call when buffer space is available;
@@ -1278,7 +1280,8 @@ run_request_next_transmission (void *cls,
1278 * if NULL is returned, @a notify will NOT be called. 1280 * if NULL is returned, @a notify will NOT be called.
1279 */ 1281 */
1280struct GNUNET_CORE_TransmitHandle * 1282struct GNUNET_CORE_TransmitHandle *
1281GNUNET_CORE_notify_transmit_ready (struct GNUNET_CORE_Handle *handle, int cork, 1283GNUNET_CORE_notify_transmit_ready (struct GNUNET_CORE_Handle *handle,
1284 int cork,
1282 enum GNUNET_CORE_Priority priority, 1285 enum GNUNET_CORE_Priority priority,
1283 struct GNUNET_TIME_Relative maxdelay, 1286 struct GNUNET_TIME_Relative maxdelay,
1284 const struct GNUNET_PeerIdentity *target, 1287 const struct GNUNET_PeerIdentity *target,