| /drivers/staging/lustre/lnet/selftest/ |
| H A D | Makefile | 3 lnet_selftest-y := console.o conrpc.o conctl.o framework.o timer.o rpc.o \
|
| H A D | brw_test.c | 261 srpc_client_rpc_t *rpc; local
293 rc = sfw_create_test_rpc(tsu, dest, sn->sn_features, npg, len, &rpc);
297 memcpy(&rpc->crpc_bulk, bulk, offsetof(srpc_bulk_t, bk_iovs[npg]));
299 brw_fill_bulk(&rpc->crpc_bulk, flags, BRW_MAGIC);
301 brw_fill_bulk(&rpc->crpc_bulk, flags, BRW_POISON);
303 req = &rpc->crpc_reqstmsg.msg_body.brw_reqst;
308 *rpcpp = rpc;
313 brw_client_done_rpc(sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc) argument
318 srpc_msg_t *msg = &rpc->crpc_replymsg;
320 srpc_brw_reqst_t *reqst = &rpc
362 brw_server_rpc_done(srpc_server_rpc_t *rpc) argument
382 brw_bulk_ready(srpc_server_rpc_t *rpc, int status) argument
418 brw_server_handle(struct srpc_server_rpc *rpc) argument
[all...] |
| H A D | conrpc.c | 54 lstcon_rpc_done(srpc_client_rpc_t *rpc) argument
56 lstcon_rpc_t *crpc = (lstcon_rpc_t *)rpc->crpc_priv;
58 LASSERT(crpc != NULL && rpc == crpc->crp_rpc);
61 spin_lock(&rpc->crpc_lock);
66 spin_unlock(&rpc->crpc_lock);
81 crpc->crp_status = rpc->crpc_status;
88 spin_unlock(&rpc->crpc_lock);
288 srpc_client_rpc_t *rpc; local
293 rpc = crpc->crp_rpc;
295 spin_lock(&rpc
390 srpc_client_rpc_t *rpc = crpc->crp_rpc; local
546 srpc_client_rpc_t *rpc; local
1089 lstcon_rpc_t *rpc; local
[all...] |
| H A D | console.c | 1827 /* User can do nothing even rpc failed, so go on */
1897 lstcon_acceptor_handle (srpc_server_rpc_t *rpc) argument
1899 srpc_msg_t *rep = &rpc->srpc_replymsg;
1900 srpc_msg_t *req = &rpc->srpc_reqstbuf->buf_msg;
1947 rc = lstcon_group_ndlink_find(grp, rpc->srpc_peer, &ndl, 0);
1953 rc = lstcon_group_ndlink_find(grp, rpc->srpc_peer, &ndl, 1);
|
| H A D | framework.c | 54 MODULE_PARM_DESC(rpc_timeout, "rpc timeout in seconds (64 by default, 0 == never)");
288 sfw_server_rpc_done(struct srpc_server_rpc *rpc) argument
290 struct srpc_service *sv = rpc->srpc_scd->scd_svc;
291 int status = rpc->srpc_status;
296 sv->sv_name, libcfs_id2str(rpc->srpc_peer),
297 swi_state2str(rpc->srpc_wi.swi_state),
300 if (rpc->srpc_bulk != NULL)
301 sfw_free_pages(rpc);
306 sfw_client_rpc_fini (srpc_client_rpc_t *rpc) argument
308 LASSERT (rpc
536 sfw_test_rpc_fini(srpc_client_rpc_t *rpc) argument
615 srpc_client_rpc_t *rpc; local
731 sfw_add_test_instance(sfw_batch_t *tsb, srpc_server_rpc_t *rpc) argument
869 sfw_test_rpc_done(srpc_client_rpc_t *rpc) argument
909 srpc_client_rpc_t *rpc = NULL; local
952 srpc_client_rpc_t *rpc = NULL; local
1037 srpc_client_rpc_t *rpc; local
1100 sfw_free_pages(srpc_server_rpc_t *rpc) argument
1107 sfw_alloc_pages(struct srpc_server_rpc *rpc, int cpt, int npages, int len, int sink) argument
1121 sfw_add_test(srpc_server_rpc_t *rpc) argument
1232 sfw_handle_server_rpc(struct srpc_server_rpc *rpc) argument
1338 sfw_bulk_ready(struct srpc_server_rpc *rpc, int status) argument
1390 srpc_client_rpc_t *rpc = NULL; local
1567 sfw_abort_rpc(srpc_client_rpc_t *rpc) argument
1579 sfw_post_rpc(srpc_client_rpc_t *rpc) argument
1783 srpc_client_rpc_t *rpc; local
[all...] |
| H A D | ping_test.c | 90 lnet_process_id_t dest, srpc_client_rpc_t **rpc)
101 rc = sfw_create_test_rpc(tsu, dest, sn->sn_features, 0, 0, rpc);
105 req = &(*rpc)->crpc_reqstmsg.msg_body.ping_reqst;
121 ping_client_done_rpc (sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc) argument
125 srpc_ping_reqst_t *reqst = &rpc->crpc_reqstmsg.msg_body.ping_reqst;
126 srpc_ping_reply_t *reply = &rpc->crpc_replymsg.msg_body.ping_reply;
131 if (rpc->crpc_status != 0) {
132 if (!tsi->tsi_stopping) /* rpc could have been aborted */
135 libcfs_id2str(rpc->crpc_dest),
136 reqst->pnr_seq, rpc
89 ping_client_prep_rpc(sfw_test_unit_t *tsu, lnet_process_id_t dest, srpc_client_rpc_t **rpc) argument
172 ping_server_handle(struct srpc_server_rpc *rpc) argument
[all...] |
| H A D | rpc.c | 36 * lnet/selftest/rpc.c
174 srpc_init_server_rpc(struct srpc_server_rpc *rpc, argument
178 memset(rpc, 0, sizeof(*rpc));
179 swi_init_workitem(&rpc->srpc_wi, rpc, srpc_handle_rpc,
183 rpc->srpc_ev.ev_fired = 1; /* no event expected now */
185 rpc->srpc_scd = scd;
186 rpc->srpc_reqstbuf = buffer;
187 rpc
196 struct srpc_server_rpc *rpc; local
252 struct srpc_server_rpc *rpc; local
655 struct srpc_server_rpc *rpc; local
734 struct srpc_server_rpc *rpc; local
759 struct srpc_server_rpc *rpc; local
791 srpc_send_request(srpc_client_rpc_t *rpc) argument
811 srpc_prepare_reply(srpc_client_rpc_t *rpc) argument
835 srpc_prepare_bulk(srpc_client_rpc_t *rpc) argument
867 srpc_do_bulk(srpc_server_rpc_t *rpc) argument
895 srpc_server_rpc_done(srpc_server_rpc_t *rpc, int status) argument
960 struct srpc_server_rpc *rpc = wi->swi_workitem.wi_data; local
1072 srpc_client_rpc_t *rpc = data; local
1091 srpc_add_client_rpc_timer(srpc_client_rpc_t *rpc) argument
1112 srpc_del_client_rpc_timer(srpc_client_rpc_t *rpc) argument
1133 srpc_client_rpc_done(srpc_client_rpc_t *rpc, int status) argument
1174 srpc_client_rpc_t *rpc; local
1302 srpc_client_rpc_t *rpc; local
1316 srpc_abort_rpc(srpc_client_rpc_t *rpc, int why) argument
1337 srpc_post_rpc(srpc_client_rpc_t *rpc) argument
1353 srpc_send_reply(struct srpc_server_rpc *rpc) argument
[all...] |
| H A D | selftest.h | 52 #include "rpc.h"
236 #define srpc_client_rpc_size(rpc) \
237 offsetof(srpc_client_rpc_t, crpc_bulk.bk_iovs[(rpc)->crpc_bulk.bk_niov])
239 #define srpc_client_rpc_addref(rpc) \
242 (rpc), libcfs_id2str((rpc)->crpc_dest), \
243 atomic_read(&(rpc)->crpc_refcount)); \
244 LASSERT(atomic_read(&(rpc)->crpc_refcount) > 0); \
245 atomic_inc(&(rpc)->crpc_refcount); \
248 #define srpc_client_rpc_decref(rpc) \
502 srpc_destroy_client_rpc(srpc_client_rpc_t *rpc) argument
518 srpc_init_client_rpc(srpc_client_rpc_t *rpc, lnet_process_id_t peer, int service, int nbulkiov, int bulklen, void (*rpc_done)(srpc_client_rpc_t *), void (*rpc_fini)(srpc_client_rpc_t *), void *priv) argument
[all...] |
| /drivers/pci/pcie/aer/ |
| H A D | aerdrv.c | 118 * @rpc: pointer to a Root Port data structure
122 static void aer_enable_rootport(struct aer_rpc *rpc) argument
124 struct pci_dev *pdev = rpc->rpd->port;
160 * @rpc: pointer to a Root Port data structure
164 static void aer_disable_rootport(struct aer_rpc *rpc) argument
166 struct pci_dev *pdev = rpc->rpd->port;
198 struct aer_rpc *rpc = get_service_data(pdev); local
208 spin_lock_irqsave(&rpc->e_lock, flags);
213 spin_unlock_irqrestore(&rpc->e_lock, flags);
222 next_prod_idx = rpc
253 struct aer_rpc *rpc; local
281 struct aer_rpc *rpc = get_service_data(dev); local
306 struct aer_rpc *rpc; local
[all...] |
| H A D | aerdrv_core.c | 744 * @rpc: pointer to the root port which holds an error
751 static int get_e_source(struct aer_rpc *rpc, struct aer_err_source *e_src) argument
756 spin_lock_irqsave(&rpc->e_lock, flags);
757 if (rpc->prod_idx == rpc->cons_idx) {
758 spin_unlock_irqrestore(&rpc->e_lock, flags);
762 *e_src = rpc->e_sources[rpc->cons_idx];
763 rpc->cons_idx++;
764 if (rpc
779 struct aer_rpc *rpc = container_of(work, struct aer_rpc, dpc_handler); local
[all...] |
| /drivers/md/ |
| H A D | dm-era-target.c | 1165 struct rpc { struct
1278 struct rpc *rpc, *tmp; local
1285 list_for_each_entry_safe(rpc, tmp, &calls, list) {
1286 rpc->result = rpc->fn0 ? rpc->fn0(era->md) : rpc->fn1(era->md, rpc->arg);
1293 list_for_each_entry_safe(rpc, tm
1331 perform_rpc(struct era *era, struct rpc *rpc) argument
1348 struct rpc rpc; local
1358 struct rpc rpc; local
[all...] |
| /drivers/dma/ |
| H A D | imx-sdma.c | 163 * @rpc: return program counter
174 u32 rpc :14; member in struct:sdma_state_registers
|