- curr->Penalty--;
- curr->OnDataReady();
- }
-
- if (curr->getSendQSize() == 0)
- {
- FOREACH_MOD(I_OnBufferFlushed,OnBufferFlushed(curr));
+ unsigned int rate = curr->MyClass->GetCommandRate();
+ if (curr->CommandFloodPenalty > rate)
+ curr->CommandFloodPenalty -= rate;
+ else
+ curr->CommandFloodPenalty = 0;
+ curr->eh.OnDataReady();