mca_vprotocol_pessimist 13 ompi/mca/vprotocol/pessimist/vprotocol_pessimist.c mca_vprotocol_pessimist_module_t mca_vprotocol_pessimist = mca_vprotocol_pessimist 55 ompi/mca/vprotocol/pessimist/vprotocol_pessimist.h OMPI_DECLSPEC extern mca_vprotocol_pessimist_module_t mca_vprotocol_pessimist; mca_vprotocol_pessimist 128 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c mca_vprotocol_pessimist.clock = 1; mca_vprotocol_pessimist 129 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c mca_vprotocol_pessimist.replay = false; mca_vprotocol_pessimist 130 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c OBJ_CONSTRUCT(&mca_vprotocol_pessimist.replay_events, opal_list_t); mca_vprotocol_pessimist 131 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c OBJ_CONSTRUCT(&mca_vprotocol_pessimist.pending_events, opal_list_t); mca_vprotocol_pessimist 132 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c OBJ_CONSTRUCT(&mca_vprotocol_pessimist.events_pool, opal_free_list_t); mca_vprotocol_pessimist 133 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c opal_free_list_init (&mca_vprotocol_pessimist.events_pool, mca_vprotocol_pessimist 142 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c mca_vprotocol_pessimist.event_buffer_max_length = mca_vprotocol_pessimist 144 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c mca_vprotocol_pessimist.event_buffer_length = 0; mca_vprotocol_pessimist 145 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c mca_vprotocol_pessimist.event_buffer = mca_vprotocol_pessimist 147 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c mca_vprotocol_pessimist.el_comm = MPI_COMM_NULL; mca_vprotocol_pessimist 149 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c return &mca_vprotocol_pessimist.super; mca_vprotocol_pessimist 155 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c free(mca_vprotocol_pessimist.event_buffer); mca_vprotocol_pessimist 156 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c OBJ_DESTRUCT(&mca_vprotocol_pessimist.replay_events); mca_vprotocol_pessimist 157 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c OBJ_DESTRUCT(&mca_vprotocol_pessimist.pending_events); mca_vprotocol_pessimist 158 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c OBJ_DESTRUCT(&mca_vprotocol_pessimist.events_pool); mca_vprotocol_pessimist 171 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_component.c vprotocol_pessimist_event_logger_disconnect(mca_vprotocol_pessimist.el_comm); mca_vprotocol_pessimist 60 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h item = opal_free_list_wait (&mca_vprotocol_pessimist.events_pool); \ mca_vprotocol_pessimist 69 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h item = opal_free_list_wait (&mca_vprotocol_pessimist.events_pool); \ mca_vprotocol_pessimist 75 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_event.h opal_free_list_return (&mca_vprotocol_pessimist.events_pool, \ mca_vprotocol_pessimist 56 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mca_vprotocol_pessimist.el_comm); mca_vprotocol_pessimist 58 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c OMPI_ERRHANDLER_INVOKE(mca_vprotocol_pessimist.el_comm, rc, mca_vprotocol_pessimist 62 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mca_vprotocol_pessimist.el_comm, MPI_STATUS_IGNORE); mca_vprotocol_pessimist 64 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c OMPI_ERRHANDLER_INVOKE(mca_vprotocol_pessimist.el_comm, rc, \ mca_vprotocol_pessimist 83 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c for(event = (mca_vprotocol_pessimist_event_t *) opal_list_get_first(&mca_vprotocol_pessimist.replay_events); mca_vprotocol_pessimist 84 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c event != (mca_vprotocol_pessimist_event_t *) opal_list_get_end(&mca_vprotocol_pessimist.replay_events); mca_vprotocol_pessimist 91 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c if(mevent->reqid == mca_vprotocol_pessimist.clock) mca_vprotocol_pessimist 96 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c opal_list_remove_item(&mca_vprotocol_pessimist.replay_events, mca_vprotocol_pessimist 106 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c assert(((*src) != MPI_ANY_SOURCE) || (mca_vprotocol_pessimist.clock > max)); mca_vprotocol_pessimist 117 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c for(event = (mca_vprotocol_pessimist_event_t *) opal_list_get_first(&mca_vprotocol_pessimist.replay_events); mca_vprotocol_pessimist 118 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c event != (mca_vprotocol_pessimist_event_t *) opal_list_get_end(&mca_vprotocol_pessimist.replay_events); mca_vprotocol_pessimist 125 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c if(devent->probeid < mca_vprotocol_pessimist.clock) mca_vprotocol_pessimist 128 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c V_OUTPUT_VERBOSE(70, "pessimist:\treplay\tdeliver\t%"PRIpclock"\tnone", mca_vprotocol_pessimist.clock); mca_vprotocol_pessimist 131 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mca_vprotocol_pessimist.clock++; mca_vprotocol_pessimist 135 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c else if(devent->probeid == mca_vprotocol_pessimist.clock) mca_vprotocol_pessimist 143 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c opal_list_remove_item(&mca_vprotocol_pessimist.replay_events, mca_vprotocol_pessimist 148 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mca_vprotocol_pessimist.clock++; mca_vprotocol_pessimist 153 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c V_OUTPUT_VERBOSE(70, "pessimist:\treplay\tdeliver\t%"PRIpclock"\tnone", mca_vprotocol_pessimist.clock); mca_vprotocol_pessimist 157 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c mca_vprotocol_pessimist.clock++; mca_vprotocol_pessimist 158 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c opal_list_remove_item(&mca_vprotocol_pessimist.replay_events, mca_vprotocol_pessimist 164 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.c V_OUTPUT_VERBOSE(50, "pessimist:\treplay\tdeliver\t%"PRIpclock"\tnot forced", mca_vprotocol_pessimist.clock); mca_vprotocol_pessimist 49 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_append(&mca_vprotocol_pessimist.pending_events, mca_vprotocol_pessimist 80 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(OPAL_UNLIKELY(mca_vprotocol_pessimist.event_buffer_length)) \ mca_vprotocol_pessimist 85 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(OPAL_UNLIKELY(ompi_comm_invalid(mca_vprotocol_pessimist.el_comm))) \ mca_vprotocol_pessimist 88 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h &mca_vprotocol_pessimist.el_comm); \ mca_vprotocol_pessimist 90 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h OMPI_ERRHANDLER_INVOKE(mca_vprotocol_pessimist.el_comm, rc, \ mca_vprotocol_pessimist 96 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist.el_comm, &req); \ mca_vprotocol_pessimist 97 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h rc = mca_pml_v.host_pml.pml_send(mca_vprotocol_pessimist.event_buffer,\ mca_vprotocol_pessimist 98 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist.event_buffer_length * \ mca_vprotocol_pessimist 101 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h MCA_PML_BASE_SEND_STANDARD, mca_vprotocol_pessimist.el_comm); \ mca_vprotocol_pessimist 103 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h OMPI_ERRHANDLER_INVOKE(mca_vprotocol_pessimist.el_comm, rc, \ mca_vprotocol_pessimist 105 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist.event_buffer_length = 0; \ mca_vprotocol_pessimist 108 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h OMPI_ERRHANDLER_INVOKE(mca_vprotocol_pessimist.el_comm, rc, \ mca_vprotocol_pessimist 119 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(OPAL_UNLIKELY(!opal_list_is_empty(&mca_vprotocol_pessimist.pending_events))) mca_vprotocol_pessimist 126 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_get_first(&mca_vprotocol_pessimist.pending_events); mca_vprotocol_pessimist 129 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_get_end(&mca_vprotocol_pessimist.pending_events); mca_vprotocol_pessimist 149 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist.event_buffer[mca_vprotocol_pessimist.event_buffer_length++] = mca_vprotocol_pessimist 151 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(mca_vprotocol_pessimist.event_buffer_length == mca_vprotocol_pessimist 152 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h mca_vprotocol_pessimist.event_buffer_max_length) mca_vprotocol_pessimist 154 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h assert(mca_vprotocol_pessimist.event_buffer_length < mca_vprotocol_pessimist.event_buffer_max_length); mca_vprotocol_pessimist 156 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_remove_item(&mca_vprotocol_pessimist.pending_events, mca_vprotocol_pessimist 172 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(mca_vprotocol_pessimist.replay && ((src) == MPI_ANY_SOURCE)) \ mca_vprotocol_pessimist 192 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h V_OUTPUT_VERBOSE(70, "pessimist:\tlog\tdeliver\t%"PRIpclock"\tnone", mca_vprotocol_pessimist.clock); mca_vprotocol_pessimist 194 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_get_last(&mca_vprotocol_pessimist.pending_events); mca_vprotocol_pessimist 199 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h event->u_event.e_delivery.probeid = mca_vprotocol_pessimist.clock++; mca_vprotocol_pessimist 207 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h devent->probeid = mca_vprotocol_pessimist.clock++; mca_vprotocol_pessimist 209 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_append(&mca_vprotocol_pessimist.pending_events, mca_vprotocol_pessimist 216 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h V_OUTPUT_VERBOSE(70, "pessimist:\tlog\tdeliver\t%"PRIpclock"\treq %"PRIpclock, mca_vprotocol_pessimist.clock, VPESSIMIST_FTREQ(req)->reqid); mca_vprotocol_pessimist 219 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h devent->probeid = mca_vprotocol_pessimist.clock++; mca_vprotocol_pessimist 221 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h opal_list_append(&mca_vprotocol_pessimist.pending_events, mca_vprotocol_pessimist 235 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_eventlog.h if(mca_vprotocol_pessimist.replay) \ mca_vprotocol_pessimist 36 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_probe.c if(mca_vprotocol_pessimist.replay) mca_vprotocol_pessimist 54 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_probe.c if(mca_vprotocol_pessimist.replay) mca_vprotocol_pessimist 31 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_recv.c mca_vprotocol_pessimist.clock, src, tag, (unsigned long) count); mca_vprotocol_pessimist 58 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_recv.c mca_vprotocol_pessimist.clock, src, tag, (unsigned long) count); mca_vprotocol_pessimist 46 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_request.h VPESSIMIST_FTREQ(req)->reqid = mca_vprotocol_pessimist.clock++; \ mca_vprotocol_pessimist 29 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_send.c mca_vprotocol_pessimist.clock, dst, tag, (unsigned long) count); mca_vprotocol_pessimist 51 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_send.c mca_vprotocol_pessimist.clock, dst, tag, (unsigned long) count); mca_vprotocol_pessimist 27 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.c #define sb mca_vprotocol_pessimist.sender_based mca_vprotocol_pessimist 87 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h (mca_vprotocol_pessimist.sender_based.sb_conv_to_pessimist_offset + \ mca_vprotocol_pessimist 101 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h opal_list_append(&mca_vprotocol_pessimist.sender_based.sb_sendreq, mca_vprotocol_pessimist 135 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h if(!opal_list_is_empty(&mca_vprotocol_pessimist.sender_based.sb_sendreq)) mca_vprotocol_pessimist 138 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h opal_list_remove_first(&mca_vprotocol_pessimist.sender_based.sb_sendreq); mca_vprotocol_pessimist 141 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h opal_list_append(&mca_vprotocol_pessimist.sender_based.sb_sendreq, mca_vprotocol_pessimist 155 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h assert(!opal_list_is_empty(&mca_vprotocol_pessimist.sender_based.sb_sendreq)); mca_vprotocol_pessimist 156 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h opal_list_remove_item(&mca_vprotocol_pessimist.sender_based.sb_sendreq, mca_vprotocol_pessimist 176 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h if(mca_vprotocol_pessimist.sender_based.sb_available < mca_vprotocol_pessimist 185 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h ftreq->sb.cursor = mca_vprotocol_pessimist.sender_based.sb_cursor; mca_vprotocol_pessimist 187 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist.sender_based.sb_cursor += mca_vprotocol_pessimist 190 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_sender_based.h mca_vprotocol_pessimist.sender_based.sb_available -= mca_vprotocol_pessimist 27 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c V_OUTPUT_VERBOSE(50, "pessimist:\tstart\trecv\t%"PRIpclock"\tfrom %d\ttag %d\tsize %lu", mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count); mca_vprotocol_pessimist 33 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c V_OUTPUT_VERBOSE(50, "pessimist:\tstart\tsend\t%"PRIpclock"\tto %d\ttag %d\tsize %lu", mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count); mca_vprotocol_pessimist 39 ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c V_OUTPUT_VERBOSE(50, "pessimist:\tstart\twrong %d\t%"PRIpclock"\tfrom %d\ttag %d\tsize %lu", pml_request->req_type, mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count);