int ptlrpc_check_bulk_sent(struct ptlrpc_bulk_desc *);
int ptlrpc_send_bulk(struct ptlrpc_bulk_desc *, int portal);
int ptl_send_buf(struct ptlrpc_request *, struct lustre_peer *, int portal);
-int ptlrpc_wait_bulk(struct ptlrpc_bulk_desc *);
+int ptlrpc_register_bulk(struct ptlrpc_bulk_desc *);
int ptlrpc_reply(struct obd_device *obddev, struct ptlrpc_service *svc,
struct ptlrpc_request *req);
int ptlrpc_error(struct obd_device *obddev, struct ptlrpc_service *svc,
bulk->b_buflen = PAGE_SIZE;
bulk->b_buf = (void *)(long)niobuf.addr;
bulk->b_portal = MDS_BULK_PORTAL;
+ bulk->b_xid = request->rq_xid;
- spin_lock(&cl->cli_lock);
- bulk->b_xid = cl->cli_xid++;
- spin_unlock(&cl->cli_lock);
-
- rc = ptlrpc_wait_bulk(bulk);
+ rc = ptlrpc_register_bulk(bulk);
if (rc) {
CERROR("%s: couldn't setup bulk sink: error %d.\n",
__FUNCTION__, rc);
*(__u32 *)ptr2 = bulk[n]->b_xid;
ptr2 = (char *)ptr2 + sizeof(__u32);
- rc = ptlrpc_wait_bulk(bulk[n]);
+ rc = ptlrpc_register_bulk(bulk[n]);
if (rc)
goto out;
}
bulk_vec[i]->b_buf = (void *)(unsigned long)dst->addr;
bulk_vec[i]->b_buflen = PAGE_SIZE;
bulk_vec[i]->b_portal = OSC_BULK_PORTAL;
- rc = ptlrpc_wait_bulk(bulk_vec[i]);
+ rc = ptlrpc_register_bulk(bulk_vec[i]);
if (rc)
goto out;
return rc;
}
-int ptlrpc_wait_bulk(struct ptlrpc_bulk_desc *bulk)
+int ptlrpc_register_bulk(struct ptlrpc_bulk_desc *bulk)
{
int rc;
CDEBUG(D_NET, "Setup bulk sink buffer: %u bytes, xid %u, portal %u\n",
bulk->b_buflen, bulk->b_xid, bulk->b_portal);
+ EXIT;
+ return 0;
cleanup2:
+ EXIT;
PtlMEUnlink(bulk->b_me_h);
cleanup1:
PtlMDUnlink(bulk->b_md_h);
-
+ EXIT;
return rc;
}
EOF
mkdir /mnt/obd
-# mount -t lustre_light -o device=3 none /mnt/obd
+mount -t lustre_light -o device=3 none /mnt/obd