Developing lightweight computation at the DSG edge

Commit 9167a5da authored by Mathias Weber's avatar Mathias Weber
Browse files

fixed commit and implemented abort (yet unsupported by Antidote)

parent 2712f4c1
......@@ -123,10 +123,19 @@ func (tx *InteractiveTransaction) read(objects ...*ApbBoundObject) (resp *ApbRea
}
func (tx *InteractiveTransaction) commit() (op *ApbCommitResp, err error) {
msg := &ApbCommitTransaction{}
msg := &ApbCommitTransaction{TransactionDescriptor: tx.txID}
err = msg.encode(tx.con)
if err != nil {
return
}
return decodeCommitResp(tx.con)
}
func (tx *InteractiveTransaction) abort() (op *ApbOperationResp, err error) {
msg := &ApbAbortTransaction{TransactionDescriptor: tx.txID}
err = msg.encode(tx.con)
if err != nil {
return
}
return decodeOperationResp(tx.con)
}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment