/third_party/node/test/parallel/ |
H A D | test-https-agent-sockets-leak.js | 22 const agent = new https.Agent({ 33 agent: agent 38 // Only one entry should exist in agent.sockets pool 39 // If there are more entries in agent.sockets, 41 assert.strictEqual(Object.keys(agent.sockets).length, 1); 45 // exist in agent.sockets pool after both request and socket 47 assert.strictEqual(Object.keys(agent.sockets).length, 0);
|
H A D | test-https-agent-sni.js | 39 const agent = new https.Agent({ 44 agent: agent, 54 agent: agent,
|
H A D | test-http-client-override-global-agent.js | 12 const agent = new http.Agent(); 13 const name = agent.getName({ port: server.address().port }); 14 http.globalAgent = agent; 17 assert(name in agent.sockets); // Agent has indeed been used
|
H A D | test-https-agent-getname.js | 10 const agent = new https.Agent(); 14 agent.getName(), 20 agent.getName({}), 50 agent.getName(options),
|
H A D | test-http-client-timeout-connect-listener.js | 19 const agent = new http.Agent({ keepAlive: true, maxSockets: 1 }); 20 const options = { port: server.address().port, agent: agent }; 24 agent.destroy();
|
H A D | test-https-client-override-global-agent.js | 23 const agent = new https.Agent(); 24 const name = agent.getName({ port: server.address().port }); 25 https.globalAgent = agent; 28 assert(name in agent.sockets); // Agent has indeed been used
|
H A D | test-http-client-timeout-option-listeners.js | 6 const agent = new http.Agent({ keepAlive: true }); 16 agent, 31 agent.destroy(); 38 const sockets = agent.sockets[`${options.host}:${options.port}:`];
|
H A D | test-http-keepalive-request.js | 44 const agent = http.Agent({ keepAlive: true }); 55 agent.destroy(); 62 agent: agent
|
H A D | test-http-keepalive-client.js | 44 const agent = http.Agent({ keepAlive: true }); 55 agent.destroy(); 61 agent: agent,
|
/third_party/node/deps/undici/src/lib/ |
H A D | global.js | 7 const Agent = require('./agent') 13 function setGlobalDispatcher (agent) { 14 if (!agent || typeof agent.dispatch !== 'function') { 15 throw new InvalidArgumentError('Argument agent must implement Agent') 18 value: agent,
|
/kernel/linux/linux-5.10/drivers/infiniband/hw/mthca/ |
H A D | mthca_mad.c | 170 struct ib_mad_agent *agent = dev->send_agent[port_num - 1][qpn]; in forward_trap() local 174 if (agent) { in forward_trap() 175 send_buf = ib_create_send_mad(agent, qpn, 0, 0, IB_MGMT_MAD_HDR, in forward_trap() 277 static void send_handler(struct ib_mad_agent *agent, in send_handler() argument 285 struct ib_mad_agent *agent; in mthca_create_agents() local 293 agent = ib_register_mad_agent(&dev->ib_dev, p + 1, in mthca_create_agents() 297 if (IS_ERR(agent)) { in mthca_create_agents() 298 ret = PTR_ERR(agent); in mthca_create_agents() 301 dev->send_agent[p][q] = agent; in mthca_create_agents() 327 struct ib_mad_agent *agent; in mthca_free_agents() local [all...] |
/kernel/linux/linux-5.10/security/yama/ |
H A D | yama_lsm.c | 48 struct task_struct *agent; member 58 agent_cmd = kstrdup_quotable_cmdline(info->agent, GFP_KERNEL); in __report_access() 63 info->agent->pid); in __report_access() 68 put_task_struct(info->agent); in __report_access() 75 struct task_struct *agent) in report_access() 78 char agent_comm[sizeof(agent->comm)]; in report_access() 89 get_task_comm(agent_comm, agent), agent->pid); in report_access() 98 get_task_struct(agent); in report_access() 101 info->agent in report_access() 74 report_access(const char *access, struct task_struct *target, struct task_struct *agent) report_access() argument [all...] |
/kernel/linux/linux-6.6/drivers/infiniband/hw/mthca/ |
H A D | mthca_mad.c | 170 struct ib_mad_agent *agent = dev->send_agent[port_num - 1][qpn]; in forward_trap() local 174 if (agent) { in forward_trap() 175 send_buf = ib_create_send_mad(agent, qpn, 0, 0, IB_MGMT_MAD_HDR, in forward_trap() 277 static void send_handler(struct ib_mad_agent *agent, in send_handler() argument 285 struct ib_mad_agent *agent; in mthca_create_agents() local 293 agent = ib_register_mad_agent(&dev->ib_dev, p + 1, in mthca_create_agents() 297 if (IS_ERR(agent)) { in mthca_create_agents() 298 ret = PTR_ERR(agent); in mthca_create_agents() 301 dev->send_agent[p][q] = agent; in mthca_create_agents() 327 struct ib_mad_agent *agent; in mthca_free_agents() local [all...] |
/kernel/linux/linux-6.6/security/yama/ |
H A D | yama_lsm.c | 48 struct task_struct *agent; member 58 agent_cmd = kstrdup_quotable_cmdline(info->agent, GFP_KERNEL); in __report_access() 63 info->agent->pid); in __report_access() 68 put_task_struct(info->agent); in __report_access() 75 struct task_struct *agent) in report_access() 78 char agent_comm[sizeof(agent->comm)]; in report_access() 89 get_task_comm(agent_comm, agent), agent->pid); in report_access() 98 get_task_struct(agent); in report_access() 101 info->agent in report_access() 74 report_access(const char *access, struct task_struct *target, struct task_struct *agent) report_access() argument [all...] |
/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/src/ |
H A D | want_agent.cpp | 47 WantAgent *agent = new (std::nothrow) WantAgent(); in Unmarshalling() local 48 if (agent == nullptr) { in Unmarshalling() 53 agent->SetPendingWant(pendingWant); in Unmarshalling() 55 return agent; in Unmarshalling()
|
/third_party/node/src/tracing/ |
H A D | trace_event.cc | 10 void TraceEventHelper::SetAgent(Agent* agent) { in SetAgent() argument 11 if (agent) { in SetAgent() 12 g_agent = agent; in SetAgent() 13 g_controller = agent->GetTracingController(); in SetAgent()
|
/base/request/request/services/tests/ |
H A D | start.rs | 25 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()
|
/third_party/node/deps/npm/node_modules/@npmcli/agent/lib/ |
H A D | index.js | 11 const getAgent = (url, { agent, proxy, noProxy, ...options } = {}) => { 13 if (agent != null) { 14 return agent 48 agent: agentCache,
|
/foundation/window/window_manager/window_scene/screen_session_manager/src/zidl/ |
H A D | screen_session_manager_lite_stub.cpp | 84 auto agent = iface_cast<IDisplayManagerAgent>(data.ReadRemoteObject()); in HandleRegisterDisplayManagerAgent() local 85 if (agent == nullptr) { in HandleRegisterDisplayManagerAgent() 89 DMError ret = RegisterDisplayManagerAgent(agent, type); in HandleRegisterDisplayManagerAgent() 97 auto agent = iface_cast<IDisplayManagerAgent>(data.ReadRemoteObject()); in HandleUnRegisterDisplayManagerAgent() local 98 if (agent == nullptr) { in HandleUnRegisterDisplayManagerAgent() 102 DMError ret = UnregisterDisplayManagerAgent(agent, type); in HandleUnRegisterDisplayManagerAgent()
|
/base/startup/init/test/unittest/innerkits/ |
H A D | innerkits_unittest.cpp | 46 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...] |
/test/testfwk/developer_test/aw/python/distributed/distribute/ |
H A D | distribute.py | 226 device.push_file(os.path.join(self.suite_dir, "agent.desc"), 264 for agent in self.agent_list: 265 if self._query_device_uuid(agent): 267 device_uuid_list, self._query_device_uuid(agent)) 272 config_agent_file = os.path.join(self.suite_dir, "agent.desc") 283 for agent in self.agent_list: 284 if self._query_device_agent_uuid(agent): 286 device_uuid_list, self._query_device_agent_uuid(agent)) 291 config_agent_file = os.path.join(self.suite_dir, "agent.desc") 303 for agent i [all...] |
/kernel/linux/linux-5.10/drivers/infiniband/core/ |
H A D | user_mad.c | 120 struct ib_mad_agent *agent[IB_UMAD_MAX_AGENTS]; member 180 return file->agents_dead ? NULL : file->agent[id]; in __get_agent() 184 struct ib_mad_agent *agent, in queue_packet() 194 if (agent == __get_agent(file, packet->mad.hdr.id)) { in queue_packet() 214 static void send_handler(struct ib_mad_agent *agent, in send_handler() argument 217 struct ib_umad_file *file = agent->context; in send_handler() 227 if (!queue_packet(file, agent, packet)) in send_handler() 233 static void recv_handler(struct ib_mad_agent *agent, in recv_handler() argument 237 struct ib_umad_file *file = agent->context; in recv_handler() 257 if (rdma_cap_opa_mad(agent in recv_handler() 183 queue_packet(struct ib_umad_file *file, struct ib_mad_agent *agent, struct ib_umad_packet *packet) queue_packet() argument 504 struct ib_mad_agent *agent; ib_umad_write() local 688 struct ib_mad_agent *agent = NULL; ib_umad_reg_agent() local 790 struct ib_mad_agent *agent = NULL; ib_umad_reg_agent2() local 901 struct ib_mad_agent *agent = NULL; ib_umad_unreg_agent() local [all...] |
/kernel/linux/linux-6.6/drivers/infiniband/core/ |
H A D | user_mad.c | 120 struct ib_mad_agent *agent[IB_UMAD_MAX_AGENTS]; member 180 return file->agents_dead ? NULL : file->agent[id]; in __get_agent() 184 struct ib_mad_agent *agent, in queue_packet() 194 if (agent == __get_agent(file, packet->mad.hdr.id)) { in queue_packet() 214 static void send_handler(struct ib_mad_agent *agent, in send_handler() argument 217 struct ib_umad_file *file = agent->context; in send_handler() 227 if (!queue_packet(file, agent, packet)) in send_handler() 233 static void recv_handler(struct ib_mad_agent *agent, in recv_handler() argument 237 struct ib_umad_file *file = agent->context; in recv_handler() 257 if (rdma_cap_opa_mad(agent in recv_handler() 183 queue_packet(struct ib_umad_file *file, struct ib_mad_agent *agent, struct ib_umad_packet *packet) queue_packet() argument 504 struct ib_mad_agent *agent; ib_umad_write() local 688 struct ib_mad_agent *agent = NULL; ib_umad_reg_agent() local 789 struct ib_mad_agent *agent = NULL; ib_umad_reg_agent2() local 897 struct ib_mad_agent *agent = NULL; ib_umad_unreg_agent() local [all...] |
/base/startup/init/services/begetctl/ |
H A D | appspawntime_cmd.c | 29 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()
|
/kernel/linux/linux-5.10/tools/perf/jvmti/ |
H A D | jvmti_agent.h | 21 int jvmti_close(void *agent); 22 int jvmti_write_code(void *agent, char const *symbol_name, 26 int jvmti_write_debug_info(void *agent, uint64_t code, int nr_lines,
|