|
|
@ -1706,7 +1706,6 @@ static bool workio_get_work(struct workio_cmd *wc) |
|
|
|
static bool stale_work(struct work *work, bool share) |
|
|
|
static bool stale_work(struct work *work, bool share) |
|
|
|
{ |
|
|
|
{ |
|
|
|
struct timeval now; |
|
|
|
struct timeval now; |
|
|
|
bool ret = false; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
gettimeofday(&now, NULL); |
|
|
|
gettimeofday(&now, NULL); |
|
|
|
if (share) { |
|
|
|
if (share) { |
|
|
@ -1716,8 +1715,12 @@ static bool stale_work(struct work *work, bool share) |
|
|
|
return true; |
|
|
|
return true; |
|
|
|
|
|
|
|
|
|
|
|
if (work->work_block != work_block) |
|
|
|
if (work->work_block != work_block) |
|
|
|
ret = true; |
|
|
|
return true; |
|
|
|
return ret; |
|
|
|
|
|
|
|
|
|
|
|
if (opt_fail_only && work->pool != current_pool()) |
|
|
|
|
|
|
|
return true; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return false; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void *submit_work_thread(void *userdata) |
|
|
|
static void *submit_work_thread(void *userdata) |
|
|
|