/arkcompiler/toolchain/test/autotest/aw/api/ |
H A D | debugger_api.py | 57 response = await self.websocket.recv_msg_of_connect_server()
58 response = json.loads(response)
59 assert response['type'] == 'addInstance'
60 assert response['instanceId'] == 0, logging.error('InstanceId of the main thread is not 0')
61 assert response['tid'] == pid
63 response = await self.websocket.recv_msg_of_connect_server()
64 response = json.loads(response)
65 assert response['typ [all...] |
H A D | runtime_api.py | 38 response = await communicate_with_debugger_server(connection.instance_id,
42 response = json.loads(response)
43 assert response == {"id": message_id, "result": {"protocols": []}}
44 return response
47 response = await communicate_with_debugger_server(connection.instance_id,
51 response = json.loads(response)
52 assert response == {"id": message_id, "result": {}}
53 return response
[all...] |
H A D | heap_profiler_api.py | 37 response = await communicate_with_debugger_server(connection.instance_id,
41 response = json.loads(response)
42 assert response == {"id": message_id, "result": {}}
43 return response
46 response = await communicate_with_debugger_server(connection.instance_id,
50 while response.startswith('{"method":"HeapProfiler.lastSeenObjectId"'):
51 response = await self.websocket.recv_msg_of_debugger_server(connection.instance_id,
53 assert r'\"location_fields\":[\"object_index\",\"script_id\",\"line\",\"column\"]' in response
54 pre_response = response
[all...] |
H A D | profiler_api.py | 37 response = await communicate_with_debugger_server(connection.instance_id,
41 response = json.loads(response)
42 assert response == {"id": message_id, "result": {}}
43 return response
46 response = await communicate_with_debugger_server(connection.instance_id,
50 response = json.loads(response)
51 assert response['id'] == message_id
52 assert all(i >= 0 for i in response['resul [all...] |
/arkcompiler/toolchain/test/autotest/scenario_test/ |
H A D | test_debug_01.py | 124 response = await self.debugger_impl.recv("Debugger.scriptParsed", main_thread) 125 assert response['params']['url'] == self.config['file_path']['entry_ability'] 126 assert response['params']['endLine'] == 0 130 response = await self.debugger_impl.recv("Debugger.paused", main_thread) 131 assert response['params']['callFrames'][0]['url'] == self.config['file_path']['entry_ability'] 132 assert response['params']['reason'] == 'Break on start' 140 response = await self.debugger_impl.recv("Debugger.scriptParsed", main_thread) 141 assert response['params']['url'] == self.config['file_path']['index'] 142 assert response['params']['endLine'] == 0 146 response [all...] |
H A D | test_debug_03.py | 116 response = await self.debugger_impl.recv("Debugger.scriptParsed", main_thread)
117 assert response['params']['url'] == self.config['file_path']['entry_ability']
118 assert response['params']['endLine'] == 0
122 response = await self.debugger_impl.recv("Debugger.paused", main_thread)
123 assert response['params']['callFrames'][0]['url'] == self.config['file_path']['entry_ability']
124 assert response['params']['reason'] == 'Break on start'
132 response = await self.debugger_impl.recv("Debugger.scriptParsed", main_thread)
133 assert response['params']['url'] == self.config['file_path']['index']
134 assert response['params']['endLine'] == 0
138 response [all...] |
H A D | test_debug_04.py | 142 response = await self.debugger_impl.send("Debugger.getPossibleAndSetBreakpointsByUrl",
144 assert response['result']['locations'][0]['id'] == 'id:10:0:' + self.config['file_path']['index']
145 assert response['result']['locations'][1]['id'] == 'id:17:0:' + self.config['file_path']['index']
146 assert response['result']['locations'][2]['id'] == 'id:25:0:' + self.config['file_path']['index']
154 response = await self.debugger_impl.recv("Debugger.scriptParsed", worker_thread)
155 assert response['params']['url'] == self.config['file_path']['index']
156 assert response['params']['endLine'] == 0
158 response = await self.debugger_impl.recv("Debugger.paused", worker_thread)
159 assert response['params']['callFrames'][0]['url'] == self.config['file_path']['index']
160 assert response['param [all...] |
H A D | test_debug_02.py | 150 response = await self.debugger_impl.send("Debugger.getPossibleAndSetBreakpointsByUrl",
152 assert response['result']['locations'][0]['id'] == 'id:53:0:' + self.config['file_path']['index']
153 assert response['result']['locations'][1]['id'] == 'id:57:0:' + self.config['file_path']['index']
161 response = await self.debugger_impl.recv("Debugger.paused", main_thread)
162 assert response['params']['callFrames'][0]['url'] == self.config['file_path']['index']
163 assert response['params']['hitBreakpoints'] == ['id:53:16:' + self.config['file_path']['index']]
167 response = await self.debugger_impl.destroy_instance()
168 if response['instanceId'] == worker_thread_1.instance_id:
180 response = await self.debugger_impl.send("Debugger.getPossibleAndSetBreakpointsByUrl",
182 assert response['resul [all...] |
/arkcompiler/toolchain/websocket/ |
H A D | http.cpp | 74 std::string HttpResponse::DecodeVersion(const std::string& response, std::string::size_type versionStartPos) in DecodeVersion() argument 77 if (versionStartPos < response.size()) { in DecodeVersion() 78 auto versionEndPos = response.find(' ', versionStartPos); in DecodeVersion() 80 return response.substr(versionStartPos, versionEndPos - versionStartPos); in DecodeVersion() 87 std::string HttpResponse::DecodeStatus(const std::string& response, std::string::size_type versionEndPos) in DecodeStatus() argument 90 if (versionEndPos < response.size() && response[versionEndPos] == ' ') { in DecodeStatus() 91 auto statusStartPos = response.find_first_not_of(' ', versionEndPos); in DecodeStatus() 93 auto statusEndPos = response.find(' ', statusStartPos); in DecodeStatus() 94 statusEndPos = (statusEndPos == std::string::npos) ? response in DecodeStatus() 105 Decode(const std::string& response, HttpResponse& parsed) Decode() argument [all...] |
H A D | http.h | 54 static bool Decode(const std::string& response, HttpResponse& parsed); 57 static std::string DecodeVersion(const std::string& response, std::string::size_type versionStartPos); 58 static std::string DecodeStatus(const std::string& response, std::string::size_type versionEndPos);
|
/arkcompiler/toolchain/tooling/agent/ |
H A D | profiler_impl.cpp | 129 DispatchResponse response = profiler_->Disable(); in Disable() local 130 SendResponse(request, response); in Disable() 135 DispatchResponse response = profiler_->Enable(); in Enable() local 138 SendResponse(request, response, result); in Enable() 143 DispatchResponse response = profiler_->Start(); in Start() local 144 SendResponse(request, response); in Start() 150 DispatchResponse response = profiler_->Stop(&profile); in Stop() local 152 SendResponse(request, response); in Stop() 157 SendResponse(request, response, result); in Stop() 168 DispatchResponse response in EnableSerializationTimeoutCheck() local 174 DispatchResponse response = profiler_->DisableSerializationTimeoutCheck(); DisableSerializationTimeoutCheck() local 185 DispatchResponse response = profiler_->SetSamplingInterval(*params); SetSamplingInterval() local 191 DispatchResponse response = profiler_->GetBestEffortCoverage(); GetBestEffortCoverage() local 197 DispatchResponse response = profiler_->StopPreciseCoverage(); StopPreciseCoverage() local 203 DispatchResponse response = profiler_->TakePreciseCoverage(); TakePreciseCoverage() local 214 DispatchResponse response = profiler_->StartPreciseCoverage(*params); StartPreciseCoverage() local 220 DispatchResponse response = profiler_->StartTypeProfile(); StartTypeProfile() local 226 DispatchResponse response = profiler_->StopTypeProfile(); StopTypeProfile() local 232 DispatchResponse response = profiler_->TakeTypeProfile(); TakeTypeProfile() local [all...] |
H A D | heapprofiler_impl.cpp | 114 DispatchResponse response = heapprofiler_->AddInspectedHeapObject(*params); in AddInspectedHeapObject() local 115 SendResponse(request, response); in AddInspectedHeapObject() 120 DispatchResponse response = heapprofiler_->CollectGarbage(); in CollectGarbage() local 121 SendResponse(request, response); in CollectGarbage() 126 DispatchResponse response = heapprofiler_->Enable(); in Enable() local 129 SendResponse(request, response, result); in Enable() 134 DispatchResponse response = heapprofiler_->Disable(); in Disable() local 135 SendResponse(request, response); in Disable() 147 DispatchResponse response = heapprofiler_->GetHeapObjectId(*params, &objectId); in GetHeapObjectId() local 149 SendResponse(request, response, resul in GetHeapObjectId() 161 DispatchResponse response = heapprofiler_->GetObjectByHeapObjectId(*params, &remoteObjectResult); GetObjectByHeapObjectId() local 174 DispatchResponse response = heapprofiler_->GetSamplingProfile(&profile); GetSamplingProfile() local 192 DispatchResponse response = heapprofiler_->StartSampling(*params); StartSampling() local 199 DispatchResponse response = heapprofiler_->StopSampling(&profile); StopSampling() local 217 DispatchResponse response = heapprofiler_->StartTrackingHeapObjects(*params); StartTrackingHeapObjects() local 228 DispatchResponse response = heapprofiler_->StopTrackingHeapObjects(*params); StopTrackingHeapObjects() local 239 DispatchResponse response = heapprofiler_->TakeHeapSnapshot(*params); TakeHeapSnapshot() local [all...] |
H A D | tracing_impl.cpp | 84 DispatchResponse response = tracing_->GetCategories(categories); in GetCategories() local 85 SendResponse(request, response); in GetCategories() 91 DispatchResponse response = tracing_->RecordClockSyncMarker(syncId); in RecordClockSyncMarker() local 92 SendResponse(request, response); in RecordClockSyncMarker() 101 DispatchResponse response = tracing_->RequestMemoryDump(std::move(params), dumpGuid, success); in RequestMemoryDump() local 102 SendResponse(request, response); in RequestMemoryDump() 109 DispatchResponse response = tracing_->Start(std::move(params)); in Start() local 110 SendResponse(request, response); in Start()
|
H A D | debugger_impl.cpp | 627 DispatchResponse response = debugger_->ContinueToLocation(*params); in ContinueToLocation() local 628 SendResponse(request, response); in ContinueToLocation() 640 DispatchResponse response = debugger_->Enable(*params, &id); in Enable() local 644 SendResponse(request, response, result); in Enable() 649 DispatchResponse response = debugger_->Disable(); in Disable() local 650 SendResponse(request, response); in Disable() 661 DispatchResponse response = debugger_->EvaluateOnCallFrame(*params, &result1); in EvaluateOnCallFrame() local 663 SendResponse(request, response); in EvaluateOnCallFrame() 668 SendResponse(request, response, result); in EvaluateOnCallFrame() 679 DispatchResponse response in GetPossibleBreakpoints() local 692 DispatchResponse response = debugger_->GetScriptSource(*params, &source); GetScriptSource() local 699 DispatchResponse response = debugger_->Pause(); Pause() local 710 DispatchResponse response = debugger_->RemoveBreakpoint(*params); RemoveBreakpoint() local 721 DispatchResponse response = debugger_->RemoveBreakpointsByUrl(*params); RemoveBreakpointsByUrl() local 732 DispatchResponse response = debugger_->Resume(*params); Resume() local 738 DispatchResponse response = debugger_->SetAsyncCallStackDepth(); SetAsyncCallStackDepth() local 752 DispatchResponse response = debugger_->SetBreakpointByUrl(*params, &outId, &outLocations); SetBreakpointByUrl() local 765 DispatchResponse response = debugger_->SetBreakpointsActive(*params); SetBreakpointsActive() local 779 DispatchResponse response = debugger_->GetPossibleAndSetBreakpointByUrl(*params, outLocation); GetPossibleAndSetBreakpointByUrl() local 792 DispatchResponse response = debugger_->SetPauseOnExceptions(*params); SetPauseOnExceptions() local 804 DispatchResponse response = debugger_->SetSkipAllPauses(*params); SetSkipAllPauses() local 815 DispatchResponse response = debugger_->SetNativeRange(*params); SetNativeRange() local 826 DispatchResponse response = debugger_->ResetSingleStepper(*params); ResetSingleStepper() local 837 DispatchResponse response = debugger_->StepInto(*params); StepInto() local 848 DispatchResponse response = debugger_->SmartStepInto(*params); SmartStepInto() local 854 DispatchResponse response = debugger_->StepOut(); StepOut() local 865 DispatchResponse response = debugger_->StepOver(*params); StepOver() local 876 DispatchResponse response = debugger_->SetMixedDebugEnabled(*params); SetMixedDebugEnabled() local 887 DispatchResponse response = debugger_->ReplyNativeCalling(*params); ReplyNativeCalling() local 893 DispatchResponse response = debugger_->SetBlackboxPatterns(); SetBlackboxPatterns() local 904 DispatchResponse response = debugger_->DropFrame(*params); DropFrame() local 924 DispatchResponse response = debugger_->CallFunctionOn(*params, &outRemoteObject, &outExceptionDetails); CallFunctionOn() local [all...] |
H A D | css_impl.cpp | 47 DispatchResponse response = DispatchResponse::Ok(); in Disable() local 48 SendResponse(request, response); in Disable()
|
H A D | page_impl.cpp | 47 DispatchResponse response = DispatchResponse::Ok(); in GetNavigationHistory() local 49 SendResponse(request, response, result); in GetNavigationHistory()
|
H A D | overlay_impl.cpp | 49 DispatchResponse response = DispatchResponse::Ok(); in Disable() local 50 SendResponse(request, response); in Disable()
|
H A D | dom_impl.cpp | 47 DispatchResponse response = DispatchResponse::Ok(); in Disable() local 48 SendResponse(request, response); in Disable()
|
/arkcompiler/toolchain/tooling/ |
H A D | dispatcher.cpp | 96 DispatchResponse response; in Create() local 97 response.code_ = code; in Create() 98 response.errorMsg_ = msg; in Create() 99 return response; in Create() 104 DispatchResponse response; in Create() local 106 response.code_ = ResponseCode::NOK; in Create() 107 response.errorMsg_ = error.value(); in Create() 109 return response; in Create() 119 DispatchResponse response; in Fail() local 120 response in Fail() 125 SendResponse(const DispatchRequest &request, const DispatchResponse &response, const PtBaseReturns &result) SendResponse() argument [all...] |
H A D | protocol_handler.cpp | 86 void ProtocolHandler::SendResponse(const DispatchRequest &request, const DispatchResponse &response, in SendResponse() argument 90 << (response.IsOk() ? "success" : "failed: " + response.GetMessage()); in SendResponse() 95 if (response.IsOk()) { in SendResponse() 98 resultObj = CreateErrorReply(response); in SendResponse() 124 std::unique_ptr<PtJson> ProtocolHandler::CreateErrorReply(const DispatchResponse &response) in CreateErrorReply() argument 128 if (!response.IsOk()) { in CreateErrorReply() 129 result->Add("code", static_cast<int32_t>(response.GetError())); in CreateErrorReply() 130 result->Add("message", response.GetMessage().c_str()); in CreateErrorReply()
|
/arkcompiler/toolchain/websocket/client/ |
H A D | websocket_client.cpp | 30 static bool ValidateServerHandShake(HttpResponse& response) in ValidateServerHandShake() argument 39 if (response.status != HTTP_SWITCHING_PROTOCOLS_STATUS_CODE) { in ValidateServerHandShake() 42 ToLowerCase(response.upgrade); in ValidateServerHandShake() 43 if (response.upgrade != HTTP_RESPONSE_REQUIRED_UPGRADE) { in ValidateServerHandShake() 46 ToLowerCase(response.connection); in ValidateServerHandShake() 47 if (response.connection != HTTP_RESPONSE_REQUIRED_CONNECTION) { in ValidateServerHandShake() 59 Trim(response.secWebSocketAccept); in ValidateServerHandShake() 60 if (response.secWebSocketAccept.size() != WebSocketKeyEncoder::ENCODED_KEY_LEN || in ValidateServerHandShake() 61 response.secWebSocketAccept.compare(reinterpret_cast<const char *>(expectedSecWebSocketAccept)) != 0) { in ValidateServerHandShake() 226 HttpResponse response; in ClientRecvWSUpgradeRsp() local [all...] |
/arkcompiler/toolchain/tooling/test/ |
H A D | profiler_impl_test.cpp | 56 DispatchResponse response = profiler->Disable(); in HWTEST_F_L0() local 57 ASSERT_TRUE(response.GetMessage() == ""); in HWTEST_F_L0() 58 ASSERT_TRUE(response.IsOk()); in HWTEST_F_L0() 65 DispatchResponse response = profiler->Enable(); in HWTEST_F_L0() local 66 ASSERT_TRUE(response.GetMessage() == ""); in HWTEST_F_L0() 67 ASSERT_TRUE(response.IsOk()); in HWTEST_F_L0() 75 DispatchResponse response = profiler->Start(); in HWTEST_F_L0() local 78 ASSERT_TRUE(response.IsOk()); in HWTEST_F_L0() 88 DispatchResponse response = profiler->Stop(&profile); in HWTEST_F_L0() local 89 ASSERT_TRUE(response in HWTEST_F_L0() 98 DispatchResponse response = profiler->SetSamplingInterval(params); HWTEST_F_L0() local 108 DispatchResponse response = profiler->EnableSerializationTimeoutCheck(params); HWTEST_F_L0() local 117 DispatchResponse response = profiler->DisableSerializationTimeoutCheck(); HWTEST_F_L0() local 126 DispatchResponse response = profiler->GetBestEffortCoverage(); HWTEST_F_L0() local 134 DispatchResponse response = profiler->StopPreciseCoverage(); HWTEST_F_L0() local 142 DispatchResponse response = profiler->TakePreciseCoverage(); HWTEST_F_L0() local 153 DispatchResponse response = profiler->StartPreciseCoverage(*params); HWTEST_F_L0() local 161 DispatchResponse response = profiler->StartTypeProfile(); HWTEST_F_L0() local 169 DispatchResponse response = profiler->StopTypeProfile(); HWTEST_F_L0() local 177 DispatchResponse response = profiler->TakeTypeProfile(); HWTEST_F_L0() local [all...] |
H A D | heapprofiler_impl_test.cpp | 93 DispatchResponse response = heapProfiler->AddInspectedHeapObject(param);
in HWTEST_F_L0() local 94 ASSERT_TRUE(response.GetMessage() == "AddInspectedHeapObject not support now");
in HWTEST_F_L0() 95 ASSERT_TRUE(!response.IsOk());
in HWTEST_F_L0() 102 DispatchResponse response = heapProfiler->CollectGarbage();
in HWTEST_F_L0() local 103 ASSERT_TRUE(response.GetMessage() == "");
in HWTEST_F_L0() 104 ASSERT_TRUE(response.IsOk());
in HWTEST_F_L0() 111 DispatchResponse response = heapProfiler->Enable();
in HWTEST_F_L0() local 112 ASSERT_TRUE(response.GetMessage() == "");
in HWTEST_F_L0() 113 ASSERT_TRUE(response.IsOk());
in HWTEST_F_L0() 120 DispatchResponse response in HWTEST_F_L0() local 131 DispatchResponse response = heapProfiler->GetHeapObjectId(params, &objectId); HWTEST_F_L0() local 142 DispatchResponse response = heapProfiler->GetObjectByHeapObjectId(*params, &remoteObjectResult); HWTEST_F_L0() local 152 DispatchResponse response = heapProfiler->GetSamplingProfile(&profile); HWTEST_F_L0() local 162 DispatchResponse response = heapProfiler->StartSampling(params); HWTEST_F_L0() local 171 DispatchResponse response = heapProfiler->StopSampling(&profile); HWTEST_F_L0() local 181 DispatchResponse response = heapProfiler->TakeHeapSnapshot(params); HWTEST_F_L0() local 422 DispatchResponse response = heapProfiler->StartSampling(params); HWTEST_F_L0() local 433 DispatchResponse response = heapProfiler->StartSampling(params); HWTEST_F_L0() local 444 DispatchResponse response = heapProfiler->StartSampling(params); HWTEST_F_L0() local [all...] |
H A D | dispatcher_test.cpp | 114 DispatchResponse response = DispatchResponse::Create(code, msg); in HWTEST_F_L0() local 115 ASSERT_TRUE(response.IsOk()); in HWTEST_F_L0() 116 ASSERT_TRUE(response.GetMessage() == ""); in HWTEST_F_L0() 119 response = DispatchResponse::Create(msg); in HWTEST_F_L0() 120 ASSERT_TRUE(!response.IsOk()); in HWTEST_F_L0() 121 ASSERT_TRUE(response.GetMessage() == "msg"); in HWTEST_F_L0() 124 response = DispatchResponse::Create(error); in HWTEST_F_L0() 125 ASSERT_TRUE(response.IsOk()); in HWTEST_F_L0() 126 ASSERT_TRUE(response.GetMessage() == ""); in HWTEST_F_L0()
|
/arkcompiler/toolchain/test/autotest/aw/ |
H A D | websocket.py | 72 response = await client.recv() 73 await received_queue.put(response) 124 response = await client.recv() 125 await receive_queue.put(response) 126 logging.info(f'[<==] Connect server receive message: {response}') 127 response = json.loads(response) 130 if (response['type'] == 'addInstance' and 132 instance_id = response['instanceId'] 153 elif response['typ [all...] |