Home
last modified time | relevance | path

Searched refs:agent (Results 1 - 25 of 69) sorted by relevance

123

/base/startup/init/interfaces/innerkits/control_fd/
H A Dcontrol_fd_service.c33 CmdTask *agent = (CmdTask *)LE_GetUserData(task); in OnClose() local
34 BEGET_ERROR_CHECK(agent != NULL, return, "[control_fd] Can not get agent"); in OnClose()
35 OH_ListRemove(&agent->item); in OnClose()
36 OH_ListInit(&agent->item); in OnClose()
60 CmdTask *agent = (CmdTask *)LE_GetUserData(task); in CmdOnRecvMessage() local
61 BEGET_ERROR_CHECK(agent != NULL, return, "[control_fd] Can not get agent"); in CmdOnRecvMessage()
73 agent->pid = fork(); in CmdOnRecvMessage()
74 if (agent in CmdOnRecvMessage()
133 CmdTask *agent = (CmdTask *)LE_GetUserData(client); CmdOnIncommingConnect() local
177 CmdTask *agent = ListEntry(node, CmdTask, item); CmdServiceProcessDelClient() local
189 CmdTask *agent = ListEntry(node, CmdTask, item); CmdServiceDestroyProc() local
[all...]
H A Dcontrol_fd_client.c35 CmdAgent *agent = (CmdAgent *)context; in ProcessPtyWrite() local
41 ssize_t wlen = write(agent->ptyFd, rbuf, rlen); in ProcessPtyWrite()
55 CmdAgent *agent = (CmdAgent *)context; in ProcessPtyRead() local
65 (void)close(agent->ptyFd); in ProcessPtyRead()
88 CmdAgent *agent = (CmdAgent *)LE_GetUserData(task); in CmdOnClose() local
89 BEGET_ERROR_CHECK(agent != NULL, return, "[control_fd] Invalid agent"); in CmdOnClose()
90 (void)close(agent->ptyFd); in CmdOnClose()
91 agent->ptyFd = -1; in CmdOnClose()
123 CmdAgent *agent in CmdAgentCreate() local
129 SendCmdMessage(const CmdAgent *agent, uint16_t type, const char *cmd, const char *ptyName) SendCmdMessage() argument
155 InitPtyInterface(CmdAgent *agent, uint16_t type, const char *cmd, CallbackSendMsgProcess callback) InitPtyInterface() argument
211 CmdAgent *agent = CmdAgentCreate(socketPath); CmdClientInit() local
[all...]
H A Dcontrol_fd.h64 typedef int (* CallbackSendMsgProcess)(const CmdAgent *agent, uint16_t type, const char *cmd, const char *ptyName);
86 int InitPtyInterface(CmdAgent *agent, uint16_t type, const char *cmd, CallbackSendMsgProcess callback);
/base/request/request/services/tests/
H A Dsearch.rs29 let agent = test_init(); in sdv_search_user()
35 let task_id = agent.construct(config); in sdv_search_user()
37 let v = agent.search(current, current - 3000, State::Any, Action::Any, Mode::Any); in sdv_search_user()
39 let v = agent.search(current + 3000, current, State::Any, Action::Any, Mode::Any); in sdv_search_user()
41 let v = agent.search( in sdv_search_user()
49 let v = agent.search( in sdv_search_user()
57 let v = agent.search( in sdv_search_user()
66 let v = agent.search( in sdv_search_user()
H A Dresume.rs25 let agent = test_init(); in sdv_start_resume()
34 let task_id = agent.construct(config); in sdv_start_resume()
35 agent.start(task_id); in sdv_start_resume()
36 agent.subscribe(task_id); in sdv_start_resume()
37 agent.pause_v10(task_id); in sdv_start_resume()
39 agent.resume(task_id); in sdv_start_resume()
42 let messages = agent.pop_task_info(task_id); in sdv_start_resume()
H A Dstart.rs25 let agent = test_init(); in sdv_start_basic()
34 let task_id = agent.construct(config); in sdv_start_basic()
35 agent.start(task_id); in sdv_start_basic()
36 agent.subscribe(task_id); in sdv_start_basic()
39 let messages = agent.pop_task_info(task_id); in sdv_start_basic()
H A Dconstruct.rs19 let agent = test_init(); in sdv_construct_basic()
21 let _task_id = agent.construct(config); in sdv_construct_basic()
/base/startup/init/services/begetctl/
H A Dappspawntime_cmd.c29 static int SendAppspawnTimeMessage(const CmdAgent *agent, uint16_t type, const char *ptyName) in SendAppspawnTimeMessage() argument
32 if ((agent == NULL) || (ptyName == NULL)) { in SendAppspawnTimeMessage()
67 CmdAgent agent; in main_cmd() local
68 int ret = InitPtyInterface(&agent, ACTION_APP_SPAWNTIME, "init", (CallbackSendMsgProcess)SendAppspawnTimeMessage); in main_cmd()
H A Ddump_service.c32 static int SendAppspawnCmdMessage(const CmdAgent *agent, uint16_t type, const char *cmd, const char *ptyName) in SendAppspawnCmdMessage() argument
35 if ((agent == NULL) || (cmd == NULL) || (ptyName == NULL)) { in SendAppspawnCmdMessage()
76 CmdAgent agent; in DumpAppspawnClientInit() local
77 int ret = InitPtyInterface(&agent, ACTION_DUMP, cmd, sendMsg); in DumpAppspawnClientInit()
H A Dsandbox.cpp118 static int SendAppspawnCmdMessage(const CmdAgent *agent, uint16_t type, const char *cmd, const char *ptyName) in SendAppspawnCmdMessage() argument
121 if ((agent == NULL) || (cmd == NULL) || (ptyName == NULL)) { in SendAppspawnCmdMessage()
158 CmdAgent agent; in CmdAppspawnClientInit() local
159 int ret = InitPtyInterface(&agent, ACTION_APP_SANDBOX, cmd, sendMsg); in CmdAppspawnClientInit()
/base/msdp/device_status/frameworks/native/src/
H A Ddevicestatus_agent.cpp35 std::shared_ptr<DeviceStatusAgent> agent = agent_.lock(); in OnDeviceStatusChanged() local
36 CHKPV(agent); in OnDeviceStatusChanged()
37 CHKPV(agent->agentEvent_); in OnDeviceStatusChanged()
38 agent->agentEvent_->OnEventResult(devicestatusData); in OnDeviceStatusChanged()
50 FI_HILOGE("Subscription agent event failed"); in SubscribeAgentEvent()
65 FI_HILOGE("Unsubscription agent event failed"); in UnsubscribeAgentEvent()
/base/startup/init/test/unittest/innerkits/
H A Dinnerkits_unittest.cpp46 int SendCmdMessage(const CmdAgent *agent, uint16_t type, const char *cmd, const char *ptyName);
61 static int CallbackSendMsgProcessTest(const CmdAgent *agent, uint16_t type, const char *cmd, const char *ptyName) in CallbackSendMsgProcessTest() argument
337 CmdAgent *agent = CmdAgentCreate(INIT_CONTROL_FD_SOCKET_PATH); in HWTEST_F() local
338 EXPECT_NE(agent, nullptr); in HWTEST_F()
339 SendCmdMessage(agent, ACTION_DUMP, "cmd", "test"); in HWTEST_F()
340 SendCmdMessage(agent, ACTION_DUMP, "cmd", nullptr); in HWTEST_F()
343 InitPtyInterface(agent, 0, "cmd", nullptr); in HWTEST_F()
344 InitPtyInterface(agent, 0, "cmd", CallbackSendMsgProcessTest); in HWTEST_F()
345 InitPtyInterface(agent, 0, nullptr, nullptr); in HWTEST_F()
355 ProcessPtyRead(nullptr, fd, &events, (void *)agent); in HWTEST_F()
[all...]
/base/inputmethod/imf/frameworks/native/inputmethod_controller/src/
H A Dinput_client_proxy.cpp30 int32_t InputClientProxy::OnInputReady(const sptr<IRemoteObject> &agent) in OnInputReady() argument
32 return SendRequest(ON_INPUT_READY, [agent](MessageParcel &data) { return ITypesUtil::Marshal(data, agent); }); in OnInputReady()
H A Dinput_method_controller.cpp246 sptr<IRemoteObject> agent = nullptr; in Attach() local
247 int32_t ret = StartInput(clientInfo_, agent); in Attach()
252 OnInputReady(agent); in Attach()
507 int32_t InputMethodController::StartInput(InputClientInfo &inputClientInfo, sptr<IRemoteObject> &agent) in StartInput() argument
515 return proxy->StartInput(inputClientInfo, agent); in StartInput()
662 auto agent = GetAgent(); in OnCursorUpdate() local
663 if (agent == nullptr) { in OnCursorUpdate()
664 IMSA_HILOGE("agent is nullptr!"); in OnCursorUpdate()
669 agent->OnCursorUpdate(cursorInfo.left, cursorInfo.top, cursorInfo.height); in OnCursorUpdate()
696 auto agent in OnSelectionChange() local
729 sptr<IRemoteObject> agent = nullptr; OnConfigurationChange() local
736 auto agent = GetAgent(); OnConfigurationChange() local
821 auto agent = GetAgent(); DispatchKeyEvent() local
896 auto agent = GetAgent(); SetCallingWindow() local
1376 auto agent = GetAgent(); SendPrivateCommand() local
[all...]
H A Dime_system_channel.cpp128 sptr<IRemoteObject> agent = nullptr; in RunConnectSystemCmd() local
131 if (!BlockRetry(RETRY_INTERVAL, BLOCK_RETRY_TIMES, [&agent, this, proxy]() -> bool { in RunConnectSystemCmd()
132 int32_t ret = proxy->ConnectSystemCmd(systemChannelStub_->AsObject(), agent); in RunConnectSystemCmd()
138 OnConnectCmdReady(agent); in RunConnectSystemCmd()
152 IMSA_HILOGD("agent has already been set."); in OnConnectCmdReady()
226 auto agent = GetSystemCmdAgent(); in SendPrivateCommand() local
227 if (agent == nullptr) { in SendPrivateCommand()
228 IMSA_HILOGE("agent is nullptr!"); in SendPrivateCommand()
231 return agent->SendPrivateCommand(privateCommand); in SendPrivateCommand()
H A Dinput_method_system_ability_proxy.cpp33 int32_t InputMethodSystemAbilityProxy::StartInput(InputClientInfo &inputClientInfo, sptr<IRemoteObject> &agent) in StartInput() argument
41 [&agent](MessageParcel &reply) { in StartInput()
42 agent = reply.ReadRemoteObject(); in StartInput()
47 int32_t InputMethodSystemAbilityProxy::ConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent) in ConnectSystemCmd() argument
52 [&agent](MessageParcel &reply) { return ITypesUtil::Unmarshal(reply, agent); }); in ConnectSystemCmd()
109 const sptr<IRemoteObject> &agent)
112 [core, agent](MessageParcel &data) {
113 return data.WriteRemoteObject(core->AsObject()) && data.WriteRemoteObject(agent);
/base/msdp/device_status/interfaces/innerkits/include/
H A Ddevicestatus_agent.h40 explicit DeviceStatusAgentCallback(std::shared_ptr<DeviceStatusAgent> agent) : agent_(agent) {}; in DeviceStatusAgentCallback() argument
/base/inputmethod/imf/services/include/
H A Dperuser_session.h77 sptr<IRemoteObject> agent{ nullptr };
84 ImeData(sptr<IInputMethodCore> core, sptr<IRemoteObject> agent, sptr<InputDeathRecipient> deathRecipient, in ImeData()
86 : core(std::move(core)), agent(std::move(agent)), deathRecipient(std::move(deathRecipient)), pid(imePid), in ImeData()
104 int32_t OnStartInput(const InputClientInfo &inputClientInfo, sptr<IRemoteObject> &agent);
106 int32_t OnSetCoreAndAgent(const sptr<IInputMethodCore> &core, const sptr<IRemoteObject> &agent);
123 int32_t OnRegisterProxyIme(const sptr<IInputMethodCore> &core, const sptr<IRemoteObject> &agent);
139 int32_t OnConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent);
195 int32_t UpdateImeData(sptr<IInputMethodCore> core, sptr<IRemoteObject> agent, pid_t pid);
196 int32_t AddImeData(ImeType type, sptr<IInputMethodCore> core, sptr<IRemoteObject> agent, pid_
[all...]
H A Di_input_method_system_ability.h45 virtual int32_t StartInput(InputClientInfo &inputClientInfo, sptr<IRemoteObject> &agent) = 0;
60 virtual int32_t SetCoreAndAgent(const sptr<IInputMethodCore> &core, const sptr<IRemoteObject> &agent) = 0;
79 virtual int32_t ConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent) = 0;
/base/inputmethod/imf/frameworks/native/inputmethod_controller/include/
H A Dinput_method_system_ability_proxy.h47 int32_t StartInput(InputClientInfo &inputClientInfo, sptr<IRemoteObject> &agent) override;
63 int32_t SetCoreAndAgent(const sptr<IInputMethodCore> &core, const sptr<IRemoteObject> &agent) override;
78 int32_t ConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent) override;
H A Di_input_client.h41 virtual int32_t OnInputReady(const sptr<IRemoteObject> &agent) = 0;
/base/inputmethod/imf/test/fuzztest/perusersession_fuzzer/
H A Dperusersession_fuzzer.cpp92 auto agent = iface_cast<IInputMethodAgent>(agentStub); in FuzzPerUserSession() local
95 userSessions->OnRegisterProxyIme(core, agent->AsObject()); in FuzzPerUserSession()
101 userSessions->OnSetCoreAndAgent(core, agent->AsObject()); in FuzzPerUserSession()
/base/hiviewdfx/hiview/interfaces/js/napi/include/
H A Dhiview_service_agent.h56 HiviewServiceDeathRecipient(HiviewServiceAgent& agent) : hiviewServiceAgent_(agent) {}; in HiviewServiceDeathRecipient() argument
/base/inputmethod/imf/frameworks/native/inputmethod_ability/src/
H A Dinput_method_core_proxy.cpp62 int32_t InputMethodCoreProxy::OnConnectSystemCmd(const sptr<IRemoteObject> &channel, sptr<IRemoteObject> &agent)
66 [&agent](MessageParcel &reply) { return ITypesUtil::Unmarshal(reply, agent); });
/base/inputmethod/imf/test/unittest/cpp_test/src/
H A Didentity_checker_test.cpp142 sptr<IRemoteObject> agent = nullptr; in HWTEST_F() local
144 int32_t ret = IdentityCheckerTest::service_->StartInput(inputClientInfo, agent); in HWTEST_F()
160 sptr<IRemoteObject> agent = nullptr; in HWTEST_F() local
162 int32_t ret = IdentityCheckerTest::service_->StartInput(inputClientInfo, agent); in HWTEST_F()
178 sptr<IRemoteObject> agent = nullptr; in HWTEST_F() local
180 int32_t ret = IdentityCheckerTest::service_->StartInput(inputClientInfo, agent); in HWTEST_F()
196 sptr<IRemoteObject> agent = nullptr; in HWTEST_F() local
198 int32_t ret = IdentityCheckerTest::service_->StartInput(inputClientInfo, agent); in HWTEST_F()

Completed in 12 milliseconds

123