Home
last modified time | relevance | path

Searched refs:payload (Results 1 – 25 of 56) sorted by relevance

123

/developtools/hdc/hdc_rust/src/daemon/
Dtask.rs58 let cmd = String::from_utf8(task_message.payload).unwrap(); in daemon_shell_task()
68 hdc::debug!("get shell data payload: {:#?}", task_message.payload); in daemon_shell_task()
72 let _ = &pty_task.tx.send(task_message.payload.clone()).await; in daemon_shell_task()
73 if task_message.payload[..].contains(&0x4_u8) { in daemon_shell_task()
99 if task_message.payload[0] > 0 { in daemon_channel_close()
103 payload: vec![task_message.payload[0] - 1], in daemon_channel_close()
121 &task_message.payload, in daemon_file_task()
122 task_message.payload.len() as u16, in daemon_file_task()
132 &task_message.payload, in daemon_file_task()
133 task_message.payload.len() as u16, in daemon_file_task()
[all …]
Dauth.rs83 recv.parse(task_message.payload)?; in handshake_init()
135 payload: send.serialize(), in handshake_init()
152 payload: send.serialize(), in make_sign_message()
173 payload: send.serialize(), in make_ok_message()
187 recv.parse(task_message.payload.clone())?; in get_new_session_id()
206 recv.parse(task_message.payload)?; in handshake_task()
303 payload: vec![0], in handshake_task()
481 payload: send.serialize(), in handshake_fail()
Ddaemon_unity.rs38 payload: message.as_bytes().to_vec(), in echo_client()
222 async fn do_jdwp_track(session_id: u32, channel_id: u32, payload: &[u8]) { in do_jdwp_track()
224 if !payload.is_empty() && payload[0] == b'p' { in do_jdwp_track()
/developtools/hdc/src/host/
Dhost_updater.cpp87 bool HostUpdater::BeginTransfer(const std::string &function, const uint8_t *payload, int payloadSiz… in BeginTransfer() argument
90 if (payload[payloadSize - 1] != '\0') { in BeginTransfer()
94 std::string cmdParam(reinterpret_cast<const char *>(payload)); in BeginTransfer()
147 bool HostUpdater::CheckCmd(HdcCommand command, uint8_t *payload, int payloadSize, size_t paramCount) in CheckCmd() argument
149 if (payloadSize < 1 || payload[payloadSize - 1] != '\0') { in CheckCmd()
153 std::string cmdParam(reinterpret_cast<char *>(payload)); in CheckCmd()
164 SendToAnother(command, payload, payloadSize); in CheckCmd()
169 bool HostUpdater::CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) in CommandDispatch() argument
172 if (!HdcTransferBase::CommandDispatch(command, payload, payloadSize)) { in CommandDispatch()
181 if (payload == nullptr || payloadSize <= 0) { in CommandDispatch()
[all …]
Dhost_app.cpp150 bool HdcHostApp::CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) in CommandDispatch() argument
152 if (!HdcTransferBase::CommandDispatch(command, payload, payloadSize)) { in CommandDispatch()
159 ret = BeginInstall(&ctxNow, (const char *)payload); in CommandDispatch()
163 AppModType mode = static_cast<AppModType>(payload[0]); in CommandDispatch()
164 bool result = static_cast<bool>(payload[1]); in CommandDispatch()
165 string s(reinterpret_cast<char *>(payload + cmdOffset), payloadSize - cmdOffset); in CommandDispatch()
170 SendToAnother(CMD_APP_UNINSTALL, payload, payloadSize); in CommandDispatch()
171 ctxNow.taskQueue.push_back(reinterpret_cast<char *>(payload)); // just compatible in CommandDispatch()
175 BeginSideload(&ctxNow, (const char *)payload); in CommandDispatch()
Dhost_updater.h27 bool CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) override;
35 …bool BeginTransfer(const std::string &function, const uint8_t *payload, int payloadSize, size_t mi…
37 bool CheckUpdateContinue(const uint16_t command, const uint8_t *payload, int payloadSize);
41 bool CheckCmd(HdcCommand command, uint8_t *payload, int payloadSize, size_t paramCount);
Dhost_unity.cpp133 bool HdcHostUnity::CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) in CommandDispatch() argument
139 if (strlen(reinterpret_cast<char *>(payload))) { // enable local log in CommandDispatch()
140 if (!InitLocalLog(reinterpret_cast<const char *>(payload))) { in CommandDispatch()
152 AppendLocalLog(reinterpret_cast<const char *>(payload), payloadSize); in CommandDispatch()
154 ServerCommand(CMD_KERNEL_ECHO_RAW, payload, payloadSize); in CommandDispatch()
Dserver.cpp466 bool HdcServer::ServerSessionHandshake(HSession hSession, uint8_t *payload, int payloadSize) in ServerSessionHandshake() argument
469 string s = string(reinterpret_cast<char *>(payload), payloadSize); in ServerSessionHandshake()
515 …FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *payload, in FetchCommand() argument
521 ret = ServerSessionHandshake(hSession, payload, payloadSize); in FetchCommand()
548 sfc->EchoClientRaw(hChannel, payload, payloadSize); in FetchCommand()
552 MessageLevel level = static_cast<MessageLevel>(*payload); in FetchCommand()
553 string s(reinterpret_cast<char *>(payload + 1), payloadSize - 1); in FetchCommand()
564 if (*payload != 0) { in FetchCommand()
565 --(*payload); in FetchCommand()
566 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
[all …]
Dserver.h24 …FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *payload,
55 uint8_t *payload, const int payloadSize) override;
60 bool ServerSessionHandshake(HSession hSession, uint8_t *payload, int payloadSize);
Dserver_for_client.h27 void EchoClientRaw(const HChannel hChannel, uint8_t *payload, const int payloadSize);
28 void SendCommandToClient(const HChannel hChannel, const uint16_t commandFlag, uint8_t *payload,
/developtools/hdc/hdc_rust/src/transfer/
Dbase.rs96 let (protect, payload) = body.split_at(expected_head_size); in unpack_task_message_lock()
107 let mut remaining = (expected_data_size - payload.len()) as i32; in unpack_task_message_lock()
113 payload: payload.to_vec(), in unpack_task_message_lock()
117 let mut total_payload = payload.to_vec(); in unpack_task_message_lock()
135 payload: total_payload, in unpack_task_message_lock()
152 payload: vec![], in unpack_task_message_lock()
194 let (protect, payload) = body.split_at(expected_head_size); in unpack_task_message()
211 payload: payload.to_vec(), in unpack_task_message()
Dtcp.rs79 let payload = read_frame(rd, expected_data_size).await?; in unpack_task_message() localVariable
83 payload, in unpack_task_message()
/developtools/hdc/hdc_rust/src/serializer/
Dpack_assemble.rs59 calc_check_sum(&task_message.payload) in concat_pack()
76 data_size: (task_message.payload.len() as u32).to_be(), in concat_pack()
82 task_message.payload.len(), in concat_pack()
83 task_message.payload.as_slice().len(), in concat_pack()
91 task_message.payload.as_slice(), in concat_pack()
/developtools/hdc/src/common/
Dfile.h26 bool CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) override;
31 bool SlaveCheck(uint8_t *payload, const int payloadSize);
37 bool FileModeSync(const uint16_t cmd, uint8_t *payload, const int payloadSize);
Dfile.cpp188 bool HdcFile::FileModeSync(const uint16_t cmd, uint8_t *payload, const int payloadSize) in FileModeSync() argument
207 string serialString(reinterpret_cast<char *>(payload), payloadSize); in FileModeSync()
245 bool HdcFile::SlaveCheck(uint8_t *payload, const int payloadSize) in SlaveCheck() argument
251 string serialString(reinterpret_cast<char *>(payload), payloadSize); in SlaveCheck()
309 bool HdcFile::CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) in CommandDispatch() argument
311 HdcTransferBase::CommandDispatch(command, payload, payloadSize); in CommandDispatch()
316 string s = string(reinterpret_cast<char *>(payload), payloadSize); in CommandDispatch()
322 ret = SlaveCheck(payload, payloadSize); in CommandDispatch()
327 ret = FileModeSync(command, payload, payloadSize); in CommandDispatch()
331 if (*payload) { // close-step3 in CommandDispatch()
[all …]
Dsession.h72 const uint16_t command, uint8_t *payload, const int payloadSize) in RedirectToTask() argument
99 …atchTaskData(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *payload,
107 …FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *payload, in FetchCommand() argument
147 …askCommandDispatch(HTaskInfo hTaskInfo, uint8_t taskType, const uint16_t command, uint8_t *payload, in TaskCommandDispatch() argument
164 if (!ptrTask->CommandDispatch(command, payload, payloadSize)) { in TaskCommandDispatch()
Dforward.h24 bool CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) override;
100 bool ForwardCommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize);
101 bool CommandForwardCheckResult(HCtxForward ctx, uint8_t *payload);
Dforward.cpp765 bool HdcForwardBase::CommandForwardCheckResult(HCtxForward ctx, uint8_t *payload) in CommandForwardCheckResult() argument
768 bool bCheck = static_cast<bool>(payload); in CommandForwardCheckResult()
783 bool HdcForwardBase::ForwardCommandDispatch(const uint16_t command, uint8_t *payload, const int pay… in ForwardCommandDispatch() argument
790 FilterCommand(payload, &id, &pContent); in ForwardCommandDispatch()
833 bool HdcForwardBase::CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSiz… in CommandDispatch() argument
842 string strCommand(reinterpret_cast<char *>(payload), payloadSize); in CommandDispatch()
850 if (!SlaveConnect(payload, true, sError)) { in CommandDispatch()
857 if (!SlaveConnect(payload, false, sError)) { in CommandDispatch()
863 if (!ForwardCommandDispatch(command, payload, payloadSize)) { in CommandDispatch()
/developtools/hdc/src/daemon/
Ddaemon.cpp147 const uint16_t command, uint8_t *payload, const int payloadSize) in RedirectToTask() argument
163 … ret = TaskCommandDispatch<HdcDaemonUnity>(hTaskInfo, TYPE_UNITY, command, payload, payloadSize); in RedirectToTask()
167 … ret = TaskCommandDispatch<HdcShell>(hTaskInfo, TYPE_SHELL, command, payload, payloadSize); in RedirectToTask()
176 ret = TaskCommandDispatch<HdcFile>(hTaskInfo, TASK_FILE, command, payload, payloadSize); in RedirectToTask()
182 … ret = TaskCommandDispatch<HdcDaemonApp>(hTaskInfo, TASK_APP, command, payload, payloadSize); in RedirectToTask()
191 …ret = TaskCommandDispatch<HdcDaemonForward>(hTaskInfo, TASK_FORWARD, command, payload, payloadSize… in RedirectToTask()
248 …monSessionHandshake(HSession hSession, const uint32_t channelId, uint8_t *payload, int payloadSize) in DaemonSessionHandshake() argument
252 string s = string(reinterpret_cast<char *>(payload), payloadSize); in DaemonSessionHandshake()
381 …FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *payload, in FetchCommand() argument
402 ret = DaemonSessionHandshake(hSession, channelId, payload, payloadSize); in FetchCommand()
[all …]
Ddaemon.h33 …FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, uint8_t *payload,
47 uint8_t *payload, const int payloadSize) override;
53 …bool DaemonSessionHandshake(HSession hSession, const uint32_t channelId, uint8_t *payload, int pay…
Ddaemon_app.cpp45 bool HdcDaemonApp::CommandDispatch(const uint16_t command, uint8_t *payload, const int payloadSize) in CommandDispatch() argument
47 if (!HdcTransferBase::CommandDispatch(command, payload, payloadSize)) { in CommandDispatch()
56 string bufString(reinterpret_cast<char *>(payload), payloadSize); in CommandDispatch()
80 string bufString(reinterpret_cast<char *>(payload), payloadSize); in CommandDispatch()
/developtools/hdc/hdc_rust/src/host/
Dtask.rs96 let payload = if task_info.params.len() > 1 && task_info.params[1] == "-h" { in channel_hilog_task() localVariable
106 payload: payload, in channel_hilog_task()
121 payload: vec![], in channel_bug_report_task()
201 payload: cmd, in channel_unity_task()
224 payload: cmd, in channel_shell_task()
235 payload: vec![0], in channel_shell_task()
241 let payload = task_info.params.join("").into_bytes(); in channel_shell_task() localVariable
247 payload, in channel_shell_task()
355 task_message.payload.len(), in tcp_handle_deamon()
373 transfer::send_channel_data(task_message.channel_id, task_message.payload).await; in session_task_dispatch()
[all …]
/developtools/profiler/device/plugins/native_hook/src/
Dstack_writer.cpp75 long StackWriter::WriteWithPayloadTimeout(const void* data, size_t size, const void* payload, size_… in WriteWithPayloadTimeout() argument
85 reinterpret_cast<const int8_t*>(payload), in WriteWithPayloadTimeout()
90 …reinterpret_cast<const int8_t*>(data), size, reinterpret_cast<const int8_t*>(payload), payloadSize… in WriteWithPayloadTimeout()
/developtools/profiler/device/services/shared_memory/include/
Dshare_memory_block.h36 …bool PutWithPayloadTimeout(const int8_t* header, uint32_t headerSize, const int8_t* payload, uint3…
37 …bool PutWithPayloadSync(const int8_t* header, uint32_t headerSize, const int8_t* payload, uint32_t…
/developtools/hdc/hdc_rust/src/common/
Dhdctransfer.rs218 payload: total, in spawn_handler()
367 payload: [1].to_vec(), in transfer_task_finish()
376 payload: [1].to_vec(), in transfer_file_finish()
385 pub async fn echo_client(session_id: u32, channel_id: u32, payload: Vec<u8>) { in echo_client()
389 payload, in echo_client()

123