non-destructive read of buffer
This commit was SVN r7114.
Этот коммит содержится в:
родитель
227947fc51
Коммит
35f96af472
@ -68,6 +68,7 @@ int mca_oob_send_packed (orte_process_name_t* peer, orte_buffer_t* buffer, int t
|
|||||||
if(rc != ORTE_SUCCESS) {
|
if(rc != ORTE_SUCCESS) {
|
||||||
return rc;
|
return rc;
|
||||||
}
|
}
|
||||||
|
orte_dps.load(buffer, dataptr, datalen);
|
||||||
|
|
||||||
msg[0].iov_base = dataptr;
|
msg[0].iov_base = dataptr;
|
||||||
msg[0].iov_len = datalen;
|
msg[0].iov_len = datalen;
|
||||||
|
@ -104,6 +104,7 @@ int mca_oob_send_packed_nb(
|
|||||||
if (rc != ORTE_SUCCESS) {
|
if (rc != ORTE_SUCCESS) {
|
||||||
return rc;
|
return rc;
|
||||||
}
|
}
|
||||||
|
orte_dps.load(buffer, dataptr, datalen);
|
||||||
|
|
||||||
/* allocate a struct to pass into callback */
|
/* allocate a struct to pass into callback */
|
||||||
if(NULL == (oob_cbdata = malloc(sizeof(mca_oob_send_cbdata_t)))) {
|
if(NULL == (oob_cbdata = malloc(sizeof(mca_oob_send_cbdata_t)))) {
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user