(t *testing.T)
| 210 | } |
| 211 | |
| 212 | func TestWriteBatchCancel_UnregistersTransaction(t *testing.T) { |
| 213 | db, err := Open( |
| 214 | DefaultOptions, |
| 215 | WithDir(t.TempDir()), |
| 216 | ) |
| 217 | require.NoError(t, err) |
| 218 | defer func() { require.NoError(t, db.Close()) }() |
| 219 | |
| 220 | wb, err := db.NewWriteBatch() |
| 221 | require.NoError(t, err) |
| 222 | require.Equal(t, int64(1), db.transactionMgr.GetActiveTxCount(), "write batch should register a tx") |
| 223 | |
| 224 | require.NoError(t, wb.Cancel()) |
| 225 | require.Equal(t, int64(0), db.transactionMgr.GetActiveTxCount(), "Cancel should unregister the tx") |
| 226 | |
| 227 | // Subsequent Cancel should be a no-op. |
| 228 | require.NoError(t, wb.Cancel()) |
| 229 | } |
| 230 | |
| 231 | func TestWriteBatchFlush_UnregistersFinalTransaction(t *testing.T) { |
| 232 | db, err := Open( |
nothing calls this directly
no test coverage detected