diff options
Diffstat (limited to 'src/mongo/util/concurrency/task.cpp')
-rw-r--r-- | src/mongo/util/concurrency/task.cpp | 70 |
1 files changed, 35 insertions, 35 deletions
diff --git a/src/mongo/util/concurrency/task.cpp b/src/mongo/util/concurrency/task.cpp index 915cdecbc66..a73938a5f75 100644 --- a/src/mongo/util/concurrency/task.cpp +++ b/src/mongo/util/concurrency/task.cpp @@ -37,49 +37,49 @@ namespace mongo { - namespace task { +namespace task { - Task::Task() - : BackgroundJob( true /* deleteSelf */ ) { - n = 0; - repeat = 0; - } +Task::Task() : BackgroundJob(true /* deleteSelf */) { + n = 0; + repeat = 0; +} - void Task::halt() { repeat = 0; } +void Task::halt() { + repeat = 0; +} - void Task::setUp() {} +void Task::setUp() {} - void Task::run() { - verify( n == 0 ); +void Task::run() { + verify(n == 0); - setUp(); + setUp(); - while( 1 ) { - n++; - try { - doWork(); - } - catch(...) { } - sleepmillis(repeat); - if( inShutdown() ) - break; - if( repeat == 0 ) - break; - } - } - - void Task::begin() { - go(); + while (1) { + n++; + try { + doWork(); + } catch (...) { } + sleepmillis(repeat); + if (inShutdown()) + break; + if (repeat == 0) + break; + } +} - void fork(Task *t) { - t->begin(); - } +void Task::begin() { + go(); +} - void repeat(Task *t, unsigned millis) { - t->repeat = millis; - t->begin(); - } +void fork(Task* t) { + t->begin(); +} - } +void repeat(Task* t, unsigned millis) { + t->repeat = millis; + t->begin(); +} +} } |