| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | client.c | 50 static int ptlrpc_send_new_req(struct ptlrpc_request *req);
51 static int ptlrpcd_check_work(struct ptlrpc_request *req);
134 struct ptlrpc_bulk_desc *ptlrpc_prep_bulk_imp(struct ptlrpc_request *req, in ptlrpc_prep_bulk_imp() argument
138 struct obd_import *imp = req->rq_import; in ptlrpc_prep_bulk_imp()
146 desc->bd_import_generation = req->rq_import_generation; in ptlrpc_prep_bulk_imp()
148 desc->bd_req = req; in ptlrpc_prep_bulk_imp()
154 req->rq_bulk = desc; in ptlrpc_prep_bulk_imp()
217 void ptlrpc_at_set_req_timeout(struct ptlrpc_request *req) in ptlrpc_at_set_req_timeout() argument
223 LASSERT(req->rq_import); in ptlrpc_at_set_req_timeout()
234 req->rq_timeout = req->rq_import->imp_server_timeout ? in ptlrpc_at_set_req_timeout()
[all …]
|
| D | sec_null.c | 79 int null_ctx_sign(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in null_ctx_sign() argument
81 req->rq_reqbuf->lm_secflvr = SPTLRPC_FLVR_NULL; in null_ctx_sign()
83 if (!req->rq_import->imp_dlm_fake) { in null_ctx_sign()
84 struct obd_device *obd = req->rq_import->imp_obd; in null_ctx_sign()
85 null_encode_sec_part(req->rq_reqbuf, in null_ctx_sign()
88 req->rq_reqdata_len = req->rq_reqlen; in null_ctx_sign()
93 int null_ctx_verify(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in null_ctx_verify() argument
97 LASSERT(req->rq_repdata); in null_ctx_verify()
99 req->rq_repmsg = req->rq_repdata; in null_ctx_verify()
100 req->rq_replen = req->rq_repdata_len; in null_ctx_verify()
[all …]
|
| D | sec.c | 319 struct ptlrpc_request *req, *next; in sptlrpc_cli_ctx_wakeup() local
322 list_for_each_entry_safe(req, next, &ctx->cc_req_list, in sptlrpc_cli_ctx_wakeup()
324 list_del_init(&req->rq_ctx_chain); in sptlrpc_cli_ctx_wakeup()
325 ptlrpc_client_wake_req(req); in sptlrpc_cli_ctx_wakeup()
394 int sptlrpc_req_get_ctx(struct ptlrpc_request *req) in sptlrpc_req_get_ctx() argument
396 struct obd_import *imp = req->rq_import; in sptlrpc_req_get_ctx()
400 LASSERT(!req->rq_cli_ctx); in sptlrpc_req_get_ctx()
407 req->rq_cli_ctx = get_my_ctx(sec); in sptlrpc_req_get_ctx()
411 if (!req->rq_cli_ctx) { in sptlrpc_req_get_ctx()
412 CERROR("req %p: fail to get context\n", req); in sptlrpc_req_get_ctx()
[all …]
|
| D | sec_plain.c | 191 int plain_ctx_sign(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in plain_ctx_sign() argument
193 struct lustre_msg *msg = req->rq_reqbuf; in plain_ctx_sign()
196 msg->lm_secflvr = req->rq_flvr.sf_rpc; in plain_ctx_sign()
202 phdr->ph_bulk_hash_alg = req->rq_flvr.u_bulk.hash.hash_alg; in plain_ctx_sign()
204 if (req->rq_pack_udesc) in plain_ctx_sign()
206 if (req->rq_pack_bulk) in plain_ctx_sign()
209 req->rq_reqdata_len = lustre_msg_size_v2(msg->lm_bufcount, in plain_ctx_sign()
215 int plain_ctx_verify(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in plain_ctx_verify() argument
217 struct lustre_msg *msg = req->rq_repdata; in plain_ctx_verify()
227 swabbed = ptlrpc_rep_need_swab(req); in plain_ctx_verify()
[all …]
|
| D | events.c | 57 struct ptlrpc_request *req = cbid->cbid_arg; in request_out_callback() local
63 DEBUG_REQ(D_NET, req, "type %d, status %d", ev->type, ev->status); in request_out_callback()
65 sptlrpc_request_out_callback(req); in request_out_callback()
66 spin_lock(&req->rq_lock); in request_out_callback()
67 req->rq_real_sent = get_seconds(); in request_out_callback()
69 req->rq_req_unlink = 0; in request_out_callback()
76 req->rq_net_err = 1; in request_out_callback()
77 ptlrpc_client_wake_req(req); in request_out_callback()
79 spin_unlock(&req->rq_lock); in request_out_callback()
81 ptlrpc_req_finished(req); in request_out_callback()
[all …]
|
| D | niobuf.c | 114 int ptlrpc_register_bulk(struct ptlrpc_request *req) in ptlrpc_register_bulk() argument
116 struct ptlrpc_bulk_desc *desc = req->rq_bulk; in ptlrpc_register_bulk()
139 if (req->rq_resend || req->rq_send_state == LUSTRE_IMP_REPLAY) in ptlrpc_register_bulk()
158 xid = req->rq_xid & ~((__u64)desc->bd_md_max_brw - 1); in ptlrpc_register_bulk()
160 req->rq_send_state != LUSTRE_IMP_REPLAY) || in ptlrpc_register_bulk()
208 req->rq_status = -ENOMEM; in ptlrpc_register_bulk()
214 req->rq_xid = --xid; in ptlrpc_register_bulk()
215 LASSERTF(desc->bd_last_xid == (req->rq_xid & PTLRPC_BULK_OPS_MASK), in ptlrpc_register_bulk()
217 desc->bd_last_xid, req->rq_xid); in ptlrpc_register_bulk()
231 desc->bd_last_xid, req->rq_xid, desc->bd_portal); in ptlrpc_register_bulk()
[all …]
|
| /drivers/macintosh/ |
| D | via-pmu68k.c | 106 static int pmu_send_request(struct adb_request *req, int sync);
114 static void pmu_done(struct adb_request *req);
192 volatile struct adb_request req; in pmu_init() local
197 pmu_request((struct adb_request *) &req, NULL, 2, PMU_SET_INTR_MASK, PMU_INT_ADB); in pmu_init()
199 while (!req.complete) { in pmu_init()
224 pmu_request((struct adb_request *) &req, NULL, 2, PMU_SET_INTR_MASK, in pmu_init()
227 while (!req.complete) { in pmu_init()
272 pmu_send_request(struct adb_request *req, int sync) in pmu_send_request() argument
278 req->complete = 1; in pmu_send_request()
284 switch (req->data[0]) { in pmu_send_request()
[all …]
|
| D | adb-iop.c | 66 static void adb_iop_end_req(struct adb_request *req, int state) in adb_iop_end_req() argument
68 req->complete = 1; in adb_iop_end_req()
69 current_req = req->next; in adb_iop_end_req()
70 if (req->done) (*req->done)(req); in adb_iop_end_req()
82 struct adb_request *req; in adb_iop_complete() local
87 req = current_req; in adb_iop_complete()
88 if ((adb_iop_state == sending) && req && req->reply_expected) { in adb_iop_complete()
105 struct adb_request *req; in adb_iop_listen() local
113 req = current_req; in adb_iop_listen()
116 printk("adb_iop_listen %p: rcvd packet, %d bytes: %02X %02X", req, in adb_iop_listen()
[all …]
|
| D | via-pmu.c | 184 static int pmu_send_request(struct adb_request *req, int sync);
216 int pmu_polled_request(struct adb_request *req);
528 struct adb_request req; in init_pmu() local
533 pmu_request(&req, NULL, 2, PMU_SET_INTR_MASK, pmu_intr_mask); in init_pmu()
535 while (!req.complete) { in init_pmu()
560 pmu_request(&req, NULL, 2, PMU_SYSTEM_READY, 2); in init_pmu()
561 while (!req.complete) in init_pmu()
566 pmu_request(&req, NULL, 1, PMU_GET_VERSION); in init_pmu()
567 pmu_wait_complete(&req); in init_pmu()
568 if (req.reply_len > 0) in init_pmu()
[all …]
|
| D | via-macii.c | 86 static int macii_send_request(struct adb_request *req, int sync);
87 static int macii_write(struct adb_request *req);
123 static int request_is_queued(struct adb_request *req) { in request_is_queued() argument
129 if (cur == req) { in request_is_queued()
205 static struct adb_request req; in macii_queue_poll() local
215 BUG_ON(request_is_queued(&req)); in macii_queue_poll()
217 adb_request(&req, NULL, ADBREQ_NOSEND, 1, in macii_queue_poll()
220 req.sent = 0; in macii_queue_poll()
221 req.complete = 0; in macii_queue_poll()
222 req.reply_len = 0; in macii_queue_poll()
[all …]
|
| D | via-cuda.c | 91 static int cuda_send_request(struct adb_request *req, int sync);
101 static int cuda_write(struct adb_request *req);
103 int cuda_request(struct adb_request *req,
120 struct adb_request req; in find_via_cuda() local
137 cuda_request(&req, NULL, 3, CUDA_PACKET, CUDA_AUTOPOLL, 1); in find_via_cuda()
138 while (!req.complete) in find_via_cuda()
146 struct adb_request req; in find_via_cuda() local
190 cuda_request(&req, NULL, 3, CUDA_PACKET, CUDA_AUTOPOLL, 1); in find_via_cuda()
191 while (!req.complete) in find_via_cuda()
307 cuda_send_request(struct adb_request *req, int sync) in cuda_send_request() argument
[all …]
|
| D | via-maciisi.c | 82 static int maciisi_send_request(struct adb_request* req, int sync);
83 static void maciisi_sync(struct adb_request *req);
84 static int maciisi_write(struct adb_request* req);
229 maciisi_send_request(struct adb_request* req, int sync) in maciisi_send_request() argument
238 req->complete = 1; in maciisi_send_request()
245 for (i = 0; i < req->nbytes; i++) { in maciisi_send_request()
246 printk(" %.2x", req->data[i]); in maciisi_send_request()
252 req->reply_expected = 1; in maciisi_send_request()
254 i = maciisi_write(req); in maciisi_send_request()
271 maciisi_sync(req); in maciisi_send_request()
[all …]
|
| /drivers/s390/scsi/ |
| D | zfcp_fsf.c | 66 static void zfcp_fsf_class_not_supp(struct zfcp_fsf_req *req) in zfcp_fsf_class_not_supp() argument
68 dev_err(&req->adapter->ccw_device->dev, "FCP device not " in zfcp_fsf_class_not_supp()
70 zfcp_erp_adapter_shutdown(req->adapter, 0, "fscns_1"); in zfcp_fsf_class_not_supp()
71 req->status |= ZFCP_STATUS_FSFREQ_ERROR; in zfcp_fsf_class_not_supp()
78 void zfcp_fsf_req_free(struct zfcp_fsf_req *req) in zfcp_fsf_req_free() argument
80 if (likely(req->pool)) { in zfcp_fsf_req_free()
81 if (likely(req->qtcb)) in zfcp_fsf_req_free()
82 mempool_free(req->qtcb, req->adapter->pool.qtcb_pool); in zfcp_fsf_req_free()
83 mempool_free(req, req->pool); in zfcp_fsf_req_free()
87 if (likely(req->qtcb)) in zfcp_fsf_req_free()
[all …]
|
| /drivers/block/drbd/ |
| D | drbd_req.c | 37 static void _drbd_start_io_acct(struct drbd_device *device, struct drbd_request *req) in _drbd_start_io_acct() argument
39 const int rw = bio_data_dir(req->master_bio); in _drbd_start_io_acct()
44 part_stat_add(cpu, &device->vdisk->part0, sectors[rw], req->i.size >> 9); in _drbd_start_io_acct()
52 static void _drbd_end_io_acct(struct drbd_device *device, struct drbd_request *req) in _drbd_end_io_acct() argument
54 int rw = bio_data_dir(req->master_bio); in _drbd_end_io_acct()
55 unsigned long duration = jiffies - req->start_jif; in _drbd_end_io_acct()
67 struct drbd_request *req; in drbd_req_new() local
69 req = mempool_alloc(drbd_request_mempool, GFP_NOIO | __GFP_ZERO); in drbd_req_new()
70 if (!req) in drbd_req_new()
73 drbd_req_make_private_bio(req, bio_src); in drbd_req_new()
[all …]
|
| /drivers/video/fbdev/msm/ |
| D | mdp_ppp.c | 92 static void rotate_dst_addr_x(struct mdp_blit_req *req, struct mdp_regs *regs) in rotate_dst_addr_x() argument
94 regs->dst0 += (req->dst_rect.w - in rotate_dst_addr_x()
95 min((uint32_t)16, req->dst_rect.w)) * regs->dst_bpp; in rotate_dst_addr_x()
96 regs->dst1 += (req->dst_rect.w - in rotate_dst_addr_x()
97 min((uint32_t)16, req->dst_rect.w)) * regs->dst_bpp; in rotate_dst_addr_x()
100 static void rotate_dst_addr_y(struct mdp_blit_req *req, struct mdp_regs *regs) in rotate_dst_addr_y() argument
102 regs->dst0 += (req->dst_rect.h - in rotate_dst_addr_y()
103 min((uint32_t)16, req->dst_rect.h)) * in rotate_dst_addr_y()
105 regs->dst1 += (req->dst_rect.h - in rotate_dst_addr_y()
106 min((uint32_t)16, req->dst_rect.h)) * in rotate_dst_addr_y()
[all …]
|
| /drivers/s390/cio/ |
| D | ccwreq.c | 42 struct ccw_request *req = &cdev->private->req; in ccwreq_next_path() local
44 if (!req->singlepath) { in ccwreq_next_path()
45 req->mask = 0; in ccwreq_next_path()
48 req->retries = req->maxretries; in ccwreq_next_path()
49 req->mask = lpm_adjust(req->mask >> 1, req->lpm); in ccwreq_next_path()
51 return req->mask; in ccwreq_next_path()
59 struct ccw_request *req = &cdev->private->req; in ccwreq_stop() local
61 if (req->done) in ccwreq_stop()
63 req->done = 1; in ccwreq_stop()
66 if (rc && rc != -ENODEV && req->drc) in ccwreq_stop()
[all …]
|
| D | device_pgid.c | 57 struct ccw_request *req = &cdev->private->req; in nop_build_cp() local
64 req->cp = cp; in nop_build_cp()
73 struct ccw_request *req = &cdev->private->req; in nop_do() local
75 req->lpm = lpm_adjust(req->lpm, sch->schib.pmcw.pam & sch->opm & in nop_do()
77 if (!req->lpm) in nop_do()
105 struct ccw_request *req = &cdev->private->req; in nop_callback() local
109 sch->vpm |= req->lpm; in nop_callback()
112 cdev->private->path_noirq_mask |= req->lpm; in nop_callback()
115 cdev->private->path_notoper_mask |= req->lpm; in nop_callback()
121 req->lpm >>= 1; in nop_callback()
[all …]
|
| /drivers/staging/cptm1217/ |
| D | clearpad_tm1217.c | 137 u8 *req, int size) in cp_tm1217_read() argument
142 retval = i2c_master_send(ts->client, &req[0], 1); in cp_tm1217_read()
149 retval = i2c_master_recv(ts->client, &req[1], size); in cp_tm1217_read()
163 u8 *req, int size) in cp_tm1217_write() argument
168 retval = i2c_master_send(ts->client, &req[0], size + 1); in cp_tm1217_write()
181 u8 req[2]; in cp_tm1217_mask_interrupt() local
184 req[0] = TMA1217_INTERRUPT_ENABLE; in cp_tm1217_mask_interrupt()
185 req[1] = 0x0; in cp_tm1217_mask_interrupt()
186 retval = cp_tm1217_write(ts, req, 1); in cp_tm1217_mask_interrupt()
195 u8 req[2]; in cp_tm1217_unmask_interrupt() local
[all …]
|
| /drivers/staging/lustre/lustre/mdc/ |
| D | mdc_request.c | 63 int mdc_unpack_capa(struct obd_export *exp, struct ptlrpc_request *req, in mdc_unpack_capa() argument
70 capa = req_capsule_server_get(&req->rq_pill, field); in mdc_unpack_capa()
85 static inline int mdc_queue_wait(struct ptlrpc_request *req) in mdc_queue_wait() argument
87 struct client_obd *cli = &req->rq_import->imp_obd->u.cli; in mdc_queue_wait()
97 rc = ptlrpc_queue_wait(req); in mdc_queue_wait()
108 struct ptlrpc_request *req; in send_getstatus() local
112 req = ptlrpc_request_alloc_pack(imp, &RQF_MDS_GETSTATUS, in send_getstatus()
114 if (req == NULL) in send_getstatus()
117 mdc_pack_body(req, NULL, NULL, 0, 0, -1, 0); in send_getstatus()
118 lustre_msg_add_flags(req->rq_reqmsg, msg_flags); in send_getstatus()
[all …]
|
| D | mdc_reint.c | 108 struct ptlrpc_request *req; in mdc_setattr() local
124 req = ptlrpc_request_alloc(class_exp2cliimp(exp), in mdc_setattr()
126 if (req == NULL) { in mdc_setattr()
130 mdc_set_capa_size(req, &RMF_CAPA1, op_data->op_capa1); in mdc_setattr()
132 req_capsule_set_size(&req->rq_pill, &RMF_MDT_EPOCH, RCL_CLIENT, in mdc_setattr()
134 req_capsule_set_size(&req->rq_pill, &RMF_EADATA, RCL_CLIENT, ealen); in mdc_setattr()
135 req_capsule_set_size(&req->rq_pill, &RMF_LOGCOOKIES, RCL_CLIENT, in mdc_setattr()
138 rc = mdc_prep_elc_req(exp, req, MDS_REINT, &cancels, count); in mdc_setattr()
140 ptlrpc_request_free(req); in mdc_setattr()
151 mdc_setattr_pack(req, op_data, ea, ealen, ea2, ea2len); in mdc_setattr()
[all …]
|
| /drivers/staging/emxx_udc/ |
| D | emxx_udc.c | 187 udc->ep0_req.req.buf = p_buf; in _nbu2ss_create_ep0_packet()
188 udc->ep0_req.req.length = length; in _nbu2ss_create_ep0_packet()
189 udc->ep0_req.req.dma = 0; in _nbu2ss_create_ep0_packet()
190 udc->ep0_req.req.zero = TRUE; in _nbu2ss_create_ep0_packet()
191 udc->ep0_req.req.complete = _nbu2ss_ep0_complete; in _nbu2ss_create_ep0_packet()
192 udc->ep0_req.req.status = -EINPROGRESS; in _nbu2ss_create_ep0_packet()
193 udc->ep0_req.req.context = udc; in _nbu2ss_create_ep0_packet()
194 udc->ep0_req.req.actual = 0; in _nbu2ss_create_ep0_packet()
483 struct nbu2ss_req *req, in _nbu2ss_dma_map_single() argument
487 if (req->req.dma == DMA_ADDR_INVALID) { in _nbu2ss_dma_map_single()
[all …]
|
| /drivers/staging/lustre/lustre/lov/ |
| D | lov_request.c | 64 struct lov_request *req = list_entry(pos, in lov_finish_set() local
67 list_del_init(&req->rq_link); in lov_finish_set()
69 if (req->rq_oi.oi_oa) in lov_finish_set()
70 OBDO_FREE(req->rq_oi.oi_oa); in lov_finish_set()
71 if (req->rq_oi.oi_md) in lov_finish_set()
72 OBD_FREE_LARGE(req->rq_oi.oi_md, req->rq_buflen); in lov_finish_set()
73 if (req->rq_oi.oi_osfs) in lov_finish_set()
74 OBD_FREE(req->rq_oi.oi_osfs, in lov_finish_set()
75 sizeof(*req->rq_oi.oi_osfs)); in lov_finish_set()
76 OBD_FREE(req, sizeof(*req)); in lov_finish_set()
[all …]
|
| /drivers/base/power/ |
| D | qos.c | 137 static int apply_constraint(struct dev_pm_qos_request *req, in apply_constraint() argument
140 struct dev_pm_qos *qos = req->dev->power.qos; in apply_constraint()
143 switch(req->type) { in apply_constraint()
146 &req->data.pnode, action, value); in apply_constraint()
151 req); in apply_constraint()
156 &req->data.pnode, action, value); in apply_constraint()
159 req->dev->power.set_latency_tolerance(req->dev, value); in apply_constraint()
163 ret = pm_qos_update_flags(&qos->flags, &req->data.flr, in apply_constraint()
233 struct dev_pm_qos_request *req, *tmp; in dev_pm_qos_constraints_destroy() local
257 plist_for_each_entry_safe(req, tmp, &c->list, data.pnode) { in dev_pm_qos_constraints_destroy()
[all …]
|
| /drivers/media/usb/dvb-usb-v2/ |
| D | ec168.c | 28 static int ec168_ctrl_msg(struct dvb_usb_device *d, struct ec168_req *req) in ec168_ctrl_msg() argument
35 switch (req->cmd) { in ec168_ctrl_msg()
41 request = req->cmd; in ec168_ctrl_msg()
45 request = req->cmd; in ec168_ctrl_msg()
65 KBUILD_MODNAME, req->cmd); in ec168_ctrl_msg()
70 buf = kmalloc(req->size, GFP_KERNEL); in ec168_ctrl_msg()
78 memcpy(buf, req->data, req->size); in ec168_ctrl_msg()
87 ret = usb_control_msg(d->udev, pipe, request, requesttype, req->value, in ec168_ctrl_msg()
88 req->index, buf, req->size, EC168_USB_TIMEOUT); in ec168_ctrl_msg()
90 dvb_usb_dbg_usb_control_msg(d->udev, request, requesttype, req->value, in ec168_ctrl_msg()
[all …]
|
| /drivers/net/ethernet/emulex/benet/ |
| D | be_cmds.c | 891 struct be_cmd_req_eq_create *req; in be_cmd_eq_create() local
899 req = embedded_payload(wrb); in be_cmd_eq_create()
901 be_wrb_cmd_hdr_prepare(&req->hdr, CMD_SUBSYSTEM_COMMON, in be_cmd_eq_create()
902 OPCODE_COMMON_EQ_CREATE, sizeof(*req), wrb, in be_cmd_eq_create()
909 req->hdr.version = ver; in be_cmd_eq_create()
910 req->num_pages = cpu_to_le16(PAGES_4K_SPANNED(q_mem->va, q_mem->size)); in be_cmd_eq_create()
912 AMAP_SET_BITS(struct amap_eq_context, valid, req->context, 1); in be_cmd_eq_create()
914 AMAP_SET_BITS(struct amap_eq_context, size, req->context, 0); in be_cmd_eq_create()
915 AMAP_SET_BITS(struct amap_eq_context, count, req->context, in be_cmd_eq_create()
917 be_dws_cpu_to_le(req->context, sizeof(req->context)); in be_cmd_eq_create()
[all …]
|