1
1
This commit was SVN r9339.
Этот коммит содержится в:
Galen Shipman 2006-03-20 15:41:45 +00:00
родитель 15bdbd5ca1
Коммит 5600932c2f
5 изменённых файлов: 11 добавлений и 8 удалений

Просмотреть файл

@ -255,7 +255,7 @@ static inline void mca_bml_base_completion(
struct mca_btl_base_descriptor_t* des, struct mca_btl_base_descriptor_t* des,
int status) int status)
{ {
mca_bml_base_context_t* ctx = des->des_cbdata; mca_bml_base_context_t* ctx = (mca_bml_base_context_t*) des->des_cbdata;
/* restore original state */ /* restore original state */
((unsigned char*)des->des_src[0].seg_addr.pval)[ctx->index] ^= ~0; ((unsigned char*)des->des_src[0].seg_addr.pval)[ctx->index] ^= ~0;
des->des_cbdata = ctx->cbdata; des->des_cbdata = ctx->cbdata;
@ -273,16 +273,17 @@ static inline int mca_bml_base_send(
{ {
static int count; static int count;
if(count <= 0) { if(count <= 0) {
count = ((1000.0 * rand())/(RAND_MAX+1.0)); count = (int) ((1000.0 * rand())/(RAND_MAX+1.0));
if(count % 2) { if(count % 2) {
/* local completion - network "drops" packet */ /* local completion - network "drops" packet */
des->des_cbfunc(bml_btl->btl, bml_btl->btl_endpoint, des, OMPI_SUCCESS); des->des_cbfunc(bml_btl->btl, bml_btl->btl_endpoint, des, OMPI_SUCCESS);
return OMPI_SUCCESS; return OMPI_SUCCESS;
} else { } else {
/* corrupt data */ /* corrupt data */
mca_bml_base_context_t* ctx = malloc(sizeof(mca_bml_base_context_t)); mca_bml_base_context_t* ctx = (mca_bml_base_context_t*)
malloc(sizeof(mca_bml_base_context_t));
if(NULL != ctx) { if(NULL != ctx) {
ctx->index = (des->des_src[0].seg_len * rand() * 1.0) / (RAND_MAX + 1.0); ctx->index = (size_t) ((des->des_src[0].seg_len * rand() * 1.0) / (RAND_MAX + 1.0));
ctx->cbfunc = des->des_cbfunc; ctx->cbfunc = des->des_cbfunc;
ctx->cbdata = des->des_cbdata; ctx->cbdata = des->des_cbdata;
((unsigned char*)des->des_src[0].seg_addr.pval)[ctx->index] ^= ~0; ((unsigned char*)des->des_src[0].seg_addr.pval)[ctx->index] ^= ~0;

Просмотреть файл

@ -174,9 +174,10 @@ int mca_pml_dr_component_fini(void)
return OMPI_SUCCESS; return OMPI_SUCCESS;
} }
void mca_pml_dr_dump( int mca_pml_dr_dump(
struct ompi_communicator_t* comm, struct ompi_communicator_t* comm,
int verbose) int verbose)
{ {
return OMPI_SUCCESS;
} }

Просмотреть файл

@ -211,7 +211,7 @@ extern int mca_pml_dr_recv(
ompi_status_public_t* status ompi_status_public_t* status
); );
extern void mca_pml_dr_dump( extern int mca_pml_dr_dump(
struct ompi_communicator_t* comm, struct ompi_communicator_t* comm,
int verbose int verbose
); );

Просмотреть файл

@ -181,7 +181,7 @@ int mca_pml_ob1_component_fini(void)
* diagnostics * diagnostics
*/ */
void mca_pml_ob1_dump(struct ompi_communicator_t* comm, int verbose) int mca_pml_ob1_dump(struct ompi_communicator_t* comm, int verbose)
{ {
struct mca_pml_comm_t* pml_comm = comm->c_pml_comm; struct mca_pml_comm_t* pml_comm = comm->c_pml_comm;
size_t i; size_t i;
@ -201,5 +201,6 @@ void mca_pml_ob1_dump(struct ompi_communicator_t* comm, int verbose)
bml_btl->btl->btl_dump(bml_btl->btl, bml_btl->btl_endpoint, verbose); bml_btl->btl->btl_dump(bml_btl->btl, bml_btl->btl_endpoint, verbose);
} }
} }
return OMPI_SUCCESS;
} }

Просмотреть файл

@ -200,7 +200,7 @@ extern int mca_pml_ob1_recv(
ompi_status_public_t* status ompi_status_public_t* status
); );
extern void mca_pml_ob1_dump( extern int mca_pml_ob1_dump(
struct ompi_communicator_t* comm, struct ompi_communicator_t* comm,
int verbose int verbose
); );