/net/9p/ |
H A D | client.c | 227 struct p9_req_t *req; local 258 req = &c->reqs[row][col]; 259 if (!req->tc) { 260 req->wq = kmalloc(sizeof(wait_queue_head_t), GFP_NOFS); 261 if (!req->wq) { 265 init_waitqueue_head(req->wq); 266 req->tc = kmalloc(sizeof(struct p9_fcall) + alloc_msize, 268 req->rc = kmalloc(sizeof(struct p9_fcall) + alloc_msize, 270 if ((!req->tc) || (!req 410 p9_client_cb(struct p9_client *c, struct p9_req_t *req) argument 478 p9_check_errors(struct p9_client *c, struct p9_req_t *req) argument 541 p9_check_zc_errors(struct p9_client *c, struct p9_req_t *req, char *uidata, int in_hdrlen, int kern_buf) argument 636 struct p9_req_t *req; local 667 struct p9_req_t *req; local 718 struct p9_req_t *req; local 804 struct p9_req_t *req; local 918 struct p9_req_t *req; local 1087 struct p9_req_t *req; local 1137 struct p9_req_t *req; local 1212 struct p9_req_t *req; local 1258 struct p9_req_t *req; local 1303 struct p9_req_t *req; local 1348 struct p9_req_t *req; local 1380 struct p9_req_t *req; local 1400 struct p9_req_t *req; local 1426 struct p9_req_t *req; local 1470 struct p9_req_t *req; local 1497 struct p9_req_t *req; local 1523 struct p9_req_t *req; local 1601 struct p9_req_t *req; local 1662 struct p9_req_t *req; local 1715 struct p9_req_t *req; local 1801 struct p9_req_t *req; local 1838 struct p9_req_t *req; local 1870 struct p9_req_t *req; local 1910 struct p9_req_t *req; local 1938 struct p9_req_t *req; local 1971 struct p9_req_t *req; local 2018 struct p9_req_t *req; local 2043 struct p9_req_t *req; local 2103 struct p9_req_t *req; local 2134 struct p9_req_t *req; local 2164 struct p9_req_t *req; local 2197 struct p9_req_t *req; local 2231 struct p9_req_t *req; local [all...] |
H A D | trans_fd.c | 119 * @req: current request being processed (if any) 142 struct p9_req_t *req; member in struct:p9_conn 192 struct p9_req_t *req, *rtmp; local 207 list_for_each_entry_safe(req, rtmp, &m->req_list, req_list) { 208 req->status = REQ_STATUS_ERROR; 209 if (!req->t_err) 210 req->t_err = err; 211 list_move(&req->req_list, &cancel_list); 213 list_for_each_entry_safe(req, rtmp, &m->unsent_req_list, req_list) { 214 req 446 struct p9_req_t *req; local 661 p9_fd_request(struct p9_client *client, struct p9_req_t *req) argument 688 p9_fd_cancel(struct p9_client *client, struct p9_req_t *req) argument [all...] |
H A D | trans_rdma.c | 115 * @req: Keeps track of requests (send) 123 struct p9_req_t *req; member in union:p9_rdma_context::__anon5 280 struct p9_req_t *req; local 284 req = NULL; 295 req = p9_tag_lookup(client, tag); 296 if (!req) 299 req->rc = c->rc; 300 req->status = REQ_STATUS_RCVD; 301 p9_client_cb(client, req); 306 p9_debug(P9_DEBUG_ERROR, "req 414 rdma_request(struct p9_client *client, struct p9_req_t *req) argument 560 rdma_cancel(struct p9_client *client, struct p9_req_t *req) argument [all...] |
H A D | trans_virtio.c | 148 struct p9_req_t *req; local 166 req = p9_tag_lookup(chan->client, rc->tag); 167 req->status = REQ_STATUS_RCVD; 168 p9_client_cb(chan->client, req); 209 static int p9_virtio_cancel(struct p9_client *client, struct p9_req_t *req) argument 259 * @req: request to be issued 264 p9_virtio_request(struct p9_client *client, struct p9_req_t *req) argument 274 req->status = REQ_STATUS_SENT; 281 VIRTQUEUE_NUM, req->tc->sdata, req 364 p9_virtio_zc_request(struct p9_client *client, struct p9_req_t *req, char *uidata, char *uodata, int inlen, int outlen, int in_hdr_len, int kern_buf) argument [all...] |
/net/bluetooth/ |
H A D | a2mp.c | 127 struct a2mp_discov_req *req = (void *) skb->data; local 133 if (len < sizeof(*req)) 136 skb_pull(skb, sizeof(*req)); 138 ext_feat = le16_to_cpu(req->ext_feat); 140 BT_DBG("mtu %d efm 0x%4.4x", le16_to_cpu(req->mtu), ext_feat); 212 struct a2mp_info_req req; local 215 req.id = cl->id; 217 sizeof(req), &req); 272 struct a2mp_info_req *req local 308 struct a2mp_amp_assoc_req req; local 334 struct a2mp_amp_assoc_req *req = (void *) skb->data; local 438 struct a2mp_physlink_req *req = (void *) skb->data; local 518 struct a2mp_physlink_req *req = (void *) skb->data; local 925 struct a2mp_physlink_req *req; local 988 struct a2mp_discov_req req; local [all...] |
H A D | hci_conn.c | 861 struct hci_conn_list_req req, *cl; local 866 if (copy_from_user(&req, arg, sizeof(req))) 869 if (!req.conn_num || req.conn_num > (PAGE_SIZE * 2) / sizeof(*ci)) 872 size = sizeof(req) + req.conn_num * sizeof(*ci); 878 hdev = hci_dev_get(req.dev_id); 903 if (++n >= req.conn_num) 910 size = sizeof(req) 922 struct hci_conn_info_req req; local 959 struct hci_auth_info_req req; local [all...] |
H A D | hci_core.c | 141 struct hci_request req; local 146 hci_req_init(&req, hdev); 148 hci_req_add_ev(&req, opcode, plen, param, event); 152 err = hci_req_run(&req, hci_req_sync_complete); 200 void (*func)(struct hci_request *req, 204 struct hci_request req; local 210 hci_req_init(&req, hdev); 214 func(&req, opt); 216 err = hci_req_run(&req, hci_req_sync_complete); 263 void (*req)(struc 199 __hci_req_sync(struct hci_dev *hdev, void (*func)(struct hci_request *req, unsigned long opt), unsigned long opt, __u32 timeout) argument 262 hci_req_sync(struct hci_dev *hdev, void (*req)(struct hci_request *req, unsigned long opt), unsigned long opt, __u32 timeout) argument 280 hci_reset_req(struct hci_request *req, unsigned long opt) argument 289 bredr_init(struct hci_request *req) argument 303 amp_init(struct hci_request *req) argument 317 hci_init1_req(struct hci_request *req, unsigned long opt) argument 342 bredr_setup(struct hci_request *req) argument 374 le_setup(struct hci_request *req) argument 426 hci_setup_inquiry_mode(struct hci_request *req) argument 435 hci_setup_event_mask(struct hci_request *req) argument 504 hci_init2_req(struct hci_request *req, unsigned long opt) argument 555 hci_setup_link_policy(struct hci_request *req) argument 574 hci_set_le_support(struct hci_request *req) argument 595 hci_init3_req(struct hci_request *req, unsigned long opt) argument 650 hci_scan_req(struct hci_request *req, unsigned long opt) argument 660 hci_auth_req(struct hci_request *req, unsigned long opt) argument 670 hci_encrypt_req(struct hci_request *req, unsigned long opt) argument 680 hci_linkpol_req(struct hci_request *req, unsigned long opt) argument 924 hci_inq_req(struct hci_request *req, unsigned long opt) argument 1081 hci_update_ad(struct hci_request *req) argument 1994 le_scan_param_req(struct hci_request *req, unsigned long opt) argument 2007 le_scan_enable_req(struct hci_request *req, unsigned long opt) argument 2585 hci_req_init(struct hci_request *req, struct hci_dev *hdev) argument 2592 hci_req_run(struct hci_request *req, hci_req_complete_t complete) argument 2676 hci_req_add_ev(struct hci_request *req, u16 opcode, u32 plen, const void *param, u8 event) argument 2706 hci_req_add(struct hci_request *req, u16 opcode, u32 plen, const void *param) argument [all...] |
H A D | hci_event.c | 930 struct hci_request req; local 932 hci_req_init(&req, hdev); 933 hci_update_ad(&req); 934 hci_req_run(&req, NULL); 1326 /* If successful wait for the name req complete event before 2436 (hdev->sent_cmd && !bt_cb(hdev->sent_cmd)->req.event)) 3704 if (hdev->sent_cmd && bt_cb(hdev->sent_cmd)->req.event == event) {
|
H A D | hci_sock.c | 860 bt_cb(skb)->req.start = true;
|
H A D | l2cap_core.c | 1033 struct l2cap_conn_req req; local 1035 req.scid = cpu_to_le16(chan->scid); 1036 req.psm = chan->psm; 1042 l2cap_send_cmd(conn, chan->ident, L2CAP_CONN_REQ, sizeof(req), &req); 1047 struct l2cap_create_chan_req req; local 1048 req.scid = cpu_to_le16(chan->scid); 1049 req.psm = chan->psm; 1050 req.amp_id = amp_id; 1055 sizeof(req), 1154 struct l2cap_info_req req; local 1187 struct l2cap_disconn_req req; local 3148 struct l2cap_conf_req *req = data; local 3268 void *req = chan->conf_req; local 3481 struct l2cap_conf_req *req = data; local 3711 struct l2cap_conn_req *req = (struct l2cap_conn_req *) data; local 3866 u8 req[128]; local 3963 struct l2cap_conf_req *req = (struct l2cap_conf_req *) data; local 4129 char req[64]; local 4188 struct l2cap_disconn_req *req = (struct l2cap_disconn_req *) data; local 4278 struct l2cap_info_req *req = (struct l2cap_info_req *) data; local 4365 struct l2cap_info_req req; local 4396 struct l2cap_create_chan_req *req = data; local 4468 struct l2cap_move_chan_req req; local 4819 struct l2cap_move_chan_req *req = data; local 5158 struct l2cap_conn_param_update_req *req; local [all...] |
H A D | mgmt.c | 597 static void update_eir(struct hci_request *req) argument 599 struct hci_dev *hdev = req->hdev; 623 hci_req_add(req, HCI_OP_WRITE_EIR, sizeof(cp), &cp); 637 static void update_class(struct hci_request *req) argument 639 struct hci_dev *hdev = req->hdev; 657 hci_req_add(req, HCI_OP_WRITE_CLASS_OF_DEV, sizeof(cod), cod); 664 struct hci_request req; local 669 hci_req_init(&req, hdev); 673 update_eir(&req); 674 update_class(&req); 1002 write_fast_connectable(struct hci_request *req, bool enable) argument 1059 struct hci_request req; local 1483 struct hci_request req; local 1565 struct hci_request req; local 1648 struct hci_request req; local 2440 update_name(struct hci_request *req) argument 2483 struct hci_request req; local 2923 struct hci_request req; local 2991 struct hci_request req; local 3303 set_bredr_scan(struct hci_request *req) argument 3343 struct hci_request req; local 3869 clear_eir(struct hci_request *req) argument 3887 struct hci_request req; local [all...] |
H A D | smp.c | 216 struct smp_cmd_pairing *req, 230 req->io_capability = conn->hcon->io_capability; 231 req->oob_flag = SMP_OOB_NOT_PRESENT; 232 req->max_key_size = SMP_MAX_ENC_KEY_SIZE; 233 req->init_key_dist = 0; 234 req->resp_key_dist = dist_keys; 235 req->auth_req = (authreq & AUTH_REQ_MASK); 243 rsp->resp_key_dist = req->resp_key_dist & dist_keys; 571 struct smp_cmd_pairing rsp, *req = (void *) skb->data; local 591 memcpy(&smp->preq[1], req, sizeo 215 build_pairing_cmd(struct l2cap_conn *conn, struct smp_cmd_pairing *req, struct smp_cmd_pairing *rsp, __u8 authreq) argument 625 struct smp_cmd_pairing *req, *rsp = (void *) skb->data; local 935 struct smp_cmd_pairing *req, *rsp; local [all...] |
/net/bluetooth/bnep/ |
H A D | bnep.h | 146 int bnep_add_connection(struct bnep_connadd_req *req, struct socket *sock); 147 int bnep_del_connection(struct bnep_conndel_req *req); 148 int bnep_get_connlist(struct bnep_connlist_req *req);
|
H A D | core.c | 533 int bnep_add_connection(struct bnep_connadd_req *req, struct socket *sock) argument 547 (*req->device) ? req->device : "bnep%d", 570 s->role = req->role; 606 strcpy(req->device, dev->name); 615 int bnep_del_connection(struct bnep_conndel_req *req) argument 624 s = __bnep_get_session(req->dst); 645 int bnep_get_connlist(struct bnep_connlist_req *req) argument 657 if (copy_to_user(req->ci, &ci, sizeof(ci))) { 662 if (++n >= req [all...] |
/net/bluetooth/cmtp/ |
H A D | cmtp.h | 61 int cmtp_add_connection(struct cmtp_connadd_req *req, struct socket *sock); 62 int cmtp_del_connection(struct cmtp_conndel_req *req); 63 int cmtp_get_connlist(struct cmtp_connlist_req *req);
|
H A D | core.c | 330 int cmtp_add_connection(struct cmtp_connadd_req *req, struct socket *sock) argument 372 session->flags = req->flags; 407 int cmtp_del_connection(struct cmtp_conndel_req *req) argument 416 session = __cmtp_get_session(&req->bdaddr); 431 int cmtp_get_connlist(struct cmtp_connlist_req *req) argument 445 if (copy_to_user(req->ci, &ci, sizeof(ci))) { 450 if (++n >= req->cnum) 453 req->ci++; 455 req->cnum = n;
|
/net/bluetooth/hidp/ |
H A D | core.c | 615 struct hidp_connadd_req *req) 631 input->id.vendor = req->vendor; 632 input->id.product = req->product; 633 input->id.version = req->version; 635 if (req->subclass & 0x40) { 651 if (req->subclass & 0x80) { 725 struct hidp_connadd_req *req) 730 session->rd_data = kzalloc(req->rd_size, GFP_KERNEL); 734 if (copy_from_user(session->rd_data, req->rd_data, req 614 hidp_setup_input(struct hidp_session *session, struct hidp_connadd_req *req) argument 724 hidp_setup_hid(struct hidp_session *session, struct hidp_connadd_req *req) argument 787 hidp_session_dev_init(struct hidp_session *session, struct hidp_connadd_req *req) argument 861 hidp_session_new(struct hidp_session **out, const bdaddr_t *bdaddr, struct socket *ctrl_sock, struct socket *intr_sock, struct hidp_connadd_req *req, struct l2cap_conn *conn) argument 1262 hidp_connection_add(struct hidp_connadd_req *req, struct socket *ctrl_sock, struct socket *intr_sock) argument 1304 hidp_connection_del(struct hidp_conndel_req *req) argument 1325 hidp_get_connlist(struct hidp_connlist_req *req) argument [all...] |
H A D | hidp.h | 124 int hidp_connection_add(struct hidp_connadd_req *req, struct socket *ctrl_sock, struct socket *intr_sock); 125 int hidp_connection_del(struct hidp_conndel_req *req); 126 int hidp_get_connlist(struct hidp_connlist_req *req);
|
/net/bluetooth/rfcomm/ |
H A D | tty.c | 181 static int rfcomm_dev_add(struct rfcomm_dev_req *req, struct rfcomm_dlc *dlc) argument 187 BT_DBG("id %d channel %d", req->dev_id, req->channel); 195 if (req->dev_id < 0) { 206 dev->id = req->dev_id; 230 bacpy(&dev->src, &req->src); 231 bacpy(&dev->dst, &req->dst); 232 dev->channel = req->channel; 234 dev->flags = req->flags & 245 if (req 369 struct rfcomm_dev_req req; local 411 struct rfcomm_dev_req req; local [all...] |
/net/caif/ |
H A D | cfctrl.c | 130 struct cfctrl_request_info *req) 134 req->sequence_no = atomic_read(&ctrl->req_seq_no); 135 list_add_tail(&req->list, &ctrl->list); 141 struct cfctrl_request_info *req) 148 if (cfctrl_req_eq(req, p)) { 207 struct cfctrl_request_info *req; local 274 req = kzalloc(sizeof(*req), GFP_KERNEL); 275 if (!req) 277 req 129 cfctrl_insert_req(struct cfctrl *ctrl, struct cfctrl_request_info *req) argument 140 cfctrl_remove_req(struct cfctrl *ctrl, struct cfctrl_request_info *req) argument 359 struct cfctrl_request_info rsp, *req; local [all...] |
/net/ceph/ |
H A D | auth_x.c | 452 struct ceph_x_service_ticket_request *req; local 464 req = p; 465 req->keys = cpu_to_le32(need); 466 p += sizeof(*req);
|
H A D | debugfs.c | 90 struct ceph_mon_generic_request *req; local 105 req = rb_entry(rp, struct ceph_mon_generic_request, node); 106 op = le16_to_cpu(req->request->hdr.type); 108 seq_printf(s, "%lld statfs\n", req->tid); 110 seq_printf(s, "%lld unknown\n", req->tid); 125 struct ceph_osd_request *req; local 129 req = rb_entry(p, struct ceph_osd_request, r_node); 131 seq_printf(s, "%lld\tosd%d\t%lld.%x\t", req->r_tid, 132 req->r_osd ? req [all...] |
H A D | mon_client.c | 391 struct ceph_mon_generic_request *req; local 395 req = rb_entry(n, struct ceph_mon_generic_request, node); 396 if (tid < req->tid) 398 else if (tid > req->tid) 401 return req; 411 struct ceph_mon_generic_request *req = NULL; local 415 req = rb_entry(parent, struct ceph_mon_generic_request, node); 416 if (new->tid < req->tid) 418 else if (new->tid > req->tid) 430 struct ceph_mon_generic_request *req local 441 put_generic_request(struct ceph_mon_generic_request *req) argument 446 get_generic_request(struct ceph_mon_generic_request *req) argument 456 struct ceph_mon_generic_request *req; local 480 do_generic_request(struct ceph_mon_client *monc, struct ceph_mon_generic_request *req) argument 512 struct ceph_mon_generic_request *req; local 544 struct ceph_mon_generic_request *req; local 604 struct ceph_mon_generic_request *req; local 644 struct ceph_mon_generic_request *req; local 709 struct ceph_mon_generic_request *req; local [all...] |
H A D | osd_client.c | 32 struct ceph_osd_request *req); 34 struct ceph_osd_request *req); 36 struct ceph_osd_request *req); 302 struct ceph_osd_request *req; local 305 req = container_of(kref, struct ceph_osd_request, r_kref); 306 if (req->r_request) 307 ceph_msg_put(req->r_request); 308 if (req->r_reply) { 309 ceph_msg_revoke_incoming(req->r_reply); 310 ceph_msg_put(req 331 struct ceph_osd_request *req; local 611 osd_req_encode_op(struct ceph_osd_request *req, struct ceph_osd_op *dst, unsigned int which) argument 710 struct ceph_osd_request *req; local 773 struct ceph_osd_request *req = NULL; local 793 struct ceph_osd_request *req; local 812 struct ceph_osd_request *req; local 836 struct ceph_osd_request *req, *nreq; local 1036 struct ceph_osd_request *req; local 1108 __register_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1126 __unregister_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1165 __cancel_request(struct ceph_osd_request *req) argument 1173 __register_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1183 __unregister_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1201 ceph_osdc_unregister_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1214 ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1239 __map_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, int force_resend) argument 1317 __send_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1356 struct ceph_osd_request *req, *tmp; local 1376 struct ceph_osd_request *req; local 1434 complete_request(struct ceph_osd_request *req) argument 1449 struct ceph_osd_request *req; local 1613 struct ceph_osd_request *req, *nreq; local 2018 ceph_osdc_build_request(struct ceph_osd_request *req, u64 off, struct ceph_snap_context *snapc, u64 snap_id, struct timespec *mtime) argument 2115 ceph_osdc_start_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, bool nofail) argument 2153 ceph_osdc_wait_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 2179 struct ceph_osd_request *req; local 2299 struct ceph_osd_request *req; local 2342 struct ceph_osd_request *req; local 2437 struct ceph_osd_request *req; local [all...] |
/net/core/ |
H A D | request_sock.c | 117 struct request_sock *req; local 119 while ((req = lopt->syn_table[i]) != NULL) { 120 lopt->syn_table[i] = req->dl_next; 122 reqsk_free(req); 144 * until 3WHS is either completed or aborted. Afterwards the req will stay 150 * When a child socket is accepted, its corresponding req->sk is set to 151 * NULL since it's no longer needed. More importantly, "req->sk == NULL" 157 * with its socket lock held. But a request_sock (req) can be accessed by 175 * When a TFO req is created, it needs to sock_hold its listener to prevent 182 void reqsk_fastopen_remove(struct sock *sk, struct request_sock *req, argument [all...] |