94 lines
3.5 KiB
C++
Executable File
94 lines
3.5 KiB
C++
Executable File
/// \file
|
|
/// \brief A simple TCP based server allowing sends and receives. Can be connected by any TCP client, including telnet.
|
|
///
|
|
/// This file is part of RakNet Copyright 2003 Jenkins Software LLC
|
|
///
|
|
/// Usage of RakNet is subject to the appropriate license agreement.
|
|
|
|
#include "NativeFeatureIncludes.h"
|
|
#if _RAKNET_SUPPORT_PacketizedTCP==1 && _RAKNET_SUPPORT_TCPInterface==1
|
|
|
|
#ifndef __PACKETIZED_TCP
|
|
#define __PACKETIZED_TCP
|
|
|
|
#include "TCPInterface.h"
|
|
#include "DS_ByteQueue.h"
|
|
#include "PluginInterface2.h"
|
|
#include "DS_Map.h"
|
|
|
|
namespace RakNet
|
|
{
|
|
|
|
class RAK_DLL_EXPORT PacketizedTCP : public TCPInterface
|
|
{
|
|
public:
|
|
// GetInstance() and DestroyInstance(instance*)
|
|
STATIC_FACTORY_DECLARATIONS(PacketizedTCP)
|
|
|
|
PacketizedTCP();
|
|
virtual ~PacketizedTCP();
|
|
|
|
/// Starts the TCP server on the indicated port
|
|
/// \param[in] port Which port to listen on.
|
|
/// \param[in] maxIncomingConnections Max incoming connections we will accept
|
|
/// \param[in] maxConnections Max total connections, which should be >= maxIncomingConnections
|
|
/// \param[in] threadPriority Passed to the thread creation routine. Use THREAD_PRIORITY_NORMAL for Windows. For Linux based systems, you MUST pass something reasonable based on the thread priorities for your application.
|
|
/// \param[in] socketFamily IP version: For IPV4, use AF_INET (default). For IPV6, use AF_INET6. To autoselect, use AF_UNSPEC.
|
|
bool Start(unsigned short port, unsigned short maxIncomingConnections, int threadPriority=-99999, unsigned short socketFamily=AF_INET);
|
|
|
|
/// Stops the TCP server
|
|
void Stop(void);
|
|
|
|
/// Sends a byte stream
|
|
void Send( const char *data, unsigned length, const SystemAddress &systemAddress, bool broadcast );
|
|
|
|
// Sends a concatenated list of byte streams
|
|
bool SendList( const char **data, const int *lengths, const int numParameters, const SystemAddress &systemAddress, bool broadcast );
|
|
|
|
/// Returns data received
|
|
Packet* Receive( void );
|
|
|
|
/// Disconnects a player/address
|
|
void CloseConnection( SystemAddress systemAddress );
|
|
|
|
/// Has a previous call to connect succeeded?
|
|
/// \return UNASSIGNED_SYSTEM_ADDRESS = no. Anything else means yes.
|
|
SystemAddress HasCompletedConnectionAttempt(void);
|
|
|
|
/// Has a previous call to connect failed?
|
|
/// \return UNASSIGNED_SYSTEM_ADDRESS = no. Anything else means yes.
|
|
SystemAddress HasFailedConnectionAttempt(void);
|
|
|
|
/// Queued events of new incoming connections
|
|
SystemAddress HasNewIncomingConnection(void);
|
|
|
|
/// Queued events of lost connections
|
|
SystemAddress HasLostConnection(void);
|
|
|
|
// Only currently tested with FileListTransfer!
|
|
void AttachPlugin( PluginInterface2 *plugin );
|
|
void DetachPlugin( PluginInterface2 *plugin );
|
|
|
|
protected:
|
|
void ClearAllConnections(void);
|
|
void RemoveFromConnectionList(const SystemAddress &sa);
|
|
void AddToConnectionList(const SystemAddress &sa);
|
|
void PushNotificationsToQueues(void);
|
|
Packet *ReturnOutgoingPacket(void);
|
|
|
|
// Plugins
|
|
DataStructures::List<PluginInterface2*> messageHandlerList;
|
|
// A single TCP recieve may generate multiple split packets. They are stored in the waitingPackets list until Receive is called
|
|
DataStructures::Queue<Packet*> waitingPackets;
|
|
DataStructures::Map<SystemAddress, DataStructures::ByteQueue *> connections;
|
|
|
|
// Mirrors single producer / consumer, but processes them in Receive() before returning to user
|
|
DataStructures::Queue<SystemAddress> _newIncomingConnections, _lostConnections, _failedConnectionAttempts, _completedConnectionAttempts;
|
|
};
|
|
|
|
} // namespace RakNet
|
|
|
|
#endif
|
|
|
|
#endif // _RAKNET_SUPPORT_*
|