SERVER-26772 removed old initial sync code

1 files changed, 0 insertions, 48 deletions

diff --git a/src/mongo/db/repl/oplogreader.h b/src/mongo/db/repl/oplogreader.h
index 641315b748f..67095a5c7ad 100644
--- a/src/mongo/db/repl/oplogreader.h
+++ b/src/mongo/db/repl/oplogreader.h
@@ -31,21 +31,12 @@
 
 #pragma once
 
-
-#include "mongo/client/constants.h"
 #include "mongo/client/dbclientcursor.h"
 #include "mongo/util/net/hostandport.h"
-#include "mongo/util/time_support.h"
 
 namespace mongo {
-
-class OperationContext;
-
 namespace repl {
 
-class ReplicationCoordinator;
-class OpTime;
-
 // {"$natural": -1 }
 extern const BSONObj reverseNaturalObj;
 
@@ -87,9 +78,6 @@ public:
     BSONObj findOne(const char* ns, const Query& q) {
         return conn()->findOne(ns, q, 0, QueryOption_SlaveOk);
     }
-    BSONObj getLastOp(const std::string& ns) {
-        return findOne(ns.c_str(), Query().sort(reverseNaturalObj));
-    }
 
     /* SO_TIMEOUT (send/recv time out) for our DBClientConnections */
     static const Seconds kSocketTimeout;
@@ -103,12 +91,8 @@ public:
         return cursor.get() != 0;
     }
 
-    void query(const char* ns, Query query, int nToReturn, int nToSkip, const BSONObj* fields = 0);
-
     void tailingQuery(const char* ns, const BSONObj& query);
 
-    void tailingQueryGTE(const char* ns, Timestamp t);
-
     bool more() {
         uassert(15910, "Doesn't have cursor for reading oplog", cursor.get());
         return cursor->more();
@@ -119,19 +103,9 @@ public:
         return cursor->moreInCurrentBatch();
     }
 
-    int currentBatchMessageSize() {
-        if (NULL == cursor->getMessage())
-            return 0;
-        return cursor->getMessage()->size();
-    }
-
     BSONObj nextSafe() {
         return cursor->nextSafe();
     }
-    BSONObj next() {
-        return cursor->next();
-    }
-
 
     // master/slave only
     void peek(std::vector<BSONObj>& v, int n) {
@@ -143,28 +117,6 @@ public:
     void putBack(BSONObj op) {
         cursor->putBack(op);
     }
-
-    HostAndPort getHost() const;
-
-    /**
-     * Connects this OplogReader to a valid sync source, using the provided lastOpTimeFetched
-     * and ReplicationCoordinator objects.
-     * If this function fails to connect to a sync source that is viable, this OplogReader
-     * is left unconnected, where this->conn() equals NULL.
-     * In the process of connecting, this function may add items to the repl coordinator's
-     * sync source blacklist.
-     * This function may throw DB exceptions.
-     */
-    void connectToSyncSource(OperationContext* opCtx,
-                             const OpTime& lastOpTimeFetched,
-                             const OpTime& requiredOpTime,
-                             ReplicationCoordinator* replCoord);
-
-private:
-    /**
-     * Checks query response for required optime.
-     */
-    Status _compareRequiredOpTimeWithQueryResponse(const OpTime& requiredOpTime);
 };
 
 }  // namespace repl