hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

revert batch rpc thread optimization

Browse Source
This commit is contained in:
obdev
2023-06-08 04:53:45 +00:00
committed by ob-robot
parent 60cef12e3e
commit 5efdb4800d
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/share/rpc/ob_batch_proxy.h
View File

@ -23,32 +23,32 @@ namespace oceanbase
namespace obrpc
{
enum {
TRX_BATCH_REQ_NODELAY = 0,
BATCH_REQ_TYPE_COUNT = 1,
ELECTION_BATCH_REQ,
ELECTION_GROUP_BATCH_REQ,
CLOG_BATCH_REQ,
CLOG_BATCH_REQ_NODELAY,
SQL_BATCH_REQ_NODELAY1,
SQL_BATCH_REQ_NODELAY2,
CLOG_BATCH_REQ_NODELAY2
ELECTION_BATCH_REQ = 0,
ELECTION_GROUP_BATCH_REQ = 1,
CLOG_BATCH_REQ = 2,
CLOG_BATCH_REQ_NODELAY = 3,
TRX_BATCH_REQ_NODELAY = 4,
SQL_BATCH_REQ_NODELAY1 = 5,
SQL_BATCH_REQ_NODELAY2 = 6,
CLOG_BATCH_REQ_NODELAY2 = 7,
BATCH_REQ_TYPE_COUNT = 8
};
inline int64_t get_batch_delay_us(const int batch_type)
{
int64_t delay[BATCH_REQ_TYPE_COUNT] = {0};
int64_t delay[BATCH_REQ_TYPE_COUNT] = {2 * 1000, 2 * 1000, 1 * 1000, 0, 0, 0, 0, 0};
return (batch_type >= 0 && batch_type < BATCH_REQ_TYPE_COUNT) ? delay[batch_type]: 0;
}
inline int64_t get_batch_buffer_size(const int batch_type)
{
int64_t batch_buffer_size_k[BATCH_REQ_TYPE_COUNT] = {256};
int64_t batch_buffer_size_k[BATCH_REQ_TYPE_COUNT] = {256, 256, 2048, 2048, 256, 256, 256, 2048};
return batch_buffer_size_k[batch_type] * 1024;
}
inline bool is_hp_rpc(const int batch_type)
{
static const bool hp_rpc_map[BATCH_REQ_TYPE_COUNT] = {false};
static const bool hp_rpc_map[BATCH_REQ_TYPE_COUNT] = {true, true, false, false, false, false, false, false};
return (batch_type >= 0 && batch_type < BATCH_REQ_TYPE_COUNT) ? hp_rpc_map[batch_type] : false;
}