Skip to content

Commit

Permalink
Run clang-format
Browse files Browse the repository at this point in the history
  • Loading branch information
hououou committed Apr 8, 2024
1 parent b531374 commit ad1d859
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 18 deletions.
32 changes: 16 additions & 16 deletions src/storage/store/list_column.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -343,8 +343,8 @@ void ListColumn::prepareCommitForChunk(Transaction* transaction, node_group_idx_
auto currentNumNodeGroups = metadataDA->getNumElements(transaction->getType());
auto isNewNodeGroup = nodeGroupIdx >= currentNumNodeGroups;
if (isNewNodeGroup) {
commitColumnChunkOutOfPlace(
transaction, nodeGroupIdx, isNewNodeGroup, dstOffsets, chunk, startSrcOffset);
commitColumnChunkOutOfPlace(transaction, nodeGroupIdx, isNewNodeGroup, dstOffsets, chunk,
startSrcOffset);
return;
}
// we first check if we can in place commit data column chunk
Expand All @@ -363,16 +363,16 @@ void ListColumn::prepareCommitForChunk(Transaction* transaction, node_group_idx_
dstOffsetsInDataColumn.push_back(dataColumnSize + dataSize++);
}
}
bool dataColumnCanCommitInPlace = dataColumn->canCommitInPlace(
transaction, nodeGroupIdx, dstOffsetsInDataColumn, dataColumnChunk, startListOffset);
bool dataColumnCanCommitInPlace = dataColumn->canCommitInPlace(transaction, nodeGroupIdx,
dstOffsetsInDataColumn, dataColumnChunk, startListOffset);
if (!dataColumnCanCommitInPlace) {
commitColumnChunkOutOfPlace(
transaction, nodeGroupIdx, isNewNodeGroup, dstOffsets, chunk, startSrcOffset);
commitColumnChunkOutOfPlace(transaction, nodeGroupIdx, isNewNodeGroup, dstOffsets, chunk,
startSrcOffset);
} else {
dataColumn->commitColumnChunkOutOfPlace(
transaction, nodeGroupIdx, isNewNodeGroup, dstOffsetsInDataColumn, dataColumnChunk, startListOffset);
sizeColumn->prepareCommitForChunk(
transaction, nodeGroupIdx, dstOffsets, listChunk->getSizeColumnChunk(), startSrcOffset);
dataColumn->commitColumnChunkOutOfPlace(transaction, nodeGroupIdx, isNewNodeGroup,
dstOffsetsInDataColumn, dataColumnChunk, startListOffset);
sizeColumn->prepareCommitForChunk(transaction, nodeGroupIdx, dstOffsets,
listChunk->getSizeColumnChunk(), startSrcOffset);
for (auto i = 0u; i < numListsToAppend; i++) {
auto listEndOffset = listChunk->getListEndOffset(startSrcOffset + i);
chunk->setValue<offset_t>(dataColumnSize + listEndOffset, startSrcOffset + i);
Expand All @@ -390,14 +390,14 @@ void ListColumn::prepareCommitForOffsetChunk(Transaction* transaction,
commitOffsetColumnChunkInPlace(nodeGroupIdx, dstOffsets, chunk, startSrcOffset);
didInPlaceCommit = true;
} else {
commitOffsetColumnChunkOutOfPlace(
transaction, nodeGroupIdx, dstOffsets, chunk, startSrcOffset);
commitOffsetColumnChunkOutOfPlace(transaction, nodeGroupIdx, dstOffsets, chunk,
startSrcOffset);
}
if (nullColumn) {
if (nullColumn->canCommitInPlace(
transaction, nodeGroupIdx, dstOffsets, chunk->getNullChunk(), startSrcOffset)) {
nullColumn->commitColumnChunkInPlace(
nodeGroupIdx, dstOffsets, chunk->getNullChunk(), startSrcOffset);
if (nullColumn->canCommitInPlace(transaction, nodeGroupIdx, dstOffsets,
chunk->getNullChunk(), startSrcOffset)) {
nullColumn->commitColumnChunkInPlace(nodeGroupIdx, dstOffsets, chunk->getNullChunk(),
startSrcOffset);
} else if (didInPlaceCommit) {
nullColumn->commitColumnChunkOutOfPlace(transaction, nodeGroupIdx, false, dstOffsets,
chunk->getNullChunk(), startSrcOffset);
Expand Down
4 changes: 2 additions & 2 deletions src/storage/store/list_column_chunk.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -165,8 +165,8 @@ void ListColumnChunk::lookup(offset_t offsetInChunk, ValueVector& output,
ListVector::resizeDataVector(&output, currentListDataSize + listSize);
// TODO(Guodong): Should add `scan` interface and use `scan` here.
for (auto i = 0u; i < listSize; i++) {
listDataColumnChunk->dataColumnChunk->lookup(
startOffset + i, *dataVector, currentListDataSize + i);
listDataColumnChunk->dataColumnChunk->lookup(startOffset + i, *dataVector,
currentListDataSize + i);
}
// reset offset
output.setValue<list_entry_t>(posInOutputVector, list_entry_t{currentListDataSize, listSize});
Expand Down

0 comments on commit ad1d859

Please sign in to comment.