@@ -66,14 +66,14 @@ func (s *Scheduler) Done() bool {
6666}
6767
6868func (s * Scheduler ) DecreaseValidationIdx (target TxnIndex ) {
69- StoreMin (& s .validation_idx , uint64 (target )) //nolint:gosec // index conversion safe
69+ StoreMin (& s .validation_idx , uint64 (target ))
7070 s .decrease_cnt .Add (1 )
7171}
7272
7373func (s * Scheduler ) CheckDone () {
7474 observed_cnt := s .decrease_cnt .Load ()
75- if s .execution_idx .Load () >= uint64 (s .block_size ) && //nolint:gosec // block size conversion safe
76- s .validation_idx .Load () >= uint64 (s .block_size ) && //nolint:gosec // block size conversion safe
75+ if s .execution_idx .Load () >= uint64 (s .block_size ) &&
76+ s .validation_idx .Load () >= uint64 (s .block_size ) &&
7777 s .num_active_tasks .Load () == 0 {
7878 if observed_cnt == s .decrease_cnt .Load () {
7979 s .done_marker .Store (true )
@@ -102,7 +102,7 @@ func (s *Scheduler) TryIncarnate(idx TxnIndex) TxnVersion {
102102//
103103// Invariant `num_active_tasks`: increased if a valid task is returned.
104104func (s * Scheduler ) NextVersionToExecute () TxnVersion {
105- if s .execution_idx .Load () >= uint64 (s .block_size ) { //nolint:gosec // block size conversion safe
105+ if s .execution_idx .Load () >= uint64 (s .block_size ) {
106106 s .CheckDone ()
107107 return InvalidTxnVersion
108108 }
@@ -116,15 +116,15 @@ func (s *Scheduler) NextVersionToExecute() TxnVersion {
116116//
117117// Invariant `num_active_tasks`: increased if a valid task is returned.
118118func (s * Scheduler ) NextVersionToValidate () TxnVersion {
119- if s .validation_idx .Load () >= uint64 (s .block_size ) { //nolint:gosec // block size conversion safe
119+ if s .validation_idx .Load () >= uint64 (s .block_size ) {
120120 s .CheckDone ()
121121 return InvalidTxnVersion
122122 }
123123 IncrAtomic (& s .num_active_tasks )
124124 idx_to_validate := FetchIncr (& s .validation_idx )
125- if idx_to_validate < uint64 (s .block_size ) { //nolint:gosec // block size conversion safe
125+ if idx_to_validate < uint64 (s .block_size ) {
126126 if ok , incarnation := s .txn_status [idx_to_validate ].IsExecuted (); ok {
127- return TxnVersion {TxnIndex (idx_to_validate ), incarnation } //nolint:gosec // index conversion safe
127+ return TxnVersion {TxnIndex (idx_to_validate ), incarnation }
128128 }
129129 }
130130
@@ -178,8 +178,7 @@ func (s *Scheduler) FinishExecution(version TxnVersion, wroteNewPath bool) (TxnV
178178
179179 deps := s .txn_dependency [version .Index ].Swap (nil )
180180 s .ResumeDependencies (deps )
181- // otherwise index already small enough
182- if s .validation_idx .Load () > uint64 (version .Index ) { //nolint:gosec // index conversion safe
181+ if s .validation_idx .Load () > uint64 (version .Index ) { // otherwise index already small enough
183182 if ! wroteNewPath {
184183 // schedule validation for current tx only, don't decrease num_active_tasks
185184 return version , TaskKindValidation
@@ -201,7 +200,7 @@ func (s *Scheduler) FinishValidation(txn TxnIndex, aborted bool) (TxnVersion, Ta
201200 if aborted {
202201 s .txn_status [txn ].SetReadyStatus ()
203202 s .DecreaseValidationIdx (txn + 1 )
204- if s .execution_idx .Load () > uint64 (txn ) { //nolint:gosec // index conversion safe
203+ if s .execution_idx .Load () > uint64 (txn ) {
205204 return s .TryIncarnate (txn ), TaskKindExecution
206205 }
207206 }
0 commit comments