Home
last modified time | relevance | path

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

1234567

/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...]
H A Dtest-http-keep-alive-close-on-header.js40 const agent = new http.Agent({ maxSockets: 1 });
41 const name = agent.getName({ port: this.address().port });
47 agent: agent
49 assert.strictEqual(agent.sockets[name].length, 1);
64 agent: agent
66 assert.strictEqual(agent.sockets[name].length, 1);
80 agent: agent
[all...]
H A Dtest-http-addrequest-localaddress.js9 const agent = require('http').globalAgent;
16 agent.maxSockets = 0;
20 agent.addRequest(req, 'localhost', 8080, '127.0.0.1');
21 assert.strictEqual(Object.keys(agent.requests).length, 1);
23 Object.keys(agent.requests)[0],
28 agent.addRequest(req, {
34 assert.strictEqual(Object.keys(agent.requests).length, 1);
36 Object.keys(agent.requests)[0],
H A Dtest-https-agent-create-connection.js11 const agent = new https.Agent();
54 _agentKey: agent.getName({ port, host })
57 const socket = agent.createConnection(options);
70 _agentKey: agent.getName({ port, host })
72 const socket = agent.createConnection(port, options);
85 _agentKey: agent.getName({ port, host })
87 const socket = agent.createConnection(port, host, options);
101 const socket = agent.createConnection(port, host, options);
113 const socket = agent.createConnection(port, host, options);
128 const socket = agent
[all...]
H A Dtest-http-client-reject-unexpected-agent.js14 'agent',
34 function createRequest(agent) {
35 const options = Object.assign(baseOptions, { agent });
49 failingAgentOptions.forEach((agent) => {
51 () => createRequest(agent),
55 message: 'The "options.agent" property must be one of Agent-like ' +
57 common.invalidArgTypeHelper(agent)
62 acceptableAgentOptions.forEach((agent) => {
63 createRequest(agent);
H A Dtest-http-agent-maxtotalsockets.js33 const agent = new http.Agent({
53 agent.destroy();
63 agent,
69 for (const key of Object.keys(agent.sockets)) {
70 assert(agent.sockets[key].length <= maxSockets);
81 for (const key of Object.keys(agent.sockets)) {
82 num += agent.sockets[key].length;
89 for (const key of Object.keys(agent.requests)) {
90 num += agent.requests[key].length;
H A Dtest-http-agent-maxsockets.js7 const agent = new http.Agent({
24 agent: agent,
30 const freepool = agent.freeSockets[Object.keys(agent.freeSockets)[0]];
33 agent.destroy();
H A Dtest-https-agent-abort-controller.js13 const agent = new Agent();
29 _agentKey: agent.getName({ port, host })
35 const connection = agent.createConnection({ ...options, signal });
46 const connection = agent.createConnection({ ...options, signal });
58 agent: agent,
74 agent: agent,
H A Dtest-http-agent-maxsockets-respected.js13 const agent = new http.Agent({
33 agent: agent,
49 const sockets = agent.sockets[Object.keys(agent.sockets)[0]];
H A Dtest-https-agent-sockets-leak.js22 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 Dtest-https-agent-sni.js39 const agent = new https.Agent({
44 agent: agent,
54 agent: agent,
H A Dtest-http-client-override-global-agent.js12 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 Dtest-https-agent-getname.js10 const agent = new https.Agent();
14 agent.getName(),
20 agent.getName({}),
50 agent.getName(options),
/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...]
/third_party/python/Lib/test/
H A Dtest_robotparser.py14 agent = 'test_robotparser' variable in BaseRobotTest
26 agent, url = url
27 return agent, url
28 return self.agent, url
32 agent, url = self.get_agent_and_url(url)
33 with self.subTest(url=url, agent=agent):
34 self.assertTrue(self.parser.can_fetch(agent, url))
38 agent, url = self.get_agent_and_url(url)
39 with self.subTest(url=url, agent
144 agent = 'figtree' global() variable in CrawlDelayAndRequestRateTest
153 agent = 'FigTree Robot libwww-perl/5.04' global() variable in DifferentAgentTest
192 agent = 'Googlebot' global() variable in AnotherInvalidRequestRateTest
208 agent = 'Googlebot' global() variable in UserAgentOrderingTest
213 agent = 'Googlebot-Mobile' global() variable in UserAgentGoogleMobileTest
224 agent = 'googlebot' global() variable in GoogleURLOrderingTest
[all...]
/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()
/third_party/node/lib/
H A D_http_client.js157 let agent = options.agent;
159 if (agent === false) {
160 agent = new defaultAgent.constructor();
161 } else if (agent === null || agent === undefined) {
163 agent = defaultAgent;
165 // Explicitly pass through this statement as agent will not be used
167 } else if (typeof agent.addRequest !== 'function') {
168 throw new ERR_INVALID_ARG_TYPE('options.agent',
[all...]
/third_party/node/deps/undici/src/lib/
H A Dglobal.js7 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,
/third_party/node/src/tracing/
H A Dtrace_event.cc10 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/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...]

Completed in 10 milliseconds

1234567