Home
last modified time | relevance | path

Searched refs:server (Results 1 – 25 of 41) sorted by relevance

12

/developtools/integration_verification/tools/fotff/pkg/gitee_common/
Dbuild.go69 server := res.GetBuildServer()
70 defer res.ReleaseBuildServer(server)
71 …%s && repo init -u https://gitee.com/openharmony/manifest.git", server.WorkSpace, server.WorkSpace)
72 …if err := utils.RunCmdViaSSHContext(ctx, server.Addr, server.User, server.Passwd, cmd); err != nil…
75 if err := utils.TransFileViaSSH(utils.Upload, server.Addr, server.User, server.Passwd,
76 …fmt.Sprintf("%s/.repo/manifest.xml", server.WorkSpace), filepath.Join(m.Workspace, config.Pkg, "ma…
80 …&& git clean -dfx && git lfs update --force && git lfs install && git lfs pull'", server.WorkSpace)
81 …if err := utils.RunCmdViaSSHContext(ctx, server.Addr, server.User, server.Passwd, cmd); err != nil…
84 cmd = fmt.Sprintf("cd %s && %s", server.WorkSpace, config.PreCompileCMD)
85 …if err := utils.RunCmdViaSSHContextNoRetry(ctx, server.Addr, server.User, server.Passwd, cmd); err…
[all …]
/developtools/profiler/hiebpf/test/unittest/
Dipc_unix_socket_test.cpp44 IpcUnixSocketServer server; variable
45 ASSERT_TRUE(server.Start(TEST_PATH_NAME));
47 ASSERT_TRUE(server.Stop());
58 IpcUnixSocketServer server; variable
59 ASSERT_TRUE(server.Start(TEST_PATH_NAME));
74 server.SetHandleCallback([&](const void *buf, size_t size) { in __anonc96ee73d0102()
75 server.SendMessage(buf, size); in __anonc96ee73d0102()
83 ASSERT_TRUE(server.Stop());
88 IpcUnixSocketServer server; variable
90 ASSERT_FALSE(server.SendMessage(cmd.data(), cmd.size()));
[all …]
/developtools/hdc/src/test/
Dut_mod.cpp169 void UtForwardWaiter(uv_loop_t *loop, uv_tcp_t *server) in UtForwardWaiter() argument
171 auto funcOnNewConn = [](uv_stream_t *server, int status) -> void { in UtForwardWaiter() argument
185 uv_tcp_init(server->loop, client); in UtForwardWaiter()
186 if (uv_accept(server, (uv_stream_t *)client) == 0) { in UtForwardWaiter()
199 if (uv_tcp_init(loop, server) || uv_ip4_addr("127.0.0.1", utForwardTargetPort, &addr)) { in UtForwardWaiter()
202 …if (uv_tcp_bind(server, (const struct sockaddr *)&addr, 0) || uv_listen((uv_stream_t *)server, 5, … in UtForwardWaiter()
208 bool UtForwardConnect(uv_loop_t *loop, uv_tcp_t *client, uv_tcp_t *server) in UtForwardConnect() argument
211 uv_tcp_t *server = (uv_tcp_t *)req->data; in UtForwardConnect() local
218 uv_close((uv_handle_t *)server, nullptr); // notify UtForwardWaiter stop in UtForwardConnect()
226 connReq->data = server; in UtForwardConnect()
[all …]
Dut_runtime.cpp62 thisClass->server->PostStopInstanceMessage(); in CheckStopServer()
71 HdcServer server(true); in StartServer() local
72 server.Initial(DEFAULT_SERVER_ADDR.c_str()); in StartServer()
73 thisClass->server = &server; in StartServer()
77 uv_idle_init(&server.loopMain, idt); in StartServer()
80 server.WorkerPendding(); in StartServer()
Dut_command.cpp21 HdcServer server(true); in TestBackgroundServerForClient() local
22 server.Initial("0.0.0.0:8710"); in TestBackgroundServerForClient()
23 server.WorkerPendding(); in TestBackgroundServerForClient()
Dut_runtime.h61 Hdc::HdcServer *server; variable
/developtools/hdc/test/unittest/common/
Duart_test.cpp43 std::unique_ptr<HdcSession> server; member in Hdc::HdcUARTBaseTest
117 server = std::make_unique<HdcSession>(); in SetUp()
118 server->serverOrDaemon = true; in SetUp()
119 server->sessionId = serverId; in SetUp()
120 server->hUART = serverHdcUart.get(); in SetUp()
234 MakeRndData(sourceData, server->sessionId);
260 ASSERT_EQ(pUARTHead->sessionId, server->sessionId); in __anon7f708f190402()
279 ASSERT_EQ(mockUARTBase.SendUARTData(server.get(), sourceData.data(), testPackageSize[i]),
294 MakeRndData(data, server->sessionId);
298 ASSERT_EQ(mockUARTBase.UartSendToHdcStream(server.get(), data.data(), i), true);
[all …]
/developtools/hdc/src/host/
Dhost_uart.cpp28 : HdcUARTBase(serverIn, externInterface), server(serverIn) in HdcHostUART()
30 uv_timer_init(&server.loopMain, &devUartWatcher); in HdcHostUART()
427 server.AdminDaemonMap(OP_REMOVE, connectKey, diNewPtr); in EnumSerialPort()
438 server.AdminDaemonMap(OP_QUERY, connectKey, diOldPtr); in EnumSerialPort()
441 server.AdminDaemonMap(OP_ADD, connectKey, diNewPtr); in EnumSerialPort()
443 server.AdminDaemonMap(OP_UPDATE, connectKey, diNewPtr); in EnumSerialPort()
454 server.FreeSession(hSession->sessionId); in EnumSerialPort()
493 externInterface.StartWorkThread(&server.loopMain, server.SessionWorkThread, in EnumSerialPort()
499 auto ctrl = server.BuildCtrlString(SP_START_SESSION, 0, nullptr, 0); in EnumSerialPort()
545 server.AdminDaemonMap(OP_QUERY, port, hdi); in EnumSerialPort()
[all …]
Dhost_tcp.cpp80 uv_udp_t server; in BroadcastFindDaemon() local
81 server.data = this; in BroadcastFindDaemon()
83 uv_udp_init(&loopBroadcast, &server); in BroadcastFindDaemon()
84 uv_udp_bind(&server, (const struct sockaddr *)&addr, UV_UDP_REUSEADDR); in BroadcastFindDaemon()
85 uv_udp_recv_start(&server, AllocStreamUDP, RecvUDP); in BroadcastFindDaemon()
Dserver_for_client.h35 static void AcceptClient(uv_stream_t *server, int status);
Dmain.cpp168 HdcServer server(true); in RunServerMode() local
169 if (!server.Initial(serverListenString.c_str())) { in RunServerMode()
173 server.WorkerPendding(); in RunServerMode()
/developtools/profiler/device/services/ipc/src/
Dservice_entry.cpp30 auto server = std::make_shared<UnixSocketServer>(); in StartServer() local
32 CHECK_TRUE(server->StartServer(addrname, *this), false, "StartServer FAIL"); in StartServer()
34 unixSocketServer_ = server; in StartServer()
/developtools/smartperf_host/ide/test/trace/
DSpApplication.test.ts65 spApplication.server = true;
66 expect(spApplication.server).toBeTruthy();
70 spApplication.server = false;
71 expect(spApplication.server).toBeFalsy();
/developtools/integration_verification/tools/fotff/utils/
Dpprof.go20 server := &http.Server{Addr: net.JoinHostPort("localhost", cfg.Port)}
22 if err := server.ListenAndServe(); err != nil {
/developtools/hdc/src/daemon/
Ddaemon_tcp.cpp69 void HdcDaemonTCP::AcceptClient(uv_stream_t *server, int status) in AcceptClient() argument
71 uv_loop_t *ptrLoop = server->loop; in AcceptClient()
72 uv_tcp_t *pServTCP = (uv_tcp_t *)server; in AcceptClient()
83 if (uv_accept(server, (uv_stream_t *)&hSession->hWorkTCP) < 0) { in AcceptClient()
Ddaemon_tcp.h34 static void AcceptClient(uv_stream_t *server, int status);
/developtools/hdc/hdc_rust/src/host/
Dclient.rs16 use super::server;
50 server::server_kill().await; in run_client_mode()
52 server::server_fork(parsed_cmd.server_addr.clone()).await; in run_client_mode()
56 server::server_kill().await; in run_client_mode()
58 server::server_fork(parsed_cmd.server_addr.clone()).await; in run_client_mode()
66 if parsed_cmd.launch_server && server::check_allow_fork().await { in run_client_mode()
67 let _ = server::server_fork(parsed_cmd.server_addr.clone()).await; in run_client_mode()
Dmain.rs20 mod server; module
67 let _ = server::run_server_mode(parsed_cmd.server_addr).await; in main()
/developtools/profiler/protos/services/
Dprofiler_service.proto30 // start tracing session, active server side tracing triggers.
33 // get server-side cached tracing data since current session started.
36 // stop tracing session, deactivate server side tracing triggers.
/developtools/smartperf_host/trace_streamer/src/protos/services/
Dprofiler_service.proto30 // start tracing session, active server side tracing triggers.
33 // get server-side cached tracing data since current session started.
36 // stop tracing session, deactivate server side tracing triggers.
/developtools/smartperf_host/ide/server/
DsmarperfServer.py19 from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer
73 class SpRequestHandler(http.server.BaseHTTPRequestHandler):
279 server = SpServer(server_address, CERT_FILE, KEY_FILE)
280 server.start()
/developtools/ace_ets2bundle/
DBUILD.gn44 ":server",
222 ohos_copy("server") {
223 sources = [ "compiler/server" ]
296 sources = [ "compiler/server" ]
297 outputs = [ target_out_dir + "/ets_loader_ark/server" ]
/developtools/hdc/src/common/
Dforward.h75 static void ListenCallback(uv_stream_t *server, const int status);
95 void OnAccept(uv_stream_t *server, HCtxForward ctxClient, uv_stream_t *client);
Dforward.cpp57 void HdcForwardBase::OnAccept(uv_stream_t *server, HCtxForward ctxClient, uv_stream_t *client) in OnAccept() argument
59 HCtxForward ctxListen = (HCtxForward)server->data; in OnAccept()
63 if (uv_accept(server, client)) { in OnAccept()
88 void HdcForwardBase::ListenCallback(uv_stream_t *server, const int status) in ListenCallback() argument
90 HCtxForward ctxListen = (HCtxForward)server->data; in ListenCallback()
113 thisClass->OnAccept(server, ctxClient, client); in ListenCallback()
/developtools/ace_ets2bundle/compiler/test/
DREADME.md19 npm config set proxy http://username:password@server:port
20 npm confit set https-proxy http://username:password@server:port

12