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

[INC SS][master] placeholder for sswriter of incremantal shared storage

Browse Source
This commit is contained in:
jw-guo 2024-11-19 13:44:39 +00:00 committed by ob-robot
parent 8aff09f2cd
commit 7088e3d372
4 changed files with 13 additions and 2 deletions
Show Stats 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

@ -29,7 +29,7 @@ LATCH_DEF_##enable(def, id, name, policy, max_spin_cnt, max_yield_cnt)
#undef LATCH_DEF_true
#undef LATCH_DEF_false
static_assert(ARRAYSIZEOF(OB_LATCHES) == 253, "DO NOT delete latch defination");
static_assert(ARRAYSIZEOF(OB_LATCHES) == 254, "DO NOT delete latch defination");
static_assert(ObLatchIds::LATCH_END == ARRAYSIZEOF(OB_LATCHES) - 1, "update id of LATCH_END before adding your defination");
}

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

@ -379,8 +379,9 @@ LATCH_DEF(DAG_PRIO_SCHEDULER, 344, "dag prio scheduler lock", LATCH_FIFO, 2000,
LATCH_DEF(LS_RESERVED_SNAPSHOT_LOCK, 345, "ls reserved snapshot lock", LATCH_FIFO, 2000, 0, true)
LATCH_DEF(STORAGE_CLOG_RECORDER_LOCK, 346, "storage clog recorder lock", LATCH_FIFO, 2000, 0, true)
LATCH_DEF(SPM_SET_LOCK, 347, "spm set latch", LATCH_FIFO, 2000, 0, true)
LATCH_DEF(SSWRITER_CTX_LOCK, 348, "sswriter ctx lock", LATCH_FIFO, 2000, 0, true)
LATCH_DEF(LATCH_END, 348, "latch end", LATCH_FIFO, 2000, 0, true)
LATCH_DEF(LATCH_END, 349, "latch end", LATCH_FIFO, 2000, 0, true)
#endif

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

@ -1220,6 +1220,8 @@ PCODE_DEF(OB_DEL_SS_TABLET_MICRO, 0x1638)
//PCODE_DEF(OB_ADMIN_ALTER_LS, 0x163A)
PCODE_DEF(OB_SET_SS_CKPT_COMPRESSOR, 0x163B)
//PCODE_DEF(OB_BROADCAST_CONFIG_VERSION, 0x163C)
//PCODE_DEF(OB_SSWRITER_GRANT, 0x163D)
//PCODE_DEF(OB_SSWRITER_LEASE_REQ, 0x163E)
//**** 注意：在此行之前增加新的RPC ID ******
//
//占位须知：

8
src/logservice/ob_log_base_type.h
View File

@ -160,6 +160,10 @@ enum ObLogBaseType
// for DBMS_SCHEDULER GC
DBMS_SCHEDULER_GC_LOG_BASE_TYPE = 50,
#ifdef OB_BUILD_SHARED_STORAGE
// for sswriter of shared storage
SHARED_STORAGE_SSWRITER_LOG_BASE_TYPE = 51,
#endif
// pay attention!!!
// add log type in log_base_type_to_string
@ -283,6 +287,10 @@ int log_base_type_to_string(const ObLogBaseType log_type,
strncpy(str ,"DBMS_SCHEDULER", str_len);
} else if (log_type == DBMS_SCHEDULER_GC_LOG_BASE_TYPE) {
strncpy(str ,"DBMS_SCHEDULER_GC", str_len);
#ifdef OB_BUILD_SHARED_STORAGE
} else if (log_type == SHARED_STORAGE_SSWRITER_LOG_BASE_TYPE) {
strncpy(str ,"SHARED_STORAGE_SSWRITER", str_len);
#endif
} else {
ret = OB_INVALID_ARGUMENT;
}