Method Rollback

twopc/twopc_test.go:325–371

(ctx context.Context, wb twopc.WriteBatch)

}

func (r *RaftNode) Rollback(ctx context.Context, wb twopc.WriteBatch) (err error) {
	log.Debugf("executing 2pc: addr = %s, phase = rollback", r.addr)
	defer log.Debugf("2pc result: addr = %s, phase = rollback, result = %v", r.addr, err)

	rwb, ok := wb.(*RaftWriteBatchReq)

	if !ok {
		err = errors.New("unexpected WriteBatch type")
		return err
	}

	cipher := etls.NewCipher([]byte(pass))
	conn, err := etls.Dial("tcp", r.addr, cipher)

	if err != nil {
		return err
	}

	muxconn, err := mux.NewOneOffMuxConn(conn)
	if err != nil {
		return
	}

	client := rpc.NewClient(muxconn)
	d, ok := ctx.Deadline()

	if ok {
		err = muxconn.SetDeadline(d)

		if err != nil {
			return err
		}
	}

	resp := new(RaftRollbackResp)
	err = client.Call("Raft.RPCRollback", &RaftRollbackReq{TxID: rwb.TxID}, resp)

	if err != nil {
		return err
	}

	if resp.ErrCode > 0 {
		err = fmt.Errorf(resp.ErrString)
	}

	return err
}

func testSetup() (err error) {
	log.SetLevel(log.DebugLevel)