aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pe.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-03-11 17:02:22 +0000
committerChristian Grothoff <christian@grothoff.org>2011-03-11 17:02:22 +0000
commitb65e5b414fdfbf53f989c77aa4c5b27a658fada2 (patch)
tree9f9dce8bc5d67ff4c58c3d3a70aa5623dd16d058 /src/fs/gnunet-service-fs_pe.c
parent562b33143ee9fa431a68ea6741e4feb3ba388f83 (diff)
downloadgnunet-b65e5b414fdfbf53f989c77aa4c5b27a658fada2.tar.gz
gnunet-b65e5b414fdfbf53f989c77aa4c5b27a658fada2.zip
prio
Diffstat (limited to 'src/fs/gnunet-service-fs_pe.c')
-rw-r--r--src/fs/gnunet-service-fs_pe.c8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c
index 306bb948c..af20c4bf3 100644
--- a/src/fs/gnunet-service-fs_pe.c
+++ b/src/fs/gnunet-service-fs_pe.c
@@ -63,6 +63,11 @@ struct GSF_RequestPlan
63 */ 63 */
64 struct GNUNET_TIME_Absolute earliest_transmission; 64 struct GNUNET_TIME_Absolute earliest_transmission;
65 65
66 /**
67 * Priority for this request for this target.
68 */
69 uint32_t priority;
70
66}; 71};
67 72
68 73
@@ -115,6 +120,7 @@ plan (struct PeerPlan *pp,
115 prd = GSF_pending_request_get_data_ (rp->pr); 120 prd = GSF_pending_request_get_data_ (rp->pr);
116 weight = 0; // FIXME: calculate real weight! 121 weight = 0; // FIXME: calculate real weight!
117 // FIXME: calculate 'rp->earliest_transmission'! 122 // FIXME: calculate 'rp->earliest_transmission'!
123 // fIXME: claculate 'rp->priority'!
118 rp->hn = GNUNET_CONTAINER_heap_insert (pp->heap, 124 rp->hn = GNUNET_CONTAINER_heap_insert (pp->heap,
119 rp, 125 rp,
120 weight); 126 weight);
@@ -206,7 +212,7 @@ schedule_peer_transmission (void *cls,
206 msize = GSF_pending_request_get_message_ (rp->pr, 0, NULL); 212 msize = GSF_pending_request_get_message_ (rp->pr, 0, NULL);
207 pp->pth = GSF_peer_transmit_ (pp->cp, 213 pp->pth = GSF_peer_transmit_ (pp->cp,
208 GNUNET_YES, 214 GNUNET_YES,
209 0 /* FIXME: pr->priority? */, 215 rp->priority,
210 GNUNET_TIME_UNIT_FOREVER_REL, 216 GNUNET_TIME_UNIT_FOREVER_REL,
211 msize, 217 msize,
212 &transmit_message_callback, 218 &transmit_message_callback,