9613b3176c
After much work by Jeff and myself, and quite a lot of discussion, it has become clear that we simply cannot resolve the infinite loops caused by RML-involved subsystems calling orte_output. The original rationale for the change to orte_output has also been reduced by shifting the output of XML-formatted vs human readable messages to an alternative approach. I have globally replaced the orte_output/ORTE_OUTPUT calls in the code base, as well as the corresponding .h file name. I have test compiled and run this on the various environments within my reach, so hopefully this will prove minimally disruptive. This commit was SVN r18619.
200 строки
7.6 KiB
C
200 строки
7.6 KiB
C
/*
|
|
* Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
|
|
* University Research and Technology
|
|
* Corporation. All rights reserved.
|
|
* Copyright (c) 2004-2006 The University of Tennessee and The University
|
|
* of Tennessee Research Foundation. All rights
|
|
* reserved.
|
|
* Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
|
|
* University of Stuttgart. All rights reserved.
|
|
* Copyright (c) 2004-2005 The Regents of the University of California.
|
|
* All rights reserved.
|
|
* $COPYRIGHT$
|
|
*
|
|
* Additional copyrights may follow
|
|
*
|
|
* $HEADER$
|
|
*/
|
|
|
|
#include "ompi_config.h"
|
|
|
|
#include "ompi/class/ompi_seq_tracker.h"
|
|
#include "opal/sys/cache.h"
|
|
#include "orte/util/show_help.h"
|
|
|
|
|
|
|
|
OBJ_CLASS_INSTANCE(ompi_seq_tracker_range_t,
|
|
opal_list_item_t,
|
|
NULL,
|
|
NULL);
|
|
|
|
|
|
static void ompi_seq_tracker_construct(ompi_seq_tracker_t* seq_tracker) {
|
|
OBJ_CONSTRUCT(&seq_tracker->seq_ids, opal_list_t);
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*)opal_list_get_end(&seq_tracker->seq_ids);
|
|
}
|
|
|
|
|
|
static void ompi_seq_tracker_destruct(ompi_seq_tracker_t* seq_tracker)
|
|
{
|
|
opal_list_item_t* item;
|
|
while(NULL != (item = opal_list_remove_first(&seq_tracker->seq_ids)))
|
|
OBJ_RELEASE(item);
|
|
OBJ_DESTRUCT(&seq_tracker->seq_ids);
|
|
}
|
|
|
|
OBJ_CLASS_INSTANCE(
|
|
ompi_seq_tracker_t,
|
|
opal_object_t,
|
|
ompi_seq_tracker_construct,
|
|
ompi_seq_tracker_destruct);
|
|
|
|
|
|
/**
|
|
* Look for duplicate sequence number in current range.
|
|
* Must be called w/ matching lock held.
|
|
*/
|
|
|
|
bool ompi_seq_tracker_check_duplicate(
|
|
ompi_seq_tracker_t* seq_tracker,
|
|
uint32_t seq_id)
|
|
{
|
|
ompi_seq_tracker_range_t* item;
|
|
const ompi_seq_tracker_range_t* sentinel = (ompi_seq_tracker_range_t*)opal_list_get_end(&seq_tracker->seq_ids);
|
|
int8_t direction = 0; /* 1 is next, -1 is previous */
|
|
|
|
item = seq_tracker->seq_ids_current;
|
|
while(true) {
|
|
if(sentinel == item) {
|
|
return false;
|
|
} else if(item->seq_id_high >= seq_id && item->seq_id_low <= seq_id) {
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*) item;
|
|
return true;
|
|
} else if(seq_id > item->seq_id_high && direction != -1) {
|
|
direction = 1;
|
|
item = (ompi_seq_tracker_range_t*) opal_list_get_next(item);
|
|
} else if(seq_id < item->seq_id_low && direction != 1) {
|
|
direction = -1;
|
|
item = (ompi_seq_tracker_range_t*) opal_list_get_prev(item);
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* insert item into sequence tracking list,
|
|
* compacts continuous regions into a single entry
|
|
* GMS::: Use a free list for the items (don't do OBJ_NEW)!
|
|
*/
|
|
void ompi_seq_tracker_insert(ompi_seq_tracker_t* seq_tracker,
|
|
uint32_t seq_id)
|
|
{
|
|
opal_list_t* seq_ids = &seq_tracker->seq_ids;
|
|
ompi_seq_tracker_range_t* item = seq_tracker->seq_ids_current;
|
|
int8_t direction = 0; /* 1 is next, -1 is previous */
|
|
ompi_seq_tracker_range_t *new_item, *next_item, *prev_item;
|
|
const ompi_seq_tracker_range_t* sentinel = (ompi_seq_tracker_range_t*)opal_list_get_end(seq_ids);
|
|
|
|
while( true ) {
|
|
if( item == sentinel ) {
|
|
new_item = OBJ_NEW(ompi_seq_tracker_range_t);
|
|
new_item->seq_id_low = new_item->seq_id_high = seq_id;
|
|
if( -1 == direction ) {
|
|
opal_list_prepend(seq_ids, (opal_list_item_t*) new_item);
|
|
} else {
|
|
opal_list_append(seq_ids, (opal_list_item_t*) new_item);
|
|
}
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*) new_item;
|
|
return;
|
|
|
|
} else if(item->seq_id_high >= seq_id && item->seq_id_low <= seq_id ) {
|
|
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*) item;
|
|
return;
|
|
|
|
} else if((item->seq_id_high + 1) == seq_id) {
|
|
|
|
next_item = (ompi_seq_tracker_range_t*) opal_list_get_next(item);
|
|
/* try to consolidate */
|
|
if( (sentinel != next_item) && next_item->seq_id_low == (seq_id+1)) {
|
|
item->seq_id_high = next_item->seq_id_high;
|
|
opal_list_remove_item(seq_ids, (opal_list_item_t*) next_item);
|
|
OBJ_RELEASE(next_item);
|
|
} else {
|
|
item->seq_id_high = seq_id;
|
|
}
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*) item;
|
|
return;
|
|
|
|
} else if((item->seq_id_low - 1) == seq_id) {
|
|
|
|
prev_item = (ompi_seq_tracker_range_t*) opal_list_get_prev(item);
|
|
/* try to consolidate */
|
|
if( (sentinel != prev_item) && prev_item->seq_id_high == (seq_id-1)) {
|
|
item->seq_id_low = prev_item->seq_id_low;
|
|
opal_list_remove_item(seq_ids, (opal_list_item_t*) prev_item);
|
|
OBJ_RELEASE(prev_item);
|
|
} else {
|
|
item->seq_id_low = seq_id;
|
|
}
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*) item;
|
|
return;
|
|
|
|
} else if(seq_id > item->seq_id_high ) {
|
|
if(direction == -1) {
|
|
/* we have gone back in the list, and we went one item too far */
|
|
new_item = OBJ_NEW(ompi_seq_tracker_range_t);
|
|
new_item->seq_id_low = new_item->seq_id_high = seq_id;
|
|
next_item = (ompi_seq_tracker_range_t*) opal_list_get_next(item);
|
|
/* insert new_item directly before item */
|
|
opal_list_insert_pos(seq_ids,
|
|
(opal_list_item_t*) next_item,
|
|
(opal_list_item_t*) new_item);
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*) new_item;
|
|
return;
|
|
} else {
|
|
direction = 1;
|
|
item = (ompi_seq_tracker_range_t*) opal_list_get_next(item);
|
|
}
|
|
} else if(seq_id < item->seq_id_low) {
|
|
if(direction == 1) {
|
|
/* we have gone forward in the list, and we went one item too far */
|
|
new_item = OBJ_NEW(ompi_seq_tracker_range_t);
|
|
new_item->seq_id_low = new_item->seq_id_high = seq_id;
|
|
opal_list_insert_pos(seq_ids,
|
|
(opal_list_item_t*) item,
|
|
(opal_list_item_t*) new_item);
|
|
|
|
seq_tracker->seq_ids_current = (ompi_seq_tracker_range_t*) new_item;
|
|
return;
|
|
} else {
|
|
direction = -1;
|
|
item = (ompi_seq_tracker_range_t*) opal_list_get_prev(item);
|
|
}
|
|
} else {
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
void ompi_seq_tracker_copy(ompi_seq_tracker_t* dst, ompi_seq_tracker_t* src)
|
|
{
|
|
opal_list_item_t* item;
|
|
for( item = opal_list_get_first(&src->seq_ids);
|
|
item != opal_list_get_end(&src->seq_ids);
|
|
item = opal_list_get_next(item)) {
|
|
ompi_seq_tracker_range_t* src_item = (ompi_seq_tracker_range_t*)item;
|
|
ompi_seq_tracker_range_t* dst_item = OBJ_NEW(ompi_seq_tracker_range_t);
|
|
dst_item->seq_id_high = src_item->seq_id_high;
|
|
dst_item->seq_id_low = src_item->seq_id_low;
|
|
opal_list_append(&dst->seq_ids, &dst_item->super);
|
|
if(src->seq_ids_current == src_item) {
|
|
dst->seq_ids_current = dst_item;
|
|
}
|
|
}
|
|
}
|