Home
last modified time | relevance | path

Searched refs:agent (Results 26 - 50 of 153) sorted by relevance

1234567

/third_party/node/test/parallel/
H A Dtest-http-client-timeout-connect-listener.js19 const agent = new http.Agent({ keepAlive: true, maxSockets: 1 });
20 const options = { port: server.address().port, agent: agent };
24 agent.destroy();
H A Dtest-https-client-override-global-agent.js23 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 Dtest-http-client-timeout-option-listeners.js6 const agent = new http.Agent({ keepAlive: true });
16 agent,
31 agent.destroy();
38 const sockets = agent.sockets[`${options.host}:${options.port}:`];
H A Dtest-http-keepalive-request.js44 const agent = http.Agent({ keepAlive: true });
55 agent.destroy();
62 agent: agent
H A Dtest-http-keepalive-client.js44 const agent = http.Agent({ keepAlive: true });
55 agent.destroy();
61 agent: agent,
H A Dtest-http-agent-close.js6 const agent = new http.Agent();
8 agent.createSocket = function(req, options, cb) {
14 agent
H A Dtest-https-agent-disable-session-reuse.js22 const agent = new https.Agent({
33 agent: agent,
H A Dtest-https-strict.js125 options.agent = agent0;
129 options.agent = agent3;
131 options.agent = agent1;
133 options.agent = agent2;
135 options.agent = agent0;
H A Dtest-http-agent-reuse-drained-socket-only.js7 const agent = new http.Agent({
28 agent,
92 agent,
109 // Make the third request, the agent should reuse the second socket we just made
111 agent,
/third_party/node/deps/npm/node_modules/@npmcli/agent/lib/
H A Dindex.js11 const getAgent = (url, { agent, proxy, noProxy, ...options } = {}) => {
13 if (agent != null) {
14 return agent
48 agent: agentCache,
/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()
/third_party/node/lib/
H A D_http_agent.js127 debug('agent.on(free)', name);
200 const agent = this;
202 agent.emit('keylog', keylog, this);
228 // Pacify parallel/test-http-agent-getname by only appending
374 function installListeners(agent, s, options) {
377 agent.emit('free', s, options);
386 agent.totalSocketCount--;
387 agent.removeSocket(s, options);
396 const sockets = agent.freeSockets;
410 agent
[all...]
/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/inputmethod/imf/frameworks/native/inputmethod_controller/src/
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);
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()
/third_party/python/Lib/urllib/
H A Drobotparser.py84 We allow that a user-agent: line is not preceded by
89 # 1: saw user-agent line
115 if line[0] == "user-agent":
147 # "This directive is independent of the user-agent line,
166 # search for given user agent matches
180 # agent not found ==> access granted
243 for agent in self.useragents:
244 ret.append(f"User-agent: {agent}")
254 """check if this entry applies to the specified agent"""
[all...]
/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...]
/third_party/node/src/
H A Dinspector_js_api.cc169 Agent* agent = env->inspector_agent(); in InspectorEnabled() local
170 return agent->IsActive(); in InspectorEnabled()
282 Agent* agent = env->inspector_agent(); in Open() local
287 ExclusiveAccess<HostPort>::Scoped host_port(agent->host_port()); in Open()
293 ExclusiveAccess<HostPort>::Scoped host_port(agent->host_port()); in Open()
297 agent->StartIoThread(); in Open()
302 Agent* agent = env->inspector_agent(); in WaitForDebugger() local
303 if (agent->IsActive()) in WaitForDebugger()
304 agent->WaitForConnect(); in WaitForDebugger()
305 args.GetReturnValue().Set(agent in WaitForDebugger()
[all...]
/third_party/node/test/async-hooks/
H A Dtest-http-agent-handle-reuse-serial.js11 // is not reused. Test is based on parallel\test-async-hooks-http-agent.js.
20 const agent = new http.Agent({
39 // agent’s pool for reuse.
41 agent, port, method: 'POST',
52 // setImmediate() to give the agent time to register the freed socket.
62 agent, port, method: 'POST', headers: {
77 agent.destroy();
H A Dtest-http-agent-handle-reuse-parallel.js11 // is not reused. Test is based on parallel\test-async-hooks-http-agent.js.
21 const agent = new http.Agent({
42 agent.destroy();
61 agent, port, method: 'POST',
67 agent, port, method: 'POST',
/third_party/node/src/tracing/
H A Dnode_trace_buffer.cc10 Agent* agent) in InternalTraceBuffer()
12 agent_(agent), id_(id) { in InternalTraceBuffer()
99 Agent* agent, uv_loop_t* tracing_loop) in NodeTraceBuffer()
101 buffer1_(max_chunks, 0, agent), in NodeTraceBuffer()
102 buffer2_(max_chunks, 1, agent) { in NodeTraceBuffer()
9 InternalTraceBuffer(size_t max_chunks, uint32_t id, Agent* agent) InternalTraceBuffer() argument
98 NodeTraceBuffer(size_t max_chunks, Agent* agent, uv_loop_t* tracing_loop) NodeTraceBuffer() argument
/base/request/request/services/tests/
H A Dconstruct.rs19 let agent = test_init(); in sdv_construct_basic()
21 let _task_id = agent.construct(config); in sdv_construct_basic()

Completed in 11 milliseconds

1234567