Method CheckToken

BaseServer/lockclient.go:281–323

* * @brief: 附带着目前持有的token，检测这个token是否还有效 * @notes: 问题的关键在于检查返回无效，其实在发出数据的一刻是有效的，但是不影响正确性 */

(pathname string, filename string, token uint64)

 * @notes: 问题的关键在于检查返回无效，其实在发出数据的一刻是有效的，但是不影响正确性
 */
func (ck *Clerk) CheckToken(pathname string, filename string, token uint64) bool {
	cnt := len(ck.servers)

	for {
		args := &CheckTokenArgs{PathName: pathname, ClientID: ck.ClientID, SeqNo: ck.seq,
			 FileName: filename, Token: token}

		reply := new(CheckTokenReply)

		ck.leader %= cnt

		if atomic.LoadInt32(&((*ck.serversIsOk)[ck.leader])) == 0 {
			ck.leader++
			continue
		}

		replyArrival := make(chan bool, 1)
		go func() {
			err := ck.servers[ck.leader].Call("RaftKV.CheckToken", args, reply)
			flag := true
			if err != nil {
				log.Printf("ERROR : CheckToken call error, Find the cause as soon as possible -> (%s).\n", err.Error())
				flag = false
			}
			replyArrival <- flag
		}()
		select {
		case <-time.After(200 * time.Millisecond):
			ck.leader++
			continue
		case ok := <-replyArrival:
			if ok && (reply.Err == OK) {
				ck.seq++
				return true
			} else if reply.Err == CheckTokenError || reply.Err == Duplicate{
				log.Printf("INFO : CheckToken (%s/%s) error -> [%s]\n", pathname, filename, reply.Err)
				ck.seq++
				return false
			}
			ck.leader++
		}
	}
}