MCPcopy Create free account
hub / github.com/nutsdb/nutsdb / GetActiveTxCount

Method GetActiveTxCount

tx_manager.go:109–111  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

107}
108
109func (tm *txManager) GetActiveTxCount() int64 {
110 return tm.activeTxCount.Load()
111}
112
113func (tm *txManager) WaitForActiveTxs(timeout time.Duration) error {
114 deadline := time.Now().Add(timeout)

Callers 12

TestTransactionManager_CreationFunction · 0.80
TestTransactionManager_RegisterUnregisterTxFunction · 0.80
TestTransactionManager_RejectTxWhenClosingFunction · 0.80
TestTransactionManager_WaitForActiveTxsFunction · 0.80
TestTransactionManager_WaitForActiveTxsTimeoutFunction · 0.80
TestTransactionManager_ConcurrentRegisterUnregisterFunction · 0.80
TestTransactionManager_MaxActiveTxsFunction · 0.80
TestWriteBatchCommit_UnregistersOnBeginTxFailureFunction · 0.80
TestWriteBatchCancel_UnregistersTransactionFunction · 0.80
TestWriteBatchFlush_UnregistersFinalTransactionFunction · 0.80
TestWriteBatchReset_ReplacesTransactionFunction · 0.80
TestDB_Close_WithActiveTxsFunction · 0.80

Calls

no outgoing calls

Tested by 12

TestTransactionManager_CreationFunction · 0.64
TestTransactionManager_RegisterUnregisterTxFunction · 0.64
TestTransactionManager_RejectTxWhenClosingFunction · 0.64
TestTransactionManager_WaitForActiveTxsFunction · 0.64
TestTransactionManager_WaitForActiveTxsTimeoutFunction · 0.64
TestTransactionManager_ConcurrentRegisterUnregisterFunction · 0.64
TestTransactionManager_MaxActiveTxsFunction · 0.64
TestWriteBatchCommit_UnregistersOnBeginTxFailureFunction · 0.64
TestWriteBatchCancel_UnregistersTransactionFunction · 0.64
TestWriteBatchFlush_UnregistersFinalTransactionFunction · 0.64
TestWriteBatchReset_ReplacesTransactionFunction · 0.64
TestDB_Close_WithActiveTxsFunction · 0.64