RPBSearchResult findPacket(u16 seqnum);
std::list<BufferedPacket> m_list;
- u16 m_list_size;
+ u32 m_list_size;
u16 m_oldest_non_answered_ack;
JMutex m_list_mutex;
-
- unsigned int writeptr;
};
/*
struct ConnectionCommand
{
enum ConnectionCommandType type;
- u16 port;
Address address;
u16 peer_id;
u8 channelnum;
ConnectionCommand(): type(CONNCMD_NONE), peer_id(PEER_ID_INEXISTENT), reliable(false), raw(false) {}
- void serve(u16 port_)
+ void serve(Address address_)
{
type = CONNCMD_SERVE;
- port = port_;
+ address = address_;
}
void connect(Address address_)
{
void processReliableCommand (ConnectionCommand &c);
void processNonReliableCommand (ConnectionCommand &c);
- void serve (u16 port);
+ void serve (Address bind_address);
void connect (Address address);
void disconnect ();
void disconnect_peer(u16 peer_id);
Connection* m_connection;
- unsigned int m_max_packet_size;
};
class Connection
void putCommand(ConnectionCommand &c);
void SetTimeoutMs(int timeout){ m_bc_receive_timeout = timeout; }
- void Serve(unsigned short port);
+ void Serve(Address bind_addr);
void Connect(Address address);
bool Connected();
void Disconnect();
void Send(u16 peer_id, u8 channelnum, SharedBuffer<u8> data, bool reliable);
u16 GetPeerID(){ return m_peer_id; }
Address GetPeerAddress(u16 peer_id);
- float GetPeerAvgRTT(u16 peer_id);
+ float getPeerStat(u16 peer_id, rtt_stat_type type);
const u32 GetProtocolID() const { return m_protocol_id; };
const std::string getDesc();
void DisconnectPeer(u16 peer_id);