Functions — github.com/AdrianHsu/MIT-6.824-Lab

hub / github.com/AdrianHsu/MIT-6.824-Lab / functions

Functions418 in github.com/AdrianHsu/MIT-6.824-Lab

⨍ Functions 418◇ Types & classes 121

↓ 2 callersMethodisunreliable

()

hw4/src/kvpaxos/server.go:189

↓ 2 callersMethodisunreliable

()

hw4/src/shardkv/server.go:482

↓ 2 callersMethodisunreliable

()

hw4/src/pbservice/server.go:77

↓ 2 callersMethodisunreliable

()

hw2/src/pbservice/server.go:305

↓ 2 callersMethodisunreliable

()

hw3/src/paxos/paxos.go:593

↓ 2 callersMethodisunreliable

()

hw3/src/kvpaxos/server.go:246

↓ 2 callersMethodisunreliable

()

hw3/src/pbservice/server.go:77

↓ 2 callersMethodkill

tell the server to shut itself down. please do not change these two functions.

hw4/src/kvpaxos/server.go:168

↓ 2 callersMethodkill

tell the server to shut itself down. please do not change these two functions.

hw3/src/kvpaxos/server.go:225

↓ 2 callersMethodleave

(gi int)

hw4/src/shardkv/test_test.go:81

↓ 2 callersFunctionnrand

()

hw3/src/kvpaxos/client.go:17

↓ 2 callersFunctionport

(tag string, host int)

hw4/src/shardkv/test_test.go:32

↓ 2 callersFunctionproxy

(t *testing.T, port string, delay *int32)

hw4/src/pbservice/test_test.go:890

↓ 2 callersFunctionproxy

(t *testing.T, port string, delay *int32)

hw2/src/pbservice/test_test.go:896

↓ 2 callersFunctionproxy

(t *testing.T, port string, delay *int32)

hw3/src/pbservice/test_test.go:890

↓ 2 callersMethodsetunreliable

please do not change these two functions.

hw4/src/kvpaxos/server.go:181

↓ 2 callersMethodsetunreliable

please do not change these two functions.

hw3/src/kvpaxos/server.go:238

↓ 2 callersMethodshardclerk

()

hw4/src/shardkv/test_test.go:69

↓ 1 callersMethodAcceptorAccept

added by Adrian acceptor's accept(n, v) handler

hw4/src/paxos/paxos.go:384

↓ 1 callersMethodAcceptorAccept

added by Adrian acceptor's accept(n, v) handler

hw3/src/paxos/paxos.go:384

↓ 1 callersMethodAcceptorDecided

added by Adrian acceptor's decided(v) handler

hw4/src/paxos/paxos.go:413

↓ 1 callersMethodAcceptorDecided

added by Adrian acceptor's decided(v) handler

hw3/src/paxos/paxos.go:413

↓ 1 callersMethodAcceptorPrepare

ACCEPTOR PART ////// added by Adrian acceptor's prepare(n) handler

hw4/src/paxos/paxos.go:352

↓ 1 callersMethodAcceptorPrepare

ACCEPTOR PART ////// added by Adrian acceptor's prepare(n) handler

hw3/src/paxos/paxos.go:352

↓ 1 callersMethodApply

(op Op)

hw4/src/shardmaster/server.go:130

↓ 1 callersMethodApply

(op Op)

hw4/src/kvpaxos/server.go:57

↓ 1 callersMethodApply

Hint: Don't directly update the stored key/value database in the Put/Append/Get handlers; instead, attempt to append a Put, Append, or Get operation t

hw4/src/shardkv/server.go:102

↓ 1 callersMethodBootstrapping

edited by Adrian initiate by the primary when it found that it's time to bootstrap the new backup since that the current view has not yet changed. so

hw2/src/pbservice/server.go:59

↓ 1 callersMethodCleanupFiles

()

hw1/src/mapreduce/mapreduce.go:345

↓ 1 callersMethodCleanupRegistration

()

hw1/src/mapreduce/mapreduce.go:373

↓ 1 callersMethodCommittedToWhom

added by Adrian now that in the prepare phase, this proposal didn't satisfy the majority. we want to find out who is the precedent proposer.

hw4/src/paxos/paxos.go:199

↓ 1 callersMethodCommittedToWhom

