clientv3: retry remote connection on txn write failure

liuchenshuo · Feb 5, 2016 · a6008f4 · a6008f4
1 parent 7960bd8
commit a6008f4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/clientv3/txn.go b/clientv3/txn.go
@@ -143,11 +143,12 @@ func (txn *txn) Commit() (*TxnResponse, error) {
 			return (*TxnResponse)(resp), nil
 		}
 
-		if txn.isWrite {
+		if isRPCError(err) {
 			return nil, err
 		}
 
-		if isRPCError(err) {
+		if txn.isWrite {
+			go kv.switchRemote(err)
 			return nil, err
 		}