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

direct load resource manage placeholder

Browse Source
This commit is contained in:
obdev
2023-11-13 09:43:08 +00:00
committed by ob-robot
parent 82f50094b7
commit 6fcd3d2020
5 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
deps/oblib/src/lib/stat/ob_latch_define.cpp vendored
View File

@ -22,7 +22,7 @@ const ObLatchDesc OB_LATCHES[] __attribute__ ((init_priority(102))) = {
#undef LATCH_DEF #undef LATCH_DEF
}; };
static_assert(ARRAYSIZEOF(OB_LATCHES) == 316, "DO NOT delete latch defination"); static_assert(ARRAYSIZEOF(OB_LATCHES) == 318, "DO NOT delete latch defination");
static_assert(ObLatchIds::LATCH_END == ARRAYSIZEOF(OB_LATCHES) - 1, "update id of LATCH_END before adding your defination"); static_assert(ObLatchIds::LATCH_END == ARRAYSIZEOF(OB_LATCHES) - 1, "update id of LATCH_END before adding your defination");
} }

4
deps/oblib/src/lib/stat/ob_latch_define.h vendored
View File

@ -330,8 +330,10 @@ LATCH_DEF(MDS_TABLE_HANDLER_LOCK, 311, "mds table handler lock", LATCH_READ_PREF
LATCH_DEF(IND_NAME_CACHE_LOCK, 312, "index name cache lock", LATCH_FIFO, 2000, 0) LATCH_DEF(IND_NAME_CACHE_LOCK, 312, "index name cache lock", LATCH_FIFO, 2000, 0)
LATCH_DEF(COMPACTION_DIAGNOSE_LOCK, 313, "compaction diagnose lock", LATCH_READ_PREFER, 2000, 0) LATCH_DEF(COMPACTION_DIAGNOSE_LOCK, 313, "compaction diagnose lock", LATCH_READ_PREFER, 2000, 0)
LATCH_DEF(OB_MAJOR_MERGE_INFO_MANAGER_LOCK, 314, "major merge info manager lock", LATCH_FIFO, 2000, 0) LATCH_DEF(OB_MAJOR_MERGE_INFO_MANAGER_LOCK, 314, "major merge info manager lock", LATCH_FIFO, 2000, 0)
LATCH_DEF(RESOURCE_SERVICE_LOCK, 315, "resource service lock", LATCH_READ_PREFER, 2000, 0)
LATCH_DEF(RESOURCE_SERVICE_SWITCH_LOCK, 316, "resource service switch lock", LATCH_FIFO, 2000, 0)
LATCH_DEF(LATCH_END, 315, "latch end", LATCH_FIFO, 2000, 0) LATCH_DEF(LATCH_END, 317, "latch end", LATCH_FIFO, 2000, 0)
#endif #endif

2
deps/oblib/src/lib/wait_event/ob_wait_event.h vendored
View File

@ -86,6 +86,8 @@ WAIT_EVENT_DEF(PX_LOOP_COND_WAIT, 15160, "px loop condition wait", "address", ""
WAIT_EVENT_DEF(SQL_SHARED_HJ_COND_WAIT, 15165, "shared hash join cond wait", "address", "", "", CONCURRENCY, true) WAIT_EVENT_DEF(SQL_SHARED_HJ_COND_WAIT, 15165, "shared hash join cond wait", "address", "", "", CONCURRENCY, true)
WAIT_EVENT_DEF(TENANT_IO_POOL_WAIT, 15261, "rwlock: tenant io pool wait", "address", "number", "tries", CONCURRENCY, true) WAIT_EVENT_DEF(TENANT_IO_POOL_WAIT, 15261, "rwlock: tenant io pool wait", "address", "number", "tries", CONCURRENCY, true)
WAIT_EVENT_DEF(DISPLAY_TASKS_LOCK_WAIT, 15262, "latch: display tasks lock wait", "address", "number", "tries", CONCURRENCY, true) WAIT_EVENT_DEF(DISPLAY_TASKS_LOCK_WAIT, 15262, "latch: display tasks lock wait", "address", "number", "tries", CONCURRENCY, true)
WAIT_EVENT_DEF(RESOURCE_SERVICE_LOCK_WAIT, 15263, "latch: resource_service lock wait", "address", "number", "tries", CONCURRENCY, true)
WAIT_EVENT_DEF(RESOURCE_SERVICE_SWITCH_LOCK_WAIT, 15264, "latch:resource_service switch lock wait", "address", "number", "tries", CONCURRENCY, true)
WAIT_EVENT_DEF(END_TRANS_WAIT, 16001, "wait end trans", "rollback", "trans_hash_value", "participant_count", COMMIT,false) WAIT_EVENT_DEF(END_TRANS_WAIT, 16001, "wait end trans", "rollback", "trans_hash_value", "participant_count", COMMIT,false)
WAIT_EVENT_DEF(START_STMT_WAIT, 16002, "wait start stmt", "trans_hash_value", "physic_plan_type", "participant_count", CLUSTER, false) WAIT_EVENT_DEF(START_STMT_WAIT, 16002, "wait start stmt", "trans_hash_value", "physic_plan_type", "participant_count", CLUSTER, false)
WAIT_EVENT_DEF(END_STMT_WAIT, 16003, "wait end stmt", "rollback", "trans_hash_value", "physic_plan_type", CLUSTER, false) WAIT_EVENT_DEF(END_STMT_WAIT, 16003, "wait end stmt", "rollback", "trans_hash_value", "physic_plan_type", CLUSTER, false)

3
deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h vendored
View File

@ -1082,3 +1082,6 @@ PCODE_DEF(OB_DIRECT_LOAD_CONTROL, 0x1604)
// update materialized view table status // update materialized view table status
// PCODE_DEF(OB_UPDATE_MVIEW_TABLE_STATUS, 0x1612) // PCODE_DEF(OB_UPDATE_MVIEW_TABLE_STATUS, 0x1612)
// for direct load resource
// PCODE_DEF(OB_DIRECT_LOAD_RESOURCE, 0x1613)

5
src/logservice/ob_log_base_type.h
View File

@ -125,6 +125,9 @@ enum ObLogBaseType
// for workload repository service // for workload repository service
WORKLOAD_REPOSITORY_SERVICE_LOG_BASE_TYPE = 38, WORKLOAD_REPOSITORY_SERVICE_LOG_BASE_TYPE = 38,
TTL_LOG_BASE_TYPE = 39, TTL_LOG_BASE_TYPE = 39,
// for table load resource manager
TABLE_LOAD_RESOURCE_SERVICE_LOG_BASE_TYPE = 40,
// pay attention!!! // pay attention!!!
// add log type in log_base_type_to_string // add log type in log_base_type_to_string
// max value // max value
@ -219,6 +222,8 @@ int log_base_type_to_string(const ObLogBaseType log_type,
strncpy(str ,"WORKLOAD_REPOSITORY_SERVICE", str_len); strncpy(str ,"WORKLOAD_REPOSITORY_SERVICE", str_len);
} else if (log_type == TTL_LOG_BASE_TYPE) { } else if (log_type == TTL_LOG_BASE_TYPE) {
strncpy(str ,"TTL_SERVICE", str_len); strncpy(str ,"TTL_SERVICE", str_len);
} else if (log_type == TABLE_LOAD_RESOURCE_SERVICE_LOG_BASE_TYPE) {
strncpy(str ,"TABLE_LOAD_RESOURCE_SERVICE", str_len);
} else { } else {
ret = OB_INVALID_ARGUMENT; ret = OB_INVALID_ARGUMENT;
} }