MCPcopy Create free account

hub / github.com/cmu440/p2 / functions

Functions252 in github.com/cmu440/p2

MethodGetServers
(args *storagerpc.GetServersArgs, reply *storagerpc.GetServersReply)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:117
MethodGetSubscriptions
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:40
MethodGetSubscriptions
GetSubscriptions retrieves a list of all users to whom the user subscribes. Replies with status NoSuchUser if the specified UserID does not exist.
src/github.com/cmu440/tribbler/tribserver/tribserver_api.go:26
MethodGetSubscriptions
(args *tribrpc.GetSubscriptionsArgs, reply *tribrpc.GetSubscriptionsReply)
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:35
MethodGetSubscriptions
(args *GetSubscriptionsArgs, reply *GetSubscriptionsReply)
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:11
MethodGetTribbles
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:66
MethodGetTribbles
GetTribbles retrieves a list of at most 100 tribbles posted by the specified UserID in reverse chronological order (most recent first). Replies with s
src/github.com/cmu440/tribbler/tribserver/tribserver_api.go:36
MethodGetTribbles
(args *tribrpc.GetTribblesArgs, reply *tribrpc.GetTribblesReply)
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:43
MethodGetTribbles
(args *GetTribblesArgs, reply *GetTribblesReply)
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:13
MethodGetTribblesBySubscription
(userID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:70
MethodGetTribblesBySubscription
GetTribblesBySubscription retrieves a list of at most 100 tribbles posted by all users to which the specified UserID is subscribed in reverse chronolo
src/github.com/cmu440/tribbler/tribserver/tribserver_api.go:42
MethodGetTribblesBySubscription
(args *tribrpc.GetTribblesArgs, reply *tribrpc.GetTribblesReply)
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:47
MethodGetTribblesBySubscription
(args *GetTribblesArgs, reply *GetTribblesReply)
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:14
FunctionNewLibstore
NewLibstore creates a new instance of a TribServer's libstore. masterServerHostPort is the master storage server's host:port. myHostPort is this Libst
src/github.com/cmu440/tribbler/libstore/libstore_impl.go:37
FunctionNewProxyCounter
(serverHostPort, myHostPort string)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:48
FunctionNewStorageServer
NewStorageServer creates and starts a new StorageServer. masterServerHostPort is the master storage server's host:port address. If empty, then this se
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:21
FunctionNewTribClient
(serverHost string, serverPort int)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:23
FunctionNewTribServer
NewTribServer creates, starts and returns a new TribServer. masterServerHostPort is the master storage server's host:port and port is this port number
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:19
MethodOverrideErr
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:79
MethodOverrideLeaseSeconds
(leaseSeconds int)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:67
MethodOverrideOff
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:89
MethodOverrideStatus
(status storagerpc.Status)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:84
MethodPostTribble
(userID, contents string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:83
MethodPostTribble
PostTribble posts a tribble on behalf of the specified UserID. The TribServer should timestamp the entry before inserting the Tribble into it's local
src/github.com/cmu440/tribbler/tribserver/tribserver_api.go:31
MethodPostTribble
(args *tribrpc.PostTribbleArgs, reply *tribrpc.PostTribbleReply)
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:39
MethodPostTribble
(args *PostTribbleArgs, reply *PostTribbleReply)
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:12
MethodPut
(key, value string)
src/github.com/cmu440/tribbler/libstore/libstore_impl.go:45
MethodPut
Put inserts the specified key/value pair into the data store. If the key does not fall within the storage server's range, it should reply with status
src/github.com/cmu440/tribbler/storageserver/storageserver_api.go:37
MethodPut
(args *storagerpc.PutArgs, reply *storagerpc.PutReply)
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:41
MethodPut
(key, value string)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:110
MethodPut
(args *storagerpc.PutArgs, reply *storagerpc.PutReply)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:180
MethodPut
(*PutArgs, *PutReply)
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:12
MethodRegisterServer
RegisterServer adds a storage server to the ring. It replies with status NotReady if not all nodes in the ring have joined. Once all nodes have joined
src/github.com/cmu440/tribbler/storageserver/storageserver_api.go:14
MethodRegisterServer
(args *storagerpc.RegisterArgs, reply *storagerpc.RegisterReply)
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:25
MethodRegisterServer
()
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:95
MethodRegisterServer
RPC methods.
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:113
MethodRemoveFromList
(key, removeItem string)
src/github.com/cmu440/tribbler/libstore/libstore_impl.go:53
MethodRemoveFromList
RemoveFromList retrieves the specified key from the data store and removes the specified value from its list. If the key does not fall within the rece
src/github.com/cmu440/tribbler/storageserver/storageserver_api.go:51
MethodRemoveFromList
(args *storagerpc.PutArgs, reply *storagerpc.PutReply)
src/github.com/cmu440/tribbler/storageserver/storageserver_impl.go:49
MethodRemoveFromList
(key, removeitem string)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:131
MethodRemoveFromList
(args *storagerpc.PutArgs, reply *storagerpc.PutReply)
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:204
MethodRemoveFromList
(*PutArgs, *PutReply)
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:14
MethodRemoveSubscription
(userID, targetUserID string)
src/github.com/cmu440/tribbler/tribclient/tribclient_impl.go:53
MethodRemoveSubscription
RemoveSubscription removes TargerUserID to UserID's list of subscriptions. Replies with status NoSuchUser if the specified UserID does not exist, and
src/github.com/cmu440/tribbler/tribserver/tribserver_api.go:22
MethodRemoveSubscription
(args *tribrpc.SubscriptionArgs, reply *tribrpc.SubscriptionReply)
src/github.com/cmu440/tribbler/tribserver/tribserver_impl.go:31
MethodRemoveSubscription
(args *SubscriptionArgs, reply *SubscriptionReply)
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:10
MethodReset
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:60
MethodRevokeLease
(args *storagerpc.RevokeLeaseArgs, reply *storagerpc.RevokeLeaseReply)
src/github.com/cmu440/tribbler/libstore/libstore_impl.go:61
MethodRevokeLease
RevokeLease is a callback RPC method that is invoked by storage servers when a lease is revoked. It should reply with status OK if the key was success
src/github.com/cmu440/tribbler/libstore/libstore_api.go:39
MethodRevokeLease
(args *storagerpc.RevokeLeaseArgs, reply *storagerpc.RevokeLeaseReply)
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:86
MethodRevokeLease
(*storagerpc.RevokeLeaseArgs, *storagerpc.RevokeLeaseReply)
src/github.com/cmu440/tribbler/rpc/librpc/rpc.go:10
FunctionStoreHash
StoreHash hashes a string key and returns a 32-bit integer. This function is provided here so that all implementations use the same hashing mechanism
src/github.com/cmu440/tribbler/libstore/libstore_api.go:45
FunctionWrap
Wrap wraps t in a type-safe wrapper struct to ensure that only the desired TribServer methods are exported to receive RPCs. You should Wrap your TribS
src/github.com/cmu440/tribbler/rpc/tribrpc/rpc.go:48
FunctionWrap
Wrap wraps l in a type-safe wrapper struct to ensure that only the desired LeaseCallbacks methods are exported to receive RPCs.
src/github.com/cmu440/tribbler/rpc/librpc/rpc.go:21
FunctionWrap
Wrap wraps s in a type-safe wrapper struct to ensure that only the desired StorageServer methods are exported to receive RPCs.
src/github.com/cmu440/tribbler/rpc/storagerpc/rpc.go:25
FunctioncleanupTribServer
Cleanup tribserver and rpc hooks
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:66
Functioninit
()
src/github.com/cmu440/tribbler/runners/srunner/srunner.go:25
Functioninit
()
src/github.com/cmu440/tribbler/runners/trunner/trunner.go:16
Functioninit
()
src/github.com/cmu440/tribbler/runners/crunner/crunner.go:24
Functioninit
()
src/github.com/cmu440/tribbler/runners/lrunner/lrunner.go:29
Functioninit
()
src/github.com/cmu440/tribbler/tests/proxycounter/proxycounter.go:44
Functionmain
()
src/github.com/cmu440/tribbler/runners/srunner/srunner.go:29
Functionmain
()
src/github.com/cmu440/tribbler/runners/trunner/trunner.go:20
Functionmain
()
src/github.com/cmu440/tribbler/runners/crunner/crunner.go:43
Functionmain
()
src/github.com/cmu440/tribbler/runners/lrunner/lrunner.go:59
Functionmain
()
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:1287
Functionmain
()
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:1025
Functionmain
()
src/github.com/cmu440/tribbler/tests/stresstest/stresstest.go:50
Functionmain
()
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:708
FunctiontestAddSubscriptionDuplicate
Add duplicate subscription
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:285
FunctiontestAddSubscriptionInvalidTargetUser
Add subscription with invaild target user
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:254
FunctiontestAddSubscriptionInvalidUser
Add subscription with invalid user
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:239
FunctiontestAddSubscriptionValid
Add valid subscription
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:269
FunctiontestAlwaysLeases
Always request leases when alwaysLease is true
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:192
FunctiontestAppendGetRemoveList
list related operations
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:340
FunctiontestAppendToListError
Handle append to list error
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:372
FunctiontestAppendToListErrorStatus
Handle append to list error reply status
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:388
FunctiontestAppendToListValid
Handle valid append to list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:404
FunctiontestCacheGetCorrect
Doesn't call server when using cache for get
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:519
FunctiontestCacheGetLeaseNotGranted
Cache respects granted flag for get
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:543
FunctiontestCacheGetLeaseNotGranted2
Cache requests leases until granted for get
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:567
FunctiontestCacheGetLeaseTimeout
Cache respects lease timeout for get
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:583
FunctiontestCacheGetLimit
Cache < limit test for get
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:490
FunctiontestCacheGetLimit2
Cache > limit test for get
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:506
FunctiontestCacheGetListCorrect
Doesn't call server when using cache for get list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:786
FunctiontestCacheGetListLeaseNotGranted
Cache respects granted flag for get list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:810
FunctiontestCacheGetListLeaseNotGranted2
Cache requests leases until granted for get list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:834
FunctiontestCacheGetListLeaseTimeout
Cache respects lease timeout for get list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:850
FunctiontestCacheGetListLimit
Cache < limit test for get list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:757
FunctiontestCacheGetListLimit2
Cache > limit test for get list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:773
FunctiontestCacheGetListMemoryLeak
Cache memory leak for get list
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:875
FunctiontestCacheGetMemoryLeak
Cache memory leak for get
src/github.com/cmu440/tribbler/tests/libtest/libtest.go:608
FunctiontestCreateUserDuplicate
Create duplicate user
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:224
FunctiontestCreateUserValid
Create valid user
src/github.com/cmu440/tribbler/tests/tribtest/tribtest.go:210
FunctiontestDelayedRevokeListWithLeaseRequest1
when revoking leases for key "x", storage server should stop leasing for "x" before revoking completes or old lease expires. this function tests the f
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:1066
FunctiontestDelayedRevokeListWithLeaseRequest2
when revoking leases for key "x", storage server should stop leasing for "x" before revoking completes or old lease expires. this function tests the l
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:1113
FunctiontestDelayedRevokeListWithUpdate1
when revoking leases for key "x", storage server should hold upcoming updates for "x", until either all revocations complete or the lease expires this
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:1158
FunctiontestDelayedRevokeListWithUpdate2
when revoking leases for key "x", storage server should hold upcoming updates for "x", until either all revocations complete or the lease expires this
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:1197
FunctiontestDelayedRevokeListWithUpdate3
remote libstores may not even reply all RevokeLease RPC calls. in this case, service should continue after lease expires
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:1241
FunctiontestDelayedRevokeListWithoutBlocking
when revoking leases for key "x", storage server should not block queries for other keys
src/github.com/cmu440/tribbler/tests/storagetest/storagetest.go:1015
← previousnext →101–200 of 252, ranked by callers