added by Adrian now that in the prepare phase, this proposal didn't satisfy the majority. we want to find out who is the precedent proposer.

hw3/src/paxos/paxos.go:199

↓ 1 callersMethodForget

added by Adrian remove those instances whose seq is less than `min`

hw4/src/paxos/paxos.go:484

↓ 1 callersMethodForget

added by Adrian remove those instances whose seq is less than `min`

hw3/src/paxos/paxos.go:484

↓ 1 callersMethodKillWorkers

Clean up all workers by sending a Shutdown RPC to each one of them Collect the number of jobs each work has performed.

hw1/src/mapreduce/master.go:18

↓ 1 callersFunctionMakeClerk

(shardmasters []string)

hw4/src/shardkv/client.go:28

↓ 1 callersFunctionMakeMapReduce

(nmap int, nreduce int, file string, master string)

hw1/src/mapreduce/mapreduce.go:99

↓ 1 callersFunctionMap

our simplified version of MapReduce does not supply a key to the Map function, as in the paper; only a value, which is a part of the input file conten

hw1/src/main/wc.go:19

↓ 1 callersMethodMigrate

(shard int)

hw4/src/shardkv/server.go:327

↓ 1 callersMethodProposerAccept

added by Adrian

hw4/src/paxos/paxos.go:269

↓ 1 callersMethodProposerAccept

added by Adrian

hw3/src/paxos/paxos.go:269

↓ 1 callersMethodProposerPrepare

added by Adrian

hw4/src/paxos/paxos.go:205

↓ 1 callersMethodProposerPrepare

added by Adrian

hw3/src/paxos/paxos.go:205

↓ 1 callersMethodProposerPropose

PROPOSER PART ////// added by Adrian main proposer function. The proposer has only 1 function.

hw4/src/paxos/paxos.go:114

↓ 1 callersMethodProposerPropose

PROPOSER PART ////// added by Adrian main proposer function. The proposer has only 1 function.

hw3/src/paxos/paxos.go:114

↓ 1 callersFunctionReduce

called once for each key generated by Map, with a list of that key's string value. should return a single output value for that key.

hw1/src/main/wc.go:36

↓ 1 callersFunctionRegister

Tell the master we exist and ready to work

hw1/src/mapreduce/worker.go:50

↓ 1 callersMethodRun

Run jobs in parallel, assuming a shared file system

hw1/src/mapreduce/mapreduce.go:384

↓ 1 callersMethodRunMaster

()

hw1/src/mapreduce/master.go:118

↓ 1 callersMethodSetunreliable

please do not change these two functions.

hw4/src/shardkv/server.go:474

↓ 1 callersMethodStartRegistrationServer

()

hw1/src/mapreduce/mapreduce.go:121

↓ 1 callersFunctionStartServer

(me string)

hw4/src/viewservice/server.go:76

↓ 1 callersFunctionStartServer

Start a shardkv server. gid is the ID of the server's replica group. shardmasters[] contains the ports of the servers that implement the shardmaster.

hw4/src/shardkv/server.go:495

↓ 1 callersFunctionStartServer

(me string)

hw2/src/viewservice/server.go:233

↓ 1 callersFunctionStartServer

(me string)

hw3/src/viewservice/server.go:76

↓ 1 callersMethodWait

(seq int)

hw4/src/shardmaster/server.go:163

↓ 1 callersMethodWait

(seq int)

hw4/src/shardkv/server.go:155

↓ 1 callersFunctionallocate

(mr *MapReduce)

hw1/src/mapreduce/master.go:41

↓ 1 callersMethodassignRole

edited by Adrian

hw2/src/viewservice/server.go:167

↓ 1 callersFunctioncheckAppends

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

hw4/src/kvpaxos/test_test.go:342

↓ 1 callersFunctioncheckAppends

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

hw3/src/kvpaxos/test_test.go:344

↓ 1 callersFunctioncheckmax

(t *testing.T, pxa []*Paxos, seq int, max int)

hw4/src/paxos/test_test.go:72

↓ 1 callersFunctioncheckmax

(t *testing.T, pxa []*Paxos, seq int, max int)

hw3/src/paxos/test_test.go:75

↓ 1 callersMethoddoGet

added by Adrian

hw3/src/kvpaxos/server.go:157

