aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-03-11 12:44:06 +0000
committerChristian Grothoff <christian@grothoff.org>2011-03-11 12:44:06 +0000
commit914ec7ef9e59b69868b92fced96d6693b2097e13 (patch)
tree9891a3f70dd894a2af1582baf1a3c9ccd53beb43 /src/fs/gnunet-service-fs.c
parent69d9f80b83053162a38a292fc8a024acb6a463a9 (diff)
downloadgnunet-914ec7ef9e59b69868b92fced96d6693b2097e13.tar.gz
gnunet-914ec7ef9e59b69868b92fced96d6693b2097e13.zip
add cork option to core api:
Diffstat (limited to 'src/fs/gnunet-service-fs.c')
-rw-r--r--src/fs/gnunet-service-fs.c3
1 files changed, 3 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,
1163 } 1163 }
1164 cp->cth 1164 cp->cth
1165 = GNUNET_CORE_notify_transmit_ready (core, 1165 = GNUNET_CORE_notify_transmit_ready (core,
1166 GNUNET_YES,
1166 0, GNUNET_TIME_UNIT_FOREVER_REL, 1167 0, GNUNET_TIME_UNIT_FOREVER_REL,
1167 (const struct GNUNET_PeerIdentity*) key, 1168 (const struct GNUNET_PeerIdentity*) key,
1168 msize + sizeof (struct PutMessage), 1169 msize + sizeof (struct PutMessage),
@@ -2169,6 +2170,7 @@ delayed_transmission_request (void *cls,
2169 &pid); 2170 &pid);
2170 cp->last_transmission_request_start = GNUNET_TIME_absolute_get (); 2171 cp->last_transmission_request_start = GNUNET_TIME_absolute_get ();
2171 cp->cth = GNUNET_CORE_notify_transmit_ready (core, 2172 cp->cth = GNUNET_CORE_notify_transmit_ready (core,
2173 GNUNET_YES,
2172 pm->priority, 2174 pm->priority,
2173 GNUNET_CONSTANTS_SERVICE_TIMEOUT, 2175 GNUNET_CONSTANTS_SERVICE_TIMEOUT,
2174 &pid, 2176 &pid,
@@ -2405,6 +2407,7 @@ add_to_pending_messages_for_peer (struct ConnectedPeer *cp,
2405 /* need to schedule transmission */ 2407 /* need to schedule transmission */
2406 cp->last_transmission_request_start = GNUNET_TIME_absolute_get (); 2408 cp->last_transmission_request_start = GNUNET_TIME_absolute_get ();
2407 cp->cth = GNUNET_CORE_notify_transmit_ready (core, 2409 cp->cth = GNUNET_CORE_notify_transmit_ready (core,
2410 GNUNET_YES,
2408 cp->pending_messages_head->priority, 2411 cp->pending_messages_head->priority,
2409 MAX_TRANSMIT_DELAY, 2412 MAX_TRANSMIT_DELAY,
2410 &pid, 2413 &pid,