Functions — github.com/YXG520/MIT6.824-6.5840

hub / github.com/YXG520/MIT6.824-6.5840 / functions

Functions548 in github.com/YXG520/MIT6.824-6.5840

⨍ Functions 548◇ Types & classes 106

↓ 2 callersFunctionnrand

()

src/kvraft/client.go:86

↓ 2 callersFunctionrandstring

(n int)

src/shardctrler/config.go:16

↓ 2 callersFunctionrandstring

(n int)

src/kvraft/config.go:22

↓ 2 callersFunctionrandstring

(n int)

src/raft/config.go:26

↓ 2 callersMethodrpcTotal

()

src/kvraft/config.go:396

↓ 2 callersMethodrpcTotal

()

src/raft/config.go:408

↓ 2 callersMethodset

(pos uint)

src/porcupine/bitset.go:29

↓ 2 callersFunctionspawn_clients_and_wait

spawn ncli clients and wait until they are all done

src/kvraft/test_test.go:116

↓ 2 callersMethodtryApply

(msg *ApplyMsg)

src/raft/util.go:89

↓ 2 callersFunctionusage

()

src/main/diskvd.go:25

↓ 2 callersFunctionusage

()

src/main/lockc.go:11

↓ 1 callersMethodAppendEntries

nextIndex常规收敛方法，经 go test -run 2B测试速度比优化后的算法慢5-10ss func (rf *Raft) AppendEntries2(targetServerId int, heart bool) { if rf.state != Leader { retur

src/raft/raft.go:405

↓ 1 callersMethodCondInstallSnapshot

(lastIncludedTerm int, lastIncludedIndex int, snapshot []byte)

src/raft/raft.go:280

↓ 1 callersMethodConfigDetectedLoop

ConfigDetectedLoop 配置检测

src/shardkv/server.go:246

↓ 1 callersMethodDisconnectClientUnlocked

caller should hold cfg.mu

src/shardctrler/config.go:212

↓ 1 callersMethodDisconnectClientUnlocked

caller should hold cfg.mu

src/kvraft/config.go:243

↓ 1 callersMethodEncodeValue

(value reflect.Value)

src/labgob/labgob.go:39

↓ 1 callersMethodGetRaftStateSize

()

src/raft/persister.go:87

↓ 1 callersMethodLeader

()

src/kvraft/config.go:329

↓ 1 callersMethodLogSize

Maximum log size across all servers

src/raft/config.go:665

↓ 1 callersMethodLongDelays

(yes bool)

src/labrpc/labrpc.go:199

↓ 1 callersMethodLongReordering

(yes bool)

src/labrpc/labrpc.go:192

↓ 1 callersFunctionMake

the service or tester wants to create a Raft server. the ports of all the Raft servers (including this one) are in peers[]. this server's port is peer

src/raft/raft.go:755

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/shardctrler/client.go:31

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/kvraft/client.go:18

↓ 1 callersFunctionMakeClerk

MakeClerk the tester calls MakeClerk. ctrlers[] is needed to call shardctrler.MakeClerk(). make_end(servername) turns a server name from a UpConfig.

src/shardkv/client.go:55

↓ 1 callersFunctionMakeClerk

the tester calls MakeClerk. ctrlers[] is needed to call shardctrler.MakeClerk(). make_end(servername) turns a server name from a Config.Groups[gid][

src/shardkv_with_bug/client.go:56

↓ 1 callersMethodMoveShard

(shardId int, GID int)

src/shardctrler/executeCmd.go:24

↓ 1 callersFunctionNewApplyHelper

(applyCh chan ApplyMsg, lastApplied int)

src/raft/util.go:57

↓ 1 callersFunctionNewLog

()

src/raft/log.go:18

↓ 1 callersFunctionNextValue

predict effect of Append(k, val) if old value is prev.

src/kvraft/test_test.go:133

↓ 1 callersMethodPersistSnapShot

------------------------------------------------------持久化快照部分----------------------------------------------------- PersistSnapShot Snapshot get snapsh

src/shardkv/server.go:485

↓ 1 callersMethodRebalanceShardsForJoin

(newGroups map[int][]string)

src/shardctrler/executeCmd.go:67

↓ 1 callersMethodRebalanceShardsForLeave

(removedGIDs []int)

src/shardctrler/executeCmd.go:141

↓ 1 callersFunctionRegister

(value interface{})

src/labgob/labgob.go:65

↓ 1 callersMethodSave

Save both Raft state and K/V snapshot as a single atomic action, to help avoid them getting out of sync.

src/raft/persister.go:59

↓ 1 callersMethodSaveRaftState

(state []byte)

src/raft/persister.go:51

↓ 1 callersMethodSaveStateAndSnapshot

Save both Raft state and K/V snapshot as a single atomic action, to help avoid them getting out of sync.

src/raft/persister.go:80

↓ 1 callersMethodShutdownServer

Shutdown a server by isolating it

src/kvraft/config.go:259

↓ 1 callersMethodStartCtrlerserver

(i int)

src/shardkv/config.go:270

↓ 1 callersMethodStartCtrlerserver

(i int)

src/shardkv_with_bug/config.go:270

↓ 1 callersMethodStartElection

()

src/raft/leader_election.go:13

↓ 1 callersFunctionStartKVServer

servers[] contains the ports of the set of servers that will cooperate via Raft to form the fault-tolerant key/value service. me is the index of the c

src/kvraft/server.go:54

↓ 1 callersFunctionStartServer

servers[] contains the ports of the set of servers that will cooperate via Raft to form the fault-tolerant shardctrler service. me is the index of the

src/shardctrler/server.go:367

↓ 1 callersFunctionStartServer

-------------------------------------------------初始化(Start)部分------------------------------------------------------ StartServer me is the index of the

src/shardkv/server.go:107

↓ 1 callersFunctionStartServer

servers[] contains the ports of the servers in this group. me is the index of the current server in servers[]. the k/v server should store snapshots

src/shardkv_with_bug/server.go:583

↓ 1 callersFunctionVisualize

(model Model, info linearizationInfo, output io.Writer)

src/porcupine/visualization.go:89

↓ 1 callersMethodaddShardHandler

(op Op)

src/shardkv/server.go:456

↓ 1 callersMethodaddShardHandler

(op Op)

src/shardkv_with_bug/reshard.go:42

↓ 1 callersMethodallReceived

()

src/shardkv/server.go:572

↓ 1 callersMethodallReceived

()

src/shardkv_with_bug/server.go:175

↓ 1 callersMethodallSent

()

src/shardkv/server.go:562

↓ 1 callersMethodallSent

()

src/shardkv_with_bug/server.go:161

↓ 1 callersMethodapplier

()

src/raft/util.go:74

↓ 1 callersMethodapplyMsgHandlerLoop

()

src/shardctrler/server.go:61

↓ 1 callersMethodapplyMsgHandlerLoop

()

src/kvraft/server.go:138

↓ 1 callersMethodapplyMsgHandlerLoop

------------------------------------------------------Loop部分-------------------------------------------------------- applyMsgHandlerLoop 处理applyCh发送过来

src/shardkv/server.go:147

↓ 1 callersMethodapplyMsgHandlerLoop

()

src/shardkv_with_bug/server.go:71

↓ 1 callersMethodbecomeCandidate

()

src/raft/leader_election.go:89

↓ 1 callersMethodbecomeLeader

()

src/raft/leader_election.go:96

↓ 1 callersFunctioncacheContains

(model Model, cache map[uint64][]cacheEntry, entry cacheEntry)

src/porcupine/checker.go:145

↓ 1 callersFunctioncall

send an RPC request to the coordinator, wait for the response. usually returns true. returns false if something goes wrong.

src/mr/worker.go:73

↓ 1 callersFunctioncheckConcurrentAppends

check that all known appends are present in a value, and are in order for each concurrent client.

src/kvraft/test_test.go:160

↓ 1 callersFunctioncheckDefault

warn if the value contains non-default values, as it would if one sent an RPC but the reply struct was already modified. if the RPC reply contains def

src/labgob/labgob.go:127

↓ 1 callersFunctioncheckDefault1

(value reflect.Value, depth int, name string)

src/labgob/labgob.go:134

↓ 1 callersMethodcheckNoLeader

check that none of the connected servers thinks it is the leader.

src/raft/config.go:479

↓ 1 callersFunctioncheckSingle

(model Model, history []entry, computePartial bool, kill *int32)

src/porcupine/checker.go:179

↓ 1 callersMethodcheckTimeout

()

src/shardctrler/config.go:47

↓ 1 callersMethodcheckTimeout

()

src/shardkv/config.go:72

↓ 1 callersMethodcheckTimeout

()

src/shardkv_with_bug/config.go:72

↓ 1 callersFunctioncheckType

(t reflect.Type)

src/labgob/labgob.go:79

↓ 1 callersMethodclear

(pos uint)

src/porcupine/bitset.go:35

↓ 1 callersMethodclone

()

src/porcupine/bitset.go:19

↓ 1 callersFunctioncomputeVisualizationData

(model Model, info linearizationInfo)

src/porcupine/visualization.go:33

↓ 1 callersFunctionconvertEntries

(events []Event)

src/porcupine/checker.go:108

↓ 1 callersMethoddeleteClient

(ck *Clerk)

src/kvraft/config.go:215

↓ 1 callersMethoddetectConfig

ConfigDetectedLoop 配置检测

src/shardkv_with_bug/server.go:227

↓ 1 callersMethoddispatch

(req reqMsg)

src/labrpc/labrpc.go:417

↓ 1 callersMethodequals

(b2 bitset)

src/porcupine/bitset.go:62

↓ 1 callersMethodexecJoinCmd

状态机执行join命令的时候

src/shardctrler/executeCmd.go:60

↓ 1 callersMethodexecLeaveCmd

状态机执行leave命令的时候

src/shardctrler/executeCmd.go:136

↓ 1 callersMethodexecMoveCmd

(op *Op)

src/shardctrler/executeCmd.go:21

↓ 1 callersMethodexecQueryCmd

浅拷贝

src/shardctrler/executeCmd.go:6

↓ 1 callersMethodifDuplicate

(clientId int64, seqId int)

src/shardctrler/server.go:50

↓ 1 callersMethodifDuplicate

判断是否是重复操作的也比较简单,因为我是对seq进行递增，所以直接比大小即可

src/kvraft/server.go:189

↓ 1 callersMethodifDuplicate

传入op的SeqId此次op

src/shardkv/server.go:543

↓ 1 callersMethodifDuplicate

判断是否是重复操作的也比较简单,因为我是对seq进行递增，所以直接比大小即可

src/shardkv_with_bug/server.go:310

↓ 1 callersMethodisNeedSnapshot

()

src/kvraft/snapshot.go:8

↓ 1 callersMethodisNeedSnapshot

()

src/shardkv_with_bug/snapshot.go:8

↓ 1 callersMethodkilled

()

src/raft/util.go:70

↓ 1 callersFunctionlength

(n *node)

src/porcupine/checker.go:83

↓ 1 callersFunctionlift

(entry *node)

src/porcupine/checker.go:159

↓ 1 callersFunctionloadPlugin

load the application Map and Reduce functions from a plugin file, e.g. ../mrapps/wc.so

src/main/mrsequential.go:91

↓ 1 callersFunctionloadPlugin

load the application Map and Reduce functions from a plugin file, e.g. ../mrapps/wc.so

src/main/mrworker.go:32

↓ 1 callersFunctionmakeEntries

(history []Operation)

src/porcupine/checker.go:48

↓ 1 callersFunctionmakeLinkedEntries

(entries []entry)

src/porcupine/checker.go:121

↓ 1 callersFunctionmakeSeed

()

src/kvraft/config.go:29

↓ 1 callersFunctionmakeSeed

()

src/raft/config.go:33

↓ 1 callersFunctionmakeSeed

()

src/shardkv/config.go:27

↓ 1 callersFunctionmakeSeed

()

src/shardkv_with_bug/config.go:27

← previous next →201–300 of 548, ranked by callers