ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

Extend Sven patch for pack/unpack.

Просмотр исходного кода 
This commit was SVN r10040.
Этот коммит содержится в:
George Bosilca 2006-05-24 14:48:00 +00:00
родитель a553c3444a
Коммит 1c55956db1
1 изменённых файлов: 4 добавлений и 5 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

9
ompi/datatype/convertor.c
Просмотреть файл

@ -192,19 +192,18 @@ int32_t ompi_convertor_pack( ompi_convertor_t* pConv,
if( NULL == iov[i].iov_base ) { if( NULL == iov[i].iov_base ) {
iov[i].iov_base = base_pointer; iov[i].iov_base = base_pointer;
pConv->bConverted += iov[i].iov_len; pConv->bConverted += iov[i].iov_len;
if( pConv->bConverted > pConv->local_size ) { if( pConv->bConverted >= pConv->local_size ) {
iov[i].iov_len -= (pConv->bConverted - pConv->local_size); iov[i].iov_len -= (pConv->bConverted - pConv->local_size);
goto predefined_data_pack; goto predefined_data_pack;
} }
} else { } else {
pConv->bConverted += iov[i].iov_len; pConv->bConverted += iov[i].iov_len;
if( pConv->bConverted > pConv->local_size ) { if( pConv->bConverted >= pConv->local_size ) {
iov[i].iov_len -= (pConv->bConverted - pConv->local_size); iov[i].iov_len -= (pConv->bConverted - pConv->local_size);
MEMCPY( iov[i].iov_base, base_pointer, iov[i].iov_len ); MEMCPY( iov[i].iov_base, base_pointer, iov[i].iov_len );
goto predefined_data_pack; goto predefined_data_pack;
} }
MEMCPY( iov[i].iov_base, base_pointer, MEMCPY( iov[i].iov_base, base_pointer, iov[i].iov_len );
iov[i].iov_len );
} }
} }
*max_data = pConv->bConverted - (*max_data); *max_data = pConv->bConverted - (*max_data);
@ -243,7 +242,7 @@ inline int32_t ompi_convertor_unpack( ompi_convertor_t* pConv,
for( i = 0; i < *out_size; i++ ) { for( i = 0; i < *out_size; i++ ) {
base_pointer = pConv->pBaseBuf + pConv->bConverted; base_pointer = pConv->pBaseBuf + pConv->bConverted;
pConv->bConverted += iov[i].iov_len; pConv->bConverted += iov[i].iov_len;
if( pConv->bConverted > pConv->local_size ) { if( pConv->bConverted >= pConv->local_size ) {
pConv->bConverted = pConv->local_size; pConv->bConverted = pConv->local_size;
iov[i].iov_len -= (pConv->bConverted - pConv->local_size); iov[i].iov_len -= (pConv->bConverted - pConv->local_size);
MEMCPY( base_pointer, iov[i].iov_base, iov[i].iov_len ); MEMCPY( base_pointer, iov[i].iov_base, iov[i].iov_len );