database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-07-29 08:21:15 +03:00
Code Activity

This patch disables OOB pool in PP

Browse Source
This commit is contained in:
Roman Nozdrin
2022-07-01 12:31:04 +00:00
committed by Roman Nozdrin
parent a3c582d9fe
commit 2c2e1f9924
2 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
primitives/primproc/bppseeder.cpp
View File

@ -1,5 +1,5 @@
/* Copyright (C) 2014 InfiniDB, Inc. /* Copyright (C) 2014 InfiniDB, Inc.
Copyright (C) 2016 MariaDB Corporation Copyright (C) 2016-22 MariaDB Corporation
This program is free software; you can redistribute it and/or This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License modify it under the terms of the GNU General Public License

14
primitives/primproc/primitiveserver.cpp
View File

@ -2084,6 +2084,7 @@ struct ReadThread
} }
else if (ismHdr->Command == BATCH_PRIMITIVE_DESTROY) else if (ismHdr->Command == BATCH_PRIMITIVE_DESTROY)
{ {
id = fBPPHandler->getUniqueID(bs, ismHdr->Command);
functor.reset(new BPPHandler::Destroy(fBPPHandler, bs)); functor.reset(new BPPHandler::Destroy(fBPPHandler, bs));
} }
else if (ismHdr->Command == BATCH_PRIMITIVE_ABORT) else if (ismHdr->Command == BATCH_PRIMITIVE_ABORT)
@ -2092,7 +2093,7 @@ struct ReadThread
functor.reset(new BPPHandler::Abort(fBPPHandler, bs)); functor.reset(new BPPHandler::Abort(fBPPHandler, bs));
} }
FairThreadPool::Job job(uniqueID, stepID, txnId, functor, outIos, weight, priority, id); FairThreadPool::Job job(uniqueID, stepID, txnId, functor, outIos, weight, priority, id);
OOBPool->addJob(job); procPoolPtr->addJob(job);
break; break;
} }
@ -2107,7 +2108,6 @@ struct ReadThread
uint32_t txnId = 0; uint32_t txnId = 0;
uint32_t stepID = 0; uint32_t stepID = 0;
uint32_t uniqueID = 0; uint32_t uniqueID = 0;
bool isSyscat = false;
if (bRotateDest) if (bRotateDest)
{ {
@ -2157,15 +2157,7 @@ struct ReadThread
isSyscat = bpps->isSysCat(); isSyscat = bpps->isSysCat();
} }
FairThreadPool::Job job(uniqueID, stepID, txnId, functor, outIos, weight, priority, id); FairThreadPool::Job job(uniqueID, stepID, txnId, functor, outIos, weight, priority, id);
procPoolPtr->addJob(job);
if (isSyscat)
{
OOBPool->addJob(job);
}
else
{
procPoolPtr->addJob(job);
}
break; break;
} }