↓ 1 callersFunctiondoMap

(mr *MapReduce)

hw1/src/mapreduce/master.go:50

↓ 1 callersFunctiondoReduce

(mr *MapReduce)

hw1/src/mapreduce/master.go:72

↓ 1 callersFunctionihash

(s string)

hw1/src/mapreduce/mapreduce.go:200

↓ 1 callersFunctionmakeInput

Make input file

hw1/src/mapreduce/test_test.go:96

↓ 1 callersFunctionmapCountFinishJobs

(mr *MapReduce)

hw1/src/mapreduce/master.go:93

↓ 1 callersFunctionnrand

()

hw4/src/kvpaxos/client.go:19

↓ 1 callersFunctionnrand

()

hw4/src/shardkv/client.go:21

↓ 1 callersFunctionnrand

this may come in handy.

hw2/src/pbservice/client.go:21

↓ 1 callersFunctionrandstring

(n int)

hw4/src/paxos/test_test.go:14

↓ 1 callersFunctionrandstring

(n int)

hw3/src/paxos/test_test.go:16

↓ 1 callersFunctionreduceCountFinishJobs

(mr *MapReduce)

hw1/src/mapreduce/master.go:105

↓ 1 callersFunctionsetupWorkers

(mr *MapReduce)

hw1/src/mapreduce/master.go:34

↓ 1 callersMethodstart1

start a k/v replica server thread.

hw4/src/shardkv/test_test.go:46

↓ 1 callersMethodtick

tick() is called once per PingInterval; it should notice if servers have died or recovered, and change the view accordingly.

hw4/src/viewservice/server.go:49

↓ 1 callersMethodtick

Ask the shardmaster if there's a new configuration; if so, re-configure.

hw4/src/shardkv/server.go:385

↓ 1 callersMethodtick

ping the viewserver periodically. if view changed: transition to new view. manage transfer of state from primary to new backup.

hw4/src/pbservice/server.go:51

↓ 1 callersMethodtick

tick() is called once per PingInterval; it should notice if servers have died or recovered, and change the view accordingly.

hw2/src/viewservice/server.go:194

↓ 1 callersMethodtick

ping the viewserver periodically. if view changed: transition to new view. manage transfer of state from primary to new backup.

hw2/src/pbservice/server.go:272

↓ 1 callersMethodtick

tick() is called once per PingInterval; it should notice if servers have died or recovered, and change the view accordingly.

hw3/src/viewservice/server.go:49

↓ 1 callersMethodtick

ping the viewserver periodically. if view changed: transition to new view. manage transfer of state from primary to new backup.

hw3/src/pbservice/server.go:51

↓ 1 callersFunctionusage

()

hw4/src/main/pbc.go:24

↓ 1 callersFunctionusage

()

hw2/src/main/pbc.go:24

↓ 1 callersFunctionusage

()

hw3/src/main/pbc.go:24

MethodBootstrap

(other *ShardState)

hw4/src/shardkv/server.go:80

MethodBootstrapped

edited by Adrian the new backup got bootstrapped.

hw2/src/pbservice/server.go:42

FunctionDPrintf

(format string, a ...interface{})

hw4/src/kvpaxos/server.go:23

FunctionDPrintf

(format string, a ...interface{})

hw4/src/shardkv/server.go:23

FunctionDPrintf

(format string, a ...interface{})

hw3/src/kvpaxos/server.go:21

MethodDoJob

The master sent us a job

hw1/src/mapreduce/worker.go:24

MethodForward

edited by Adrian to leverage determinism of the state machine forward any state necessary for backup to `mimic` the execution do exactly the same PutA

hw2/src/pbservice/server.go:103

MethodForwardGet

edited by Adrian to leverage determinism of the state machine the backup got a Get request forwarded by the primary

hw2/src/pbservice/server.go:80

MethodGet

(args *GetArgs, reply *GetReply)

hw4/src/kvpaxos/server.go:121

MethodGet

server Get() RPC handler.

hw4/src/viewservice/server.go:36

MethodGet

(args *GetArgs, reply *GetReply)

hw4/src/shardkv/server.go:196

MethodGet

(args *GetArgs, reply *GetReply)

hw4/src/pbservice/server.go:28

MethodGet

server Get() RPC handler.

hw2/src/viewservice/server.go:96

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