hcq/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!3177 移除buildLocalStreamContext中不必要的palloc0调用

Browse Source 
Merge pull request !3177 from xiyanziran/master_unusedinit
This commit is contained in:
opengauss-bot
2023-05-24 01:57:49 +00:00
committed by Gitee
parent f120bdefa1 1971a993e8
commit 53a4a65834
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/gausskernel/process/stream/execStream.cpp
View File

@ -352,13 +352,13 @@ static StreamSharedContext* buildLocalStreamContext(Stream* streamNode, PlannedS
scanLoc = (int*)palloc0(sizeof(int) * consumerNum);
/* Init data status. */
dataStatus = (DataStatus**)palloc0(sizeof(DataStatus*) * consumerNum);
is_connect_end = (bool**)palloc0(sizeof(bool*) * consumerNum);
messages = (StringInfo**)palloc0(sizeof(StringInfo*) * consumerNum);
dataStatus = (DataStatus**)palloc(sizeof(DataStatus*) * consumerNum);
is_connect_end = (bool**)palloc(sizeof(bool*) * consumerNum);
messages = (StringInfo**)palloc(sizeof(StringInfo*) * consumerNum);
for (int i = 0; i < consumerNum; i++) {
dataStatus[i] = (DataStatus*)palloc0(sizeof(DataStatus) * producerNum);
is_connect_end[i] = (bool*)palloc0(sizeof(bool) * producerNum);
messages[i] = (StringInfo*)palloc0(sizeof(StringInfo) * producerNum);
dataStatus[i] = (DataStatus*)palloc(sizeof(DataStatus) * producerNum);
is_connect_end[i] = (bool*)palloc(sizeof(bool) * producerNum);
messages[i] = (StringInfo*)palloc(sizeof(StringInfo) * producerNum);
for (int j = 0; j < producerNum; j++) {
dataStatus[i][j] = DATA_EMPTY;
is_connect_end[i][j] = false;
@ -369,12 +369,12 @@ static StreamSharedContext* buildLocalStreamContext(Stream* streamNode, PlannedS
/* Init shared batches or tuples */
if (IsA((Plan*)streamNode, VecStream)) {
sharedBatches = (VectorBatch***)palloc0(sizeof(VectorBatch**) * consumerNum);
sharedBatches = (VectorBatch***)palloc(sizeof(VectorBatch**) * consumerNum);
for (int i = 0; i < consumerNum; i++) {
sharedBatches[i] = (VectorBatch**)palloc0(sizeof(VectorBatch*) * producerNum);
}
} else {
sharedTuples = (TupleVector***)palloc0(sizeof(TupleVector**) * consumerNum);
sharedTuples = (TupleVector***)palloc(sizeof(TupleVector**) * consumerNum);
for (int i = 0; i < consumerNum; i++) {
sharedTuples[i] = (TupleVector**)palloc0(sizeof(TupleVector*) * producerNum);
}

2
src/gausskernel/process/stream/streamProducer.cpp
View File

@ -1816,7 +1816,7 @@ void StreamProducer::initSharedContext()
/* Init tuples. */
for (int i = 0; i < m_connNum; i++) {
TupleVector* TupleVec = (TupleVector*)palloc0(sizeof(TupleVector));
TupleVec->tupleVector = (TupleTableSlot**)palloc0(sizeof(TupleTableSlot*) * TupleVectorMaxSize);
TupleVec->tupleVector = (TupleTableSlot**)palloc(sizeof(TupleTableSlot*) * TupleVectorMaxSize);
m_sharedContext->sharedTuples[i][u_sess->stream_cxt.smp_id] = TupleVec;
for (int j = 0; j < TupleVectorMaxSize; j++) {