Home
last modified time | relevance | path

Searched refs:client (Results 1 – 25 of 34) sorted by relevance

12

/developtools/profiler/hiebpf/test/unittest/
Dipc_unix_socket_test.cpp52 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/
Dssh.go56 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/
Dut_mod.cpp172 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 …]
Dut_command.cpp32 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/
DHiProfilerClient.test.ts30 expect(hiProfilerClient.client).toBeUndefined();
34 hiProfilerClient.client = true;
35 expect(hiProfilerClient.client).toBeTruthy();
DProfilerClient.test.ts20 expect(ProfilerClient.client).toBeUndefined();
23 ProfilerClient.client = true;
24 expect(ProfilerClient.client).toBeTruthy();
/developtools/smartperf_host/ide/src/trace/grpc/
DHiProfilerClient.ts27 get client(): ProfilerClient { method in HiProfilerClient
31 set client(value: ProfilerClient) { method in HiProfilerClient
DProfilerClient.ts49 get client(): any { method in ProfilerClient
53 set client(value: any) { method in ProfilerClient
/developtools/hdc/src/host/
Dhost_tcp.cpp70 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()
Dmain.cpp203 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/
Dmain.rs16 mod client; module
82 if let Err(e) = client::run_client_mode(parsed_cmd).await { in main()
/developtools/hdc/
DREADME.md19client 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/
Dsp_server_socket.cpp68 …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()
DREADME_zh.md6 …//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/
Dsp_server_socket.h45 struct sockaddr_in client; variable
/developtools/profiler/host/smartperf/client/client_ui/
DREADME_zh.md5 …//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/
DHdcDeviceManager.ts77 const client = this.clientList.get(serialNumber); constant
78 if (client) {
79 if (client.usbDevice!.opened) {
/developtools/profiler/hiebpf/src/
Dhiebpf.cpp98 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/
DHdcJdwpSimulator.h49 static void ProcessIncoming(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf);
DHdcJdwpSimulator.cpp96 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/
DliteOsUpgrade_L1_shequ_dv_app.py146 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/
DBUILD.gn21 [ "//developtools/profiler/host/smartperf/client/client_ui/:SmartPerf" ]
/developtools/profiler/device/plugins/arkts_plugin/include/
Darkts_plugin.h54 bool Recv(int32_t client, char* buf, size_t totalLen, int32_t flags) const;
/developtools/smartperf_host/trace_streamer/doc/
Dapp_startup.md10 ProcessTouchEvent:在callstack表中查找包含"H:client dispatch touchId:"的字符,即为启动第1阶段。注:一次点击存在多个,取后面trace前的最后一…
/developtools/hdc/src/common/
Dforward.cpp57 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()

12