.

go/transaction/transaction.go

@@ -138,6 +138,10 @@ func (txn *transaction) Abort() {
 	wg.Wait()
 
 	// XXX set txn status
+	txn.mu.Lock()
+	// assert .status == Aborting
+	txn.status = Aborted			// XXX what if errBeforeCompletion?
+	txn.mu.Unlock()
 
 	// sync.AfterCompletion
 	n = len(syncv)

go/transaction/transaction_test.go

@@ -95,8 +95,8 @@ func TestAbort(t *testing.T) {
 	// XXX +sync
 
 	txn.Abort()
-	if dm.nabort != 1 {
-		t.Fatalf("abort: nabort=%d;  want=1", dm.nabort)
+	if !(dm.nabort == 1 && txn.Status() == Aborted) {
+		t.Fatalf("abort: nabort=%d; txn.Status=%v", dm.nabort, txn.Status())
 	}
 
 	// txn.Abort() -> panic	XXX