Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cmu440/p2
/ functions
Functions
252 in github.com/cmu440/p2
⨍
Functions
252
◇
Types & classes
50
↓ 65 callers
Method
Reset
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:17
↓ 57 callers
Function
checkErrorStatus
Check error and status
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:146
↓ 46 callers
Function
createUser
Helper functions
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:160
↓ 36 callers
Function
checkError
Check error
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:142
↓ 30 callers
Method
Get
(key string)
src/github.com/cmu440/tribbler/libstore/libstore_api.go:24
↓ 29 callers
Function
postTribble
(user, contents string)
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:188
↓ 28 callers
Method
GetList
(key string)
src/github.com/cmu440/tribbler/libstore/libstore_api.go:26
↓ 27 callers
Function
addSubscription
(user, target string)
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:167
↓ 24 callers
Function
checkErrorStatus
Check error and status
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:95
↓ 24 callers
Function
checkLimits
Check rpc and byte count limits.
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:80
↓ 23 callers
Method
AppendToList
(key, newItem string)
src/github.com/cmu440/tribbler/libstore/libstore_api.go:27
↓ 20 callers
Method
Put
(key, value string)
src/github.com/cmu440/tribbler/libstore/libstore_api.go:25
↓ 18 callers
Method
GetRpcCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:24
↓ 15 callers
Function
checkLimits
Check rpc and byte count limits
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:127
↓ 12 callers
Method
GetLeaseRequestCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:26
↓ 12 callers
Method
ResetDelay
()
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:78
↓ 12 callers
Method
SetDelay
(f float32)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:82
↓ 12 callers
Function
isTimeOK
We treat a RPC call finihsed in 0.5 seconds as OK
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:200
↓ 11 callers
Function
forceCacheGet
Force key into cache by requesting 2 * QUERY_CACHE_THRESH gets
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:103
↓ 10 callers
Method
OverrideOff
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:23
↓ 10 callers
Method
RemoveFromList
(key, removeItem string)
src/github.com/cmu440/tribbler/libstore/libstore_api.go:28
↓ 10 callers
Function
forceCacheGetList
Force key into cache by requesting 2 * QUERY_CACHE_THRESH get lists
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:111
↓ 9 callers
Function
checkTribbles
Check tribbles
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:131
↓ 8 callers
Method
OverrideLeaseSeconds
(leaseSeconds int)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:18
↓ 7 callers
Function
printStatus
(cmdName string, status tribrpc.Status, err error)
src/github.com/cmu440/tribbler/runners/crunner/crunner.go:128
↓ 6 callers
Function
delayedRevoke
helper function for delayed revoke tests
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:516
↓ 6 callers
Function
delayedRevokeList
helper function for delayed revoke tests
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:965
↓ 6 callers
Function
getTribblesBySubscription
(user string)
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:202
↓ 5 callers
Method
OverrideErr
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:21
↓ 5 callers
Method
OverrideStatus
(status storagerpc.Status)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:22
↓ 5 callers
Function
checkList
Check list
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:179
↓ 5 callers
Function
getTribbles
(user string)
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:195
↓ 4 callers
Method
DisableLease
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:19
↓ 4 callers
Method
EnableLease
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:20
↓ 4 callers
Function
removeSubscription
(user, target string)
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:174
↓ 4 callers
Function
revokeLease
Revoke lease
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:119
↓ 3 callers
Method
AddSubscription
(userID, targetUser string)
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:13
↓ 3 callers
Method
Close
()
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:18
↓ 3 callers
Method
CreateUser
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:11
↓ 3 callers
Method
GetSubscriptions
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:12
↓ 3 callers
Method
GetTribbles
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:15
↓ 3 callers
Method
GetTribblesBySubscription
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:16
↓ 3 callers
Method
PostTribble
(userID, contents string)
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:17
↓ 3 callers
Method
RemoveSubscription
(userID, targetUser string)
src/github.com/cmu440/tribbler/tribclient/tribclient_api.go:14
↓ 3 callers
Function
cacheKey
Cache a key
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:205
↓ 3 callers
Function
cacheKeyList
Cache a list key
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:225
↓ 3 callers
Function
cleanupLibstore
Cleanup libstore and rpc hooks
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:89
↓ 3 callers
Function
initLibstore
Initialize proxy and libstore
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:42
↓ 2 callers
Method
GetByteCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:25
↓ 2 callers
Function
checkError
Check error
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:161
↓ 2 callers
Method
doSub
(funcName, userID, targetUserID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:57
↓ 2 callers
Method
doTrib
(funcName, userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:74
↓ 2 callers
Function
getSubscription
(user string)
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:181
↓ 2 callers
Function
printTribbles
(tribbles []tribrpc.Tribble)
src/github.com/cmu440/tribbler/runners/crunner/crunner.go:142
↓ 2 callers
Function
validateTribbles
(tribbles *[]tribrpc.Tribble, numTargets int)
src/github.com/cmu440/tribbler/tests/stresstest/stresstest.go:195
↓ 1 callers
Method
GetServers
(*GetServersArgs, *GetServersReply)
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:9
↓ 1 callers
Method
RegisterServer
(*RegisterArgs, *RegisterReply)
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:8
↓ 1 callers
Function
checkSubscriptions
Check subscriptions
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:110
↓ 1 callers
Function
initStorageTester
(server, myhostport string)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:54
↓ 1 callers
Function
initTribServer
(masterServerHostPort string, tribServerPort int)
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:45
↓ 1 callers
Function
printTribble
(t tribrpc.Tribble)
src/github.com/cmu440/tribbler/runners/crunner/crunner.go:138
↓ 1 callers
Function
tribStatusToString
(status tribrpc.Status)
src/github.com/cmu440/tribbler/runners/crunner/crunner.go:114
↓ 1 callers
Function
validateSubscriptions
(subscriptions *[]string)
src/github.com/cmu440/tribbler/tests/stresstest/stresstest.go:184
Method
AddSubscription
(userID, targetUserID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:49
Method
AddSubscription
AddSubscription adds TargerUserID to UserID's list of subscriptions. Replies with status NoSuchUser if the specified UserID does not exist, and NoSuch
src/github.com/cmu440/tribbler/tribserver/tribserver_api.go:17
Method
AddSubscription
(args *tribrpc.SubscriptionArgs, reply *tribrpc.SubscriptionReply)
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:27
Method
AddSubscription
(args *SubscriptionArgs, reply *SubscriptionReply)
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:9
Method
AppendToList
(key, newItem string)
src/github.com/cmu440/tribbler/libstore/libstore_impl.go:57
Method
AppendToList
AppendToList retrieves the specified key from the data store and appends the specified value to its list. If the key does not fall within the receivin
src/github.com/cmu440/tribbler/storageserver/storageserver_api.go:44
Method
AppendToList
(args *storagerpc.PutArgs, reply *storagerpc.PutReply)
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:45
Method
AppendToList
(key, newitem string)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:138
Method
AppendToList
(args *storagerpc.PutArgs, reply *storagerpc.PutReply)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:192
Method
AppendToList
(*PutArgs, *PutReply)
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:13
Method
Close
()
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:92
Method
CreateUser
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:31
Method
CreateUser
CreateUser creates a user with the specified UserID. Replies with status Exists if the user has previously been created.
src/github.com/cmu440/tribbler/tribserver/tribserver_api.go:12
Method
CreateUser
(args *tribrpc.CreateUserArgs, reply *tribrpc.CreateUserReply)
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:23
Method
CreateUser
(args *CreateUserArgs, reply *CreateUserReply)
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:8
Method
DisableLease
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:71
Method
EnableLease
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:75
Method
Get
(key string)
src/github.com/cmu440/tribbler/libstore/libstore_impl.go:41
Method
Get
Get retrieves the specified key from the data store and replies with the key's value and a lease if one was requested. If the key does not fall within
src/github.com/cmu440/tribbler/storageserver/storageserver_api.go:25
Method
Get
(args *storagerpc.GetArgs, reply *storagerpc.GetReply)
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:33
Method
Get
(key string, wantlease bool)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:117
Method
Get
(args *storagerpc.GetArgs, reply *storagerpc.GetReply)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:128
Method
Get
(*GetArgs, *GetReply)
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:10
Method
GetByteCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:99
Method
GetLeaseGrantedCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:27
Method
GetLeaseGrantedCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:107
Method
GetLeaseRequestCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:103
Method
GetList
(key string)
src/github.com/cmu440/tribbler/libstore/libstore_impl.go:49
Method
GetList
GetList retrieves the specified key from the data store and replies with the key's list value and a lease if one was requested. If the key does not fa
src/github.com/cmu440/tribbler/storageserver/storageserver_api.go:32
Method
GetList
(args *storagerpc.GetArgs, reply *storagerpc.GetListReply)
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:37
Method
GetList
(key string, wantlease bool)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:124
Method
GetList
(args *storagerpc.GetArgs, reply *storagerpc.GetListReply)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:153
Method
GetList
(*GetArgs, *GetListReply)
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:11
Method
GetRpcCount
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:95
Method
GetServers
GetServers retrieves a list of all connected nodes in the ring. It replies with status NotReady if not all nodes in the ring have joined.
src/github.com/cmu440/tribbler/storageserver/storageserver_api.go:18
Method
GetServers
(args *storagerpc.GetServersArgs, reply *storagerpc.GetServersReply)
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:29
Method
GetServers
()
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:103
next →
1–100 of 252, ranked by callers