X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Ffs%2Fgnunet-service-fs_pe.h;h=dd66f82ed50d9854ed7a54a236a37091dec9b1d5;hb=d23a815951413af100c74b38cdd09a01ca1c280a;hp=d7000135663e4f58f049f19b94b679c6ec7c597d;hpb=86d7f49fc64f0c766d4bec6b3f34879f108fc8a9;p=oweals%2Fgnunet.git diff --git a/src/fs/gnunet-service-fs_pe.h b/src/fs/gnunet-service-fs_pe.h index d70001356..dd66f82ed 100644 --- a/src/fs/gnunet-service-fs_pe.h +++ b/src/fs/gnunet-service-fs_pe.h @@ -1,6 +1,6 @@ /* This file is part of GNUnet. - (C) 2011 Christian Grothoff (and other contributing authors) + Copyright (C) 2011 GNUnet e.V. GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published @@ -14,8 +14,8 @@ You should have received a copy of the GNU General Public License along with GNUnet; see the file COPYING. If not, write to the - Free Software Foundation, Inc., 59 Temple Place - Suite 330, - Boston, MA 02111-1307, USA. + Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + Boston, MA 02110-1301, USA. */ /** @@ -34,20 +34,17 @@ * * @param cp peer with the entry * @param pr request with the entry - * @param weight determines position of the entry in the cp queue, - * lower weights are earlier in the queue */ void -GSF_plan_add_ (const struct GSF_ConnectedPeer *cp, - struct GSF_PendingRequest *pr, - GNUNET_CONTAINER_HeapCostType weight); +GSF_plan_add_ (struct GSF_ConnectedPeer *cp, + struct GSF_PendingRequest *pr); /** * Notify the plan about a peer being no longer available; * destroy all entries associated with this peer. * - * @param cp connected peer + * @param cp connected peer */ void GSF_plan_notify_peer_disconnect_ (const struct GSF_ConnectedPeer *cp); @@ -60,29 +57,21 @@ GSF_plan_notify_peer_disconnect_ (const struct GSF_ConnectedPeer *cp); * @param pr request that is done */ void -GSF_plan_notify_request_done_ (const struct GSF_PendingRequest *pr); - +GSF_plan_notify_request_done_ (struct GSF_PendingRequest *pr); /** - * Get the lowest-weight entry for the respective peer - * from the plan. Removes the entry from the plan's queue. + * Get the last transmission attempt time for the request plan list + * referenced by 'rpr_head', that was sent to 'sender' * - * @param cp connected peer to query for the next request - * @return NULL if the queue for this peer is empty + * @param pr_head request plan reference list to check. + * @param sender the peer that we've sent the request to. + * @param result the timestamp to fill. + * @return GNUNET_YES if 'result' was changed, GNUNET_NO otherwise. */ -struct GSF_PendingRequest * -GSF_plan_get_ (const struct GSF_ConnectedPeer *cp); - - -/** - * Get the size of the request queue for the given peer. - * - * @param cp connected peer to query - * @return number of entries in this peer's request queue - */ -unsigned int -GSF_plan_size_ (const struct GSF_ConnectedPeer *cp); - +int +GSF_request_plan_reference_get_last_transmission_ (struct GSF_PendingRequestPlanBijection *pr_head, + struct GSF_ConnectedPeer *sender, + struct GNUNET_TIME_Absolute *result); /** * Initialize plan subsystem.