gnunet-service-fs_cp.h

Go to the documentation of this file.

/*
     This file is part of GNUnet.
     Copyright (C) 2011 GNUnet e.V.
 
     GNUnet is free software: you can redistribute it and/or modify it
     under the terms of the GNU Affero General Public License as published
     by the Free Software Foundation, either version 3 of the License,
     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
     Affero General Public License for more details.
 
     You should have received a copy of the GNU Affero General Public License
     along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
     SPDX-License-Identifier: AGPL3.0-or-later
 */
 
#ifndef GNUNET_SERVICE_FS_CP_H
#define GNUNET_SERVICE_FS_CP_H
 
#include "fs.h"
#include "gnunet-service-fs.h"
 
 
#define MAX_QUEUE_PER_PEER 24
 
#define P2P_SUCCESS_LIST_SIZE 8
 
#define CS2P_SUCCESS_LIST_SIZE 8
 
 
struct GSF_PeerPerformanceData
{
  struct GSF_LocalClient *last_client_replies[CS2P_SUCCESS_LIST_SIZE];
 
  GNUNET_PEER_Id last_p2p_replies[P2P_SUCCESS_LIST_SIZE];
 
  struct GNUNET_TIME_Relative avg_reply_delay;
 
  struct GNUNET_TIME_Relative migration_delay;
 
  struct GNUNET_TIME_Absolute migration_blocked_until;
 
  struct GNUNET_TIME_Absolute last_request_times[MAX_QUEUE_PER_PEER];
 
  struct GNUNET_LOAD_Value *transmission_delay;
 
  double avg_priority;
 
  GNUNET_PEER_Id pid;
 
  const struct GNUNET_PeerIdentity *peer;
 
  uint32_t respect;
 
  unsigned int pending_queries;
 
  unsigned int pending_replies;
};
 
 
typedef void
(*GSF_ConnectedPeerIterator) (void *cls,
                              const struct GNUNET_PeerIdentity *peer,
                              struct GSF_ConnectedPeer *cp,
                              const struct GSF_PeerPerformanceData *ppd);
 
 
typedef size_t
(*GSF_GetMessageCallback) (void *cls,
                           size_t buf_size,
                           void *buf);
 
 
typedef void
(*GSF_PeerReserveCallback) (void *cls,
                            struct GSF_ConnectedPeer *cp,
                            int success);
 
 
struct GSF_PeerTransmitHandle;
 
 
void *
GSF_peer_connect_handler (void *cls,
                          const struct GNUNET_PeerIdentity *peer,
                          struct GNUNET_MQ_Handle *mq);
 
 
struct GSF_ConnectedPeer *
GSF_peer_get_ (const struct GNUNET_PeerIdentity *peer);
 
 
void
GSF_update_peer_latency_ (const struct GNUNET_PeerIdentity *id,
                          struct GNUNET_TIME_Relative latency);
 
 
void
GSF_peer_transmit_ (struct GSF_ConnectedPeer *cp,
                    int is_query,
                    uint32_t priority,
                    struct GNUNET_MQ_Envelope *env);
 
 
void
GSF_peer_update_performance_ (struct GSF_ConnectedPeer *cp,
                              struct GNUNET_TIME_Absolute request_time,
                              uint32_t request_priority);
 
 
void
GSF_peer_update_responder_client_ (struct GSF_ConnectedPeer *cp,
                                   struct GSF_LocalClient *initiator_client);
 
 
void
GSF_peer_update_responder_peer_ (struct GSF_ConnectedPeer *cp,
                                 const struct GSF_ConnectedPeer
                                 *initiator_peer);
 
 
void
handle_p2p_migration_stop (void *cls,
                           const struct MigrationStopMessage *message);
 
 
void
handle_p2p_get (void *cls,
                const struct GetMessage *gm);
 
 
struct GSF_PeerPerformanceData *
GSF_get_peer_performance_data_ (struct GSF_ConnectedPeer *cp);
 
 
void
GSF_block_peer_migration_ (struct GSF_ConnectedPeer *cp,
                           struct GNUNET_TIME_Absolute block_time);
 
 
void
GSF_peer_disconnect_handler (void *cls,
                             const struct GNUNET_PeerIdentity *peer,
                             void *internal_cls);
 
 
void
GSF_handle_local_client_disconnect_ (const struct GSF_LocalClient *lc);
 
 
void
GSF_connected_peer_change_preference_ (struct GSF_ConnectedPeer *cp,
                                       uint64_t pref);
 
 
void
GSF_connected_peer_get_identity_ (const struct GSF_ConnectedPeer *cp,
                                  struct GNUNET_PeerIdentity *id);
 
 
const struct GNUNET_PeerIdentity *
GSF_connected_peer_get_identity2_ (const struct GSF_ConnectedPeer *cp);
 
 
void
GSF_iterate_connected_peers_ (GSF_ConnectedPeerIterator it, void *it_cls);
 
 
void
GSF_connected_peer_init_ (void);
 
 
void
GSF_connected_peer_done_ (void);
 
 
#endif
/* end of gnunet-service-fs_cp.h */