include/ccKVS/inline_util.h
static inline void refill_recvs(uint16_t rem_req_i, struct ibv_recv_wr* rem_recv_wr, struct hrd_ctrl_blk* cb)
{
	if (rem_req_i > 0) {
		if (ENABLE_ASSERTIONS == 1) assert(rem_req_i <= WINDOW_SIZE);
		int i;
		struct ibv_recv_wr *bad_recv_wr;
		for(i = 0; i < rem_req_i; i++)
			rem_recv_wr[i].next = (i == rem_req_i - 1) ?
								  NULL : &rem_recv_wr[i + 1];
		int ret = ibv_post_recv(cb->dgram_qp[REMOTE_UD_QP_ID], &rem_recv_wr[0], &bad_recv_wr);
		CPE(ret, " Refill Remote: ibv_post_recv error", ret);
	}
}
// Client uses this to post receive requests for the remote answers
Client uses this to post receive requests for the remote answers
Client uses this to post receive requests for the remote answers
static inline void refill_recvs(uint16_t rem_req_i, struct ibv_recv_wr* rem_recv_wr, struct hrd_ctrl_blk* cb)
{
	if (rem_req_i > 0) {
		if (ENABLE_ASSERTIONS == 1) assert(rem_req_i <= WINDOW_SIZE);
		int i;
		struct ibv_recv_wr *bad_recv_wr;
		for(i = 0; i < rem_req_i; i++)
			rem_recv_wr[i].next = (i == rem_req_i - 1) ?
								  NULL : &rem_recv_wr[i + 1];
		int ret = ibv_post_recv(cb->dgram_qp[REMOTE_UD_QP_ID], &rem_recv_wr[0], &bad_recv_wr);
		CPE(ret, " Refill Remote: ibv_post_recv error", ret);
	}
}
static inline void refill_recvs ( uint16_t rem_req_i , struct ibv_recv_wr * rem_recv_wr , struct hrd_ctrl_blk * cb ) { if ( rem_req_i > 0 ) { if ( ENABLE_ASSERTIONS == 1 ) assert ( rem_req_i <= WINDOW_SIZE ) ; int i ; struct ibv_recv_wr * bad_recv_wr ; for ( i = 0 ; i < rem_req_i ; i ++ ) rem_recv_wr [ i ] . next = ( i == rem_req_i - 1 ) ? NULL : & rem_recv_wr [ i + 1 ] ; int ret = ibv_post_recv ( cb -> dgram_qp [ REMOTE_UD_QP_ID ] , & rem_recv_wr [ 0 ] , & bad_recv_wr ) ; CPE ( ret , " " , ret ) ; } }
Client uses this to post receive requests for the remote answers
Client uses this to post receive requests for the remote answers