lomg 发表于 2019-1-31 11:58:51

etcd raft如何实现Linearizable Read

// 执行ReadIndex,ctx是request idif err := s.r.ReadIndex(cctx, ctx); err != nil {  
            cancel()            if err == raft.ErrStopped {                return
  
            }
  
            plog.Errorf("failed to get read index from raft: %v", err)
  
            nr.notify(err)            continue}//等待request id对应的ReadState从readStateC中pop出来for !timeout && !done {
  
            select {            case rs =
页: [1]
查看完整版本: etcd raft如何实现Linearizable Read