mop 1083 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_msg_error_t *mop = (mca_oob_tcp_msg_error_t*)cbdata; mop 1088 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACQUIRE_OBJECT(mop); mop 1093 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->hop)); mop 1096 orte/mca/oob/tcp/oob_tcp_component.c memcpy(&ui64, (char*)&(mop->hop), sizeof(uint64_t)); mop 1110 orte/mca/oob/tcp/oob_tcp_component.c mop->rmsg->retries++; mop 1112 orte/mca/oob/tcp/oob_tcp_component.c ORTE_OOB_SEND(mop->rmsg); mop 1114 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(mop); mop 1119 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_msg_error_t *mop = (mca_oob_tcp_msg_error_t*)cbdata; mop 1124 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACQUIRE_OBJECT(mop); mop 1129 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->hop)); mop 1133 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(mop); mop 1138 orte/mca/oob/tcp/oob_tcp_component.c memcpy(&ui64, (char*)&(mop->hop), sizeof(uint64_t)); mop 1150 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->snd->hdr.dst), mop 1151 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->hop)); mop 1152 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACTIVATE_PROC_STATE(&mop->hop, ORTE_PROC_STATE_UNABLE_TO_SEND_MSG); mop 1153 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(mop); mop 1159 orte/mca/oob/tcp/oob_tcp_component.c memcpy(&ui64, (char*)&(mop->snd->hdr.dst), sizeof(uint64_t)); mop 1165 orte/mca/oob/tcp/oob_tcp_component.c ORTE_NAME_PRINT(&mop->snd->hdr.dst)); mop 1166 orte/mca/oob/tcp/oob_tcp_component.c ORTE_ACTIVATE_PROC_STATE(&mop->hop, ORTE_PROC_STATE_UNABLE_TO_SEND_MSG); mop 1167 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(mop); mop 1175 orte/mca/oob/tcp/oob_tcp_component.c MCA_OOB_TCP_HDR_NTOH(&mop->snd->hdr); mop 1177 orte/mca/oob/tcp/oob_tcp_component.c snd->retries = mop->rmsg->retries + 1; mop 1178 orte/mca/oob/tcp/oob_tcp_component.c snd->dst = mop->snd->hdr.dst; mop 1179 orte/mca/oob/tcp/oob_tcp_component.c snd->origin = mop->snd->hdr.origin; mop 1180 orte/mca/oob/tcp/oob_tcp_component.c snd->tag = mop->snd->hdr.tag; mop 1181 orte/mca/oob/tcp/oob_tcp_component.c snd->seq_num = mop->snd->hdr.seq_num; mop 1182 orte/mca/oob/tcp/oob_tcp_component.c snd->data = mop->snd->data; mop 1183 orte/mca/oob/tcp/oob_tcp_component.c snd->count = mop->snd->hdr.nbytes; mop 1189 orte/mca/oob/tcp/oob_tcp_component.c mop->snd->data = NULL; mop 1191 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(mop); mop 223 orte/mca/oob/tcp/oob_tcp_sendrecv.h mca_oob_tcp_msg_op_t *mop; \ mop 229 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop = OBJ_NEW(mca_oob_tcp_msg_op_t); \ mop 230 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->msg = (ms); \ mop 231 orte/mca/oob/tcp/oob_tcp_sendrecv.h ORTE_THREADSHIFT(mop, (ms)->peer->ev_base, \ mop 246 orte/mca/oob/tcp/oob_tcp_sendrecv.h mca_oob_tcp_msg_error_t *mop; \ mop 254 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop = OBJ_NEW(mca_oob_tcp_msg_error_t); \ mop 256 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->snd = (s); \ mop 262 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->snd = snd; \ mop 274 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->hop.jobid = (h)->jobid; \ mop 275 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->hop.vpid = (h)->vpid; \ mop 277 orte/mca/oob/tcp/oob_tcp_sendrecv.h ORTE_THREADSHIFT(mop, orte_oob_base.ev_base, \ mop 283 orte/mca/oob/tcp/oob_tcp_sendrecv.h mca_oob_tcp_msg_error_t *mop; \ mop 289 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop = OBJ_NEW(mca_oob_tcp_msg_error_t); \ mop 290 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->rmsg = (r); \ mop 291 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->hop.jobid = (h)->jobid; \ mop 292 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->hop.vpid = (h)->vpid; \ mop 295 orte/mca/oob/tcp/oob_tcp_sendrecv.h ORTE_THREADSHIFT(mop, orte_oob_base.ev_base, \