mirror of
https://github.com/RetroShare/RetroShare.git
synced 2024-10-01 02:35:48 -04:00
cc9df9a80f
* Increased Timeout Periods for UDP connections - this was stopping half of them from succeeding. * The other bug (Heartbeat / stream issues) has not been solved. * Fixed up initialisation of p3BitDht data. * add DropPeers() as NON-ACTIVE (this allows peers which aren't VISIBLE to still try and connect) * export AddFriends/FOF/Others to LinkMgr to allow further SSL IDs to be added to p3BitDht. * Export UDP Addresses to DhtWindow. * switch off lots of debugging. git-svn-id: http://svn.code.sf.net/p/retroshare/code/trunk@4469 b45a01b8-16f6-495d-af2f-9b41ad6348cc
352 lines
11 KiB
C++
352 lines
11 KiB
C++
/*
|
|
* libretroshare/src/pqi: p3linkmgr.h
|
|
*
|
|
* 3P/PQI network interface for RetroShare.
|
|
*
|
|
* Copyright 2007-2011 by Robert Fernie.
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Library General Public
|
|
* License Version 2 as published by the Free Software Foundation.
|
|
*
|
|
* This library 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
|
|
* Library General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Library General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
|
|
* USA.
|
|
*
|
|
* Please report all bugs and problems to "retroshare@lunamutt.com".
|
|
*
|
|
*/
|
|
|
|
#ifndef MRK_PQI_LINK_MANAGER_HEADER
|
|
#define MRK_PQI_LINK_MANAGER_HEADER
|
|
|
|
#include "pqi/pqimonitor.h"
|
|
#include "pqi/pqiipset.h"
|
|
|
|
//#include "pqi/p3dhtmgr.h"
|
|
//#include "pqi/p3upnpmgr.h"
|
|
#include "pqi/pqiassist.h"
|
|
|
|
#include "pqi/p3cfgmgr.h"
|
|
|
|
#include "util/rsthreads.h"
|
|
|
|
class ExtAddrFinder ;
|
|
class DNSResolver ;
|
|
|
|
/* order of attempts ... */
|
|
const uint32_t RS_NET_CONN_TCP_ALL = 0x000f;
|
|
const uint32_t RS_NET_CONN_UDP_ALL = 0x00f0;
|
|
const uint32_t RS_NET_CONN_TUNNEL = 0x0f00;
|
|
|
|
const uint32_t RS_NET_CONN_TCP_LOCAL = 0x0001;
|
|
const uint32_t RS_NET_CONN_TCP_EXTERNAL = 0x0002;
|
|
const uint32_t RS_NET_CONN_TCP_UNKNOW_TOPOLOGY = 0x0004;
|
|
const uint32_t RS_NET_CONN_UDP_DHT_SYNC = 0x0010;
|
|
const uint32_t RS_NET_CONN_UDP_PEER_SYNC = 0x0020; /* coming soon */
|
|
|
|
/* extra flags */
|
|
// not sure if needed yet.
|
|
//const uint32_t RS_NET_CONN_PEERAGE = 0x0f00;
|
|
//const uint32_t RS_NET_CONN_SERVER = 0x0100; /* TCP only */
|
|
//const uint32_t RS_NET_CONN_PEER = 0x0200; /* all UDP */
|
|
|
|
const uint32_t RS_TCP_STD_TIMEOUT_PERIOD = 5; /* 5 seconds! */
|
|
const uint32_t RS_UDP_STD_TIMEOUT_PERIOD = 80; /* 80 secs, allows UDP TTL to get to 40! - Plenty of time (30+80) = 110 secs */
|
|
|
|
class peerAddrInfo
|
|
{
|
|
public:
|
|
peerAddrInfo(); /* init */
|
|
|
|
bool found;
|
|
uint32_t type;
|
|
pqiIpAddrSet addrs;
|
|
time_t ts;
|
|
};
|
|
|
|
class peerConnectAddress
|
|
{
|
|
public:
|
|
peerConnectAddress(); /* init */
|
|
|
|
struct sockaddr_in addr;
|
|
uint32_t delay; /* to stop simultaneous connects */
|
|
uint32_t period; /* UDP only */
|
|
uint32_t type;
|
|
uint32_t flags; /* CB FLAGS defined in pqimonitor.h */
|
|
time_t ts;
|
|
|
|
// Extra Parameters for Relay connections.
|
|
struct sockaddr_in proxyaddr;
|
|
struct sockaddr_in srcaddr;
|
|
uint32_t bandwidth;
|
|
};
|
|
|
|
class peerConnectState
|
|
{
|
|
public:
|
|
peerConnectState(); /* init */
|
|
|
|
std::string id;
|
|
//std::string gpg_id;
|
|
|
|
//uint32_t netMode; /* EXT / UPNP / UDP / INVALID */
|
|
//uint32_t visState; /* STD, GRAY, DARK */
|
|
|
|
//struct sockaddr_in localaddr, serveraddr;
|
|
|
|
//used to store current ip (for config and connection management)
|
|
//struct sockaddr_in currentlocaladdr; /* Mandatory */
|
|
//struct sockaddr_in currentserveraddr; /* Mandatory */
|
|
//std::string dyndns;
|
|
|
|
|
|
/* list of addresses from various sources */
|
|
//pqiIpAddrSet ipAddrs;
|
|
|
|
/***** Below here not stored permanently *****/
|
|
|
|
bool dhtVisible;
|
|
|
|
//time_t lastcontact;
|
|
|
|
uint32_t connecttype; // RS_NET_CONN_TCP_ALL / RS_NET_CONN_UDP_ALL
|
|
time_t lastavailable;
|
|
time_t lastattempt;
|
|
|
|
std::string name;
|
|
|
|
//std::string location;
|
|
|
|
uint32_t state;
|
|
uint32_t actions;
|
|
|
|
uint32_t source; /* most current source */
|
|
peerAddrInfo dht;
|
|
peerAddrInfo disc;
|
|
peerAddrInfo peer;
|
|
|
|
/* a list of connect attempts to make (in order) */
|
|
bool inConnAttempt;
|
|
peerConnectAddress currentConnAddrAttempt;
|
|
std::list<peerConnectAddress> connAddrs;
|
|
|
|
|
|
};
|
|
|
|
class p3tunnel;
|
|
class RsPeerGroupItem;
|
|
class RsGroupInfo;
|
|
|
|
class p3PeerMgr;
|
|
class p3NetMgr;
|
|
|
|
class p3PeerMgrIMPL;
|
|
class p3NetMgrIMPL;
|
|
|
|
std::string textPeerConnectState(peerConnectState &state);
|
|
|
|
/*******
|
|
* Virtual Interface to allow testing
|
|
*
|
|
*/
|
|
|
|
class p3LinkMgr: public pqiConnectCb
|
|
{
|
|
public:
|
|
|
|
p3LinkMgr() { return; }
|
|
virtual ~p3LinkMgr() { return; }
|
|
|
|
|
|
virtual const std::string getOwnId() = 0;
|
|
virtual bool isOnline(const std::string &ssl_id) = 0;
|
|
virtual void getOnlineList(std::list<std::string> &ssl_peers) = 0;
|
|
|
|
/**************** handle monitors *****************/
|
|
virtual void addMonitor(pqiMonitor *mon) = 0;
|
|
virtual void removeMonitor(pqiMonitor *mon) = 0;
|
|
|
|
/****************** Connections *******************/
|
|
virtual bool connectAttempt(const std::string &id, struct sockaddr_in &raddr,
|
|
struct sockaddr_in &proxyaddr, struct sockaddr_in &srcaddr,
|
|
uint32_t &delay, uint32_t &period, uint32_t &type, uint32_t &flags, uint32_t &bandwidth) = 0;
|
|
|
|
virtual bool connectResult(const std::string &id, bool success, uint32_t flags, struct sockaddr_in remote_peer_address) = 0;
|
|
virtual bool retryConnect(const std::string &id) = 0;
|
|
|
|
/* Network Addresses */
|
|
virtual bool setLocalAddress(struct sockaddr_in addr) = 0;
|
|
virtual struct sockaddr_in getLocalAddress() = 0;
|
|
|
|
/************* DEPRECIATED FUNCTIONS (TO REMOVE) ********/
|
|
|
|
virtual void getFriendList(std::list<std::string> &ssl_peers) = 0; // ONLY used by p3peers.cc USE p3PeerMgr instead.
|
|
virtual int getOnlineCount() = 0; // ONLY used by p3peers.cc
|
|
virtual int getFriendCount() = 0; // ONLY used by p3serverconfig.cc & p3peers.cc
|
|
virtual bool getFriendNetStatus(const std::string &id, peerConnectState &state) = 0; // ONLY used by p3peers.cc
|
|
|
|
virtual void setTunnelConnection(bool b) = 0; // ONLY used by p3peermgr.cc & p3peers.cc MOVE => p3PeerMgr
|
|
virtual bool getTunnelConnection() = 0; // ONLY used by p3peermgr.cc & p3peers.cc MOVE => p3PeerMgr
|
|
|
|
|
|
/******* overloaded from pqiConnectCb *************/
|
|
// THESE MUSTn't BE specfied HERE - as overloaded from pqiConnectCb.
|
|
//virtual void peerStatus(std::string id, const pqiIpAddrSet &addrs,
|
|
// uint32_t type, uint32_t flags, uint32_t source) = 0;
|
|
//virtual void peerConnectRequest(std::string id, struct sockaddr_in raddr,
|
|
// struct sockaddr_in proxyaddr, struct sockaddr_in srcaddr,
|
|
// uint32_t source, uint32_t flags, uint32_t delay, uint32_t bandwidth) = 0;
|
|
|
|
/****************************************************************************/
|
|
/****************************************************************************/
|
|
/****************************************************************************/
|
|
|
|
};
|
|
|
|
|
|
|
|
class p3LinkMgrIMPL: public p3LinkMgr
|
|
{
|
|
public:
|
|
|
|
/************************************************************************************************/
|
|
/* EXTERNAL INTERFACE */
|
|
/************************************************************************************************/
|
|
|
|
virtual const std::string getOwnId();
|
|
virtual bool isOnline(const std::string &ssl_id);
|
|
virtual void getOnlineList(std::list<std::string> &ssl_peers);
|
|
|
|
|
|
/**************** handle monitors *****************/
|
|
virtual void addMonitor(pqiMonitor *mon);
|
|
virtual void removeMonitor(pqiMonitor *mon);
|
|
|
|
/****************** Connections *******************/
|
|
virtual bool connectAttempt(const std::string &id, struct sockaddr_in &raddr,
|
|
struct sockaddr_in &proxyaddr, struct sockaddr_in &srcaddr,
|
|
uint32_t &delay, uint32_t &period, uint32_t &type, uint32_t &flags, uint32_t &bandwidth);
|
|
|
|
virtual bool connectResult(const std::string &id, bool success, uint32_t flags, struct sockaddr_in remote_peer_address);
|
|
virtual bool retryConnect(const std::string &id);
|
|
|
|
/* Network Addresses */
|
|
virtual bool setLocalAddress(struct sockaddr_in addr);
|
|
virtual struct sockaddr_in getLocalAddress();
|
|
|
|
/******* overloaded from pqiConnectCb *************/
|
|
virtual void peerStatus(std::string id, const pqiIpAddrSet &addrs,
|
|
uint32_t type, uint32_t flags, uint32_t source);
|
|
virtual void peerConnectRequest(std::string id, struct sockaddr_in raddr,
|
|
struct sockaddr_in proxyaddr, struct sockaddr_in srcaddr,
|
|
uint32_t source, uint32_t flags, uint32_t delay, uint32_t bandwidth);
|
|
|
|
|
|
/************* DEPRECIATED FUNCTIONS (TO REMOVE) ********/
|
|
|
|
virtual void getFriendList(std::list<std::string> &ssl_peers); // ONLY used by p3peers.cc USE p3PeerMgr instead.
|
|
virtual int getOnlineCount(); // ONLY used by p3peers.cc
|
|
virtual int getFriendCount(); // ONLY used by p3serverconfig.cc & p3peers.cc
|
|
virtual bool getFriendNetStatus(const std::string &id, peerConnectState &state); // ONLY used by p3peers.cc
|
|
|
|
virtual void setTunnelConnection(bool b); // ONLY used by p3peermgr.cc & p3peers.cc MOVE => p3PeerMgr
|
|
virtual bool getTunnelConnection(); // ONLY used by p3peermgr.cc & p3peers.cc MOVE => p3PeerMgr
|
|
|
|
/************************************************************************************************/
|
|
/* Extra IMPL Functions (used by p3PeerMgr, p3NetMgr + Setup) */
|
|
/************************************************************************************************/
|
|
|
|
p3LinkMgrIMPL(p3PeerMgrIMPL *peerMgr, p3NetMgrIMPL *netMgr);
|
|
|
|
void tick();
|
|
|
|
/* THIS COULD BE ADDED TO INTERFACE */
|
|
void setFriendVisibility(const std::string &id, bool isVisible);
|
|
|
|
/* add/remove friends */
|
|
int addFriend(const std::string &ssl_id, bool isVisible);
|
|
int removeFriend(const std::string &ssl_id);
|
|
|
|
void printPeerLists(std::ostream &out);
|
|
|
|
protected:
|
|
/* THESE CAN PROBABLY BE REMOVED */
|
|
//bool shutdown(); /* blocking shutdown call */
|
|
//bool getOwnNetStatus(peerConnectState &state);
|
|
|
|
|
|
protected:
|
|
/****************** Internal Interface *******************/
|
|
|
|
/* Internal Functions */
|
|
void statusTick();
|
|
|
|
/* monitor control */
|
|
void tickMonitors();
|
|
|
|
/* connect attempts UDP */
|
|
bool tryConnectUDP(const std::string &id, struct sockaddr_in &rUdpAddr,
|
|
struct sockaddr_in &proxyaddr, struct sockaddr_in &srcaddr,
|
|
uint32_t flags, uint32_t delay, uint32_t bandwidth);
|
|
|
|
/* connect attempts TCP */
|
|
bool retryConnectTCP(const std::string &id);
|
|
|
|
void locked_ConnectAttempt_SpecificAddress(peerConnectState *peer, struct sockaddr_in *remoteAddr);
|
|
void locked_ConnectAttempt_CurrentAddresses(peerConnectState *peer, struct sockaddr_in *localAddr, struct sockaddr_in *serverAddr);
|
|
void locked_ConnectAttempt_HistoricalAddresses(peerConnectState *peer, const pqiIpAddrSet &ipAddrs);
|
|
void locked_ConnectAttempt_AddDynDNS(peerConnectState *peer, std::string dyndns, uint16_t dynPort);
|
|
void locked_ConnectAttempt_AddTunnel(peerConnectState *peer);
|
|
|
|
bool locked_ConnectAttempt_Complete(peerConnectState *peer);
|
|
|
|
bool locked_CheckPotentialAddr(const struct sockaddr_in *addr, time_t age);
|
|
bool addAddressIfUnique(std::list<peerConnectAddress> &addrList, peerConnectAddress &pca, bool pushFront);
|
|
|
|
|
|
private:
|
|
// These should have there own Mutex Protection,
|
|
//p3tunnel *mP3tunnel;
|
|
DNSResolver *mDNSResolver ;
|
|
|
|
p3PeerMgrIMPL *mPeerMgr;
|
|
p3NetMgrIMPL *mNetMgr;
|
|
|
|
RsMutex mLinkMtx; /* protects below */
|
|
|
|
uint32_t mRetryPeriod;
|
|
|
|
bool mStatusChanged;
|
|
|
|
struct sockaddr_in mLocalAddress;
|
|
|
|
std::list<pqiMonitor *> clients;
|
|
|
|
bool mAllowTunnelConnection;
|
|
|
|
/* external Address determination */
|
|
//bool mUpnpAddrValid, mStunAddrValid;
|
|
//struct sockaddr_in mUpnpExtAddr;
|
|
|
|
//peerConnectState mOwnState;
|
|
|
|
std::map<std::string, peerConnectState> mFriendList;
|
|
std::map<std::string, peerConnectState> mOthersList;
|
|
|
|
std::list<RsPeerGroupItem *> groupList;
|
|
uint32_t lastGroupId;
|
|
|
|
/* relatively static list of banned ip addresses */
|
|
std::list<struct in_addr> mBannedIpList;
|
|
};
|
|
|
|
#endif // MRK_PQI_LINK_MANAGER_HEADER
|