| /developtools/smartperf_host/trace_streamer/src/rpc/ |
| D | http_server.cpp | 104 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
105 if (sockets_[index].Accept(client->sock_)) { in Run()
106 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
107 clientThreads_.push_back(std::move(client)); in Run()
144 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
145 if (sockets_[i].Accept(client->sock_)) { in Run()
146 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
147 clientThreads_.push_back(std::move(client)); in Run()
209 HttpSocket& client) in ProcessAndParseReq() argument
211 if (!client.Recv(recvBuf.data() + recvPos, recvLen)) { in ProcessAndParseReq()
[all …]
|
| D | http_server.h | 53 void ProcessClient(HttpSocket& client);
54 void ProcessRequest(HttpSocket& client, RequestST& request);
55 static void HttpResponse(HttpSocket& client, const std::string& status, bool hasBody = false);
64 HttpSocket& client);
|
| D | http_socket.cpp | 105 bool HttpSocket::Accept(HttpSocket& client) in Accept() argument
113 client.domain_ = domain_; in Accept()
114 client.sockId_ = clientId; in Accept()
|
| /developtools/profiler/host/smartperf/trace_streamer/src/rpc/ |
| D | http_server.cpp | 94 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
95 if (sockets_[index].Accept(client->sock_)) { in Run()
96 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
97 clientThreads_.push_back(std::move(client)); in Run()
140 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
141 if (sockets_[i].Accept(client->sock_)) { in Run()
142 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
143 clientThreads_.push_back(std::move(client)); in Run()
208 void HttpServer::ProcessClient(HttpSocket& client) in ProcessClient() argument
219 WSAEventSelect(client.GetFd(), recvEvent, FD_READ | FD_CLOSE); in ProcessClient()
[all …]
|
| D | http_server.h | 53 void ProcessClient(HttpSocket& client);
54 void ProcessRequest(HttpSocket& client, RequestST& request);
55 static void HttpResponse(HttpSocket& client, const std::string& status, bool hasBody = false);
|
| D | http_socket.cpp | 105 bool HttpSocket::Accept(HttpSocket& client) in Accept() argument
113 client.domain_ = domain_; in Accept()
114 client.sockId_ = clientId; in Accept()
|
| /developtools/profiler/hiebpf/test/unittest/ |
| D | ipc_unix_socket_test.cpp | 52 IpcUnixSocketClient client; variable
53 ASSERT_FALSE(client.Connect(TEST_PATH_NAME));
61 IpcUnixSocketClient client; variable
62 ASSERT_TRUE(client.Connect(TEST_PATH_NAME));
64 ASSERT_TRUE(client.SendMessage(cmd.data(), cmd.size()));
70 ASSERT_TRUE(client.RecvMessage(buf.data(), size, timeout));
77 ASSERT_TRUE(client.SendMessage(cmd.data(), cmd.size()));
78 ASSERT_TRUE(client.RecvMessage(buf.data(), size, timeout));
82 client.Disconnect();
95 IpcUnixSocketClient client; variable
[all …]
|
| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/rpc/ |
| D | http_server.cpp | 93 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
94 if (sockets_[index].Accept(client->sock_)) { in Run()
95 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
96 clientThreads_.push_back(std::move(client)); in Run()
139 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
140 if (sockets_[i].Accept(client->sock_)) { in Run()
141 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
142 clientThreads_.push_back(std::move(client)); in Run()
207 void HttpServer::ProcessClient(HttpSocket& client) in ProcessClient() argument
218 WSAEventSelect(client.GetFd(), recvEvent, FD_READ | FD_CLOSE); in ProcessClient()
[all …]
|
| D | http_server.h | 53 void ProcessClient(HttpSocket& client);
54 static void ProcessRequest(HttpSocket& client, RequestST& request);
|
| D | http_socket.cpp | 105 bool HttpSocket::Accept(HttpSocket& client) in Accept() argument
113 client.domain_ = domain_; in Accept()
114 client.sockId_ = clientId; in Accept()
|
| /developtools/smartperf_host/trace_streamer/sdk/dubai_sdk/rpc/ |
| D | http_server.cpp | 93 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
94 if (sockets_[index].Accept(client->sock_)) { in Run()
95 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
96 clientThreads_.push_back(std::move(client)); in Run()
139 std::unique_ptr<ClientThread> client = std::make_unique<ClientThread>(); in Run() local
140 if (sockets_[i].Accept(client->sock_)) { in Run()
141 … client->thread_ = std::thread(&HttpServer::ProcessClient, this, std::ref(client->sock_)); in Run()
142 clientThreads_.push_back(std::move(client)); in Run()
207 void HttpServer::ProcessClient(HttpSocket& client) in ProcessClient() argument
218 WSAEventSelect(client.GetFd(), recvEvent, FD_READ | FD_CLOSE); in ProcessClient()
[all …]
|
| D | http_server.h | 53 void ProcessClient(HttpSocket& client);
54 static void ProcessRequest(HttpSocket& client, RequestST& request);
|
| D | http_socket.cpp | 105 bool HttpSocket::Accept(HttpSocket& client) in Accept() argument
113 client.domain_ = domain_; in Accept()
114 client.sockId_ = clientId; in Accept()
|
| /developtools/integration_verification/tools/fotff/utils/ |
| D | ssh.go | 56 client, err := newSSHClient(addr, user, passwd)
61 defer client.Close()
62 session, err := client.NewSession()
120 client, err := sftp.NewClient(c)
125 defer client.Close()
130 if src, err = client.Open(remoteFile); err != nil {
146 client.Remove(remoteFile)
147 client.MkdirAll(filepath.Dir(remoteFile))
148 if dst, err = client.Create(remoteFile); err != nil {
|
| /developtools/hdc/src/test/ |
| D | ut_mod.cpp | 172 auto funcOnRead = [](uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) -> void { in UtForwardWaiter() argument
178 uv_close((uv_handle_t *)client, [](uv_handle_t *handle) { free(handle); }); in UtForwardWaiter()
184 uv_tcp_t *client = new uv_tcp_t(); in UtForwardWaiter() local
185 uv_tcp_init(server->loop, client); in UtForwardWaiter()
186 if (uv_accept(server, (uv_stream_t *)client) == 0) { in UtForwardWaiter()
187 uv_read_start((uv_stream_t *)client, in UtForwardWaiter()
194 uv_close((uv_handle_t *)client, [](uv_handle_t *handle) { free(handle); }); in UtForwardWaiter()
208 bool UtForwardConnect(uv_loop_t *loop, uv_tcp_t *client, uv_tcp_t *server) in UtForwardConnect() argument
228 if (uv_tcp_init(loop, client)) { in UtForwardConnect()
232 if (uv_tcp_connect(connReq, client, (const struct sockaddr *)&addr, funcConn)) { in UtForwardConnect()
[all …]
|
| D | ut_command.cpp | 32 HdcClient client(false, debugServerPort, &loopMain); in TestRunClient() local
33 client.Initial(debugConnectKey); in TestRunClient()
34 client.ExecuteCommand(cmd); in TestRunClient()
|
| /developtools/smartperf_host/ide/test/trace/grpc/ |
| D | HiProfilerClient.test.ts | 31 expect(hiProfilerClient.client).toBeUndefined();
35 hiProfilerClient.client = true;
36 expect(hiProfilerClient.client).toBeTruthy();
|
| D | ProfilerClient.test.ts | 21 expect(ProfilerClient.client).toBeUndefined();
24 ProfilerClient.client = true;
25 expect(ProfilerClient.client).toBeTruthy();
|
| /developtools/smartperf_host/ide/src/trace/grpc/ |
| D | HiProfilerClient.ts | 27 get client(): ProfilerClient { method in HiProfilerClient
31 set client(value: ProfilerClient) { method in HiProfilerClient
|
| D | ProfilerClient.ts | 49 get client(): any { method in ProfilerClient
53 set client(value: any) { method in ProfilerClient
|
| /developtools/profiler/host/smartperf/ide/src/trace/grpc/ |
| D | HiProfilerClient.ts | 27 get client(): ProfilerClient { method in HiProfilerClient
31 set client(value: ProfilerClient) { method in HiProfilerClient
|
| D | ProfilerClient.ts | 49 get client(): any { method in ProfilerClient
53 set client(value: any) { method in ProfilerClient
|
| /developtools/hdc/src/host/ |
| D | host_tcp.cpp | 70 uv_udp_t client; in BroadcastFindDaemon() local
73 uv_udp_init(&loopBroadcast, &client); in BroadcastFindDaemon()
74 uv_udp_bind(&client, (const struct sockaddr *)&addr, 0); in BroadcastFindDaemon()
75 uv_udp_set_broadcast(&client, 1); in BroadcastFindDaemon()
78 uv_udp_send(&req, &client, &buf, 1, (const struct sockaddr *)&addr, nullptr); in BroadcastFindDaemon()
|
| /developtools/profiler/host/smartperf/client/client_command/ |
| D | sp_server_socket.cpp | 67 …sendto(sock, sendBuf.c_str(), sendBuf.size(), 0, reinterpret_cast<struct sockaddr*>(&client), len); in Sendto()
90 …int l = recvfrom(sock, rbuf, sizeof(rbuf) - 1, 0, reinterpret_cast<struct sockaddr*>(&client), &le… in Recvfrom()
|
| /developtools/hdc/ |
| D | README.md | 19 …client part: the client running on the development machine, the user can request to execute the co…
21 …he development machine. The server manages the communication between the client and the device-sid…
23 …nHarmony device running on demand, and is responsible for processing requests from the client side.
|