Lines Matching refs:dr
1154 #define DRHASH(dr) XIDHASH((dr)->dr_xid) argument
1181 struct dupreq *dr; in svc_rdma_kdup() local
1192 dr = rdmadrhashtbl[XIDHASH(xid)]; in svc_rdma_kdup()
1193 while (dr != NULL) { in svc_rdma_kdup()
1194 if (dr->dr_xid == xid && in svc_rdma_kdup()
1195 dr->dr_proc == req->rq_proc && in svc_rdma_kdup()
1196 dr->dr_prog == req->rq_prog && in svc_rdma_kdup()
1197 dr->dr_vers == req->rq_vers && in svc_rdma_kdup()
1198 dr->dr_addr.len == req->rq_xprt->xp_rtaddr.len && in svc_rdma_kdup()
1199 bcmp((caddr_t)dr->dr_addr.buf, in svc_rdma_kdup()
1201 dr->dr_addr.len) == 0) { in svc_rdma_kdup()
1202 status = dr->dr_status; in svc_rdma_kdup()
1204 bcopy(dr->dr_resp.buf, res, size); in svc_rdma_kdup()
1206 *dupcachedp = (dr->dr_resfree != NULL); in svc_rdma_kdup()
1208 dr->dr_status = DUP_INPROGRESS; in svc_rdma_kdup()
1209 *drpp = dr; in svc_rdma_kdup()
1215 dr = dr->dr_chain; in svc_rdma_kdup()
1223 dr = kmem_alloc(sizeof (*dr), KM_NOSLEEP); in svc_rdma_kdup()
1224 if (dr == NULL) { in svc_rdma_kdup()
1228 dr->dr_resp.buf = NULL; in svc_rdma_kdup()
1229 dr->dr_resp.maxlen = 0; in svc_rdma_kdup()
1230 dr->dr_addr.buf = NULL; in svc_rdma_kdup()
1231 dr->dr_addr.maxlen = 0; in svc_rdma_kdup()
1233 dr->dr_next = rdmadrmru->dr_next; in svc_rdma_kdup()
1234 rdmadrmru->dr_next = dr; in svc_rdma_kdup()
1236 dr->dr_next = dr; in svc_rdma_kdup()
1240 dr = rdmadrmru->dr_next; in svc_rdma_kdup()
1241 while (dr->dr_status == DUP_INPROGRESS) { in svc_rdma_kdup()
1242 dr = dr->dr_next; in svc_rdma_kdup()
1243 if (dr == rdmadrmru->dr_next) { in svc_rdma_kdup()
1248 unhash(dr); in svc_rdma_kdup()
1249 if (dr->dr_resfree) { in svc_rdma_kdup()
1250 (*dr->dr_resfree)(dr->dr_resp.buf); in svc_rdma_kdup()
1253 dr->dr_resfree = NULL; in svc_rdma_kdup()
1254 rdmadrmru = dr; in svc_rdma_kdup()
1256 dr->dr_xid = REQTOXID(req); in svc_rdma_kdup()
1257 dr->dr_prog = req->rq_prog; in svc_rdma_kdup()
1258 dr->dr_vers = req->rq_vers; in svc_rdma_kdup()
1259 dr->dr_proc = req->rq_proc; in svc_rdma_kdup()
1260 if (dr->dr_addr.maxlen < req->rq_xprt->xp_rtaddr.len) { in svc_rdma_kdup()
1261 if (dr->dr_addr.buf != NULL) in svc_rdma_kdup()
1262 kmem_free(dr->dr_addr.buf, dr->dr_addr.maxlen); in svc_rdma_kdup()
1263 dr->dr_addr.maxlen = req->rq_xprt->xp_rtaddr.len; in svc_rdma_kdup()
1264 dr->dr_addr.buf = kmem_alloc(dr->dr_addr.maxlen, KM_NOSLEEP); in svc_rdma_kdup()
1265 if (dr->dr_addr.buf == NULL) { in svc_rdma_kdup()
1266 dr->dr_addr.maxlen = 0; in svc_rdma_kdup()
1267 dr->dr_status = DUP_DROP; in svc_rdma_kdup()
1272 dr->dr_addr.len = req->rq_xprt->xp_rtaddr.len; in svc_rdma_kdup()
1273 bcopy(req->rq_xprt->xp_rtaddr.buf, dr->dr_addr.buf, dr->dr_addr.len); in svc_rdma_kdup()
1274 if (dr->dr_resp.maxlen < size) { in svc_rdma_kdup()
1275 if (dr->dr_resp.buf != NULL) in svc_rdma_kdup()
1276 kmem_free(dr->dr_resp.buf, dr->dr_resp.maxlen); in svc_rdma_kdup()
1277 dr->dr_resp.maxlen = (unsigned int)size; in svc_rdma_kdup()
1278 dr->dr_resp.buf = kmem_alloc(size, KM_NOSLEEP); in svc_rdma_kdup()
1279 if (dr->dr_resp.buf == NULL) { in svc_rdma_kdup()
1280 dr->dr_resp.maxlen = 0; in svc_rdma_kdup()
1281 dr->dr_status = DUP_DROP; in svc_rdma_kdup()
1286 dr->dr_status = DUP_INPROGRESS; in svc_rdma_kdup()
1288 drhash = (uint32_t)DRHASH(dr); in svc_rdma_kdup()
1289 dr->dr_chain = rdmadrhashtbl[drhash]; in svc_rdma_kdup()
1290 rdmadrhashtbl[drhash] = dr; in svc_rdma_kdup()
1293 *drpp = dr; in svc_rdma_kdup()
1302 svc_rdma_kdupdone(struct dupreq *dr, caddr_t res, void (*dis_resfree)(), in svc_rdma_kdupdone() argument
1305 ASSERT(dr->dr_resfree == NULL); in svc_rdma_kdupdone()
1307 bcopy(res, dr->dr_resp.buf, size); in svc_rdma_kdupdone()
1308 dr->dr_resfree = dis_resfree; in svc_rdma_kdupdone()
1310 dr->dr_status = status; in svc_rdma_kdupdone()
1317 unhash(struct dupreq *dr) in unhash() argument
1325 drhash = (uint32_t)DRHASH(dr); in unhash()
1328 if (drt == dr) { in unhash()