diff options
author | Christian Grothoff <christian@grothoff.org> | 2014-01-30 19:22:23 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2014-01-30 19:22:23 +0000 |
commit | 6daf13eaa64b5b041edce219f30ab8dcfe38cdf5 (patch) | |
tree | c56e4517a0ee08cfb013e296b7d7cf33f2ab49d8 /src/core/core_api.c | |
parent | 6fd0a7efde08115b568b99b7755861a50f1b6c2e (diff) | |
download | gnunet-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.c | 11 |
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 | */ |
702 | static void | 702 | static void |
703 | trigger_next_request (struct GNUNET_CORE_Handle *h, int ignore_currently_down) | 703 | trigger_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 | */ |
744 | static void | 745 | static void |
745 | main_notify_handler (void *cls, const struct GNUNET_MessageHeader *msg) | 746 | main_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 | */ |
1280 | struct GNUNET_CORE_TransmitHandle * | 1282 | struct GNUNET_CORE_TransmitHandle * |
1281 | GNUNET_CORE_notify_transmit_ready (struct GNUNET_CORE_Handle *handle, int cork, | 1283 | GNUNET_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, |