登录免费注册



Scheduler

首页  思维导图  详情



Scheduler

2017-01-08 18:56:25   0  举报





仅支持查看

AI智能生成

StoreHandler

StoreHandler

模版推荐

作者其他创作

大纲/内容

Scheduler

notify

Msg::Quit

Scheduler::shutdown

Msg::RawCmd

Scheduler::on_receive_new_cmd

Scheduler::schedule_command

Scheduler::insert_ctx，将请求上下文保存到cmd_ctxs中

Scheduler::lock_and_get_snapshot

Scheduler::acquire_lock,获取到lock，执行下一步，否则插入到等待队列中

Scheduler::get_snapshot

RaftKv.async_snapshot

Msg::SnapshotFinished

Scheduler::on_snapshot_finished

Scheduler::process_by_worker

process_read,处理只读命令

Command::Get

SnapshotStore::get

ProcessResult::Value 

<div>ReadFinished</div>

发送到Scheduler.channel

Command::BatchGet

SnapshotStore::batch_get

ProcessResult::MultiKvpairs

ReadFinished

发送到Scheduler.channel

Command::Scan

SnapshotStore::scanner

ProcessResult::MultiKvpairs

ReadFinished

发送到Scheduler.channel

Command::ScanLock

MvccReader::new

MvccReader::scan_lock

Command::ResolveLock

MvccReader::new

MvccReader::scan_lock

Command::Gc

MvccReader::new

MvccReader::scan_keys

发送Msg::ReadFinished

process_write，处理写命令

Scheduler::process_write_impl

Command::Prewrite

MvccTxn::new

MvccTxn::prewrite

Command::Commit

MvccTxn::new

MvccTxn::commit

Command::Cleanup

MvccTxn::new

MvccTxn::rollback

Command::Rollback

MvccTxn::new

MvccTxn::rollback

Command::ResolveLock

MvccTxn::new

Command::Gc

MvccTxn::new

MvccTxn::gc

发送Msg::WritePrepareFinished

Msg::ReadFinished

Scheduler::on_read_finished

根据cid删除请求上下文，remove_ctx

判断执行结果是否是ProcessResult::NextCommand 

是

调度执行下一个命令，Scheduler::schedule_command

不是

执行最终的回调函数，execute_callback，参数是StorageCb，ProcessResult

StorageCb::Boolean

ProcessResult::Res 

StorageCb::Booleans

ProcessResult::MultiRes

StorageCb::SingleValue

ProcessResult::Value

StorageCb::KvPairs

ProcessResult::MultiKvpairs

StorageCb::Locks

ProcessResult::Locks

释放锁，Scheduler::release_lock

Msg::WritePrepareFinished

Scheduler::on_write_prepare_finished

Msg::WritePrepareFailed

Scheduler::on_write_prepare_failed

Msg::WriteFinished

Scheduler::on_write_finished

tick

 Collect

Get Started

scheduler

 Collect

Get Started

scheduler

 Collect

Get Started

Spark stack

 Collect

Get Started

运行过程













评论

0 条评论

下一页



图形选择

思维导图

主题

补充说明

AI生成





修改AI描述

去编辑

重新生成

提示 

关闭后当前内容将不会保存，是否继续？

取消

确定

Document