| /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/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 | 30 expect(hiProfilerClient.client).toBeUndefined(); 34 hiProfilerClient.client = true; 35 expect(hiProfilerClient.client).toBeTruthy();
|
| D | ProfilerClient.test.ts | 20 expect(ProfilerClient.client).toBeUndefined(); 23 ProfilerClient.client = true; 24 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/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()
|
| D | main.cpp | 203 HdcClient client(false, serverListenString, &loopMain, commands == CMDSTR_CHECK_SERVER); in RunClientMode() local 212 client.CtrlServiceWork(commands.c_str()); in RunClientMode() 220 client.Initial(connectKey); in RunClientMode() 221 client.ExecuteCommand(commands.c_str()); in RunClientMode()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | main.rs | 16 mod client; module 82 if let Err(e) = client::run_client_mode(parsed_cmd).await { in main()
|
| /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.
|
| /developtools/profiler/host/smartperf/client/client_command/ |
| D | sp_server_socket.cpp | 68 …sendto(sock, sendBuf.c_str(), sendBuf.size(), 0, reinterpret_cast<struct sockaddr*>(&client), len); in Sendto() 93 …int l = recvfrom(sock, rbuf, sizeof(rbuf) - 1, 0, reinterpret_cast<struct sockaddr*>(&client), &le… in Recvfrom()
|
| D | README_zh.md | 6 …//gitee.com/openharmony/developtools_profiler/blob/master/host/smartperf/client/client_ui/README_z… 10 /developtools/profiler/host/smartperf/client/client_command
|
| /developtools/profiler/host/smartperf/client/client_command/include/ |
| D | sp_server_socket.h | 45 struct sockaddr_in client; variable
|
| /developtools/profiler/host/smartperf/client/client_ui/ |
| D | README_zh.md | 5 …//gitee.com/openharmony/developtools_profiler/blob/master/host/smartperf/client/client_command/REA… 10 /developtools/profiler/host/smartperf/client/client_ui
|
| /developtools/smartperf_host/ide/src/hdc/ |
| D | HdcDeviceManager.ts | 77 const client = this.clientList.get(serialNumber); constant 78 if (client) { 79 if (client.usbDevice!.opened) {
|
| /developtools/profiler/hiebpf/src/ |
| D | hiebpf.cpp | 98 static bool SendIpcCommand(OHOS::Developtools::Hiebpf::IpcUnixSocketClient &client, in SendIpcCommand() argument 101 …CHECK_TRUE(client.SendMessage(&cmd, sizeof(HiebpfIpcCommand)), false, "send request(0x%x) failed\n… in SendIpcCommand() 105 CHECK_TRUE(client.RecvMessage(buf, size, timeout), false, "recv reply failed\n"); in SendIpcCommand()
|
| /developtools/hdc/src/test/jdwp/ |
| D | HdcJdwpSimulator.h | 49 static void ProcessIncoming(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf);
|
| D | HdcJdwpSimulator.cpp | 96 void HdcJdwpSimulator::ProcessIncoming(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) in ProcessIncoming() argument 125 SendToStream(client, buf, HANDSHAKE_MESSAGE.size() + nread + 1, in ProcessIncoming() 134 uv_close((uv_handle_t *)client, NULL); in ProcessIncoming()
|
| /developtools/integration_verification/DeployDevice/src/func/liteOsUpgrade/ |
| D | liteOsUpgrade_L1_shequ_dv_app.py | 146 client = paramiko.Transport((tftp_ip,22)) 147 client.connect(username=username,password=passwd) 148 sftp = paramiko.SFTPClient.from_transport(client) 214 client.close() 220 client.close()
|
| /developtools/profiler/host/smartperf/client/ |
| D | BUILD.gn | 21 [ "//developtools/profiler/host/smartperf/client/client_ui/:SmartPerf" ]
|
| /developtools/profiler/device/plugins/arkts_plugin/include/ |
| D | arkts_plugin.h | 54 bool Recv(int32_t client, char* buf, size_t totalLen, int32_t flags) const;
|
| /developtools/smartperf_host/trace_streamer/doc/ |
| D | app_startup.md | 10 ProcessTouchEvent:在callstack表中查找包含"H:client dispatch touchId:"的字符,即为启动第1阶段。注:一次点击存在多个,取后面trace前的最后一…
|
| /developtools/hdc/src/common/ |
| D | forward.cpp | 57 void HdcForwardBase::OnAccept(uv_stream_t *server, HCtxForward ctxClient, uv_stream_t *client) in OnAccept() argument 63 if (uv_accept(server, client)) { in OnAccept() 92 uv_stream_t *client = nullptr; in ListenCallback() local 107 client = (uv_stream_t *)&ctxClient->tcp; in ListenCallback() 111 client = (uv_stream_t *)&ctxClient->pipe; in ListenCallback() 113 thisClass->OnAccept(server, ctxClient, client); in ListenCallback()
|