Lines Matching refs:clientSocket
86 WebSocketClient clientSocket;
89 retClient = clientSocket.InitToolchainWebSocketForSockName(UNIX_DOMAIN_PATH_1 + std::to_string(appPid), 5);
91 retClient = clientSocket.InitToolchainWebSocketForPort(TCP_PORT, 5);
94 retClient = clientSocket.ClientSendWSUpgradeReq();
96 retClient = clientSocket.ClientRecvWSUpgradeRsp();
98 retClient = clientSocket.SendReply(HELLO_SERVER);
100 std::string recv = clientSocket.Decode();
103 retClient = clientSocket.SendReply(CLIENT_OK);
106 retClient = clientSocket.SendReply(LONG_MSG);
108 recv = clientSocket.Decode();
111 retClient = clientSocket.SendReply(CLIENT_OK);
114 retClient = clientSocket.SendReply(LONG_LONG_MSG);
116 recv = clientSocket.Decode();
119 retClient = clientSocket.SendReply(CLIENT_OK);
122 retClient = clientSocket.SendReply(PING, FrameType::PING); // send a ping frame and wait for pong frame
124 recv = clientSocket.Decode(); // get the pong frame
126 retClient = clientSocket.SendReply(QUIT);
128 clientSocket.Close();
182 WebSocketClient clientSocket;
185 retClient = clientSocket.InitToolchainWebSocketForSockName(UNIX_DOMAIN_PATH_2 + std::to_string(appPid), 5);
187 retClient = clientSocket.InitToolchainWebSocketForPort(TCP_PORT, 5);
190 retClient = clientSocket.ClientSendWSUpgradeReq();
192 retClient = clientSocket.ClientRecvWSUpgradeRsp();
194 retClient = clientSocket.SendReply(HELLO_SERVER + std::to_string(i));
196 std::string recv = clientSocket.Decode();
199 retClient = clientSocket.SendReply(CLIENT_OK + std::to_string(i));
202 clientSocket.Close();
226 WebSocketClient clientSocket;
227 ASSERT_STREQ(clientSocket.GetSocketStateString().c_str(), "closed");
228 ASSERT_FALSE(clientSocket.ClientSendWSUpgradeReq());
229 ASSERT_FALSE(clientSocket.ClientRecvWSUpgradeRsp());
230 ASSERT_FALSE(clientSocket.SendReply(HELLO_SERVER));
248 WebSocketClient clientSocket;
252 clientSocket.SetCloseConnectionCallback(closeCallBack);
255 ASSERT_TRUE(clientSocket.InitToolchainWebSocketForSockName(UNIX_DOMAIN_PATH_3 + std::to_string(appPid), 5));
257 ASSERT_TRUE(clientSocket.InitToolchainWebSocketForSockName(UNIX_DOMAIN_PATH_3 + std::to_string(appPid), 5));
259 ASSERT_TRUE(clientSocket.InitToolchainWebSocketForPort(TCP_PORT, 5));
261 ASSERT_TRUE(clientSocket.InitToolchainWebSocketForPort(TCP_PORT, 5));
263 ASSERT_TRUE(clientSocket.ClientSendWSUpgradeReq());
264 ASSERT_FALSE(clientSocket.ClientRecvWSUpgradeRsp());