create_events(void)
{
DAT_RETURN ret;
+ DAT_EVD_PARAM param;
/* create CNO */
if (use_cno) {
/* create dto SND EVD, with CNO if use_cno was set */
ret = dat_evd_create( h_ia,
- MSG_BUF_COUNT+MAX_RDMA_RD+burst*2,
+ (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2,
h_dto_cno,
DAT_EVD_DTO_FLAG,
&h_dto_req_evd );
LOGPRINTF("%d dto_rcv_evd created %p\n", getpid(), h_dto_rcv_evd );
}
+ /* query DTO req EVD and check size */
+ ret = dat_evd_query( h_dto_req_evd,
+ DAT_EVD_FIELD_EVD_QLEN,
+ ¶m );
+ if(ret != DAT_SUCCESS) {
+ fprintf(stderr, "%d Error dat_evd_query request evd: %s\n",
+ getpid(),DT_RetToString(ret));
+ return (ret);
+ }
+ else if (param.evd_qlen < (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2) {
+ fprintf(stderr, "%d Error dat_evd qsize too small: %d < %d\n",
+ getpid(), param.evd_qlen,
+ (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2);
+ return (ret);
+ }
+
+ LOGPRINTF("%d dto_req_evd QLEN - requested %d and actual %d\n",
+ getpid(), (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2,
+ param.evd_qlen);
+
return DAT_SUCCESS;
}