MCPcopy Create free account

hub / github.com/ailidani/paxi / functions

Functions575 in github.com/ailidani/paxi

↓ 3 callersMethodSend
Send sends message into t.send chan
transport.go:24
↓ 3 callersMethodSend
(to ID, m interface{})
socket.go:69
↓ 3 callersMethodString
()
sdpaxos/msg.go:36
↓ 3 callersMethodString
()
paxos/msg.go:77
↓ 3 callersMethodcontains
(key paxi.Key)
wankeeper/tokens.go:20
↓ 3 callersMethodhappenBefore
(b operation)
operation.go:13
↓ 3 callersMethodinit
(key paxi.Key)
wankeeper/replica.go:101
↓ 3 callersFunctionnewChecker
()
checker.go:15
↓ 3 callersFunctionrun
(transport string, t *testing.T)
socket_test.go:21
↓ 3 callersMethodset
(key paxi.Key, id paxi.ID)
wankeeper/tokens.go:37
↓ 3 callersFunctionuniformTest
(p Policy, t *testing.T)
policy_test.go:8
↓ 3 callersMethodupdateCommit
(id paxi.ID)
epaxos/replica.go:102
↓ 2 callersMethodAddOperation
AddOperation adds the operation
history.go:44
↓ 2 callersMethodBFS
BFS returns breadth first search vertices from a given source
lib/graph.go:86
↓ 2 callersMethodCrash
drop message by chance p for t seconds
socket.go:35
↓ 2 callersMethodInit
()
benchmark.go:14
↓ 2 callersMethodLinearizable
Linearizable concurrently checks if each partition of the history is linearizable and returns the total number of anomaly reads
history.go:55
↓ 2 callersFunctionMakeDefaultConfig
MakeDefaultConfig returns Config object with few default values only used by init() and master
config.go:56
↓ 2 callersFunctionNewBenchmark
NewBenchmark returns new Benchmark object given implementation of DB interface
benchmark.go:89
↓ 2 callersFunctionNewClient
(id paxi.ID)
paxos/client.go:16
↓ 2 callersFunctionNewClient
()
chain/client.go:15
↓ 2 callersFunctionNewHistory
NewHistory creates a History map
history.go:24
↓ 2 callersFunctionNewLimiter
NewLimiter creates a new rate limiter, where rate is operations per second
rate.go:18
↓ 2 callersMethodP1a
(r paxi.Request)
hpaxos/paxos.go:66
↓ 2 callersMethodP2a
P2a starts phase 2 accept
paxos/paxos.go:111
↓ 2 callersMethodP2a
(s int)
hpaxos/paxos.go:83
↓ 2 callersMethodPeek
Peek views the top item on the stack
lib/stack.go:24
↓ 2 callersMethodPop
Pop the top item of the stack and return it
lib/stack.go:32
↓ 2 callersMethodRun
Run starts the main logic of benchmarking
benchmark.go:135
↓ 2 callersFunctionSimulation
Simulation enable go channel transportation to simulate distributed environment
config.go:50
↓ 2 callersFunctionStatistic
Statistic function creates Stat object from raw latency data
stat.go:44
↓ 2 callersMethodStop
()
benchmark.go:17
↓ 2 callersMethodString
()
m2paxos/msg.go:50
↓ 2 callersMethodVertices
()
lib/graph.go:71
↓ 2 callersFunctionWarningf
(format string, v ...interface{})
log/log.go:158
↓ 2 callersMethodWriteFile
WriteFile writes stat to new file in path
stat.go:25
↓ 2 callersMethodadd
(o *operation)
checker.go:21
↓ 2 callersMethodattributes
attibutes generates the sequence and dependency attributes for command
epaxos/replica.go:60
↓ 2 callersMethodcollect
(latencies <-chan time.Duration)
benchmark.go:277
↓ 2 callersMethodexec
()
paxos/paxos.go:343
↓ 2 callersMethodexec
()
vpaxos/paxos.go:149
↓ 2 callersMethodexec
()
hpaxos/paxos.go:273
↓ 2 callersMethodexec
(key paxi.Key)
wankeeper/replica.go:177
↓ 2 callersMethodforward
()
paxos/paxos.go:369
↓ 2 callersMethodgetBuffer
()
log/log.go:70
↓ 2 callersMethodjson
(id ID, key Key, value Value)
client.go:166
↓ 2 callersMethodlead
(requests ...*paxi.Request)
wankeeper/leader.go:42
↓ 2 callersMethodmine
()
blockchain/block.go:43
↓ 2 callersMethodnext
generates key based on distribution
benchmark.go:202
↓ 2 callersMethodput
(k Key, v Value)
db.go:123
↓ 2 callersMethodquery
(k paxi.Key, id paxi.ID)
vpaxos/master.go:27
↓ 2 callersFunctionreplica
(id paxi.ID)
server/server.go:31
↓ 2 callersMethodreplicas
replicas returns the next 2 neighbors of current node as its replicas
dynamo/replica.go:43
↓ 2 callersFunctionrun
(cmd string, args []string)
cmd/cmd.go:35
↓ 2 callersMethodvisit
(v interface{}, colors map[interface{}]color)
lib/graph.go:180
↓ 2 callersMethodworker
(keys <-chan int, result chan<- time.Duration)
benchmark.go:246
↓ 1 callersMethodAll
()
quorum.go:55
↓ 1 callersMethodAllZones
AllZones returns true if there is at one ack from each zone
quorum.go:70
↓ 1 callersFunctionConflict
Conflict checks if two commands are conflicting as reorder them will end in different states
db.go:165
↓ 1 callersMethodConsensus
(Key)
client.go:27
↓ 1 callersMethodCycle
Cycle returns the first cycle with vertices
lib/graph.go:212
↓ 1 callersMethodCyclic
Cyclic returns true if the graph contains a cycle
lib/graph.go:195
↓ 1 callersFunctionDefaultBConfig
DefaultBConfig returns a default benchmark config
benchmark.go:51
↓ 1 callersMethodDrop
Fault injection
socket.go:32
↓ 1 callersMethodDrop
Drop drops every message send for t seconds
client.go:344
↓ 1 callersMethodEmpty
()
db.go:25
↓ 1 callersMethodEmpty
()
lib/stack.go:50
↓ 1 callersMethodFGridQ1
FGridQ1 is flexible grid quorum for phase 1
quorum.go:100
↓ 1 callersMethodFGridQ2
FGridQ2 is flexible grid quorum for phase 2
quorum.go:111
↓ 1 callersMethodFastQuorum
FastQuorum from fast paxos
quorum.go:65
↓ 1 callersMethodFrom
From returns all vertices in graph that can be reached directly from v
lib/graph.go:76
↓ 1 callersFunctionGenesis
Genesis gets the genesis block which has byte[1024] data byte[256] prev hash
blockchain/block.go:78
↓ 1 callersMethodGetURL
(id ID, key Key)
client.go:83
↓ 1 callersMethodGridColumn
GridColumn == all nodes in one zone
quorum.go:90
↓ 1 callersMethodGridRow
GridRow == AllZones
quorum.go:85
↓ 1 callersMethodHandleRequest
(r paxi.Request)
hpaxos/paxos.go:62
↓ 1 callersMethodHistory
(Key)
db.go:55
↓ 1 callersMethodID
()
node.go:49
↓ 1 callersMethodIsWrite
()
db.go:36
↓ 1 callersMethodLoad
Load will create all K keys to DB
benchmark.go:104
↓ 1 callersMethodLoad
Load loads configuration from config file in JSON format
config.go:97
↓ 1 callersMethodMultiGet
MultiGet concurrently read values from n nodes
client.go:207
↓ 1 callersMethodMulticastQuorum
MulticastQuorum sends msg to random number of nodes
socket.go:21
↓ 1 callersMethodN
N returns total number of nodes
config.go:77
↓ 1 callersFunctionNewDatabase
NewDatabase returns database that impelements Database interface
db.go:70
↓ 1 callersFunctionNewMiner
NewMiner creates new Miner as paxi node
blockchain/miner.go:23
↓ 1 callersFunctionNewPaxos
NewPaxos creates new paxos instance
hpaxos/paxos.go:37
↓ 1 callersFunctionNewReplica
(id paxi.ID)
paxos_group/replica.go:20
↓ 1 callersFunctionNewReplica
NewReplica initialize replica and register all message types
epaxos/replica.go:30
↓ 1 callersFunctionNewReplica
(id paxi.ID)
sdpaxos/replica.go:33
↓ 1 callersFunctionNewReplica
NewReplica generates new Paxos replica
paxos/replica.go:29
↓ 1 callersFunctionNewReplica
NewReplica create new Replica instance
m2paxos/replica.go:15
↓ 1 callersFunctionNewReplica
(id paxi.ID)
chain/replica.go:30
↓ 1 callersFunctionNewReplica
(id paxi.ID)
vpaxos/replica.go:24
↓ 1 callersFunctionNewReplica
NewReplica generates new Paxos replica
hpaxos/replica.go:15
↓ 1 callersFunctionNewReplica
(id paxi.ID)
dynamo/replica.go:18
↓ 1 callersFunctionNewReplica
NewReplica creates new replica object for wankeeper
wankeeper/replica.go:34
↓ 1 callersFunctionNewReplica
(id paxi.ID)
kpaxos/replica.go:17
↓ 1 callersFunctionNewReplica
NewReplica create new Replica instance
wpaxos/replica.go:20
↓ 1 callersFunctionNewReplica
NewReplica generates ABD replica
abd/replica.go:37
← previousnext →101–200 of 575, ranked by callers