continue;
}
- magic = *((int *)(server->evnt.mem_desc.start
+ magic = *((int *)(server->evnt.md.start
+ server->evnt.offset));
if(magic != 0xdeadbeef) {
- printk("LustreError: Unexpected Packet to the server\n");
+ CERROR("Unexpected Packet to the server\n");
}
memcpy (server->in_buf, &ping_bulk_magic, sizeof(ping_bulk_magic));
server->mdout.threshold = 1;
server->mdout.options = PTL_MD_EVENT_START_DISABLE | PTL_MD_OP_PUT;
server->mdout.user_ptr = NULL;
- server->mdout.eventq = PTL_EQ_NONE;
+ server->mdout.eq_handle = PTL_EQ_NONE;
/* Bind the outgoing buffer */
if ((rc = PtlMDBind (server->ni, server->mdout,
server->mdin.threshold = 1;
server->mdin.options = PTL_MD_EVENT_START_DISABLE | PTL_MD_OP_PUT;
server->mdin.user_ptr = NULL;
- server->mdin.eventq = server->eq;
+ server->mdin.eq_handle = server->eq;
if ((rc = PtlMDAttach (server->me, server->mdin,
PTL_UNLINK, &server->mdin_h))) {
}
server->evnt = *ev;
- printk ("Lustre: received ping from nid "LPX64" "
+ CWARN ("received ping from nid "LPX64" "
"(off=%u rlen=%u mlen=%u head=%x seq=%d size=%d)\n",
ev->initiator.nid, ev->offset, ev->rlength, ev->mlength,
- *((int *)(ev->mem_desc.start + ev->offset)),
- *((int *)(ev->mem_desc.start + ev->offset + sizeof(unsigned))),
- *((int *)(ev->mem_desc.start + ev->offset + 2 *
+ *((int *)(ev->md.start + ev->offset)),
+ *((int *)(ev->md.start + ev->offset + sizeof(unsigned))),
+ *((int *)(ev->md.start + ev->offset + 2 *
sizeof(unsigned))));
packets_valid++;
server->mdin.threshold = 1;
server->mdin.options = PTL_MD_EVENT_START_DISABLE | PTL_MD_OP_PUT;
server->mdin.user_ptr = NULL;
- server->mdin.eventq = server->eq;
+ server->mdin.eq_handle = server->eq;
memset (server->in_buf, 0, STDSIZE);
if ((rc = PtlMDAttach (server->me, server->mdin,