sstore/stage: fix parameter handling in sstore_stage_local_compress_waitpid_cb()
since open-mpi/ompi@8f496b01b7 sstore_stage_local_compress_waitpid_cb is invoked with an orte_wait_tracker_t *, that must be used to reach the orte_sstore_stage_local_app_snapshot_info_t *. Signed-off-by: Gilles Gouaillardet <gilles@rist.or.jp>
Этот коммит содержится в:
родитель
c4cd12bc43
Коммит
f7e29127bc
@ -1,9 +1,11 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright (c) 2010 The Trustees of Indiana University.
|
* Copyright (c) 2010 The Trustees of Indiana University.
|
||||||
* All rights reserved.
|
* All rights reserved.
|
||||||
* Copyright (c) 2004-2011 The University of Tennessee and The University
|
* Copyright (c) 2004-2011 The University of Tennessee and The University
|
||||||
* of Tennessee Research Foundation. All rights
|
* of Tennessee Research Foundation. All rights
|
||||||
* reserved.
|
* reserved.
|
||||||
|
* Copyright (c) 2017 Research Organization for Information Science
|
||||||
|
* and Technology (RIST). All rights reserved.
|
||||||
* $COPYRIGHT$
|
* $COPYRIGHT$
|
||||||
*
|
*
|
||||||
* Additional copyrights may follow
|
* Additional copyrights may follow
|
||||||
@ -1550,8 +1552,9 @@ static int start_compression(orte_sstore_stage_local_snapshot_info_t *handle_inf
|
|||||||
static void sstore_stage_local_compress_waitpid_cb(orte_proc_t *proc, void* cbdata)
|
static void sstore_stage_local_compress_waitpid_cb(orte_proc_t *proc, void* cbdata)
|
||||||
{
|
{
|
||||||
orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL;
|
orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL;
|
||||||
|
orte_wait_tracker_t *t2 = (orte_wait_tracker_t *)cbdata;
|
||||||
|
|
||||||
app_info = (orte_sstore_stage_local_app_snapshot_info_t*)cbdata;
|
app_info = (orte_sstore_stage_local_app_snapshot_info_t*)t2->cbdata;
|
||||||
|
|
||||||
OPAL_OUTPUT_VERBOSE((10, mca_sstore_stage_component.super.output_handle,
|
OPAL_OUTPUT_VERBOSE((10, mca_sstore_stage_component.super.output_handle,
|
||||||
"sstore:stage:(local): waitpid(%6d) Compression finished for Process %s",
|
"sstore:stage:(local): waitpid(%6d) Compression finished for Process %s",
|
||||||
@ -1560,6 +1563,7 @@ static void sstore_stage_local_compress_waitpid_cb(orte_proc_t *proc, void* cbda
|
|||||||
|
|
||||||
app_info->compress_pid = 0;
|
app_info->compress_pid = 0;
|
||||||
OBJ_RELEASE(proc);
|
OBJ_RELEASE(proc);
|
||||||
|
OBJ_RELEASE(t2);
|
||||||
}
|
}
|
||||||
|
|
||||||
static int wait_all_compressed(orte_sstore_stage_local_snapshot_info_t *handle_info)
|
static int wait_all_compressed(orte_sstore_stage_local_snapshot_info_t *handle_info)
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user