/third_party/lwip/src/apps/snmp/ |
H A D | snmp_msg.c | 256 static err_t snmp_process_get_request(struct snmp_request *request); 257 static err_t snmp_process_getnext_request(struct snmp_request *request); 258 static err_t snmp_process_getbulk_request(struct snmp_request *request); 259 static err_t snmp_process_set_request(struct snmp_request *request); 261 static err_t snmp_parse_inbound_frame(struct snmp_request *request); 262 static err_t snmp_prepare_outbound_frame(struct snmp_request *request); 263 static err_t snmp_complete_outbound_frame(struct snmp_request *request); 264 static void snmp_execute_write_callbacks(struct snmp_request *request); 275 struct snmp_request request; in snmp_receive() local 277 memset(&request, in snmp_receive() 403 snmp_process_varbind(struct snmp_request *request, struct snmp_varbind *vb, u8_t get_next) snmp_process_varbind() argument 484 snmp_process_get_request(struct snmp_request *request) snmp_process_get_request() argument 520 snmp_process_getnext_request(struct snmp_request *request) snmp_process_getnext_request() argument 556 snmp_process_getbulk_request(struct snmp_request *request) snmp_process_getbulk_request() argument 654 snmp_process_set_request(struct snmp_request *request) snmp_process_set_request() argument 766 snmp_parse_inbound_frame(struct snmp_request *request) snmp_parse_inbound_frame() argument 1268 snmp_prepare_outbound_frame(struct snmp_request *request) snmp_prepare_outbound_frame() argument 1602 snmp_complete_outbound_frame(struct snmp_request *request) snmp_complete_outbound_frame() argument 1835 snmp_execute_write_callbacks(struct snmp_request *request) snmp_execute_write_callbacks() argument [all...] |
/third_party/node/test/parallel/ |
H A D | test-http2-compat-socket-set.js | 21 server.on('request', common.mustCall(function(request, response) { 24 assert.strictEqual(request.stream.destroyed, false); 25 request.socket.destroyed = true; 26 assert.strictEqual(request.stream.destroyed, true); 27 request.socket.destroyed = false; 29 assert.strictEqual(request.stream.readable, true); 30 request.socket.readable = false; 31 assert.strictEqual(request.stream.readable, false); 33 assert.strictEqual(request [all...] |
H A D | test-http2-compat-socket.js | 27 server.on('request', common.mustCall(function(request, response) { 28 assert.ok(request.socket instanceof net.Socket); 30 assert.strictEqual(request.socket, response.socket); 32 assert.ok(request.socket.readable); 33 request.resume(); 34 assert.ok(request.socket.writable); 35 assert.strictEqual(request.socket.destroyed, false); 37 request.socket.setTimeout(987); 38 assert.strictEqual(request [all...] |
H A D | test-http2-compat-serverrequest-trailers.js | 19 server.once('request', common.mustCall(function(request, response) { 21 request.setEncoding('utf8'); 22 request.on('data', common.mustCallAtLeast((chunk) => data += chunk)); 23 request.on('end', common.mustCall(() => { 24 const trailers = request.trailers; 39 ], request.rawTrailers); 53 const request = client.request(headers, { waitForTrailers: true }); 55 request [all...] |
H A D | test-http-parser.js | 73 // Simple request test. 76 const request = Buffer.from('GET /hello HTTP/1.1\r\n\r\n'); 88 parser.execute(request, 0, request.length); 102 () => { parser.execute(request, 0, request.length); }, 112 const request = Buffer.from( 137 parser.execute(request, 0, request.length); 145 const request [all...] |
/third_party/icu/icu4c/source/python/icutools/databuilder/renderers/ |
H A D | makefile.py | 37 for request in requests: 38 make_rules += get_gnumake_rules_helper(request, **kwargs) 86 def get_gnumake_rules_helper(request, common_vars, **kwargs): 88 if isinstance(request, PrintFileRequest): 89 var_name = "%s_CONTENT" % request.name.upper() 93 content = request.content 96 name = request.name, 99 output_file = request.output_file, 103 MAKEFILENAME = files_to_makefile([request.output_file], common_vars), 111 if isinstance(request, CopyReques [all...] |
H A D | common_exec.py | 21 for request in requests: 22 status = run_helper(request, common_vars, verbose=verbose, **kwargs) 43 def run_helper(request, common_vars, platform, tool_dir, verbose, tool_cfg=None, **kwargs): 44 if isinstance(request, PrintFileRequest): 46 DIRNAME = utils.dir_for(request.output_file).format(**common_vars), 47 FILENAME = request.output_file.filename, 52 f.write(request.content) 54 if isinstance(request, CopyRequest): 56 DIRNAME = utils.dir_for(request.input_file).format(**common_vars), 57 FILENAME = request [all...] |
/third_party/skia/third_party/externals/icu/source/python/icutools/databuilder/renderers/ |
H A D | makefile.py | 37 for request in requests: 38 make_rules += get_gnumake_rules_helper(request, **kwargs) 86 def get_gnumake_rules_helper(request, common_vars, **kwargs): 88 if isinstance(request, PrintFileRequest): 89 var_name = "%s_CONTENT" % request.name.upper() 93 content = request.content 96 name = request.name, 99 output_file = request.output_file, 103 MAKEFILENAME = files_to_makefile([request.output_file], common_vars), 111 if isinstance(request, CopyReques [all...] |
H A D | common_exec.py | 21 for request in requests: 22 status = run_helper(request, common_vars, verbose=verbose, **kwargs) 43 def run_helper(request, common_vars, platform, tool_dir, verbose, tool_cfg=None, **kwargs): 44 if isinstance(request, PrintFileRequest): 46 DIRNAME = utils.dir_for(request.output_file).format(**common_vars), 47 FILENAME = request.output_file.filename, 52 f.write(request.content) 54 if isinstance(request, CopyRequest): 56 DIRNAME = utils.dir_for(request.input_file).format(**common_vars), 57 FILENAME = request [all...] |
/third_party/node/deps/undici/src/lib/fetch/ |
H A D | index.js | 13 const { Request, makeRequest } = require('./request') 79 // 2 terminated listeners get added per request, 143 // 3. Let request be requestObject’s request. 144 const request = requestObject[kState] 148 // 1. Abort the fetch() call with p, request, null, and 150 abortFetch(p, request, null, requestObject.signal.reason) 156 // 5. Let globalObject be request’s client’s global object. 157 const globalObject = request.client.globalObject 160 // request’ [all...] |
/third_party/libdrm/amdgpu/ |
H A D | amdgpu_gpu_info.c | 36 struct drm_amdgpu_info request; in amdgpu_query_info() local 38 memset(&request, 0, sizeof(request)); in amdgpu_query_info() 39 request.return_pointer = (uintptr_t)value; in amdgpu_query_info() 40 request.return_size = size; in amdgpu_query_info() 41 request.query = info_id; in amdgpu_query_info() 43 return drmCommandWrite(dev->fd, DRM_AMDGPU_INFO, &request, in amdgpu_query_info() 50 struct drm_amdgpu_info request; in amdgpu_query_crtc_from_id() local 52 memset(&request, 0, sizeof(request)); in amdgpu_query_crtc_from_id() 66 struct drm_amdgpu_info request; amdgpu_read_mm_registers() local 85 struct drm_amdgpu_info request; amdgpu_query_hw_ip_count() local 101 struct drm_amdgpu_info request; amdgpu_query_hw_ip_info() local 118 struct drm_amdgpu_info request; amdgpu_query_firmware_version() local 323 struct drm_amdgpu_info request; amdgpu_query_sensor_info() local 338 struct drm_amdgpu_info request; amdgpu_query_video_caps_info() local [all...] |
/third_party/skia/third_party/externals/dawn/src/dawn_wire/client/ |
H A D | Device.cpp | 51 mErrorScopes.CloseAll([](ErrorScopeData* request) { in ~Device() 52 request->callback(WGPUErrorType_Unknown, "Device destroyed before callback", in ~Device() 53 request->userdata); in ~Device() 56 mCreatePipelineAsyncRequests.CloseAll([](CreatePipelineAsyncRequest* request) { in ~Device() 57 if (request->createComputePipelineAsyncCallback != nullptr) { in ~Device() 58 request->createComputePipelineAsyncCallback( in ~Device() 60 "Device destroyed before callback", request->userdata); in ~Device() 62 ASSERT(request->createRenderPipelineAsyncCallback != nullptr); in ~Device() 63 request->createRenderPipelineAsyncCallback( in ~Device() 65 "Device destroyed before callback", request in ~Device() 174 ErrorScopeData request; OnPopErrorScopeCallback() local 236 CreatePipelineAsyncRequest request = {}; CreateComputePipelineAsync() local 255 CreatePipelineAsyncRequest request; OnCreateComputePipelineAsyncCallback() local 287 CreatePipelineAsyncRequest request = {}; CreateRenderPipelineAsync() local 306 CreatePipelineAsyncRequest request; OnCreateRenderPipelineAsyncCallback() local [all...] |
H A D | Buffer.cpp | 152 mRequests.CloseAll([status](MapRequestData* request) { in ClearAllCallbacks() 153 if (request->callback != nullptr) { in ClearAllCallbacks() 154 request->callback(status, request->userdata); in ClearAllCallbacks() 173 // Create the request structure that will hold information while this mapping is in MapAsync() 175 MapRequestData request = {}; in MapAsync() local 176 request.callback = callback; in MapAsync() 177 request.userdata = userdata; in MapAsync() 178 request.offset = offset; in MapAsync() 179 request in MapAsync() 203 MapRequestData request; OnMapAsyncCallback() local [all...] |
/third_party/node/deps/undici/src/lib/cache/ |
H A D | cache.js | 9 const { Request } = require('../fetch/request') 20 * @property {any} request 26 * @see https://w3c.github.io/ServiceWorker/#dfn-request-response-list 32 * @see https://w3c.github.io/ServiceWorker/#dfn-relevant-request-response-list 45 async match (request, options = {}) { 49 request = webidl.converters.RequestInfo(request) 52 const p = await this.matchAll(request, options) 61 async matchAll (request = undefined, options = {}) { 64 if (request ! [all...] |
/third_party/toybox/toys/other/ |
H A D | vconfig.c | 32 struct vlan_ioctl_args request; in vconfig_main() local 36 memset(&request, 0, sizeof(struct vlan_ioctl_args)); in vconfig_main() 49 request.u.name_type = i; in vconfig_main() 50 request.cmd = SET_VLAN_NAME_TYPE_CMD; in vconfig_main() 51 xioctl(fd, SIOCSIFVLAN, &request); in vconfig_main() 57 xstrncpy(request.device1, toys.optargs[1], sizeof(request.device1)); in vconfig_main() 60 request.cmd = ADD_VLAN_CMD; in vconfig_main() 61 if (toys.optargs[2]) request.u.VID = atolx_range(toys.optargs[2], 0, 4094); in vconfig_main() 62 if (request in vconfig_main() [all...] |
/third_party/node/deps/npm/node_modules/make-fetch-happen/lib/cache/ |
H A D | policy.js | 12 // request for storability 16 const requestObject = (request) => { 18 method: request.method, 19 url: request.url, 21 compress: request.compress, 24 request.headers.forEach((value, key) => { 46 constructor ({ entry, request, response, options }) { 48 this.request = requestObject(request) 51 this.policy = new CacheSemantics(this.request, thi [all...] |
/third_party/vk-gl-cts/external/vulkancts/vkscserver/ |
H A D | tests.cpp | 102 StoreContentRequest request; in RunStoreContentTests() local 103 request.data = {1, 2, 3, 4}; in RunStoreContentTests() 104 request.name = "@test1"; in RunStoreContentTests() 106 server.SendRequest(request, response); in RunStoreContentTests() 112 StoreContentRequest request; in RunStoreContentTests() local 113 request.data = {5,6,7,8,9}; in RunStoreContentTests() 114 request.name = "@test1"; in RunStoreContentTests() 116 server.SendRequest(request, response); in RunStoreContentTests() 125 GetContentRequest request; in RunGetContentTests() local 126 request in RunGetContentTests() 136 GetContentRequest request; RunGetContentTests() local 149 CompileShaderRequest request; RunCompileShaderTests() local [all...] |
/third_party/ltp/testcases/network/nfsv4/locks/ |
H A D | locktests.c | 148 struct flock request; in validationResults() local 162 request.l_type = F_WRLCK; in validationResults() 163 request.l_whence = SEEK_SET; in validationResults() 164 request.l_start = i; in validationResults() 165 request.l_len = 1; in validationResults() 166 fcntl(dp.fd, F_GETLK, &request); in validationResults() 168 if (request.l_type != F_UNLCK) in validationResults() 263 void lockWholeFile(struct flock *request) in lockWholeFile() argument 265 request->l_whence = SEEK_SET; in lockWholeFile() 266 request in lockWholeFile() 383 serializeFLock(struct flock *request) serializeFLock() argument 407 unSerializeFLock(struct flock *request) unSerializeFLock() argument 417 serverSendLockClient(struct flock *request, int client) serverSendLockClient() argument 423 serverSendLockLocal(struct flock *request, int slave) serverSendLockLocal() argument 429 getLockSection(struct flock *request) getLockSection() argument 582 struct flock request; master() local 753 struct flock request; slave() local [all...] |
/third_party/protobuf/conformance/ |
H A D | conformance_php.php | 28 function doTest($request) 32 if ($request->getPayload() == "protobuf_payload") { 33 if ($request->getMessageType() == "conformance.FailureSet") { 36 } elseif ($request->getMessageType() == "protobuf_test_messages.proto3.TestAllTypesProto3") { 38 $test_message->mergeFromString($request->getProtobufPayload()); 43 } elseif ($request->getMessageType() == "protobuf_test_messages.proto2.TestAllTypesProto2") { 47 trigger_error("Protobuf request doesn't have specific payload type", E_USER_ERROR); 49 } elseif ($request->getPayload() == "json_payload") { 51 ($request->getTestCategory() == 54 $test_message->mergeFromJsonString($request 99 $request = new \\Conformance\\ConformanceRequest(); global() variable [all...] |
H A D | conformance_python.py | 56 def do_test(request): 59 if request.message_type == "conformance.FailureSet": 113 isProto3 = (request.message_type == "protobuf_test_messages.proto3.TestAllTypesProto3") 114 isJson = (request.WhichOneof('payload') == 'json_payload') 115 isProto2 = (request.message_type == "protobuf_test_messages.proto2.TestAllTypesProto2") 118 raise ProtocolError("Protobuf request doesn't have specific payload type") 124 if request.WhichOneof('payload') == 'protobuf_payload': 126 test_message.ParseFromString(request.protobuf_payload) 131 elif request.WhichOneof('payload') == 'json_payload': 134 request [all...] |
/third_party/icu/icu4c/source/python/icutools/databuilder/ |
H A D | utils.py | 76 def repeated_execution_request_looper(request): 79 dict(zip(request.repeat_with, t)) 80 for t in zip(*request.repeat_with.values()) 84 ld = [{} for _ in range(len(request.input_files))] 85 return zip(ld, request.specific_dep_files, request.input_files, request.output_files) 88 def format_single_request_command(request, cmd_template, common_vars): 90 ARGS = request.args.format( 91 INPUT_FILES = [file.filename for file in request [all...] |
/third_party/skia/third_party/externals/icu/source/python/icutools/databuilder/ |
H A D | utils.py | 76 def repeated_execution_request_looper(request): 79 dict(zip(request.repeat_with, t)) 80 for t in zip(*request.repeat_with.values()) 84 ld = [{} for _ in range(len(request.input_files))] 85 return zip(ld, request.specific_dep_files, request.input_files, request.output_files) 88 def format_single_request_command(request, cmd_template, common_vars): 90 ARGS = request.args.format( 91 INPUT_FILES = [file.filename for file in request [all...] |
/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
H A D | memory_test.cpp | 30 marl::Allocation::Request request; in TEST_F() local 31 request.alignment = alignment; in TEST_F() 32 request.size = size; in TEST_F() 33 request.useGuards = useGuards; in TEST_F() 35 auto allocation = allocator->allocate(request); in TEST_F() 37 ASSERT_EQ(allocation.request.size, request.size); in TEST_F() 38 ASSERT_EQ(allocation.request.alignment, request.alignment); in TEST_F() 39 ASSERT_EQ(allocation.request in TEST_F() 80 marl::Allocation::Request request; TEST_F() local [all...] |
/third_party/skia/third_party/externals/microhttpd/src/microspdy/ |
H A D | applicationlayer.c | 37 struct SPDY_Request *request, in spdy_callback_response_done() 45 SPDY_destroy_request(request); in spdy_callback_response_done() 52 * the stream to create (HTTP) request object and pass it to the client. 69 struct SPDY_Request * request = NULL; in spdy_handler_new_stream() local 83 if(NULL==(request = malloc(sizeof(struct SPDY_Request)))) in spdy_handler_new_stream() 86 memset(request, 0, sizeof(struct SPDY_Request)); in spdy_handler_new_stream() 87 request->stream = stream; in spdy_handler_new_stream() 128 SPDY_destroy_request(request); in spdy_handler_new_stream() 135 request->method=method; in spdy_handler_new_stream() 136 request in spdy_handler_new_stream() 35 spdy_callback_response_done(void *cls, struct SPDY_Response *response, struct SPDY_Request *request, enum SPDY_RESPONSE_RESULT status, bool streamopened) spdy_callback_response_done() argument 217 struct SPDY_Request *request = (struct SPDY_Request *)cls; spdy_handler_response_queue_result() local 525 SPDY_queue_response(struct SPDY_Request * request, struct SPDY_Response *response, bool closestream, bool consider_priority, SPDY_ResponseResultCallback rrcb, void * rrcb_cls) SPDY_queue_response() argument 685 SPDY_get_session_for_request(const struct SPDY_Request * request) SPDY_get_session_for_request() argument 725 SPDY_get_cls_from_request(struct SPDY_Request * request) SPDY_get_cls_from_request() argument 738 SPDY_set_cls_to_request(struct SPDY_Request * request, void * cls) SPDY_set_cls_to_request() argument [all...] |
/third_party/python/Lib/ |
H A D | socketserver.py | 15 For request-based servers (including socket-based): 17 - client address verification before further looking at the request 19 at the request before anything else, e.g. logging) 21 - synchronous (one request is handled at a time) 22 - forking (each request is handled by a new process) 23 - threading (each request is handled by a new thread) 65 with your request handler class. 67 The request handler class must be different for datagram or stream 68 services. This can be hidden by using the request handler 83 class will essentially render the service "deaf" while one request i [all...] |