mirror of
https://github.com/debauchee/barrier.git
synced 2026-02-11 14:15:46 +08:00
fee4095624
synergy.cpp and server.cpp into cmd/synergyd as synergyd.cpp. Moved and renamed related files. Moved remaining source files into lib/.... Modified and added makefiles as appropriate. Result is that library files are under lib with each library in its own directory and program files are under cmd with each command in its own directory.
54 lines
1023 B
C++
54 lines
1023 B
C++
#ifndef CTCPSOCKET_H
|
|
#define CTCPSOCKET_H
|
|
|
|
#include "IDataSocket.h"
|
|
#include "CNetwork.h"
|
|
|
|
class CMutex;
|
|
template <class T>
|
|
class CCondVar;
|
|
class CThread;
|
|
class CBufferedInputStream;
|
|
class CBufferedOutputStream;
|
|
|
|
//! TCP data socket
|
|
/*!
|
|
A data socket using TCP.
|
|
*/
|
|
class CTCPSocket : public IDataSocket {
|
|
public:
|
|
CTCPSocket();
|
|
CTCPSocket(CNetwork::Socket);
|
|
~CTCPSocket();
|
|
|
|
// ISocket overrides
|
|
virtual void bind(const CNetworkAddress&);
|
|
virtual void close();
|
|
|
|
// IDataSocket overrides
|
|
virtual void connect(const CNetworkAddress&);
|
|
virtual IInputStream* getInputStream();
|
|
virtual IOutputStream* getOutputStream();
|
|
|
|
private:
|
|
void init();
|
|
void ioThread(void*);
|
|
void ioCleanup();
|
|
void ioService();
|
|
void closeInput(void*);
|
|
void closeOutput(void*);
|
|
|
|
private:
|
|
enum { kClosed = 0, kRead = 1, kWrite = 2, kReadWrite = 3 };
|
|
|
|
CNetwork::Socket m_fd;
|
|
CBufferedInputStream* m_input;
|
|
CBufferedOutputStream* m_output;
|
|
|
|
CMutex* m_mutex;
|
|
CThread* m_thread;
|
|
UInt32 m_connected;
|
|
};
|
|
|
|
#endif
|