add cork option to core api:

2 files changed, 5 insertions, 0 deletions

diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c
index cbfac9322..101698160 100644
--- a/src/fs/gnunet-service-fs.c
+++ b/src/fs/gnunet-service-fs.c
@@ -1163,6 +1163,7 @@ consider_migration (void *cls,
     }
   cp->cth 
     = GNUNET_CORE_notify_transmit_ready (core,
+                                         GNUNET_YES,
                                          0, GNUNET_TIME_UNIT_FOREVER_REL,
                                          (const struct GNUNET_PeerIdentity*) key,
                                          msize + sizeof (struct PutMessage),
@@ -2169,6 +2170,7 @@ delayed_transmission_request (void *cls,
                        &pid);
   cp->last_transmission_request_start = GNUNET_TIME_absolute_get ();
   cp->cth = GNUNET_CORE_notify_transmit_ready (core,
+                                               GNUNET_YES,
                                                pm->priority,
                                                GNUNET_CONSTANTS_SERVICE_TIMEOUT,
                                                &pid,
@@ -2405,6 +2407,7 @@ add_to_pending_messages_for_peer (struct ConnectedPeer *cp,
   /* need to schedule transmission */
   cp->last_transmission_request_start = GNUNET_TIME_absolute_get ();
   cp->cth = GNUNET_CORE_notify_transmit_ready (core,
+                                               GNUNET_YES,
                                                cp->pending_messages_head->priority,
                                                MAX_TRANSMIT_DELAY,
                                                &pid,
diff --git a/src/fs/gnunet-service-fs_cp.c b/src/fs/gnunet-service-fs_cp.c
index 6e39d7bd2..4d1cba508 100644
--- a/src/fs/gnunet-service-fs_cp.c
+++ b/src/fs/gnunet-service-fs_cp.c
@@ -368,6 +368,7 @@ core_reserve_callback (void *cls,
     {
       /* reservation success, try transmission now! */
       pth->cth = GNUNET_CORE_notify_transmit_ready (GSF_core,
+                                                    GNUNET_YES,
                                                     pth->priority,
                                                     GNUNET_TIME_absolute_get_remaining (pth->timeout),
                                                     peer,
@@ -1110,6 +1111,7 @@ GSF_peer_transmit_ (struct GSF_ConnectedPeer *cp,
   if (is_ready)
     {
       pth->cth = GNUNET_CORE_notify_transmit_ready (GSF_core,
+                                                    GNUNET_YES,
                                                     priority,
                                                     timeout,
                                                     &target,