diff --git a/src/share/rpc/ob_batch_proxy.h b/src/share/rpc/ob_batch_proxy.h index 7dfb4208fe..fb448a3328 100644 --- a/src/share/rpc/ob_batch_proxy.h +++ b/src/share/rpc/ob_batch_proxy.h @@ -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; }