RepoMirrors/mars
1
0
Fork 0
mirror of https://github.com/schoebel/mars synced 2025-02-05 23:02:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

trans_logger: cease queue banning upon real progress

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2013-01-01 15:52:54 +01:00
parent e4ace4a8d5
commit 5fe6ff76df
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib_timing.h
View File

@ -119,6 +119,12 @@ bool banning_is_hit(struct banning *ban)
return (ban->ban_last_hit && ban->ban_last_hit >= now);
}
extern inline
void banning_reset(struct banning *ban)
{
ban->ban_last_hit = 0;
}
/* Threshold: trigger a banning whenever some latency threshold
* is exceeded.
*/

7
mars_trans_logger.c
View File

@ -1481,6 +1481,8 @@ void phase0_endio(void *private, int error)
*/
__trans_logger_ref_put(brick, orig_mref_a);
banning_reset(&brick->q_phase[0].q_banning);
wake_up_interruptible_all(&brick->worker_event);
return;
err:
@ -1675,6 +1677,8 @@ void phase1_endio(struct generic_callback *cb)
qq_dec_flying(&brick->q_phase[1]);
banning_reset(&brick->q_phase[1].q_banning);
// queue up for the next phase
qq_wb_insert(&brick->q_phase[2], wb);
wake_up_interruptible_all(&brick->worker_event);
@ -1787,6 +1791,7 @@ void phase2_endio(void *private, int error)
CHECK_ATOMIC(&wb->w_sub_log_count, 1);
if (atomic_dec_and_test(&wb->w_sub_log_count)) {
banning_reset(&brick->q_phase[2].q_banning);
_phase2_endio(wb);
}
return;
@ -1916,6 +1921,8 @@ void phase3_endio(struct generic_callback *cb)
free_writeback(wb);
banning_reset(&brick->q_phase[3].q_banning);
wake_up_interruptible_all(&brick->worker_event);
return;