summaryrefslogtreecommitdiff
path: root/src/mongo/util/concurrency/task.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/util/concurrency/task.cpp')
-rw-r--r--src/mongo/util/concurrency/task.cpp70
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();
+}
+}
}