/third_party/libphonenumber/migrator/migrator-servlet/src/main/java/com/google/phonenumbers/ |
H A D | ServletMain.java | 63 protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { in doPost() argument 73 FileItemIterator iterator = upload.getItemIterator(req); in doPost() 110 req.setAttribute("number", number); in doPost() 111 req.setAttribute("numberCountryCode", countryCode); in doPost() 113 handleSingleNumberMigration(req, resp, number, countryCode, customRecipe); in doPost() 122 handleFileMigration(req, resp, numbersFromFile.build(), countryCode, customRecipe, fileName); in doPost() 128 protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { in doGet() argument 130 String fileName = "+" + matcher.removeFrom(req.getParameter("countryCode")) + "_Migration_ " + in doGet() 131 matcher.removeFrom(req.getParameter("fileName")); in doGet() 132 String fileContent = req in doGet() 154 handleSingleNumberMigration(HttpServletRequest req, HttpServletResponse resp, String number, String countryCode, String customRecipe) handleSingleNumberMigration() argument 200 handleFileMigration(HttpServletRequest req, HttpServletResponse resp, ImmutableList<String> numbersList, String countryCode, String customRecipe, String fileName) handleFileMigration() argument [all...] |
/third_party/node/test/parallel/ |
H A D | test-http-generic-streams.js | 10 const server = http.createServer(common.mustCall((req, res) => { 19 const req = http.request({ 28 req.end(); 34 const server = http.createServer(common.mustCall((req, res) => { 44 const req = http.request({ 54 req.shouldKeepAlive = true; 55 req.end(); 66 const server = http.createServer(common.mustCall((req, res) => { 67 req.setEncoding('utf8'); 68 req [all...] |
H A D | test-http-client-timeout-agent.js | 35 const server = http.createServer((req, res) => { 36 const m = /\/(.*)/.exec(req.url); 52 const req = http.request(options); 53 req.id = requests_sent; 54 req.on('response', (res) => { 56 console.log(`res#${this.req.id} data:${data}`); 59 console.log(`res#${this.req.id} end`); 61 req.destroy(); 64 req.on('close', function() { 65 console.log(`req# [all...] |
/foundation/window/window_manager_lite/services/wms/ |
H A D | lite_wms.h | 33 static void WMSRequestHandle(int funcId, void* origin, IpcIo* req, IpcIo* reply); 41 static void GetSurface(IpcIo* req, IpcIo* reply); 42 static void Show(IpcIo* req, IpcIo* reply); 43 static void Hide(IpcIo* req, IpcIo* reply); 44 static void RaiseToTop(IpcIo* req, IpcIo* reply); 45 static void LowerToBottom(IpcIo* req, IpcIo* reply); 46 static void MoveTo(IpcIo* req, IpcIo* reply); 47 static void Resize(IpcIo* req, IpcIo* reply); 48 static void Update(IpcIo* req, IpcIo* reply); 49 static void CreateWindow(IpcIo* req, IpcI [all...] |
/third_party/libuv/docs/code/uvcat/ |
H A D | main.c | 6 void on_read(uv_fs_t *req); 16 void on_write(uv_fs_t *req) { in on_write() argument 17 if (req->result < 0) { in on_write() 18 fprintf(stderr, "Write error: %s\n", uv_strerror((int)req->result)); in on_write() 25 void on_read(uv_fs_t *req) { in on_read() argument 26 if (req->result < 0) { in on_read() 27 fprintf(stderr, "Read error: %s\n", uv_strerror(req->result)); in on_read() 29 else if (req->result == 0) { in on_read() 34 else if (req->result > 0) { in on_read() 35 iov.len = req in on_read() 40 on_open(uv_fs_t *req) on_open() argument [all...] |
/third_party/node/test/internet/ |
H A D | test-http2-issue-32922.js | 18 const req = clientSession.request({ [HTTP2_HEADER_PATH]: '/' }); 19 req.on('error', (err) => { 22 req.on('response', (_headers) => { 23 req.on('data', (_chunk) => { }); 24 req.on('end', () => { 38 const req = clientSession.request({ [HTTP2_HEADER_PATH]: '/' }); 39 req.on('error', (err) => { 42 req.on('response', (_headers) => { 43 req.on('data', (_chunk) => { }); 44 req [all...] |
/third_party/mesa3d/src/glx/ |
H A D | dri2.c | 226 xDRI2QueryVersionReq *req; in DRI2QueryVersion() local 232 GetReq(DRI2QueryVersion, req); in DRI2QueryVersion() 233 req->reqType = info->codes->major_opcode; in DRI2QueryVersion() 234 req->dri2ReqType = X_DRI2QueryVersion; in DRI2QueryVersion() 235 req->majorVersion = DRI2_MAJOR; in DRI2QueryVersion() 236 req->minorVersion = DRI2_MINOR; in DRI2QueryVersion() 273 xDRI2ConnectReq *req; in DRI2Connect() local 278 GetReq(DRI2Connect, req); in DRI2Connect() 279 req->reqType = info->codes->major_opcode; in DRI2Connect() 280 req in DRI2Connect() 341 xDRI2AuthenticateReq *req; DRI2Authenticate() local 369 xDRI2CreateDrawableReq *req; DRI2CreateDrawable() local 386 xDRI2DestroyDrawableReq *req; DRI2DestroyDrawable() local 408 xDRI2GetBuffersReq *req; DRI2GetBuffers() local 467 xDRI2GetBuffersReq *req; DRI2GetBuffersWithFormat() local 524 xDRI2CopyRegionReq *req; DRI2CopyRegion() local [all...] |
H A D | indirect_glx.c | 93 xGLXMakeCurrentReq *req; in SendMakeCurrentRequest() local 95 GetReq(GLXMakeCurrent, req); in SendMakeCurrentRequest() 96 req->reqType = opcode; in SendMakeCurrentRequest() 97 req->glxCode = X_GLXMakeCurrent; in SendMakeCurrentRequest() 98 req->drawable = draw; in SendMakeCurrentRequest() 99 req->context = gc_id; in SendMakeCurrentRequest() 100 req->oldContextTag = gc_tag; in SendMakeCurrentRequest() 111 xGLXMakeContextCurrentReq *req; in SendMakeCurrentRequest() local 113 GetReq(GLXMakeContextCurrent, req); in SendMakeCurrentRequest() 114 req in SendMakeCurrentRequest() 123 xGLXMakeCurrentReadSGIReq *req; SendMakeCurrentRequest() local 215 xGLXWaitGLReq *req; indirect_wait_gl() local 234 xGLXWaitXReq *req; indirect_wait_x() local [all...] |
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/include/cloud_disk/ |
H A D | file_operations_base.h | 30 virtual void Lookup(fuse_req_t req, fuse_ino_t parent, const char *name); 31 virtual void Access(fuse_req_t req, fuse_ino_t ino, int mask); 32 virtual void GetAttr(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi); 33 virtual void Open(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi); 34 virtual void Forget(fuse_req_t req, fuse_ino_t ino, uint64_t nLookup); 35 virtual void ForgetMulti(fuse_req_t req, size_t count, struct fuse_forget_data *forgets); 36 virtual void MkDir(fuse_req_t req, fuse_ino_t parent, const char *name, mode_t mode); 37 virtual void RmDir(fuse_req_t req, fuse_ino_t parent, const char *name); 38 virtual void Unlink(fuse_req_t req, fuse_ino_t parent, const char *name); 39 virtual void Release(fuse_req_t req, fuse_ino_ [all...] |
H A D | fuse_operations.h | 25 static void Lookup(fuse_req_t req, fuse_ino_t parent, const char *name); 26 static void Access(fuse_req_t req, fuse_ino_t ino, int mask); 27 static void GetAttr(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi); 28 static void Open(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi); 29 static void Forget(fuse_req_t req, fuse_ino_t ino, uint64_t nLookup); 30 static void ForgetMulti(fuse_req_t req, size_t count, struct fuse_forget_data *forgets); 31 static void MkDir(fuse_req_t req, fuse_ino_t parent, const char *name, mode_t mode); 32 static void RmDir(fuse_req_t req, fuse_ino_t parent, const char *name); 33 static void Unlink(fuse_req_t req, fuse_ino_t parent, const char *name); 34 static void Release(fuse_req_t req, fuse_ino_ [all...] |
/foundation/multimedia/media_lite/services/recorder_lite/server/src/ |
H A D | recorder_service.cpp | 52 void RecorderClientMng::Dispatch(int32_t funcId, pid_t pid, IpcIo *req, IpcIo *reply) in Dispatch() argument 69 VideoSourceType *src = (VideoSourceType*)ReadRawData(req, sizeof(VideoSourceType)); in Dispatch() 78 ReadInt32(req, &src); in Dispatch() 79 VideoCodecFormat *enc = (VideoCodecFormat*)ReadRawData(req, sizeof(VideoCodecFormat)); in Dispatch() 86 ReadInt32(req, &src); in Dispatch() 88 ReadInt32(req, &width); in Dispatch() 90 ReadInt32(req, &height); in Dispatch() 97 ReadInt32(req, &sourceId); in Dispatch() 99 ReadInt32(req, &frameRate); in Dispatch() 106 ReadInt32(req, in Dispatch() [all...] |
/third_party/libuv/src/ |
H A D | uv-data-getter-setters.c | 65 uv_req_type uv_req_get_type(const uv_req_t* req) { in uv_req_get_type() argument 66 return req->type; in uv_req_get_type() 69 void* uv_req_get_data(const uv_req_t* req) { in uv_req_get_data() argument 70 return req->data; in uv_req_get_data() 73 void uv_req_set_data(uv_req_t* req, void* data) { in uv_req_set_data() argument 74 req->data = data; in uv_req_set_data() 93 uv_fs_type uv_fs_get_type(const uv_fs_t* req) { in uv_fs_get_type() argument 94 return req->fs_type; in uv_fs_get_type() 97 ssize_t uv_fs_get_result(const uv_fs_t* req) { in uv_fs_get_result() argument 98 return req in uv_fs_get_result() 101 uv_fs_get_ptr(const uv_fs_t* req) uv_fs_get_ptr() argument 105 uv_fs_get_path(const uv_fs_t* req) uv_fs_get_path() argument 109 uv_fs_get_statbuf(uv_fs_t* req) uv_fs_get_statbuf() argument [all...] |
/third_party/ltp/testcases/kernel/syscalls/setsockopt/ |
H A D | setsockopt09.c | 48 struct tpacket_req3 req = { in run() local 56 req.tp_block_nr = 256; in run() 57 req.tp_frame_nr = req.tp_block_size * req.tp_block_nr; in run() 58 req.tp_frame_nr /= req.tp_frame_size; in run() 73 SAFE_SETSOCKOPT(sock, SOL_PACKET, PACKET_RX_RING, &req, in run() 74 sizeof(req)); in run() 75 req in run() [all...] |
/third_party/node/deps/uv/src/ |
H A D | uv-data-getter-setters.c | 65 uv_req_type uv_req_get_type(const uv_req_t* req) { in uv_req_get_type() argument 66 return req->type; in uv_req_get_type() 69 void* uv_req_get_data(const uv_req_t* req) { in uv_req_get_data() argument 70 return req->data; in uv_req_get_data() 73 void uv_req_set_data(uv_req_t* req, void* data) { in uv_req_set_data() argument 74 req->data = data; in uv_req_set_data() 93 uv_fs_type uv_fs_get_type(const uv_fs_t* req) { in uv_fs_get_type() argument 94 return req->fs_type; in uv_fs_get_type() 97 ssize_t uv_fs_get_result(const uv_fs_t* req) { in uv_fs_get_result() argument 98 return req in uv_fs_get_result() 101 uv_fs_get_ptr(const uv_fs_t* req) uv_fs_get_ptr() argument 105 uv_fs_get_path(const uv_fs_t* req) uv_fs_get_path() argument 109 uv_fs_get_statbuf(uv_fs_t* req) uv_fs_get_statbuf() argument [all...] |
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/eap_peer/ |
H A D | eap_pax.c | 93 static struct wpabuf * eap_pax_alloc_resp(const struct eap_pax_hdr *req, in eap_pax_alloc_resp() argument 107 pax->mac_id = req->mac_id; in eap_pax_alloc_resp() 108 pax->dh_group_id = req->dh_group_id; in eap_pax_alloc_resp() 109 pax->public_key_id = req->public_key_id; in eap_pax_alloc_resp() 117 const struct eap_pax_hdr *req, in eap_pax_process_std_1() 134 if (req->flags & EAP_PAX_FLAGS_CE) { in eap_pax_process_std_1() 141 left = req_plen - sizeof(*req); in eap_pax_process_std_1() 150 pos = (const u8 *) (req + 1); in eap_pax_process_std_1() 180 if (eap_pax_initial_key_derivation(req->mac_id, data->ak, data->rand.e, in eap_pax_process_std_1() 191 resp = eap_pax_alloc_resp(req, i in eap_pax_process_std_1() 115 eap_pax_process_std_1(struct eap_pax_data *data, struct eap_method_ret *ret, u8 id, const struct eap_pax_hdr *req, size_t req_plen) eap_pax_process_std_1() argument 231 eap_pax_process_std_3(struct eap_pax_data *data, struct eap_method_ret *ret, u8 id, const struct eap_pax_hdr *req, size_t req_plen) eap_pax_process_std_3() argument 337 const struct eap_pax_hdr *req; eap_pax_process() local [all...] |
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/eap_peer/ |
H A D | eap_pax.c | 93 static struct wpabuf * eap_pax_alloc_resp(const struct eap_pax_hdr *req, in eap_pax_alloc_resp() argument 107 pax->mac_id = req->mac_id; in eap_pax_alloc_resp() 108 pax->dh_group_id = req->dh_group_id; in eap_pax_alloc_resp() 109 pax->public_key_id = req->public_key_id; in eap_pax_alloc_resp() 117 const struct eap_pax_hdr *req, in eap_pax_process_std_1() 134 if (req->flags & EAP_PAX_FLAGS_CE) { in eap_pax_process_std_1() 141 left = req_plen - sizeof(*req); in eap_pax_process_std_1() 150 pos = (const u8 *) (req + 1); in eap_pax_process_std_1() 180 if (eap_pax_initial_key_derivation(req->mac_id, data->ak, data->rand.e, in eap_pax_process_std_1() 191 resp = eap_pax_alloc_resp(req, i in eap_pax_process_std_1() 115 eap_pax_process_std_1(struct eap_pax_data *data, struct eap_method_ret *ret, u8 id, const struct eap_pax_hdr *req, size_t req_plen) eap_pax_process_std_1() argument 231 eap_pax_process_std_3(struct eap_pax_data *data, struct eap_method_ret *ret, u8 id, const struct eap_pax_hdr *req, size_t req_plen) eap_pax_process_std_3() argument 337 const struct eap_pax_hdr *req; eap_pax_process() local [all...] |
/foundation/multimedia/camera_lite/services/server/include/ |
H A D | camera_server.h | 29 static void CameraServerRequestHandle(int funcId, void *origin, IpcIo *req, IpcIo *reply); 31 void GetCameraAbility(IpcIo *req, IpcIo *reply); 32 void GetCameraInfo(IpcIo *req, IpcIo *reply); 33 void GetCameraIdList(IpcIo *req, IpcIo *reply); 34 void CreateCamera(IpcIo *req, IpcIo *reply); 35 void CloseCamera(IpcIo *req, IpcIo *reply); 36 void SetCameraConfig(IpcIo *req, IpcIo *reply); 37 void SetFrameConfig(IpcIo *req, IpcIo *reply); 38 void TriggerLoopingCapture(IpcIo *req, IpcIo *reply); 39 void StopLoopingCapture(IpcIo *req, IpcI [all...] |
/third_party/libuv/test/ |
H A D | benchmark-fs-stat.c | 32 #define sync_stat(req, path) \ 34 uv_fs_stat(NULL, (req), (path), NULL); \ 35 uv_fs_req_cleanup((req)); \ 66 uv_fs_t req; in sync_bench() local 73 sync_stat(&req, path); in sync_bench() 86 struct async_req* req = container_of(fs_req, struct async_req, fs_req); in stat_cb() local 87 uv_fs_req_cleanup(&req->fs_req); in stat_cb() 88 if (*req->count == 0) return; in stat_cb() 89 uv_fs_stat(uv_default_loop(), &req->fs_req, req in stat_cb() 96 struct async_req* req; async_bench() local [all...] |
/third_party/libdrm/freedreno/kgsl/ |
H A D | kgsl_bo.c | 35 struct drm_kgsl_gem_memtype req = { in set_memtype() local 41 &req, sizeof(req)); in set_memtype() 48 struct drm_kgsl_gem_alloc req = { in bo_alloc() local 58 &req, sizeof(req)); in bo_alloc() 64 kgsl_bo->offset = req.offset; in bo_alloc() 139 struct drm_kgsl_gem_create req = { in kgsl_bo_new_handle() local 145 &req, sizeof(req)); in kgsl_bo_new_handle() 197 struct kgsl_map_user_mem req = { fd_bo_from_fbdev() local 227 struct drm_kgsl_gem_bufinfo req = { kgsl_bo_gpuaddr() local 277 struct drm_kgsl_gem_active req = { kgsl_bo_set_timestamp() local 296 struct drm_kgsl_gem_bufinfo req = { kgsl_bo_get_timestamp() local [all...] |
/third_party/backends/backend/ |
H A D | hp5400_internal.c | 747 hp5400_test_scan_response (struct ScanResponse *resp, struct ScanRequest *req) in hp5400_test_scan_response() argument 749 (void) req; /* to avoid compilation warning */ in hp5400_test_scan_response() 770 DoAverageScan (int iHandle, struct ScanRequest *req, int code, in DoAverageScan() argument 782 if (InitScan2 (SCAN_TYPE_CALIBRATION, req, &HWParams, &res, 0, code) != 0) in DoAverageScan() 821 DoScan (int iHandle, struct ScanRequest *req, const char *filename, int code, in DoScan() argument 847 if (InitScan2 (SCAN_TYPE_NORMAL, req, &HWParams, res, 1, 0x40) != 0) in DoScan() 874 struct ScanRequest req; in Calibrate() local 884 memset(&req, 0, sizeof(req)); in Calibrate() 886 req in Calibrate() 1010 struct ScanRequest req; hp5400_scan() local 1145 struct ScanRequest req; InitScan() local 1195 InitScan2(enum ScanType scantype, struct ScanRequest *req, THWParams * pHWParams, struct ScanResponse *result, int iColourOffset, int code) InitScan2() argument [all...] |
/third_party/lzma/Asm/arm64/ |
H A D | LzmaDecOpt.S | 41 .macro PLOAD dest:req, mem:req 44 .macro PLOAD_PREINDEXED dest:req, mem:req, offset:req 47 .macro PLOAD_2 dest:req, mem1:req, mem2:req 50 .macro PLOAD_LSL dest:req, mem1:req, mem [all...] |
/third_party/NuttX/drivers/usbdev/gadget/ |
H A D | cdcacm.c | 79 struct usbdev_req_s *req; /* The contained request */ member 87 struct usbdev_req_s *req; /* The contained request */ member 100 bool wating; /* if notify request is NULL, try submit(notify, req) again */ 184 FAR struct usbdev_req_s *req); 202 FAR struct usbdev_req_s *req); 204 FAR struct usbdev_req_s *req); 350 FAR struct usbdev_req_s *req; in cdcacm_sndpacket() local 362 req = wrcontainer->req; in cdcacm_sndpacket() 389 ret = memcpy_s(req in cdcacm_sndpacket() 436 struct usbdev_req_s *req; cdcacm_fill_rdrequest() local 489 FAR struct usbdev_req_s *req; cdcacm_recvpacket() local 562 FAR struct usbdev_req_s *req; cdcacm_requeue_rdrequest() local 662 FAR struct usbdev_req_s *req; cdcacm_allocreq() local 690 cdcacm_freereq(FAR struct usbdev_ep_s *ep, FAR struct usbdev_req_s *req) cdcacm_freereq() argument 887 cdcacm_rdcomplete(FAR struct usbdev_ep_s *ep, FAR struct usbdev_req_s *req) cdcacm_rdcomplete() argument 940 cdcacm_wrcomplete(FAR struct usbdev_ep_s *ep, FAR struct usbdev_req_s *req) cdcacm_wrcomplete() argument 1339 cdcacm_set_line_complete(FAR struct usbdev_ep_s *ep, FAR struct usbdev_req_s *req) cdcacm_set_line_complete() argument 1376 FAR struct usbdev_req_s *req; cdcacm_setup() local 1550 cdcacm_serial_connect_state(const struct cdcacm_dev_s *priv, struct usbdev_req_s *req, const void *data, uint16_t value, uint32_t len) cdcacm_serial_connect_state() argument 1586 FAR struct usbdev_req_s *req; cdcacm_serial_connect() local 1631 FAR struct usbdev_req_s *req; cdcacm_serial_disconnect() local [all...] |
/third_party/nghttp2/src/ |
H A D | shrpx_https_upstream.cc | 140 auto &req = downstream->request(); in htp_uricb() local 145 req.method = htp->method; in htp_uricb() 147 if (req.fs.buffer_size() + len > in htp_uricb() 151 << req.fs.buffer_size() + len; in htp_uricb() 160 req.fs.add_extra_buffer_size(len); in htp_uricb() 162 if (req.method == HTTP_CONNECT) { in htp_uricb() 163 req.authority = in htp_uricb() 164 concat_string_ref(balloc, req.authority, StringRef{data, len}); in htp_uricb() 166 req.path = concat_string_ref(balloc, req in htp_uricb() 177 auto &req = downstream->request(); htp_hdr_keycb() local 232 auto &req = downstream->request(); htp_hdr_valcb() local 257 rewrite_request_host_path_from_uri(BlockAllocator &balloc, Request &req, const StringRef &uri, http_parser_url &u) rewrite_request_host_path_from_uri() argument 343 auto &req = downstream->request(); htp_hdrs_completecb() local 590 auto &req = downstream->request(); htp_msg_completecb() local 979 const auto &req = downstream->request(); send_reply() local 1123 const auto &req = downstream->request(); on_downstream_header_complete() local 1364 const auto &req = downstream->request(); on_downstream_body_complete() local 1411 auto &req = downstream->request(); redirect_to_https() local [all...] |
/third_party/ltp/testcases/lib/ |
H A D | tst_ns_ifmove.c | 34 } req; variable 69 memset(&req, 0, sizeof(req)); in main() 70 req.nh.nlmsg_len = NLMSG_LENGTH(sizeof(struct ifinfomsg)); in main() 71 req.nh.nlmsg_flags = NLM_F_REQUEST; in main() 72 req.nh.nlmsg_type = RTM_NEWLINK; in main() 73 req.ifi.ifi_family = AF_UNSPEC; in main() 74 req.ifi.ifi_index = intf_index; in main() 75 req.ifi.ifi_change = 0xffffffff; in main() 76 rta = (struct rtattr *)(((char *) &req) in main() [all...] |
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
H A D | netlink.c | 176 } req; in netlink_send_oper_ifla() local 181 os_memset(&req, 0, sizeof(req)); in netlink_send_oper_ifla() 183 req.hdr.nlmsg_len = NLMSG_LENGTH(sizeof(struct ifinfomsg)); in netlink_send_oper_ifla() 184 req.hdr.nlmsg_type = RTM_SETLINK; in netlink_send_oper_ifla() 185 req.hdr.nlmsg_flags = NLM_F_REQUEST; in netlink_send_oper_ifla() 186 req.hdr.nlmsg_seq = ++nl_seq; in netlink_send_oper_ifla() 187 req.hdr.nlmsg_pid = 0; in netlink_send_oper_ifla() 189 req.ifinfo.ifi_family = AF_UNSPEC; in netlink_send_oper_ifla() 190 req in netlink_send_oper_ifla() [all...] |