Home
last modified time | relevance | path

Searched refs:connection (Results 1 - 16 of 16) sorted by relevance

/arkcompiler/toolchain/test/autotest/aw/api/
H A Ddebugger_api.py72 connection = ThreadConnectionInfo(instance_id, send_queue, recv_queue)
73 return connection
81 async def enable(self, message_id, connection, params):
82 response = await communicate_with_debugger_server(connection.instance_id,
83 connection.send_msg_queue,
84 connection.received_msg_queue,
87 response = await self.websocket.recv_msg_of_debugger_server(connection.instance_id,
88 connection.received_msg_queue)
92 async def disable(self, message_id, connection, params):
93 response = await communicate_with_debugger_server(connection
[all...]
H A Druntime_api.py37 async def enable(self, message_id, connection, params):
38 response = await communicate_with_debugger_server(connection.instance_id,
39 connection.send_msg_queue,
40 connection.received_msg_queue,
46 async def run_if_waiting_for_debugger(self, message_id, connection, params):
47 response = await communicate_with_debugger_server(connection.instance_id,
48 connection.send_msg_queue,
49 connection.received_msg_queue,
55 async def get_properties(self, message_id, connection, params):
56 response = await communicate_with_debugger_server(connection
[all...]
H A Dheap_profiler_api.py36 async def start_tracking_heap_objects(self, message_id, connection, params):
37 response = await communicate_with_debugger_server(connection.instance_id,
38 connection.send_msg_queue,
39 connection.received_msg_queue,
45 async def stop_tracking_heap_objects(self, message_id, connection, params):
46 response = await communicate_with_debugger_server(connection.instance_id,
47 connection.send_msg_queue,
48 connection.received_msg_queue,
51 response = await self.websocket.recv_msg_of_debugger_server(connection.instance_id,
52 connection
[all...]
H A Dprofiler_api.py36 async def start(self, message_id, connection, params):
37 response = await communicate_with_debugger_server(connection.instance_id,
38 connection.send_msg_queue,
39 connection.received_msg_queue,
45 async def stop(self, message_id, connection, params):
46 response = await communicate_with_debugger_server(connection.instance_id,
47 connection.send_msg_queue,
48 connection.received_msg_queue,
55 async def set_sampling_interval(self, message_id, connection, params):
56 response = await communicate_with_debugger_server(connection
[all...]
H A Dprotocol_api.py32 async def send(self, protocol_name, connection, params=None):
40 return await self.dispatch_table.get(protocol)[0](message_id, connection, params)
42 async def recv(self, protocol_name, connection, params=None):
49 return await self.dispatch_table.get(protocol)[0](connection, params)
/arkcompiler/runtime_core/static_core/plugins/ets/tests/debugger/src/arkdb/
H A Ddebug_client.py41 connection: ArkConnection,
49 self.connection = connection
62 return await self.connection.send_and_wait_for(
70 async with self.connection.wait_for(event_type=event_type, buffer_size=buffer_size) as proxy:
77 await self.connection.send(
84 return await self.connection.send_and_wait_for(
97 await self.connection.send(send_arg)
106 return await self.connection.send_and_wait_for(
120 return await self.connection
[all...]
H A Ddebug_connection.py56 def connection(self) -> trio_cdp.CdpConnection: member in ArkConnection
/arkcompiler/toolchain/websocket/client/
H A Dwebsocket_client.cpp46 ToLowerCase(response.connection); in ValidateServerHandShake()
47 if (response.connection != HTTP_RESPONSE_REQUIRED_CONNECTION) { in ValidateServerHandShake()
76 int connection = socket(AF_INET, SOCK_STREAM, 0); in InitToolchainWebSocketForPort() local
77 if (connection < SOCKET_SUCCESS) { in InitToolchainWebSocketForPort()
82 SetConnectionSocket(connection); in InitToolchainWebSocketForPort()
85 if (!SetWebSocketTimeOut(connection, timeoutLimit)) { in InitToolchainWebSocketForPort()
109 ret = connect(connection, reinterpret_cast<struct sockaddr*>(&clientAddr), sizeof(clientAddr)); in InitToolchainWebSocketForPort()
128 int connection = socket(AF_UNIX, SOCK_STREAM, 0); in InitToolchainWebSocketForSockName() local
129 if (connection < SOCKET_SUCCESS) { in InitToolchainWebSocketForSockName()
134 SetConnectionSocket(connection); in InitToolchainWebSocketForSockName()
[all...]
/arkcompiler/toolchain/websocket/server/
H A Dwebsocket_server.cpp39 return req.connection.find("Upgrade") != std::string::npos && in ValidateHandShakeMessage()
153 LOGW("MoveToConnectingState during closing connection"); in MoveToConnectingState()
156 LOGW("MoveToConnectingState during already established connection"); in MoveToConnectingState()
159 LOGE("MoveToConnectingState during opening connection, which violates WebSocketServer guarantees"); in MoveToConnectingState()
168 // Server `Close` happened, `serverFd_` was closed, new connection must not be opened. in MoveToConnectingState()
312 if (listen(serverFd_, 1) != SOCKET_SUCCESS) { // 1: connection num in InitUnixWebSocket()
397 // "The server MUST close the connection upon receiving a frame that is not masked." in ValidateIncomingFrame()
420 WebSocketServer::ConnectionState WebSocketServer::WaitConnectingStateEnds(ConnectionState connection) in WaitConnectingStateEnds() argument
435 while (connection == ConnectionState::CONNECTING) { in WaitConnectingStateEnds()
437 // Try to shutdown the already accepted connection socke in WaitConnectingStateEnds()
464 auto connection = GetConnectionState(); Close() local
[all...]
H A Dwebsocket_server.h34 * @brief Accept new posix-socket connection.
62 * @brief Initialize connection with unix-socket.
65 * Note that this mode supports only a single connection,
67 * @param socketfd connection socket file descriptor, must be correctly opened before calling the method.
73 * @brief Accept new unix-socket connection.
86 * @brief Set callback for calling after accepted new connection.
92 * @brief Close server endpoint and connection sockets.
130 * @param connection previously loaded connection state.
131 * @returns updated connection stat
[all...]
/arkcompiler/toolchain/tooling/client/tcpServer/test/
H A Djs_test_base.py46 connection = 0
47 while(connection < 5):
68 connection = connection + 1
69 if connection == 5:
/arkcompiler/toolchain/websocket/test/
H A Dhttp_decoder_test.cpp73 ASSERT_EQ(parsed.connection, EXPECTED_CONNECTION); in HWTEST_F()
85 ASSERT_EQ(parsed.connection, ""); in HWTEST_F()
98 ASSERT_EQ(parsed.connection, EXPECTED_CONNECTION); in HWTEST_F()
111 ASSERT_EQ(parsed.connection, ""); in HWTEST_F()
/arkcompiler/runtime_core/static_core/runtime/tooling/inspector/connection/asio/
H A Dserver_endpoint.h19 #include "tooling/inspector/connection/server_endpoint_base.h"
46 // set new connection only if there is no already existing one in Pin()
53 // expect that the given connection is the one already stored in Unpin()
64 if (auto connection = GetPinnedConnection()) {
65 connection->send(message, websocketpp::frame::opcode::text);
H A Dserver_endpoint-inl.h55 if (auto connection = GetPinnedConnection()) { in Close()
57 connection->close(websocketpp::close::status::going_away, "", ec); in Close()
59 LOG(ERROR, DEBUGGER) << "Error closing websocket connection: " << ec.message(); in Close()
/arkcompiler/toolchain/websocket/
H A Dhttp.h36 std::string connection; member
50 std::string connection; member
H A Dhttp.cpp66 parsed.connection = DecodeHeader(request, CONNECTION); in Decode()
116 parsed.connection = DecodeHeader(response, CONNECTION); in Decode()

Completed in 5 milliseconds