GetActiveOperationCount returns the number of active operations. Uses atomic counter for lock-free operation.
()
| 243 | // GetActiveOperationCount returns the number of active operations. |
| 244 | // Uses atomic counter for lock-free operation. |
| 245 | func (hm *Manager) GetActiveOperationCount() int64 { |
| 246 | return hm.activeOperationCount.Load() |
| 247 | } |
| 248 | |
| 249 | // MarkSMigratedSeqIDProcessed attempts to mark a SMIGRATED SeqID as processed. |
| 250 | // Returns true if this is the first time processing this SeqID (should process), |