Skip to content

Commit c590687

Browse files
committed
impl socket connection
1 parent 3b8049a commit c590687

File tree

2 files changed

+302
-105
lines changed

2 files changed

+302
-105
lines changed

src/dds.net-connector-cpp.lib/connector/src/internal/inc/network_client.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,7 @@ namespace dds {
8585
virtual void connect(std::string ipv4, unsigned short tcpPort) override;
8686
virtual void disconnect() override;
8787

88+
8889
private:
8990
Logger* logger;
9091
BufferManager* bufferManager;
@@ -109,6 +110,10 @@ namespace dds {
109110
bool isIOThreadStarted;
110111
std::thread* ioThread;
111112

113+
bool createSocket();
114+
void connectWithServer();
115+
bool isDataAvailable(int timeoutSecond = 0, int timeoutMicrosecond = 100);
116+
112117

113118
friend void ioThreadFunc(NetworkClient* client);
114119
};

0 commit comments

Comments
 (0)