diff options
| author | Antonin Kral <a.kral@bobek.cz> | 2010-08-11 12:38:57 +0200 |
|---|---|---|
| committer | Antonin Kral <a.kral@bobek.cz> | 2010-08-11 12:38:57 +0200 |
| commit | 7645618fd3914cb8a20561625913c20d49504a49 (patch) | |
| tree | 8370f846f58f6d71165b7a0e2eda04648584ec76 /db/repl/rs_optime.h | |
| parent | 68c73c3c7608b4c87f07440dc3232801720b1168 (diff) | |
| download | mongodb-7645618fd3914cb8a20561625913c20d49504a49.tar.gz | |
Imported Upstream version 1.6.0
Diffstat (limited to 'db/repl/rs_optime.h')
| -rw-r--r-- | db/repl/rs_optime.h | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/db/repl/rs_optime.h b/db/repl/rs_optime.h new file mode 100644 index 0000000..b3607fa --- /dev/null +++ b/db/repl/rs_optime.h @@ -0,0 +1,58 @@ +// @file rs_optime.h
+
+/*
+ * Copyright (C) 2010 10gen Inc.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3,
+ * as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#pragma once
+
+#include "../../util/optime.h"
+
+namespace mongo {
+
+ const char rsoplog[] = "local.oplog.rs"; +
+ /*
+ class RSOpTime : public OpTime {
+ public:
+ bool initiated() const { return getSecs() != 0; }
+ };*/
+
+ /*struct RSOpTime {
+ unsigned long long ord;
+
+ RSOpTime() : ord(0) { }
+
+ bool initiated() const { return ord > 0; }
+
+ void initiate() {
+ assert( !initiated() );
+ ord = 1000000;
+ }
+
+ ReplTime inc() {
+ DEV assertInWriteLock();
+ return ++ord;
+ }
+
+ string toString() const { return str::stream() << ord; }
+
+ // query the oplog and set the highest value herein. acquires a db read lock. throws.
+ void load();
+ };
+
+ extern RSOpTime rsOpTime;*/
+
+}
|