Functions — github.com/Vanilla-Beauty/MIT6.5840

hub / github.com/Vanilla-Beauty/MIT6.5840 / functions

Functions443 in github.com/Vanilla-Beauty/MIT6.5840

⨍ Functions 443◇ Types & classes 93

↓ 1 callersFunctionReadSpecificFile

(targetNumber int, path string)

src/mr/utils.go:75

↓ 1 callersFunctionRegister

(value interface{})

src/labgob/labgob.go:58

↓ 1 callersFunctionRemoveGidServers

(me int, configs []Config, gids []int)

src/shardctrler/util.go:198

↓ 1 callersMethodSendHeartBeats

()

src/raft/raft.go:787

↓ 1 callersMethodShutdownServer

Shutdown a server by isolating it

src/kvraft/config.go:255

↓ 1 callersMethodStartCtrlerserver

(i int)

src/shardkv/config.go:270

↓ 1 callersFunctionStartKVServer

(servers []*labrpc.ClientEnd, me int, persister *raft.Persister, maxraftstate int)

src/kvraft/server.go:365

↓ 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:274

↓ 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/server.go:75

↓ 1 callersFunctionVisualize

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

src/porcupine/visualization.go:89

↓ 1 callersMethodadd_cache

(gid int, servers []string)

src/shardctrler/common.go:47

↓ 1 callersFunctioncacheContains

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

src/porcupine/checker.go:145

↓ 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:159

↓ 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 de

src/labgob/labgob.go:122

↓ 1 callersFunctioncheckDefault1

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

src/labgob/labgob.go:129

↓ 1 callersMethodcheckNoLeader

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

src/raft/config.go:484

↓ 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 callersFunctioncheckType

(t reflect.Type)

src/labgob/labgob.go:72

↓ 1 callersMethodclear

(pos uint)

src/porcupine/bitset.go:35

↓ 1 callersMethodclone

()

src/porcupine/bitset.go:19

↓ 1 callersMethodcollectVote

(serverTo int, args *RequestVoteArgs, muVote *sync.Mutex, voteCount *int)

src/raft/raft.go:983

↓ 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:211

↓ 1 callersMethoddispatch

(req reqMsg)

src/labrpc/labrpc.go:403

↓ 1 callersMethodequals

(b2 bitset)

src/porcupine/bitset.go:62

↓ 1 callersMethodhandleAppendEntries

(serverTo int, args *AppendEntriesArgs)

src/raft/raft.go:660

↓ 1 callersMethodhandleInstallSnapshot

(serverTo int)

src/raft/raft.go:454

↓ 1 callersFunctionihash

use ihash(key) % NReduce to choose the reduce task number for each KeyValue emitted by Map.

src/mr/worker.go:32

↓ 1 callersMethodinitTask

(files []string)

src/mr/coordinator.go:48

↓ 1 callersMethodkilled

()

src/shardctrler/server.go:195

↓ 1 callersMethodkilled

()

src/kvraft/server.go:247

↓ 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:26

↓ 1 callersFunctionmakeSeed

()

src/raft/config.go:37

↓ 1 callersFunctionmakeSeed

()

src/shardkv/config.go:27

↓ 1 callersMethodmake_partition

Partition servers into 2 groups and put current leader in minority

src/kvraft/config.go:339

↓ 1 callersMethodmove_cache

()

src/shardctrler/common.go:79

↓ 1 callersFunctionnewBitset

data layout: bits 0-63 are in data[0], the next are in data[1], etc.

src/porcupine/bitset.go:10

↓ 1 callersFunctionnparallel

(phase string)

src/mrapps/mtiming.go:19

↓ 1 callersFunctionnparallel

(phase string)

src/mrapps/rtiming.go:17

↓ 1 callersFunctionnrand

()

src/shardctrler/client.go:26

↓ 1 callersFunctionnrand

()

src/kvraft/client.go:22

↓ 1 callersFunctionpartitioner

repartition the servers periodically

src/kvraft/test_test.go:182

↓ 1 callersMethodpopcnt

()

src/porcupine/bitset.go:46

↓ 1 callersMethodprocessReq

(req reqMsg)

src/labrpc/labrpc.go:218

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/shardctrler/config.go:24

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/kvraft/config.go:34

↓ 1 callersMethodreadEndnameInfo

(endname interface{})

src/labrpc/labrpc.go:192

↓ 1 callersMethodreadPersist

restore previously persisted state.

src/raft/raft.go:171

