From: Christian Grothoff Date: Mon, 7 Feb 2011 21:53:52 +0000 (+0000) Subject: stuff X-Git-Tag: initial-import-from-subversion-38251~19159 X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=de952b871bfe79a7f2b79d9ab04dc37933d49bf1;p=oweals%2Fgnunet.git stuff --- diff --git a/src/fs/gnunet-service-fs.h b/src/fs/gnunet-service-fs.h index a66339b91..ca8d4cdc5 100644 --- a/src/fs/gnunet-service-fs.h +++ b/src/fs/gnunet-service-fs.h @@ -44,12 +44,5 @@ struct GSF_PendingRequest; struct GSF_LocalClient; -/** - * Entry in the query transmission plan. - */ -struct GSF_PlanEntry; - - - #endif /* end of gnunet-service-fs.h */ diff --git a/src/fs/gnunet-service-fs_cp.c b/src/fs/gnunet-service-fs_cp.c index a3994adf5..4c7c1b52d 100644 --- a/src/fs/gnunet-service-fs_cp.c +++ b/src/fs/gnunet-service-fs_cp.c @@ -33,6 +33,10 @@ #define TRUST_FLUSH_FREQ GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 5) + +/** + * Handle to cancel a transmission request. + */ struct GSF_PeerTransmitHandle { @@ -954,5 +958,4 @@ GSF_handle_local_client_disconnect_ (const struct GSF_LocalClient *lc) } -#endif -/* end of gnunet-service-fs_cp.h */ +/* end of gnunet-service-fs_cp.c */ diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c new file mode 100644 index 000000000..ec6f315ff --- /dev/null +++ b/src/fs/gnunet-service-fs_pe.c @@ -0,0 +1,101 @@ +/* + This file is part of GNUnet. + (C) 2011 Christian Grothoff (and other contributing authors) + + GNUnet is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3, or (at your + option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + 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. +*/ + +/** + * @file fs/gnunet-service-fs_pe.c + * @brief API to manage query plan + * @author Christian Grothoff + */ +#include "platform.h" +#include "gnunet-service-fs_pe.h" + + +/** + * Create a new query plan entry. + * + * @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_ (struct GSF_ConnectedPeer *cp, + struct GSF_PendingRequest *pr, + double weight) +{ + // FIXME +} + + +/** + * Notify the plan about a peer being no longer available; + * destroy all entries associated with this peer. + * + * @param cp connected peer + */ +void +GSF_plan_notify_peer_disconnect_ (struct GSF_ConnectedPeer *cp) +{ + // FIXME +} + + +/** + * Notify the plan about a request being done; + * destroy all entries associated with this request. + * + * @param pr request that is done + */ +void +GSF_plan_notify_request_done_ (struct GSF_PendingRequest *pr) +{ + // FIXME +} + + +/** + * Get the lowest-weight entry for the respective peer + * from the plan. Removes the entry from the plan's queue. + * + * @param cp connected peer to query for the next request + * @return NULL if the queue for this peer is empty + */ +struct GSF_PendingRequest * +GSF_plan_get_ (struct GSF_ConnectedPeer *cp) +{ + return NULL; // FIXME +} + + +/** + * 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_ (struct GSF_ConnectedPeer *cp) +{ + return 0; // FIXME +} + + + +/* end of gnunet-service-fs_pe.h */ diff --git a/src/fs/gnunet-service-fs_pe.h b/src/fs/gnunet-service-fs_pe.h index 24fbcbb7a..09baebc1a 100644 --- a/src/fs/gnunet-service-fs_pe.h +++ b/src/fs/gnunet-service-fs_pe.h @@ -34,45 +34,54 @@ * * @param cp peer with the entry * @param pr request with the entry - * @param position position of the entry in the cp queue - * @return handle for the new plan entry + * @param weight determines position of the entry in the cp queue, + * lower weights are earlier in the queue */ -struct GSF_PlanEntry * -GSF_plan_entry_create_ (struct GSF_ConnectedPeer *cp, - struct GSF_PendingRequest *pr, - unsigned int position); +void +GSF_plan_add_ (struct GSF_ConnectedPeer *cp, + struct GSF_PendingRequest *pr, + double weight); /** - * Notify the plan about a new peer to use. + * Notify the plan about a peer being no longer available; + * destroy all entries associated with this peer. * * @param cp connected peer */ void -GSF_plan_notify_new_peer_ (struct GSF_ConnectedPeer *cp); +GSF_plan_notify_peer_disconnect_ (struct GSF_ConnectedPeer *cp); /** - * Notify the plan about a peer being no longer available. + * Notify the plan about a request being done; + * destroy all entries associated with this request. * - * @param cp connected peer + * @param pr request that is done */ void -GSF_plan_notify_peer_disconnect_ (struct GSF_ConnectedPeer *cp); - +GSF_plan_notify_request_done_ (struct GSF_PendingRequest *pr); /** - * Get the first plan entry for the given connected peer. - * FIXME... + * Get the lowest-weight entry for the respective peer + * from the plan. Removes the entry from the plan's queue. * - * @param cp connected peer - * @return NULL if there is no request planned for this peer + * @param cp connected peer to query for the next request + * @return NULL if the queue for this peer is empty */ struct GSF_PendingRequest * GSF_plan_get_ (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_ (struct GSF_ConnectedPeer *cp); #endif /* end of gnunet-service-fs_pe.h */