| /third_party/node/test/parallel/ |
| H A D | test-listen-fd-cluster.js | 140 http.createServer(function(req, res) {
142 console.error('%s %s', req.method, req.url, req.headers);
|
| /third_party/nghttp2/src/ |
| H A D | shrpx_memcached_connection.h | 82 MemcachedRequest *req; member
107 int add_request(std::unique_ptr<MemcachedRequest> req);
124 void make_request(MemcachedSendbuf *sendbuf, MemcachedRequest *req);
126 size_t serialized_size(MemcachedRequest *req);
|
| /third_party/node/benchmark/async_hooks/ |
| H A D | async-resource-vs-destroy.js | 103 const server = createServer((req, res) => {
105 getServe(getCLS, setCLS)(req, res);
137 return async function serve(req, res) {
148 return function serve(req, res) {
|
| /third_party/ltp/testcases/open_posix_testsuite/functional/semaphores/ |
| H A D | sem_sleepingbarber.c | 47 struct timespec req; in mdelay() local
48 req.tv_sec = msecs / 1000; in mdelay()
49 req.tv_nsec = (msecs % 1000) * 1000000; in mdelay()
50 nanosleep(&req, NULL); in mdelay()
|
| /third_party/node/deps/openssl/openssl/crypto/cmp/ |
| H A D | cmp_http.c | 48 * Send the PKIMessage req and on success return the response, else NULL.
52 const OSSL_CMP_MSG *req) in OSSL_CMP_MSG_http_perform()
62 if (ctx == NULL || req == NULL) { in OSSL_CMP_MSG_http_perform()
69 if ((req_mem = ASN1_item_i2d_mem_bio(it, (const ASN1_VALUE *)req)) == NULL) in OSSL_CMP_MSG_http_perform()
89 keep_alive(ctx->keep_alive, req->body->type)); in OSSL_CMP_MSG_http_perform()
51 OSSL_CMP_MSG_http_perform(OSSL_CMP_CTX *ctx, const OSSL_CMP_MSG *req) OSSL_CMP_MSG_http_perform() argument
|
| /third_party/node/deps/uvwasi/src/ |
| H A D | sync_helpers.c | 30 static void do_stream_shutdown(uv_shutdown_t* req, int status) { in do_stream_shutdown() argument
32 shutdown_data = uv_handle_get_data((uv_handle_t*) req->handle); in do_stream_shutdown()
40 uv_shutdown_t req; in shutdown_stream_sync() local
48 uv_shutdown(&req, stream, do_stream_shutdown); in shutdown_stream_sync()
|
| /third_party/openssl/crypto/cmp/ |
| H A D | cmp_http.c | 48 * Send the PKIMessage req and on success return the response, else NULL.
52 const OSSL_CMP_MSG *req) in OSSL_CMP_MSG_http_perform()
62 if (ctx == NULL || req == NULL) { in OSSL_CMP_MSG_http_perform()
69 if ((req_mem = ASN1_item_i2d_mem_bio(it, (const ASN1_VALUE *)req)) == NULL) in OSSL_CMP_MSG_http_perform()
89 keep_alive(ctx->keep_alive, req->body->type)); in OSSL_CMP_MSG_http_perform()
51 OSSL_CMP_MSG_http_perform(OSSL_CMP_CTX *ctx, const OSSL_CMP_MSG *req) OSSL_CMP_MSG_http_perform() argument
|
| /foundation/communication/netstack/frameworks/js/builtin/fetch/src/ |
| H A D | fetch_module.cpp | 65 bool FetchModule::JsObjectToRequestData(JSIValue options, RequestData *req) in JsObjectToRequestData() argument
77 req->SetUrl(urlString.get()); in JsObjectToRequestData()
79 req->SetMethod(GetMethodFromOptions(options)); in JsObjectToRequestData()
80 HTTP_REQUEST_INFO("request method is %s", req->GetMethod().c_str()); in JsObjectToRequestData()
82 req->SetResponseType(GetResponseTypeFromOptions(options)); in JsObjectToRequestData()
87 GetNameValue(jsHeaders.get(), const_cast<std::map<std::string, std::string> &>(req->GetHeader())); in JsObjectToRequestData()
90 ParseExtraData(options, req); in JsObjectToRequestData()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
| H A D | obex_session.h | 238 void SetLastReqHeader(const ObexHeader &req) in SetLastReqHeader() argument
240 lastReqHeader_ = std::make_unique<ObexHeader>(req); in SetLastReqHeader()
260 const ObexHeader &req, std::shared_ptr<ObexBodyObject> writer, bool supportSrm, int srmpCount) in CreateReceivedObject()
262 receivedObject_ = std::make_unique<ObexClientReceivedObject>(req, writer, supportSrm, srmpCount); in CreateReceivedObject()
275 const ObexHeader &req, std::shared_ptr<ObexBodyObject> &bodyReader, uint16_t &mtu) in CreateSendObject()
277 sendObject_ = std::make_unique<ObexClientSendObject>(req, bodyReader, mtu); in CreateSendObject()
360 int SendGetResponse(const ObexHeader &req, ObexHeader &resp, std::shared_ptr<ObexBodyObject> reader = nullptr);
259 CreateReceivedObject( const ObexHeader &req, std::shared_ptr<ObexBodyObject> writer, bool supportSrm, int srmpCount) CreateReceivedObject() argument
274 CreateSendObject( const ObexHeader &req, std::shared_ptr<ObexBodyObject> &bodyReader, uint16_t &mtu) CreateSendObject() argument
|
| /foundation/filemanagement/user_file_service/utils/ |
| H A D | file_util.h | 75 static void fs_req_cleanup(uv_fs_t* req)
in fs_req_cleanup() argument
77 uv_fs_req_cleanup(req);
in fs_req_cleanup()
78 if (req) {
in fs_req_cleanup()
79 delete req;
in fs_req_cleanup()
80 req = nullptr;
in fs_req_cleanup()
84 static int CheckFsStatByPath(const string &path, uv_fs_t* req)
in CheckFsStatByPath() argument
86 int ret = uv_fs_stat(nullptr, req, path.c_str(), nullptr);
in CheckFsStatByPath()
|
| /third_party/libuv/test/ |
| H A D | test-stdio-over-pipes.c | 84 static void after_write(uv_write_t* req, int status) { in after_write() argument
91 free(req); in after_write()
98 uv_write_t* req; in on_read() local
109 req = malloc(sizeof(*req)); in on_read()
110 r = uv_write(req, (uv_stream_t*) &in, &wrbuf, 1, after_write); in on_read()
192 static void after_pipe_write(uv_write_t* req, int status) { in after_pipe_write() argument
|
| H A D | benchmark-multi-accept.c | 83 static void ipc_write_cb(uv_write_t* req, int status);
85 static void ipc_connect_cb(uv_connect_t* req, int status);
100 static void cl_connect_cb(uv_connect_t* req, int status);
139 static void ipc_write_cb(uv_write_t* req, int status) { in ipc_write_cb() argument
141 ctx = container_of(req, struct ipc_peer_ctx, write_req); in ipc_write_cb()
153 static void ipc_connect_cb(uv_connect_t* req, int status) { in ipc_connect_cb() argument
155 ctx = container_of(req, struct ipc_client_ctx, connect_req); in ipc_connect_cb()
330 static void cl_connect_cb(uv_connect_t* req, int status) { in cl_connect_cb() argument
331 struct client_ctx* ctx = container_of(req, struct client_ctx, connect_req); in cl_connect_cb()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/p2p/ |
| H A D | p2p_dev_disc.c | 70 struct wpabuf *req; in p2p_send_dev_disc_req() local
79 req = p2p_build_dev_disc_req(p2p, go, dev->info.p2p_device_addr); in p2p_send_dev_disc_req()
80 if (req == NULL) in p2p_send_dev_disc_req()
97 wpabuf_head(req), wpabuf_len(req), wait_time) < 0) { in p2p_send_dev_disc_req()
99 wpabuf_free(req); in p2p_send_dev_disc_req()
104 wpabuf_free(req); in p2p_send_dev_disc_req()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/p2p/ |
| H A D | p2p_dev_disc.c | 70 struct wpabuf *req; in p2p_send_dev_disc_req() local
79 req = p2p_build_dev_disc_req(p2p, go, dev->info.p2p_device_addr); in p2p_send_dev_disc_req()
80 if (req == NULL) in p2p_send_dev_disc_req()
97 wpabuf_head(req), wpabuf_len(req), wait_time) < 0) { in p2p_send_dev_disc_req()
99 wpabuf_free(req); in p2p_send_dev_disc_req()
104 wpabuf_free(req); in p2p_send_dev_disc_req()
|
| /third_party/ffmpeg/libavcodec/ |
| H A D | v4l2_context.c | 441 struct v4l2_requestbuffers req = { in v4l2_release_buffers() local
459 return ioctl(ctx_to_m2mctx(ctx)->fd, VIDIOC_REQBUFS, &req); in v4l2_release_buffers()
711 struct v4l2_requestbuffers req; in ff_v4l2_context_init() local
723 memset(&req, 0, sizeof(req)); in ff_v4l2_context_init()
724 req.count = ctx->num_buffers; in ff_v4l2_context_init()
725 req.memory = V4L2_MEMORY_MMAP; in ff_v4l2_context_init()
726 req.type = ctx->type; in ff_v4l2_context_init()
727 ret = ioctl(s->fd, VIDIOC_REQBUFS, &req); in ff_v4l2_context_init()
733 ctx->num_buffers = req in ff_v4l2_context_init()
[all...] |
| /third_party/vk-gl-cts/external/vulkancts/modules/vulkan/amber/ |
| H A D | vktAmberTestCase.cpp | 201 for (auto req : m_imageRequirements) in checkSupport()
202 checkImageSupport(ctx.getInstanceInterface(), ctx.getPhysicalDevice(), req); in checkSupport()
204 for (auto req : m_bufferRequirements) in checkSupport()
207 ctx.getInstanceInterface().getPhysicalDeviceFormatProperties(ctx.getPhysicalDevice(), req.m_format, &prop); in checkSupport()
209 if ((req.m_featureFlags & prop.bufferFeatures) != req.m_featureFlags) in checkSupport()
472 void AmberTestCase::addBufferRequirement (BufferRequirement req) in addBufferRequirement() argument
474 m_bufferRequirements.push_back(req); in addBufferRequirement()
493 for (auto& req : requiredFeatures) in validateRequirements()
495 if (req in validateRequirements()
[all...] |
| /third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/amber/ |
| H A D | vktAmberTestCase.cpp | 200 for (auto req : m_imageRequirements) in checkSupport()
201 checkImageSupport(ctx.getInstanceInterface(), ctx.getPhysicalDevice(), req); in checkSupport()
203 for (auto req : m_bufferRequirements) in checkSupport()
206 ctx.getInstanceInterface().getPhysicalDeviceFormatProperties(ctx.getPhysicalDevice(), req.m_format, &prop); in checkSupport()
208 if ((req.m_featureFlags & prop.bufferFeatures) != req.m_featureFlags) in checkSupport()
471 void AmberTestCase::addBufferRequirement (BufferRequirement req) in addBufferRequirement() argument
473 m_bufferRequirements.push_back(req); in addBufferRequirement()
492 for (auto& req : requiredFeatures) in validateRequirements()
494 if (req in validateRequirements()
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/eap_server/ |
| H A D | eap_server_teap.c | 464 struct wpabuf *req; in eap_teap_build_start() local
468 req = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_TEAP, in eap_teap_build_start()
470 if (!req) { in eap_teap_build_start()
477 wpabuf_put_u8(req, EAP_TLS_FLAGS_START | EAP_TEAP_FLAGS_OUTER_TLV_LEN | in eap_teap_build_start()
479 wpabuf_put_be32(req, outer_tlv_len); in eap_teap_build_start()
481 start = wpabuf_put(req, 0); in eap_teap_build_start()
484 eap_teap_put_tlv(req, TEAP_TLV_AUTHORITY_ID, in eap_teap_build_start()
487 end = wpabuf_put(req, 0); in eap_teap_build_start()
497 return req; in eap_teap_build_start()
551 struct wpabuf *req, *id_tl in eap_teap_build_phase2_req() local
890 struct wpabuf *req = NULL; eap_teap_buildReq() local
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/wps/ |
| H A D | wps_upnp.c | 921 struct ifreq req; in get_netif_info() local
934 os_strlcpy(req.ifr_name, net_if, sizeof(req.ifr_name)); in get_netif_info()
935 if (ioctl(sock, SIOCGIFADDR, &req) < 0) { in get_netif_info()
940 addr = (void *) &req.ifr_addr; in get_netif_info()
946 os_memset(&req, 0, sizeof(req)); in get_netif_info()
947 os_strlcpy(req.ifr_name, net_if, sizeof(req.ifr_name)); in get_netif_info()
948 if (ioctl(sock, SIOCGIFNETMASK, &req) < in get_netif_info()
[all...] |
| /third_party/backends/frontend/ |
| H A D | saned.c | 353 SANE_Authorization_Req req; in auth_callback() local
440 sanei_w_authorization_req (&wire, &req); in auth_callback()
447 if (req.username) in auth_callback()
448 strcpy (username, req.username); in auth_callback()
449 if (req.password) in auth_callback()
450 strcpy (password, req.password); in auth_callback()
451 if (!req.resource || strcmp (req.resource, res) != 0) in auth_callback()
455 res, req.resource); in auth_callback()
457 sanei_w_free (&wire, (WireCodecFunc) sanei_w_authorization_req, &req); in auth_callback()
1342 SANE_Init_Req req; init() local
1990 SANE_Control_Option_Req req; global() local
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/eap_server/ |
| H A D | eap_server_teap.c | 452 struct wpabuf *req; in eap_teap_build_start() local
456 req = eap_msg_alloc(EAP_VENDOR_IETF, EAP_TYPE_TEAP, in eap_teap_build_start()
458 if (!req) { in eap_teap_build_start()
465 wpabuf_put_u8(req, EAP_TLS_FLAGS_START | EAP_TEAP_FLAGS_OUTER_TLV_LEN | in eap_teap_build_start()
467 wpabuf_put_be32(req, outer_tlv_len); in eap_teap_build_start()
469 start = wpabuf_put(req, 0); in eap_teap_build_start()
472 eap_teap_put_tlv(req, TEAP_TLV_AUTHORITY_ID, in eap_teap_build_start()
475 end = wpabuf_put(req, 0); in eap_teap_build_start()
485 return req; in eap_teap_build_start()
526 struct wpabuf *req; in eap_teap_build_phase2_req() local
828 struct wpabuf *req = NULL; eap_teap_buildReq() local
[all...] |
| /third_party/musl/src/time/ |
| H A D | nanosleep.c | 4 int nanosleep(const struct timespec *req, struct timespec *rem) in nanosleep() argument
6 return __syscall_ret(-__clock_nanosleep(CLOCK_REALTIME, 0, req, rem)); in nanosleep()
|
| /third_party/musl/src/malloc/mallocng/ |
| H A D | malloc.c | 241 static struct meta *alloc_group(int sc, size_t req) in alloc_group() argument
308 req += IB + UNIT; in alloc_group()
309 req += -req & (pagesize-1); in alloc_group()
310 if (req<size+UNIT || (req>=4*pagesize && 2*cnt>usage)) { in alloc_group()
312 needed = req; in alloc_group()
356 static int alloc_slot(int sc, size_t req) in alloc_slot() argument
361 struct meta *g = alloc_group(sc, req); in alloc_slot()
|
| /third_party/musl/porting/linux/user/src/malloc/mallocng/ |
| H A D | malloc.c | 238 static struct meta *alloc_group(int sc, size_t req) in alloc_group() argument
305 req += IB + UNIT; in alloc_group()
306 req += -req & (pagesize-1); in alloc_group()
307 if (req<size+UNIT || (req>=4*pagesize && 2*cnt>usage)) { in alloc_group()
309 needed = req; in alloc_group()
351 static int alloc_slot(int sc, size_t req) in alloc_slot() argument
356 struct meta *g = alloc_group(sc, req); in alloc_slot()
|
| /third_party/backends/include/sane/ |
| H A D | sanei_net.h | 130 extern void sanei_w_init_req (Wire *w, SANE_Init_Req *req);
136 extern void sanei_w_control_option_req (Wire *w, SANE_Control_Option_Req *req);
142 extern void sanei_w_authorization_req (Wire *w, SANE_Authorization_Req *req);
|