↓ 1 callersMethodreadSnapshot

(data []byte)

src/raft/raft.go:205

↓ 1 callersMethodremove_cache

(gids []int)

src/shardctrler/common.go:57

↓ 1 callersMethodremove_group

(gids []int)

src/shardctrler/common.go:68

↓ 1 callersFunctionrenumber

(events []Event)

src/porcupine/checker.go:92

↓ 1 callersFunctionrun_client

a client runs the function f and then signals it is done

src/kvraft/test_test.go:105

↓ 1 callersMethodsendAppendEntries

(serverTo int, args *AppendEntriesArgs, reply *AppendEntriesReply)

src/raft/raft.go:535

↓ 1 callersMethodsendInstallSnapshot

(serverTo int, args *InstallSnapshotArgs, reply *InstallSnapshotReply)

src/raft/raft.go:368

↓ 1 callersMethodsendRequestVote

code to send a RequestVote RPC to a server. server is the index of the target server in rf.peers[]. expects RPC arguments in args. fills in *reply wit

src/raft/raft.go:887

↓ 1 callersMethodserver

start a thread that listens for RPCs from worker.go

src/mr/coordinator.go:218

↓ 1 callersMethodsetlongreordering

(longrel bool)

src/raft/config.go:422

↓ 1 callersMethodshardclerk

()

src/shardkv/config.go:292

↓ 1 callersMethodticker

()

src/raft/raft.go:1058

↓ 1 callersFunctionunlift

(entry *node)

src/porcupine/checker.go:169

↓ 1 callersFunctionusage

()

src/main/pbc.go:25

MethodAppend

(key string, value string)

src/kvraft/client.go:140

MethodAppendEntries

AppendEntries handler

src/raft/raft.go:541

MethodAskForTask

Your code here -- RPC handlers for the worker to call. an example RPC handler. the RPC argument and reply types are defined in rpc.go.

src/mr/coordinator.go:67

FunctionCheckEvents

(model Model, history []Event)

src/porcupine/porcupine.go:23

FunctionCheckEventsTimeout

timeout = 0 means no timeout if this operation times out, then a false positive is possible

src/porcupine/porcupine.go:30

FunctionCheckEventsVerbose

timeout = 0 means no timeout if this operation times out, then a false positive is possible

src/porcupine/porcupine.go:37

FunctionCheckOperations

(model Model, history []Operation)

src/porcupine/porcupine.go:5

FunctionCheckOperationsTimeout

timeout = 0 means no timeout if this operation times out, then a false positive is possible

src/porcupine/porcupine.go:12

FunctionCheckOperationsVerbose

timeout = 0 means no timeout if this operation times out, then a false positive is possible

src/porcupine/porcupine.go:19

MethodConnectClient

(ck *Clerk, to []int)

src/shardctrler/config.go:205

FunctionDefaultDescribeOperation

(input interface{}, output interface{})

src/porcupine/model.go:63

FunctionDefaultDescribeState

(state interface{})

src/porcupine/model.go:67

MethodDisconnectClient

(ck *Clerk, from []int)

src/shardctrler/config.go:221

MethodDisconnectClient

(ck *Clerk, from []int)

src/kvraft/config.go:248

MethodGet

(args *GetArgs, reply *GetReply)

src/kvraft/server.go:221

MethodGet

(args *GetArgs, reply *GetReply)

src/shardkv/server.go:31

MethodGetCount

get a server's count of incoming RPCs.

src/labrpc/labrpc.go:364

MethodHandler1

(args string, reply *int)

src/labrpc/test_test.go:23

MethodHandler2

(args int, reply *string)

src/labrpc/test_test.go:30

MethodHandler3

(args int, reply *int)

src/labrpc/test_test.go:37

MethodHandler4

args is a pointer

src/labrpc/test_test.go:45

MethodHandler5

args is a not pointer

src/labrpc/test_test.go:50

MethodHandler6

(args string, reply *int)

src/labrpc/test_test.go:54

MethodHandler7

(args int, reply *string)

src/labrpc/test_test.go:60

MethodInstallSnapshot

InstallSnapshot handler

src/raft/raft.go:374

MethodJoin

(args *JoinArgs, reply *JoinReply)

src/shardctrler/server.go:147

MethodLeave

(args *LeaveArgs, reply *LeaveReply)

src/shardctrler/server.go:156

MethodLen

for sorting by key.

src/main/mrsequential.go:21

MethodLen

for sorting by key.

src/mr/worker.go:26

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