markClientVersion is used to mark that a key was set by a client and not by replication.
(key string)
| 135 | // markClientVersion is used to mark that a key was set by a client and not by |
| 136 | // replication. |
| 137 | func (r *rpcServer) markClientVersion(key string) { |
| 138 | r.l.Lock() |
| 139 | defer r.l.Unlock() |
| 140 | delete(r.versions, key) |
| 141 | } |
| 142 | |
| 143 | // Set is used to set the value of a key. |
| 144 | func (r *rpcServer) Set(args StorageArgs, resp *struct{}) error { |