Home
last modified time | relevance | path

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

12345678910>>...12

/kernel/linux/linux-5.10/drivers/net/ethernet/mellanox/mlx5/core/lib/
H A Dhv_vhca.c34 void (*control)(struct mlx5_hv_vhca_agent *agent,
36 void (*invalidate)(struct mlx5_hv_vhca_agent *agent,
38 void (*cleanup)(struct mlx5_hv_vhca_agent *agent);
81 struct mlx5_hv_vhca_agent *agent = hv_vhca->agents[i]; in mlx5_hv_vhca_invalidate_work() local
83 if (!agent || !agent->invalidate) in mlx5_hv_vhca_invalidate_work()
86 if (!(BIT(agent->type) & hwork->block_mask)) in mlx5_hv_vhca_invalidate_work()
89 agent->invalidate(agent, hwork->block_mask); in mlx5_hv_vhca_invalidate_work()
120 struct mlx5_hv_vhca_agent *agent in mlx5_hv_vhca_agents_control() local
138 struct mlx5_hv_vhca_agent *agent = hv_vhca->agents[i]; mlx5_hv_vhca_capabilities() local
146 mlx5_hv_vhca_control_agent_invalidate(struct mlx5_hv_vhca_agent *agent, u64 block_mask) mlx5_hv_vhca_control_agent_invalidate() argument
196 mlx5_hv_vhca_control_agent_destroy(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_control_agent_destroy() argument
203 struct mlx5_hv_vhca_agent *agent; mlx5_hv_vhca_init() local
227 struct mlx5_hv_vhca_agent *agent; mlx5_hv_vhca_cleanup() local
252 mlx5_hv_vhca_agent_create(struct mlx5_hv_vhca *hv_vhca, enum mlx5_hv_vhca_agent_type type, void (*control)(struct mlx5_hv_vhca_agent*, struct mlx5_hv_vhca_control_block *block), void (*invalidate)(struct mlx5_hv_vhca_agent*, u64 block_mask), void (*cleaup)(struct mlx5_hv_vhca_agent *agent), void *priv) mlx5_hv_vhca_agent_create() argument
261 struct mlx5_hv_vhca_agent *agent; mlx5_hv_vhca_agent_create() local
296 mlx5_hv_vhca_agent_destroy(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_agent_destroy() argument
318 mlx5_hv_vhca_data_block_prepare(struct mlx5_hv_vhca_agent *agent, struct mlx5_hv_vhca_data_block *data_block, void *src, int len, int *offset) mlx5_hv_vhca_data_block_prepare() argument
331 mlx5_hv_vhca_agent_seq_update(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_agent_seq_update() argument
336 mlx5_hv_vhca_agent_write(struct mlx5_hv_vhca_agent *agent, void *buf, int len) mlx5_hv_vhca_agent_write() argument
368 mlx5_hv_vhca_agent_priv(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_agent_priv() argument
[all...]
/kernel/linux/linux-6.6/drivers/net/ethernet/mellanox/mlx5/core/lib/
H A Dhv_vhca.c34 void (*control)(struct mlx5_hv_vhca_agent *agent,
36 void (*invalidate)(struct mlx5_hv_vhca_agent *agent,
38 void (*cleanup)(struct mlx5_hv_vhca_agent *agent);
81 struct mlx5_hv_vhca_agent *agent = hv_vhca->agents[i]; in mlx5_hv_vhca_invalidate_work() local
83 if (!agent || !agent->invalidate) in mlx5_hv_vhca_invalidate_work()
86 if (!(BIT(agent->type) & hwork->block_mask)) in mlx5_hv_vhca_invalidate_work()
89 agent->invalidate(agent, hwork->block_mask); in mlx5_hv_vhca_invalidate_work()
120 struct mlx5_hv_vhca_agent *agent in mlx5_hv_vhca_agents_control() local
138 struct mlx5_hv_vhca_agent *agent = hv_vhca->agents[i]; mlx5_hv_vhca_capabilities() local
146 mlx5_hv_vhca_control_agent_invalidate(struct mlx5_hv_vhca_agent *agent, u64 block_mask) mlx5_hv_vhca_control_agent_invalidate() argument
196 mlx5_hv_vhca_control_agent_destroy(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_control_agent_destroy() argument
203 struct mlx5_hv_vhca_agent *agent; mlx5_hv_vhca_init() local
227 struct mlx5_hv_vhca_agent *agent; mlx5_hv_vhca_cleanup() local
252 mlx5_hv_vhca_agent_create(struct mlx5_hv_vhca *hv_vhca, enum mlx5_hv_vhca_agent_type type, void (*control)(struct mlx5_hv_vhca_agent*, struct mlx5_hv_vhca_control_block *block), void (*invalidate)(struct mlx5_hv_vhca_agent*, u64 block_mask), void (*cleaup)(struct mlx5_hv_vhca_agent *agent), void *priv) mlx5_hv_vhca_agent_create() argument
261 struct mlx5_hv_vhca_agent *agent; mlx5_hv_vhca_agent_create() local
296 mlx5_hv_vhca_agent_destroy(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_agent_destroy() argument
318 mlx5_hv_vhca_data_block_prepare(struct mlx5_hv_vhca_agent *agent, struct mlx5_hv_vhca_data_block *data_block, void *src, int len, int *offset) mlx5_hv_vhca_data_block_prepare() argument
331 mlx5_hv_vhca_agent_seq_update(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_agent_seq_update() argument
336 mlx5_hv_vhca_agent_write(struct mlx5_hv_vhca_agent *agent, void *buf, int len) mlx5_hv_vhca_agent_write() argument
368 mlx5_hv_vhca_agent_priv(struct mlx5_hv_vhca_agent *agent) mlx5_hv_vhca_agent_priv() argument
[all...]
/third_party/node/test/parallel/
H A Dtest-http-agent-scheduling.js14 function makeRequest(url, agent, callback) {
16 .request(url, { agent }, (res) => {
29 function bulkRequest(url, agent, done) {
31 let count = agent.maxSockets;
33 for (let i = 0; i < agent.maxSockets; i++) {
34 makeRequest(url, agent, callback);
52 const agent = new http.Agent({
57 bulkRequest(url, agent, (ports) => {
58 makeRequest(url, agent, (port) => {
60 makeRequest(url, agent, (por
[all...]
H A Dtest-http-agent-keepalive.js30 const agent = new Agent({
53 agent: agent,
60 assert.strictEqual(agent.sockets[name].length, 1);
61 assert.strictEqual(agent.freeSockets[name], undefined);
62 assert.strictEqual(agent.totalSocketCount, 1);
72 assert.strictEqual(agent.sockets[name].length, 1);
73 assert.strictEqual(agent.freeSockets[name], undefined);
75 assert.strictEqual(agent.sockets[name], undefined);
76 assert.strictEqual(agent
[all...]
H A Dtest-http-keep-alive.js35 const agent = new http.Agent({ maxSockets: 1 });
40 name = agent.getName({ port: this.address().port });
42 path: '/', headers: headers, port: this.address().port, agent: agent
44 assert.strictEqual(agent.sockets[name].length, 1);
45 assert.strictEqual(agent.requests[name].length, 2);
50 path: '/', headers: headers, port: this.address().port, agent: agent
52 assert.strictEqual(agent.sockets[name].length, 1);
53 assert.strictEqual(agent
[all...]
/foundation/window/window_manager/window_scene/session_manager/src/
H A Dsession_manager_agent_controller.cpp83 for (auto& agent : smAgentContainer_.GetAgentsByType( in UpdateCameraFloatWindowStatus()
85 if (agent != nullptr) { in UpdateCameraFloatWindowStatus()
86 agent->UpdateCameraFloatWindowStatus(accessTokenId, isShowing); in UpdateCameraFloatWindowStatus()
93 for (auto& agent : smAgentContainer_.GetAgentsByType( in UpdateFocusChangeInfo()
95 if (agent != nullptr) { in UpdateFocusChangeInfo()
96 agent->UpdateFocusChangeInfo(focusChangeInfo, isFocused); in UpdateFocusChangeInfo()
105 for (auto& agent : smAgentContainer_.GetAgentsByType( in UpdateWindowModeTypeInfo()
107 if (agent != nullptr) { in UpdateWindowModeTypeInfo()
108 agent->UpdateWindowModeTypeInfo(type); in UpdateWindowModeTypeInfo()
116 for (auto& agent in NotifyAccessibilityWindowInfo()
[all...]
/foundation/window/window_manager/dmserver/src/
H A Ddisplay_manager_agent_controller.cpp47 for (auto& agent : agents) { in NotifyDisplayPowerEvent()
48 agent->NotifyDisplayPowerEvent(event, status); in NotifyDisplayPowerEvent()
60 for (auto& agent : agents) { in NotifyDisplayStateChanged()
61 agent->NotifyDisplayStateChanged(id, state); in NotifyDisplayStateChanged()
76 for (auto& agent : agents) { in OnScreenConnect()
77 agent->OnScreenConnect(screenInfo); in OnScreenConnect()
88 for (auto& agent : agents) { in OnScreenDisconnect()
89 agent->OnScreenDisconnect(screenId); in OnScreenDisconnect()
103 for (auto& agent : agents) { in OnScreenChange()
104 agent in OnScreenChange()
[all...]
/kernel/linux/linux-5.10/drivers/infiniband/core/
H A Dmad_rmpp.c47 struct ib_mad_agent_private *agent; member
87 void ib_cancel_rmpp_recvs(struct ib_mad_agent_private *agent) in ib_cancel_rmpp_recvs() argument
92 spin_lock_irqsave(&agent->lock, flags); in ib_cancel_rmpp_recvs()
93 list_for_each_entry(rmpp_recv, &agent->rmpp_list, list) { in ib_cancel_rmpp_recvs()
97 spin_unlock_irqrestore(&agent->lock, flags); in ib_cancel_rmpp_recvs()
99 flush_workqueue(agent->qp_info->port_priv->wq); in ib_cancel_rmpp_recvs()
102 &agent->rmpp_list, list) { in ib_cancel_rmpp_recvs()
137 msg = ib_create_send_mad(&rmpp_recv->agent->agent, recv_wc->wc->src_qp, in ack_recv()
151 static struct ib_mad_send_buf *alloc_response_msg(struct ib_mad_agent *agent, in alloc_response_msg() argument
178 ack_ds_ack(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *recv_wc) ack_ds_ack() argument
212 nack_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *recv_wc, u8 rmpp_status) nack_recv() argument
276 create_rmpp_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) create_rmpp_recv() argument
323 find_rmpp_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) find_rmpp_recv() argument
342 acquire_rmpp_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) acquire_rmpp_recv() argument
357 insert_rmpp_recv(struct ib_mad_agent_private *agent, struct mad_rmpp_recv *rmpp_recv) insert_rmpp_recv() argument
394 window_size(struct ib_mad_agent_private *agent) window_size() argument
469 continue_rmpp(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) continue_rmpp() argument
528 start_rmpp(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) start_rmpp() argument
598 abort_send(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc, u8 rmpp_status) abort_send() argument
638 process_ds_ack(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc, int newwin) process_ds_ack() argument
648 process_rmpp_ack(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_ack() argument
743 process_rmpp_data(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_data() argument
775 process_rmpp_stop(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_stop() argument
789 process_rmpp_abort(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_abort() argument
805 ib_process_rmpp_recv_wc(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) ib_process_rmpp_recv_wc() argument
844 struct ib_mad_agent_private *agent = mad_send_wr->mad_agent_priv; init_newwin() local
[all...]
H A Dagent.c42 #include "agent.h"
50 struct ib_mad_agent *agent[2]; member
62 if (entry->agent[1]->device == device && in __ib_get_agent_port()
63 entry->agent[1]->port_num == port_num) in __ib_get_agent_port()
86 struct ib_mad_agent *agent; in agent_send_response() local
97 dev_err(&device->dev, "Unable to find port agent\n"); in agent_send_response()
101 agent = port_priv->agent[qpn]; in agent_send_response()
102 ah = ib_create_ah_from_wc(agent->qp->pd, wc, grh, port_num); in agent_send_response()
112 send_buf = ib_create_send_mad(agent, w in agent_send_response()
[all...]
/kernel/linux/linux-6.6/drivers/infiniband/core/
H A Dmad_rmpp.c47 struct ib_mad_agent_private *agent; member
87 void ib_cancel_rmpp_recvs(struct ib_mad_agent_private *agent) in ib_cancel_rmpp_recvs() argument
92 spin_lock_irqsave(&agent->lock, flags); in ib_cancel_rmpp_recvs()
93 list_for_each_entry(rmpp_recv, &agent->rmpp_list, list) { in ib_cancel_rmpp_recvs()
97 spin_unlock_irqrestore(&agent->lock, flags); in ib_cancel_rmpp_recvs()
99 flush_workqueue(agent->qp_info->port_priv->wq); in ib_cancel_rmpp_recvs()
102 &agent->rmpp_list, list) { in ib_cancel_rmpp_recvs()
137 msg = ib_create_send_mad(&rmpp_recv->agent->agent, recv_wc->wc->src_qp, in ack_recv()
151 static struct ib_mad_send_buf *alloc_response_msg(struct ib_mad_agent *agent, in alloc_response_msg() argument
178 ack_ds_ack(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *recv_wc) ack_ds_ack() argument
212 nack_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *recv_wc, u8 rmpp_status) nack_recv() argument
276 create_rmpp_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) create_rmpp_recv() argument
323 find_rmpp_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) find_rmpp_recv() argument
342 acquire_rmpp_recv(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) acquire_rmpp_recv() argument
357 insert_rmpp_recv(struct ib_mad_agent_private *agent, struct mad_rmpp_recv *rmpp_recv) insert_rmpp_recv() argument
394 window_size(struct ib_mad_agent_private *agent) window_size() argument
469 continue_rmpp(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) continue_rmpp() argument
528 start_rmpp(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) start_rmpp() argument
598 abort_send(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc, u8 rmpp_status) abort_send() argument
638 process_ds_ack(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc, int newwin) process_ds_ack() argument
648 process_rmpp_ack(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_ack() argument
743 process_rmpp_data(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_data() argument
775 process_rmpp_stop(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_stop() argument
789 process_rmpp_abort(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) process_rmpp_abort() argument
805 ib_process_rmpp_recv_wc(struct ib_mad_agent_private *agent, struct ib_mad_recv_wc *mad_recv_wc) ib_process_rmpp_recv_wc() argument
844 struct ib_mad_agent_private *agent = mad_send_wr->mad_agent_priv; init_newwin() local
[all...]
H A Dagent.c42 #include "agent.h"
50 struct ib_mad_agent *agent[2]; member
62 if (entry->agent[1]->device == device && in __ib_get_agent_port()
63 entry->agent[1]->port_num == port_num) in __ib_get_agent_port()
86 struct ib_mad_agent *agent; in agent_send_response() local
97 dev_err(&device->dev, "Unable to find port agent\n"); in agent_send_response()
101 agent = port_priv->agent[qpn]; in agent_send_response()
102 ah = ib_create_ah_from_wc(agent->qp->pd, wc, grh, port_num); in agent_send_response()
112 send_buf = ib_create_send_mad(agent, w in agent_send_response()
[all...]
/foundation/window/window_manager/wmserver/src/
H A Dwindow_manager_agent_controller.cpp41 for (auto& agent : wmAgentContainer_.GetAgentsByType(WindowManagerAgentType::WINDOW_MANAGER_AGENT_TYPE_FOCUS)) { in UpdateFocusChangeInfo()
42 agent->UpdateFocusChangeInfo(focusChangeInfo, focused); in UpdateFocusChangeInfo()
48 for (auto& agent : wmAgentContainer_.GetAgentsByType( in UpdateWindowModeTypeInfo()
50 agent->UpdateWindowModeTypeInfo(type); in UpdateWindowModeTypeInfo()
60 for (auto& agent : wmAgentContainer_.GetAgentsByType( in UpdateSystemBarRegionTints()
62 agent->UpdateSystemBarRegionTints(displayId, tints); in UpdateSystemBarRegionTints()
70 for (auto& agent : wmAgentContainer_.GetAgentsByType( in NotifyAccessibilityWindowInfo()
72 agent->NotifyAccessibilityWindowInfo(infos, type); in NotifyAccessibilityWindowInfo()
80 for (auto& agent : wmAgentContainer_.GetAgentsByType( in UpdateWindowVisibilityInfo()
82 agent in UpdateWindowVisibilityInfo()
[all...]
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/softbus/
H A Dsoftbus_agent_test.cpp110 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); in HWTEST_F() local
111 EXPECT_EQ(agent->sessionName_, "DistributedFileService/mnt/hmdfs/100/account"); in HWTEST_F()
131 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); in HWTEST_F() local
132 bool flag = agent->IsSameAccount(NETWORKID_ONE); in HWTEST_F()
134 flag = agent->IsSameAccount(NETWORKID_TWO); in HWTEST_F()
136 flag = agent->IsSameAccount(NETWORKID_THREE); in HWTEST_F()
139 flag = agent->IsSameAccount(NETWORKID_ONE); in HWTEST_F()
157 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); in HWTEST_F() local
160 agent->QuitDomain(); in HWTEST_F()
181 std::shared_ptr<SoftbusAgent> agent in HWTEST_F() local
209 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
244 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
270 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
294 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
318 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
344 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
371 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
398 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
423 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
447 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
478 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
509 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
536 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
560 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
591 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
614 std::shared_ptr<SoftbusAgent> agent = std::make_shared<SoftbusAgent>(wmp); HWTEST_F() local
[all...]
/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...]
/foundation/window/window_manager/utils/include/
H A Dclient_agent_container.h35 bool RegisterAgent(const sptr<T1>& agent, T2 type);
36 bool UnregisterAgent(const sptr<T1>& agent, T2 type);
39 int32_t GetAgentPid(const sptr<T1>& agent);
43 bool UnregisterAgentLocked(std::set<sptr<T1>>& agents, const sptr<IRemoteObject>& agent);
50 bool operator()(sptr<T1> agent) in operator ()()
52 if (agent == nullptr) { in operator ()()
53 WLOGFE("agent is invalid"); in operator ()()
56 return agent->AsObject() == remoteObject_; in operator ()()
74 bool ClientAgentContainer<T1, T2>::RegisterAgent(const sptr<T1>& agent, T2 type) in RegisterAgent() argument
77 if (agent in RegisterAgent()
90 UnregisterAgent(const sptr<T1>& agent, T2 type) UnregisterAgent() argument
119 UnregisterAgentLocked(std::set<sptr<T1>>& agents, const sptr<IRemoteObject>& agent) UnregisterAgentLocked() argument
175 GetAgentPid(const sptr<T1>& agent) GetAgentPid() argument
[all...]
/kernel/linux/linux-5.10/drivers/net/ethernet/mellanox/mlx5/core/en/
H A Dhv_vhca_stats.c60 struct mlx5_hv_vhca_agent *agent; in mlx5e_hv_vhca_stats_work() local
70 agent = sagent->agent; in mlx5e_hv_vhca_stats_work()
76 rc = mlx5_hv_vhca_agent_write(agent, buf, buf_len); in mlx5e_hv_vhca_stats_work()
93 static void mlx5e_hv_vhca_stats_control(struct mlx5_hv_vhca_agent *agent, in mlx5e_hv_vhca_stats_control() argument
99 priv = mlx5_hv_vhca_agent_priv(agent); in mlx5e_hv_vhca_stats_control()
116 static void mlx5e_hv_vhca_stats_cleanup(struct mlx5_hv_vhca_agent *agent) in mlx5e_hv_vhca_stats_cleanup() argument
118 struct mlx5e_priv *priv = mlx5_hv_vhca_agent_priv(agent); in mlx5e_hv_vhca_stats_cleanup()
126 struct mlx5_hv_vhca_agent *agent; in mlx5e_hv_vhca_stats_create() local
132 agent in mlx5e_hv_vhca_stats_create()
[all...]
/kernel/linux/linux-5.10/drivers/target/sbp/
H A Dsbp_target.c259 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_login()
262 struct sbp_tport *tport = agent->tport; in sbp_management_request_login()
478 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_query_logins()
490 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_reconnect()
493 struct sbp_tport *tport = agent->tport; in sbp_management_request_reconnect()
549 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_logout()
552 struct sbp_tport *tport = agent->tport; in sbp_management_request_logout()
669 struct sbp_target_agent *agent) in tgt_agent_rw_agent_state()
677 spin_lock_bh(&agent->lock); in tgt_agent_rw_agent_state()
678 state = agent in tgt_agent_rw_agent_state()
258 sbp_management_request_login( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_login() argument
477 sbp_management_request_query_logins( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_query_logins() argument
489 sbp_management_request_reconnect( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_reconnect() argument
548 sbp_management_request_logout( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_logout() argument
668 tgt_agent_rw_agent_state(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_agent_state() argument
694 tgt_agent_rw_agent_reset(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_agent_reset() argument
710 tgt_agent_rw_orb_pointer(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_orb_pointer() argument
749 tgt_agent_rw_doorbell(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_doorbell() argument
779 tgt_agent_rw_unsolicited_status_enable(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_unsolicited_status_enable() argument
801 struct sbp_target_agent *agent = callback_data; tgt_agent_rw() local
899 tgt_agent_check_active(struct sbp_target_agent *agent) tgt_agent_check_active() argument
932 struct sbp_target_agent *agent = tgt_agent_fetch_work() local
1015 struct sbp_target_agent *agent; sbp_target_agent_register() local
1044 sbp_target_agent_unregister(struct sbp_target_agent *agent) sbp_target_agent_unregister() argument
1455 struct sbp_management_agent *agent = sbp_mgt_agent_process() local
1586 struct sbp_management_agent *agent = callback_data; sbp_mgt_agent_rw() local
1641 struct sbp_management_agent *agent; sbp_management_agent_register() local
1667 sbp_management_agent_unregister(struct sbp_management_agent *agent) sbp_management_agent_unregister() argument
[all...]
/kernel/linux/linux-6.6/drivers/target/sbp/
H A Dsbp_target.c259 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_login()
262 struct sbp_tport *tport = agent->tport; in sbp_management_request_login()
478 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_query_logins()
490 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_reconnect()
493 struct sbp_tport *tport = agent->tport; in sbp_management_request_reconnect()
549 struct sbp_management_agent *agent, struct sbp_management_request *req, in sbp_management_request_logout()
552 struct sbp_tport *tport = agent->tport; in sbp_management_request_logout()
669 struct sbp_target_agent *agent) in tgt_agent_rw_agent_state()
677 spin_lock_bh(&agent->lock); in tgt_agent_rw_agent_state()
678 state = agent in tgt_agent_rw_agent_state()
258 sbp_management_request_login( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_login() argument
477 sbp_management_request_query_logins( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_query_logins() argument
489 sbp_management_request_reconnect( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_reconnect() argument
548 sbp_management_request_logout( struct sbp_management_agent *agent, struct sbp_management_request *req, int *status_data_size) sbp_management_request_logout() argument
668 tgt_agent_rw_agent_state(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_agent_state() argument
694 tgt_agent_rw_agent_reset(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_agent_reset() argument
710 tgt_agent_rw_orb_pointer(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_orb_pointer() argument
749 tgt_agent_rw_doorbell(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_doorbell() argument
779 tgt_agent_rw_unsolicited_status_enable(struct fw_card *card, int tcode, void *data, struct sbp_target_agent *agent) tgt_agent_rw_unsolicited_status_enable() argument
801 struct sbp_target_agent *agent = callback_data; tgt_agent_rw() local
899 tgt_agent_check_active(struct sbp_target_agent *agent) tgt_agent_check_active() argument
932 struct sbp_target_agent *agent = tgt_agent_fetch_work() local
1015 struct sbp_target_agent *agent; sbp_target_agent_register() local
1044 sbp_target_agent_unregister(struct sbp_target_agent *agent) sbp_target_agent_unregister() argument
1452 struct sbp_management_agent *agent = sbp_mgt_agent_process() local
1583 struct sbp_management_agent *agent = callback_data; sbp_mgt_agent_rw() local
1638 struct sbp_management_agent *agent; sbp_management_agent_register() local
1664 sbp_management_agent_unregister(struct sbp_management_agent *agent) sbp_management_agent_unregister() argument
[all...]
/kernel/linux/linux-5.10/drivers/mfd/
H A Dtwl4030-irq.c438 struct sih_agent *agent = irq_data_get_irq_chip_data(data); in twl4030_sih_mask() local
440 agent->imr |= BIT(data->irq - agent->irq_base); in twl4030_sih_mask()
441 agent->imr_change_pending = true; in twl4030_sih_mask()
446 struct sih_agent *agent = irq_data_get_irq_chip_data(data); in twl4030_sih_unmask() local
448 agent->imr &= ~BIT(data->irq - agent->irq_base); in twl4030_sih_unmask()
449 agent->imr_change_pending = true; in twl4030_sih_unmask()
454 struct sih_agent *agent = irq_data_get_irq_chip_data(data); in twl4030_sih_set_type() local
460 agent in twl4030_sih_set_type()
467 struct sih_agent *agent = irq_data_get_irq_chip_data(data); twl4030_sih_bus_lock() local
474 struct sih_agent *agent = irq_data_get_irq_chip_data(data); twl4030_sih_bus_sync_unlock() local
582 struct sih_agent *agent = irq_get_handler_data(irq); handle_twl4030_sih() local
615 struct sih_agent *agent; twl4030_sih_setup() local
[all...]
/kernel/linux/linux-6.6/drivers/mfd/
H A Dtwl4030-irq.c439 struct sih_agent *agent = irq_data_get_irq_chip_data(data); in twl4030_sih_mask() local
441 agent->imr |= BIT(data->irq - agent->irq_base); in twl4030_sih_mask()
442 agent->imr_change_pending = true; in twl4030_sih_mask()
447 struct sih_agent *agent = irq_data_get_irq_chip_data(data); in twl4030_sih_unmask() local
449 agent->imr &= ~BIT(data->irq - agent->irq_base); in twl4030_sih_unmask()
450 agent->imr_change_pending = true; in twl4030_sih_unmask()
455 struct sih_agent *agent = irq_data_get_irq_chip_data(data); in twl4030_sih_set_type() local
461 agent in twl4030_sih_set_type()
468 struct sih_agent *agent = irq_data_get_irq_chip_data(data); twl4030_sih_bus_lock() local
475 struct sih_agent *agent = irq_data_get_irq_chip_data(data); twl4030_sih_bus_sync_unlock() local
583 struct sih_agent *agent = irq_get_handler_data(irq); handle_twl4030_sih() local
616 struct sih_agent *agent; twl4030_sih_setup() local
[all...]
/kernel/linux/linux-6.6/drivers/net/ethernet/mellanox/mlx5/core/en/
H A Dhv_vhca_stats.c60 struct mlx5_hv_vhca_agent *agent; in mlx5e_hv_vhca_stats_work() local
70 agent = sagent->agent; in mlx5e_hv_vhca_stats_work()
76 rc = mlx5_hv_vhca_agent_write(agent, buf, buf_len); in mlx5e_hv_vhca_stats_work()
93 static void mlx5e_hv_vhca_stats_control(struct mlx5_hv_vhca_agent *agent, in mlx5e_hv_vhca_stats_control() argument
99 priv = mlx5_hv_vhca_agent_priv(agent); in mlx5e_hv_vhca_stats_control()
116 static void mlx5e_hv_vhca_stats_cleanup(struct mlx5_hv_vhca_agent *agent) in mlx5e_hv_vhca_stats_cleanup() argument
118 struct mlx5e_priv *priv = mlx5_hv_vhca_agent_priv(agent); in mlx5e_hv_vhca_stats_cleanup()
126 struct mlx5_hv_vhca_agent *agent; in mlx5e_hv_vhca_stats_create() local
132 agent in mlx5e_hv_vhca_stats_create()
[all...]
/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/src/
H A Dwant_agent_helper.cpp177 std::shared_ptr<WantAgent> agent = std::make_shared<WantAgent>(std::make_shared<PendingWant>(target)); in GetWantAgent() local
179 return agent; in GetWantAgent()
182 WantAgentConstant::OperationType WantAgentHelper::GetType(std::shared_ptr<WantAgent> agent) in GetType() argument
184 if ((agent == nullptr) || (agent->GetPendingWant() == nullptr)) { in GetType()
188 return agent->GetPendingWant()->GetType(agent->GetPendingWant()->GetTarget()); in GetType()
191 ErrCode WantAgentHelper::TriggerWantAgent(std::shared_ptr<WantAgent> agent, in TriggerWantAgent() argument
195 if (agent == nullptr) { in TriggerWantAgent()
199 std::shared_ptr<PendingWant> pendingWant = agent in TriggerWantAgent()
226 Cancel(const std::shared_ptr<WantAgent> agent) Cancel() argument
242 IsEquals( const std::shared_ptr<WantAgent> &agent, const std::shared_ptr<WantAgent> &otherAgent) IsEquals() argument
255 GetBundleName(const std::shared_ptr<WantAgent> &agent, std::string &bundleName) GetBundleName() argument
272 GetUid(const std::shared_ptr<WantAgent> &agent, int32_t &uid) GetUid() argument
288 GetWant(const std::shared_ptr<WantAgent> &agent) GetWant() argument
305 RegisterCancelListener( const std::shared_ptr<CancelListener> &cancelListener, const std::shared_ptr<WantAgent> &agent) RegisterCancelListener() argument
322 UnregisterCancelListener( const std::shared_ptr<CancelListener> &cancelListener, const std::shared_ptr<WantAgent> &agent) UnregisterCancelListener() argument
339 ToString(const std::shared_ptr<WantAgent> &agent) ToString() argument
457 GetType(const std::shared_ptr<WantAgent> &agent, int32_t &operType) GetType() argument
467 GetWant(const std::shared_ptr<WantAgent> &agent, std::shared_ptr<AAFwk::Want> &want) GetWant() argument
[all...]
/foundation/window/window_manager/test/fuzztest/wms/windowagent_fuzzer/
H A Dwindow_agent_fuzzer.cpp46 void CheckWindowAgentFunctionsPart1(sptr<WindowAgent> agent, const uint8_t* data, size_t size) in CheckWindowAgentFunctionsPart1() argument
48 if (agent == nullptr || data == nullptr || size < DATA_MIN_SIZE) { in CheckWindowAgentFunctionsPart1()
58 agent->UpdateWindowRect(rect, boolVal, reason); in CheckWindowAgentFunctionsPart1()
62 agent->UpdateWindowMode(mode); in CheckWindowAgentFunctionsPart1()
66 agent->UpdateWindowModeSupportInfo(modeSupportInfo); in CheckWindowAgentFunctionsPart1()
67 agent->UpdateFocusStatus(boolVal); in CheckWindowAgentFunctionsPart1()
68 agent->NotifyForegroundInteractiveStatus(boolVal); in CheckWindowAgentFunctionsPart1()
81 agent->UpdateAvoidArea(avoidArea, type); in CheckWindowAgentFunctionsPart1()
85 agent->UpdateWindowState(state); in CheckWindowAgentFunctionsPart1()
88 void CheckWindowAgentFunctionsPart2(sptr<WindowAgent> agent, cons argument
[all...]
/kernel/linux/linux-5.10/drivers/infiniband/sw/rdmavt/
H A Dmad.c88 static void rvt_send_mad_handler(struct ib_mad_agent *agent, in rvt_send_mad_handler() argument
98 * If driver needs to be notified of mad agent creation then call back
104 struct ib_mad_agent *agent; in rvt_create_mad_agents() local
111 agent = ib_register_mad_agent(&rdi->ibdev, p + 1, in rvt_create_mad_agents()
115 if (IS_ERR(agent)) { in rvt_create_mad_agents()
116 ret = PTR_ERR(agent); in rvt_create_mad_agents()
120 rvp->send_agent = agent; in rvt_create_mad_agents()
132 agent = rvp->send_agent; in rvt_create_mad_agents()
134 ib_unregister_mad_agent(agent); in rvt_create_mad_agents()
147 * If driver needs notification of mad agent remova
151 struct ib_mad_agent *agent; rvt_free_mad_agents() local
[all...]

Completed in 14 milliseconds

12345678910>>...12