Home
last modified time | relevance | path

Searched refs:req (Results 476 - 500 of 1551) sorted by relevance

1...<<11121314151617181920>>...63

/third_party/node/test/parallel/
H A Dtest-http2-status-code-invalid.js32 const req = client.request();
33 req.on('response', common.mustCall((headers) => {
36 req.resume();
37 req.on('end', common.mustCall(() => {
H A Dtest-https-selfsigned-no-keycertsign-no-crash.js42 const httpsServer = https.createServer(serverOptions, (req, res) => {
57 const req = https.request(clientOptions, common.mustCall((res) => {
61 req.on('error', common.mustNotCall());
62 req.end();
H A Dtest-async-hooks-execution-async-resource-await.js22 async function handler(req, res) {
23 executionAsyncResource()[sym] = { state: req.url };
30 const server = createServer(function(req, res) {
31 handler(req, res);
H A Dtest-http-client-agent.js31 const server = http.Server(common.mustCall((req, res) => {
32 if (req.url === '/0') {
55 const req = http.get({
59 const socket = req.socket;
H A Dtest-http-server-options-highwatermark.js26 }, common.mustCall((req, res) => {
27 assert.strictEqual(req._readableState.highWaterMark, getDefaultHighWaterMark() * 2);
38 common.mustCall((req, res) => {
39 assert.strictEqual(req._readableState.highWaterMark, getDefaultHighWaterMark());
H A Dtest-http2-pack-end-stream-flag.js48 const req = client.request({ ':path': path });
49 req.resume();
50 req.end();
51 req.on('end', () => client.close());
H A Dtest-tcp-wrap-connect.js16 const req = new TCPConnectWrap();
17 const err = client.connect(req, '127.0.0.1', this.address().port);
20 req.oncomplete = function(status, client_, req_, readable, writable) {
23 assert.strictEqual(req_, req);
/third_party/node/test/sequential/
H A Dtest-http-server-keep-alive-timeout-slow-server.js7 const server = http.createServer(common.mustCall((req, res) => {
8 if (req.url === '/first') {
26 const req = http.request({ agent, path, port }, common.mustCall((res) => {
41 req.end();
H A Dtest-gc-http-client-onerror.js11 function serverHandler(req, res) {
12 req.resume();
37 const req = http.get({
44 onGC(req, { ongc });
/third_party/node/src/
H A Dthreadpoolwork-inl.h40 [](uv_work_t* req) { in ScheduleWork()
41 ThreadPoolWork* self = ContainerOf(&ThreadPoolWork::work_req_, req); in ScheduleWork()
48 [](uv_work_t* req, int status) { in ScheduleWork()
49 ThreadPoolWork* self = ContainerOf(&ThreadPoolWork::work_req_, req); in ScheduleWork()
/drivers/peripheral/usb/net/src/
H A Dusb_net_host.c139 struct UsbRawRequest *req = (struct UsbRawRequest *)requestArg; in UsbnetHostTXComplete() local
140 if (req == NULL) { in UsbnetHostTXComplete()
141 HDF_LOGE("%{public}s:%{public}d req is null!", __func__, __LINE__); in UsbnetHostTXComplete()
145 struct UsbHostWb *wb = (struct UsbHostWb *)req->userData; in UsbnetHostTXComplete()
151 if (req->status != USB_REQUEST_COMPLETED) { in UsbnetHostTXComplete()
152 HDF_LOGE("%{public}s: write req failed, status = %{public}d", __func__, req->status); in UsbnetHostTXComplete()
355 static int32_t UsbnetHostNotificationBufferProcess(const struct UsbRawRequest *req, in UsbnetHostNotificationBufferProcess() argument
372 usbNet->nbSize - usbNet->nbIndex, req->buffer, copySize); in UsbnetHostNotificationBufferProcess()
402 struct UsbRawRequest *req in UsbnetHostReqCallback() local
502 struct UsbRawRequest *req = (struct UsbRawRequest *)requestArg; UsbnetHostReadBulkCallback() local
[all...]
/drivers/hdf_core/framework/test/unittest/model/usb/host/src/
H A Dusb_raw_io.c125 struct UsbRawRequest *req = (struct UsbRawRequest *)requestArg; in AcmWriteBulkCallback() local
129 if (req == NULL) { in AcmWriteBulkCallback()
130 printf("%s:%d req is NULL!", __func__, __LINE__); in AcmWriteBulkCallback()
133 struct RawWb *wb = (struct RawWb *)req->userData; in AcmWriteBulkCallback()
139 if (req->status != USB_REQUEST_COMPLETED) { in AcmWriteBulkCallback()
140 printf("%s: write req failed, status=%d", __func__, req->status); in AcmWriteBulkCallback()
148 struct UsbRawRequest *req = (struct UsbRawRequest *)requestArg; in AcmWriteIsoCallback() local
149 printf("%s:%d status:%d\n", __func__, __LINE__, req->status); in AcmWriteIsoCallback()
154 struct UsbRawRequest *req in AcmReadBulkCallback() local
191 struct UsbRawRequest *req = (struct UsbRawRequest *)requestArg; AcmNotifyReqCallback() local
[all...]
/third_party/curl/lib/
H A Dfile.c131 data->req.p.file = calloc(1, sizeof(struct FILEPROTO)); in file_setup_connection()
132 if(!data->req.p.file) in file_setup_connection()
146 struct FILEPROTO *file = data->req.p.file; in file_connect()
256 struct FILEPROTO *file = data->req.p.file; in file_done()
288 struct FILEPROTO *file = data->req.p.file; in file_upload()
340 /* Yikes! Curl_fillreadbuffer uses data->req.upload_fromhere to READ in file_upload()
342 uphere_save = data->req.upload_fromhere; in file_upload()
347 data->req.upload_fromhere = buffer; in file_upload()
393 data->req.upload_fromhere = uphere_save; in file_upload()
428 file = data->req in file_do()
[all...]
/third_party/libuv/src/unix/
H A Dpipe.c225 void uv_pipe_connect(uv_connect_t* req, in uv_pipe_connect() argument
231 err = uv_pipe_connect2(req, handle, name, strlen(name), 0, cb); in uv_pipe_connect()
235 handle->connect_req = req; in uv_pipe_connect()
237 uv__req_init(handle->loop, req, UV_CONNECT); in uv_pipe_connect()
238 req->handle = (uv_stream_t*) handle; in uv_pipe_connect()
239 req->cb = cb; in uv_pipe_connect()
240 uv__queue_init(&req->queue); in uv_pipe_connect()
248 int uv_pipe_connect2(uv_connect_t* req, in uv_pipe_connect2() argument
328 handle->connect_req = req; in uv_pipe_connect2()
330 uv__req_init(handle->loop, req, UV_CONNEC in uv_pipe_connect2()
[all...]
/third_party/libwebsockets/lib/roles/netlink/
H A Dops-netlink.c479 struct nl_req_s req; in rops_pt_init_destroy_netlink() local
561 memset(&req, 0, sizeof(req)); in rops_pt_init_destroy_netlink()
565 req.hdr.nlmsg_len = NLMSG_LENGTH(sizeof(req.gen)); in rops_pt_init_destroy_netlink()
566 req.hdr.nlmsg_type = RTM_GETROUTE; in rops_pt_init_destroy_netlink()
567 req.hdr.nlmsg_flags = NLM_F_REQUEST | NLM_F_DUMP; in rops_pt_init_destroy_netlink()
568 req.hdr.nlmsg_seq = 1; in rops_pt_init_destroy_netlink()
569 req.hdr.nlmsg_pid = (uint32_t)getpid(); in rops_pt_init_destroy_netlink()
570 req in rops_pt_init_destroy_netlink()
[all...]
/third_party/mesa3d/src/freedreno/vulkan/
H A Dtu_drm.c67 struct drm_msm_param req = { in tu_drm_get_param() local
72 int ret = drmCommandWriteRead(dev->local_fd, DRM_MSM_GET_PARAM, &req, in tu_drm_get_param()
73 sizeof(req)); in tu_drm_get_param()
77 *value = req.value; in tu_drm_get_param()
150 struct drm_msm_submitqueue req = { in tu_drm_submitqueue_new() local
156 DRM_MSM_SUBMITQUEUE_NEW, &req, sizeof(req)); in tu_drm_submitqueue_new()
160 *queue_id = req.id; in tu_drm_submitqueue_new()
174 struct drm_gem_close req = { in tu_gem_close() local
178 drmIoctl(dev->fd, DRM_IOCTL_GEM_CLOSE, &req); in tu_gem_close()
185 struct drm_msm_gem_info req = { tu_gem_info() local
258 struct drm_msm_gem_new req = { tu_bo_init_new() local
1017 struct drm_msm_gem_submit req = { tu_queue_submit_locked() local
1116 struct drm_msm_wait_fence req = { tu_device_wait_u_trace() local
[all...]
/third_party/rust/crates/rust-openssl/openssl-sys/src/handwritten/
H A Dx509.rs346 pub fn X509_REQ_get_version(req: *const X509_REQ) -> c_long; in X509_REQ_get_version()
347 pub fn X509_REQ_set_version(req: *mut X509_REQ, version: c_long) -> c_int; in X509_REQ_set_version()
349 pub fn X509_REQ_get_subject_name(req: *const X509_REQ) -> *mut X509_NAME; in X509_REQ_get_subject_name()
353 pub fn X509_REQ_set_subject_name(req: *mut X509_REQ, name: #[const_ptr_if(ossl300)] X509_NAME) -> c_int; in X509_REQ_set_subject_name()
357 pub fn X509_REQ_set_pubkey(req: *mut X509_REQ, pkey: *mut EVP_PKEY) -> c_int; in X509_REQ_set_pubkey()
358 pub fn X509_REQ_get_pubkey(req: *mut X509_REQ) -> *mut EVP_PKEY; in X509_REQ_get_pubkey()
359 pub fn X509_REQ_get_extensions(req: *mut X509_REQ) -> *mut stack_st_X509_EXTENSION; in X509_REQ_get_extensions()
363 pub fn X509_REQ_add_extensions(req: *mut X509_REQ, exts: #[const_ptr_if(ossl300)] stack_st_X509_EXTENSION) in X509_REQ_add_extensions()
368 pub fn X509_REQ_get_attr_count(req: *const X509_REQ) -> c_int; in X509_REQ_get_attr_count()
369 pub fn X509_REQ_get_attr_by_NID(req in X509_REQ_get_attr_count()
[all...]
/third_party/wpa_supplicant/wpa_supplicant-2.9/wpa_supplicant/
H A Dgas_query.c48 struct wpabuf *req; member
147 wpabuf_free(query->req); in gas_query_free()
286 struct wpabuf *req, unsigned int wait_time) in gas_query_tx()
296 MAC2STR(query->addr), (unsigned int) wpabuf_len(req), in gas_query_tx()
299 u8 *categ = wpabuf_mhead_u8(req); in gas_query_tx()
316 query->sa, bssid, wpabuf_head(req), in gas_query_tx()
317 wpabuf_len(req), wait_time, in gas_query_tx()
329 struct wpabuf *req; in gas_query_tx_comeback_req() local
332 req = gas_build_comeback_req(query->dialog_token); in gas_query_tx_comeback_req()
333 if (req in gas_query_tx_comeback_req()
285 gas_query_tx(struct gas_query *gas, struct gas_query_pending *query, struct wpabuf *req, unsigned int wait_time) gas_query_tx() argument
809 gas_query_req(struct gas_query *gas, const u8 *dst, int freq, int wildcard_bssid, struct wpabuf *req, void (*cb)(void *ctx, const u8 *dst, u8 dialog_token, enum gas_query_result result, const struct wpabuf *adv_proto, const struct wpabuf *resp, u16 status_code), void *ctx) gas_query_req() argument
[all...]
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/wpa_supplicant/
H A Dgas_query.c49 struct wpabuf *req; member
148 wpabuf_free(query->req); in gas_query_free()
277 struct wpabuf *req, unsigned int wait_time) in gas_query_tx()
287 MAC2STR_SEC(query->addr), (unsigned int) wpabuf_len(req), in gas_query_tx()
290 u8 *categ = wpabuf_mhead_u8(req); in gas_query_tx()
307 query->sa, bssid, wpabuf_head(req), in gas_query_tx()
308 wpabuf_len(req), wait_time, in gas_query_tx()
320 struct wpabuf *req; in gas_query_tx_comeback_req() local
323 req = gas_build_comeback_req(query->dialog_token); in gas_query_tx_comeback_req()
324 if (req in gas_query_tx_comeback_req()
276 gas_query_tx(struct gas_query *gas, struct gas_query_pending *query, struct wpabuf *req, unsigned int wait_time) gas_query_tx() argument
822 gas_query_req(struct gas_query *gas, const u8 *dst, int freq, int wildcard_bssid, int maintain_addr, struct wpabuf *req, void (*cb)(void *ctx, const u8 *dst, u8 dialog_token, enum gas_query_result result, const struct wpabuf *adv_proto, const struct wpabuf *resp, u16 status_code), void *ctx) gas_query_req() argument
[all...]
/test/xts/hats/kernel/syscalls/fileio/clocknanosleep/
H A DClockNanoSleepApiTest.cpp60 struct timespec req = {1, 0}; in HWTEST_F() local
83 int ret = clock_nanosleep(CLOCK_REALTIME, 0, &req, &rem); in HWTEST_F()
100 struct timespec req = {0, 100}; in HWTEST_F() local
102 int ret = clock_nanosleep(CLOCK_REALTIME, 0, &req, nullptr); in HWTEST_F()
/test/xts/hats/kernel/syscalls/timer/nanosleep/
H A DNanoSleepApiTest.cpp61 struct timespec req = {0, 100000L}; in HWTEST_F() local
84 int result = nanosleep(&req, &rem); in HWTEST_F()
102 struct timespec req = {0, 100}; in HWTEST_F() local
105 int result = nanosleep(&req, &rem); in HWTEST_F()
/third_party/libuv/test/
H A Dtest-pipe-connect-error.c63 uv_connect_t req; in TEST_IMPL() local
68 uv_pipe_connect(&req, &client, BAD_PIPENAME, connect_cb); in TEST_IMPL()
83 uv_connect_t req; in TEST_IMPL() local
88 uv_pipe_connect(&req, &client, path, connect_cb_file); in TEST_IMPL()
/third_party/libuv/src/
H A Dfs-poll.c52 static void poll_cb(uv_fs_t* req);
185 static void poll_cb(uv_fs_t* req) { in poll_cb() argument
191 ctx = container_of(req, struct poll_ctx, fs_req); in poll_cb()
197 if (req->result != 0) { in poll_cb()
198 if (ctx->busy_polling != req->result) { in poll_cb()
200 req->result, in poll_cb()
203 ctx->busy_polling = req->result; in poll_cb()
208 statbuf = &req->statbuf; in poll_cb()
218 uv_fs_req_cleanup(req); in poll_cb()
/third_party/mesa3d/src/etnaviv/drm/
H A Detnaviv_cmd_stream.c207 struct drm_etnaviv_gem_submit req = { in etna_cmd_stream_flush() local
221 req.flags |= ETNA_SUBMIT_FENCE_FD_IN | ETNA_SUBMIT_NO_IMPLICIT; in etna_cmd_stream_flush()
222 req.fence_fd = in_fence_fd; in etna_cmd_stream_flush()
226 req.flags |= ETNA_SUBMIT_FENCE_FD_OUT; in etna_cmd_stream_flush()
229 req.flags |= ETNA_SUBMIT_SOFTPIN; in etna_cmd_stream_flush()
235 &req, sizeof(req)); in etna_cmd_stream_flush()
240 priv->last_timestamp = req.fence; in etna_cmd_stream_flush()
248 *out_fence_fd = req.fence_fd; in etna_cmd_stream_flush()
/third_party/node/deps/uv/src/
H A Dfs-poll.c52 static void poll_cb(uv_fs_t* req);
185 static void poll_cb(uv_fs_t* req) { in poll_cb() argument
191 ctx = container_of(req, struct poll_ctx, fs_req); in poll_cb()
197 if (req->result != 0) { in poll_cb()
198 if (ctx->busy_polling != req->result) { in poll_cb()
200 req->result, in poll_cb()
203 ctx->busy_polling = req->result; in poll_cb()
208 statbuf = &req->statbuf; in poll_cb()
218 uv_fs_req_cleanup(req); in poll_cb()

Completed in 12 milliseconds

1...<<11121314151617181920>>...63