rps.h

Go to the documentation of this file.

/*
      This file is part of GNUnet
      Copyright (C) 2012-2013 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
 */
#include "gnunet_rps_service.h"

#define GNUNET_RPS_CADET_PORT 31337


GNUNET_NETWORK_STRUCT_BEGIN

/***********************************************************************
 * P2P Messages
***********************************************************************/

struct GNUNET_RPS_P2P_PullReplyMessage
{
  struct GNUNET_MessageHeader header;

  uint32_t num_peers GNUNET_PACKED;

  /* Followed by num_peers * GNUNET_PeerIdentity */
};



/***********************************************************************
 * Client-Service Messages
***********************************************************************/

struct GNUNET_RPS_CS_SeedMessage
{
  struct GNUNET_MessageHeader header;

  uint32_t num_peers GNUNET_PACKED;

  /* Followed by num_peers * GNUNET_PeerIdentity */
};

#if ENABLE_MALICIOUS

struct GNUNET_RPS_CS_ActMaliciousMessage
{
  struct GNUNET_MessageHeader header;

  struct GNUNET_PeerIdentity attacked_peer;

  uint32_t type GNUNET_PACKED;

  uint32_t num_peers GNUNET_PACKED;

  /* Followed by num_peers * GNUNET_PeerIdentity when the type of malicious
     behaviour is 1 */
};
#endif /* ENABLE_MALICIOUS */


struct GNUNET_RPS_CS_SubStartMessage
{
  struct GNUNET_MessageHeader header;

  uint32_t reserved GNUNET_PACKED;

  struct GNUNET_TIME_RelativeNBO round_interval;

  struct GNUNET_HashCode hash GNUNET_PACKED;
};


struct GNUNET_RPS_CS_SubStopMessage
{
  struct GNUNET_MessageHeader header;

  struct GNUNET_HashCode hash GNUNET_PACKED;
};


/* Debug messages */

struct GNUNET_RPS_CS_DEBUG_ViewRequest
{
  struct GNUNET_MessageHeader header;

  uint32_t num_updates GNUNET_PACKED;
};

struct GNUNET_RPS_CS_DEBUG_ViewReply
{
  struct GNUNET_MessageHeader header;

  uint32_t id GNUNET_PACKED;

  uint64_t num_peers GNUNET_PACKED;
};
  /* Followed by num_peers * GNUNET_PeerIdentity */

struct GNUNET_RPS_CS_DEBUG_StreamRequest
{
  struct GNUNET_MessageHeader header;
};

struct GNUNET_RPS_CS_DEBUG_StreamReply
{
  struct GNUNET_MessageHeader header;

  uint64_t num_peers GNUNET_PACKED;

  // TODO maybe source of peer (pull/push list, peerinfo, ...)

  /* Followed by num_peers * GNUNET_PeerIdentity */
};

GNUNET_NETWORK_STRUCT_END

/***********************************************************************
 * Defines from old gnunet-service-rps_peers.h
***********************************************************************/

enum Peers_PeerFlags
{
  Peers_PULL_REPLY_PENDING   = 0x01,

  /* IN_OTHER_GOSSIP_LIST = 0x02, unneeded? */
  /* IN_OWN_SAMPLER_LIST  = 0x04, unneeded? */
  /* IN_OWN_GOSSIP_LIST   = 0x08, unneeded? */

  Peers_ONLINE               = 0x20,

  Peers_TO_DESTROY           = 0x40,
};

enum Peers_ChannelFlags
{
  Peers_CHANNEL_ESTABLISHED_TWICE = 0x1,

  Peers_CHANNEL_CLEAN = 0x2,

  Peers_CHANNEL_DESTROING = 0x4,
};


enum Peers_ChannelRole
{
  Peers_CHANNEL_ROLE_SENDING   = 0x01,

  Peers_CHANNEL_ROLE_RECEIVING = 0x02,
};

typedef void (* PeerOp) (void *cls, const struct GNUNET_PeerIdentity *peer);

typedef int
(*PeersIterator) (void *cls,
                  const struct GNUNET_PeerIdentity *peer);


extern struct GNUNET_STATISTICS_Handle *stats;