oceanbase
-- mode:org --
- rootserver module for oceanbase 1.0.
** thread model
*** independent thread rootservice has indenpendent threads
- ObRootBalancer: Load balancing
- ObLeaderCoordinator: Leader coordinating
- ObHeartbeatChecker: Heartbeat detection, high time precision, independent thread work
- ObEventHistoryTableOperator::ObDedupQueue: event_history asynchronous update task queue
- ObRootService::task_queue.task_queue: Asynchronous task queue, the number of threads can be configured, the default is 4
- ObRootService::task_queue.timer_: timer thread
- ObMajorFreezeLauncher: Major freeze
- ObDailyMergeScheduler: Daily merge
*** Timer and asynchronous tasks
Timer and asynchronous tasks are performed by the ObRootService::task_queue_.
**** Timertask
All timed tasks are AsyncTimerTask. When triggered, an asynchronous task is generated, which can be executed quickly without blocking the timer thread.
- ObRestartTask : async task after restart
- ObRefreshServerTask : refresh server list after startup
- ObEventTableClearTask : regular cleaning event_table
- ObCheckServerTask : regular check server_status in memory are same with __all_server table, if not, a ObAllServerTask will be generated
- ObInnerTableMonitorTask : regular cleaning schema_table
**** asynchronous tasks
Rootservice has the following asynchronous tasks, which are executed by the ObRootService::ObAsyncTaskQueue. Asynchronous task supports retrying when execution fails.
- ObUpdateRsListTask : Update rslist metadata asynchronously and will retry until success
- ObAllServerTask : check and update server status in memory, ensure it is same with __all_server
** ObRootBalancer The load balancing module performs background tasks such as load balancing and replica supplement in the whole cluster. It includes the following components:
*** ObRootBalancer (ob_root_balancer.h) Background thread, entry class, drive the operation of other policy modules.
*** TenantBalanceInfo (ob_balance_info.h) The data structure class records all kinds of cross reference decoupling among zone, server, unit, partition and replica, and provides query interface for algorithm implementation of each policy module of load balancing. The gather_stat method is used to initialize the data structure
*** ObUnitBalance (ob_unit_balancer.h) Load balancing main policy class.
*** ObPartitionGroupCoordinator (ob_partition_group_coordinator.h) Implementation of partition group and unit group scheduling strategy
*** ObRereplication (ob_rereplication.h)
- if the replica num of partition less than define, it will generate add_replica task
*** ObServerChecker (ob_server_checker.h) It has nothing to do with load balancing
- The delete server function needs to migrate the replicas in the background. This class is responsible for checking whether the server can be safely deleted and marked in the background.
- If the machine is offline, drive EmptyServerChecker to check