Loading source/adios2/toolkit/sst/cp/cp_reader.c +4 −2 Original line number Diff line number Diff line Loading @@ -1050,8 +1050,10 @@ extern SstStatusValue SstAdvanceStep(SstStream Stream, SstStepMode mode, Stream->ReaderTimestep = Entry->MetadataMsg->Timestep; SstFullMetadata Mdata = malloc(sizeof(struct _SstFullMetadata)); Mdata->WriterCohortSize = Entry->MetadataMsg->CohortSize; Mdata->WriterMetadata = malloc(sizeof(Mdata->WriterMetadata[0]) * Mdata->WriterCohortSize); for (int i = 0; i < Mdata->WriterCohortSize; i++) { Mdata->WriterMetadata = malloc(sizeof(Mdata->WriterMetadata[0]) * Mdata->WriterCohortSize); for (int i = 0; i < Mdata->WriterCohortSize; i++) { Mdata->WriterMetadata[i] = &Entry->MetadataMsg->Metadata[i]; } if (Stream->DP_Interface->TimestepInfoFormats == NULL) Loading source/adios2/toolkit/sst/cp/cp_writer.c +10 −4 Original line number Diff line number Diff line Loading @@ -1316,15 +1316,21 @@ extern void SstInternalProvideTimestep( int NullCount = 0; for (int i = 0; i < Stream->CohortSize; i++) { if (pointers[i]->Metadata) { if (pointers[i]->Metadata) { Msg->Metadata[i] = *(pointers[i]->Metadata); } else { } else { Msg->Metadata[i].DataSize = 0; Msg->Metadata[i].block = NULL; } if (pointers[i]->AttributeData) { if (pointers[i]->AttributeData) { Msg->AttributeData[i] = *(pointers[i]->AttributeData); } else { } else { Msg->AttributeData[i].DataSize = 0; Msg->AttributeData[i].block = NULL; } Loading source/adios2/toolkit/sst/cp/ffs_marshal.c +2 −2 Original line number Diff line number Diff line Loading @@ -1566,8 +1566,8 @@ static void BuildVarList(SstStream Stream, TSMetadataMsg MetaData, "NULL for WriterRank = %d\n", WriterRank); } FFSformat = FFSTypeHandle_from_encode( Stream->ReaderFFSContext, MetaData->Metadata[WriterRank].block); FFSformat = FFSTypeHandle_from_encode(Stream->ReaderFFSContext, MetaData->Metadata[WriterRank].block); if (!FFShas_conversion(FFSformat)) { Loading Loading
source/adios2/toolkit/sst/cp/cp_reader.c +4 −2 Original line number Diff line number Diff line Loading @@ -1050,8 +1050,10 @@ extern SstStatusValue SstAdvanceStep(SstStream Stream, SstStepMode mode, Stream->ReaderTimestep = Entry->MetadataMsg->Timestep; SstFullMetadata Mdata = malloc(sizeof(struct _SstFullMetadata)); Mdata->WriterCohortSize = Entry->MetadataMsg->CohortSize; Mdata->WriterMetadata = malloc(sizeof(Mdata->WriterMetadata[0]) * Mdata->WriterCohortSize); for (int i = 0; i < Mdata->WriterCohortSize; i++) { Mdata->WriterMetadata = malloc(sizeof(Mdata->WriterMetadata[0]) * Mdata->WriterCohortSize); for (int i = 0; i < Mdata->WriterCohortSize; i++) { Mdata->WriterMetadata[i] = &Entry->MetadataMsg->Metadata[i]; } if (Stream->DP_Interface->TimestepInfoFormats == NULL) Loading
source/adios2/toolkit/sst/cp/cp_writer.c +10 −4 Original line number Diff line number Diff line Loading @@ -1316,15 +1316,21 @@ extern void SstInternalProvideTimestep( int NullCount = 0; for (int i = 0; i < Stream->CohortSize; i++) { if (pointers[i]->Metadata) { if (pointers[i]->Metadata) { Msg->Metadata[i] = *(pointers[i]->Metadata); } else { } else { Msg->Metadata[i].DataSize = 0; Msg->Metadata[i].block = NULL; } if (pointers[i]->AttributeData) { if (pointers[i]->AttributeData) { Msg->AttributeData[i] = *(pointers[i]->AttributeData); } else { } else { Msg->AttributeData[i].DataSize = 0; Msg->AttributeData[i].block = NULL; } Loading
source/adios2/toolkit/sst/cp/ffs_marshal.c +2 −2 Original line number Diff line number Diff line Loading @@ -1566,8 +1566,8 @@ static void BuildVarList(SstStream Stream, TSMetadataMsg MetaData, "NULL for WriterRank = %d\n", WriterRank); } FFSformat = FFSTypeHandle_from_encode( Stream->ReaderFFSContext, MetaData->Metadata[WriterRank].block); FFSformat = FFSTypeHandle_from_encode(Stream->ReaderFFSContext, MetaData->Metadata[WriterRank].block); if (!FFShas_conversion(FFSformat)) { Loading