Home
last modified time | relevance | path

Searched refs:client (Results 1 - 15 of 15) sorted by relevance

/arkcompiler/runtime_core/static_core/plugins/ets/tests/debugger/src/tests/
H A Dtest_breaks_props.py107 paused = await client.resume_and_wait_for_paused()
113 paused=paused_locator(paused=paused, client=client),
121 async with debug_locator.connect(nursery) as client:
122 await client.configure(nursery)
123 _ = await client.run_if_waiting_for_debugger()
125 (bp_id, _) = await client.set_breakpoint_by_url(
165 async def _check(client: DebuggerClient, brekpoint: Breakpoint):
167 paused = await client.resume_and_wait_for_paused()
172 paused=paused_locator(paused=paused, client
[all...]
H A Dtest_steps.py101 async with debug_locator.connect(nursery) as client:
102 await client.configure(nursery)
103 paused = await client.run_if_waiting_for_debugger()
105 await client.resume()
109 async def _pause_and_get_vars(client: DebuggerClient, log: RichLogger, script_file: ScriptFile, line_number: int):
110 paused = await client.continue_to_location(script_id=runtime.ScriptId("0"), line_number=line_number)
122 for props in [(await client.get_properties(obj_id))[0]
151 async with debug_locator.connect(nursery) as client:
153 await client.configure(nursery)
154 await client
[all...]
H A Dtest_stepping.py57 client = paused_step.client
61 paused = await client.step_into()
63 paused = await client.step_into()
H A Dtest_restart_frame.py53 paused = await stop_point.client.restart_frame(0) # now we returned into frame of the main
62 paused = await stop_point.client.restart_frame(0)
71 paused = await stop_point.client.restart_frame(0)
78 paused = await stop_point.client.restart_frame(1)
H A Dtest_object_preview.py105 properties = await paused.client.get_properties(
/arkcompiler/toolchain/websocket/
H A Dnetwork.cpp21 bool Recv(int32_t client, std::string& buffer, int32_t flags) in Recv() argument
26 auto succeeded = Recv(client, buffer.data(), buffer.size(), flags); in Recv()
33 bool Recv(int32_t client, char* buf, size_t totalLen, int32_t flags) in Recv() argument
38 while ((len = recv(client, buf + recvLen, totalLen - recvLen, flags)) < 0 && in Recv()
51 bool Recv(int32_t client, uint8_t* buf, size_t totalLen, int32_t flags) in Recv() argument
53 return Recv(client, reinterpret_cast<char *>(buf), totalLen, flags); in Recv()
56 bool Send(int32_t client, const std::string& message, int32_t flags) in Send() argument
58 return Send(client, message.c_str(), message.size(), flags); in Send()
61 bool Send(int32_t client, const char* buf, size_t totalLen, int32_t flags) in Send() argument
65 ssize_t len = send(client, bu in Send()
[all...]
H A Dnetwork.h23 bool Recv(int32_t client, std::string& buffer, int32_t flags);
25 bool Recv(int32_t client, char* buf, size_t totalLen, int32_t flags);
27 bool Recv(int32_t client, uint8_t* buf, size_t totalLen, int32_t flags);
29 bool Send(int32_t client, const std::string& message, int32_t flags);
31 bool Send(int32_t client, const char* buf, size_t totalLen, int32_t flags);
/arkcompiler/toolchain/test/autotest/aw/
H A Dwebsocket.py57 async def _sender(client, send_queue):
58 assert client.state == websockets.protocol.OPEN, logging.error(f'Client state of _sender is: {client.state}')
63 await client.close(reason='close')
65 await client.send(json.dumps(send_message))
68 async def _receiver(client, received_queue):
69 assert client.state == websockets.protocol.OPEN, logging.error(f'Client state of _receiver is: {client.state}')
72 response = await client.recv()
107 client
[all...]
/arkcompiler/runtime_core/static_core/plugins/ets/tests/debugger/src/arkdb/
H A Ddebug.py83 client: DebuggerClient
115 async with debug_locator.connect(nursery) as client:
116 await client.configure(nursery)
117 await client.run_if_waiting_for_debugger()
119 bp.breakpoint_id, bp.locations = await client.set_breakpoint_by_url(
125 client=client,
193 paused = await context.client.resume_and_wait_for_paused()
197 paused=paused_locator(paused=paused, client=context.client, met
[all...]
H A Dwalker.py49 client: DebuggerClient,
55 self.client = client
73 paused = await self.client.resume_and_wait_for_paused()
77 locator=Locator(client=self.client, meta=self.meta),
93 client=context.client,
H A Ddebug_types.py41 def __init__(self, client: DebuggerClient, meta: SourceMeta | None = None) -> None:
42 self.client = client
47 result, _, _, _ = await self.client.get_properties(id, generate_preview=False)
78 def client(self): member in Wrap
79 return self.locator.client
222 return await self.client.resume_and_wait_for_paused()
237 compiled_expression = self.client.code_compiler.compile_expression(
256 return await self.client.evaluate(compiled_expression_bytecode)
259 def paused_locator(paused: debugger.Paused, client
[all...]
H A Ddebug_client.py239 def __init__(self, client: DebuggerClient) -> None:
241 self.client = client
245 await self.client.set_breakpoints_active(True)
246 br, locs = await self.client.set_breakpoint_by_url(line_number=line_number, url=url)
269 await self.client.get_possible_breakpoints(
/arkcompiler/toolchain/tooling/test/client_utils/
H A Dtest_util.cpp18 #include "tooling/client/domain/debugger_client.h"
19 #include "tooling/client/domain/runtime_client.h"
20 #include "tooling/client/utils/cli_command.h"
21 #include "tooling/client/session/session.h"
22 #include "websocket/client/websocket_client.h"
113 WebSocketClient &client = SessionManager::getInstance().GetCurrentSession()->GetWebSocketClient(); in ForkSocketClient() local
124 std::string recv = client.Decode(); in ForkSocketClient()
125 HandleAcceptanceMessages(action, client, recv, success); in ForkSocketClient()
144 void TestUtil::HandleAcceptanceMessages(ActionInfo action, WebSocketClient &client, std::string &recv, bool &success) in HandleAcceptanceMessages() argument
155 recv = client in HandleAcceptanceMessages()
[all...]
H A Dtest_util.h21 #include "tooling/client/domain/debugger_client.h"
22 #include "tooling/client/domain/runtime_client.h"
23 #include "tooling/client/manager/domain_manager.h"
69 static void HandleAcceptanceMessages(ActionInfo action, WebSocketClient &client, std::string &recv, bool &success);
/arkcompiler/ets_frontend/test/scripts/utils/download_sdk_and_image/
H A Ddownload.py133 with httpx.Client() as client:
134 response = client.head(download_url)
147 with httpx.Client() as client:
148 response = client.head(download_url)
165 with client.stream('GET', download_url, headers=headers) as response:

Completed in 5 milliseconds