Method CommitWith

tx.go:102–132

(cb func(error))

}

func (tx *Tx) CommitWith(cb func(error)) {
	if cb == nil {
		panic("Nil callback provided to CommitWith")
	}

	if tx.isClosed() {
		go runTxnCallback(&txnCb{user: cb, err: ErrCannotCommitAClosedTx})
		return
	}

	if tx.db == nil {
		tx.setStatusClosed()
		go runTxnCallback(&txnCb{user: cb, err: ErrDBClosed})
		return
	}

	tx.setStatusCommitting()

	commitCb, err := tx.commitAndSend()
	if err != nil {
		tx.handleErr(err)
		tx.setStatusClosed()
		tx.unlock()
		tx.db = nil
		tx.pendingWrites = nil
		go runTxnCallback(&txnCb{user: cb, err: err})
		return
	}

	go runTxnCallback(&txnCb{user: cb, commit: commitCb})
}

func (tx *Tx) commitAndSend() (func() error, error) {
	req, err := tx.db.sendToWriteCh(tx)