Key/value server with no network failures#

太简单了以至于没什么好记录的，no network failures意味着实现线性化只需要加锁就可以了。

Key/value server with dropped messages#

实验要求是server再次收到已完成过的请求时丢弃重复请求不处理，只需要用map记录下处理过且未经客户端确认的请求，在收到客户端ACK后清理即可。

内存释放#

起初是使用了map存储nrand()生成的操作id和对应的append操作发生前的结果字符串，但是这样没法通过memory use many appends这个case。然后注意到其实append操作不会修改之前的存在结果，所以历史map可以改为存储append前的value字符串长度，这样就可以将string改为int以此节省内存。

server代码#

1
type KVServer struct {
2
  mu sync.Mutex
3
  // Your definitions here.
4
  pairs   map[string]string
5
  history map[int64]int
6
}
7

8
func (kv *KVServer) Get(args *GetArgs, reply *GetReply) {
9
  // Your code here.
10
  kv.mu.Lock()
11
  defer kv.mu.Unlock()
12

13
  reply.Value = kv.pairs[args.Key]
14

15
}
16

17
func (kv *KVServer) Put(args *PutAppendArgs, reply *PutAppendReply) {
18
  // Your code here.
19

20
  kv.mu.Lock()
21
  defer kv.mu.Unlock()
22
  kv.pairs[args.Key] = args.Value
23
  delete(kv.history, args.ID)
24
}
25

26
func (kv *KVServer) Append(args *PutAppendArgs, reply *PutAppendReply) {
27
  // Your code here.
28
  kv.mu.Lock()
29
  defer kv.mu.Unlock()
30
  if args.Report {
31
    delete(kv.history, args.ID)
32
    return
33
  }
34
  if val, ok := kv.history[args.ID]; ok {
35
    reply.Value = kv.pairs[args.Key][:val]
36
    return
37
  }
38
  reply.Value = kv.pairs[args.Key]
39
  kv.history[args.ID] = len(reply.Value)
40
  kv.pairs[args.Key] += args.Value
41
}
42

43
func StartKVServer() *KVServer {
44
  kv := new(KVServer)
45

46
  // You may need initialization code here.
47
  kv.pairs = make(map[string]string)
48
  kv.history = make(map[int64]int)
49

50
  return kv
51
}