summaryrefslogtreecommitdiff
path: root/src/mongo/db/dbmessage.h
diff options
context:
space:
mode:
authorYoonsoo Kim <yoonsoo.kim@mongodb.com>2021-08-10 17:39:49 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-08-10 18:34:30 +0000
commit8016ab594857e6e53daff9ae6bba7f9f2336ad1e (patch)
tree2946d3a3475da763e3c6b13ca80362333b7756de /src/mongo/db/dbmessage.h
parent3888d215464a081c831074918ad590a8e3ba74a1 (diff)
downloadmongo-8016ab594857e6e53daff9ae6bba7f9f2336ad1e.tar.gz
SERVER-58140 Remove legacy update/delete parsers
Diffstat (limited to 'src/mongo/db/dbmessage.h')
-rw-r--r--src/mongo/db/dbmessage.h37
1 files changed, 14 insertions, 23 deletions
diff --git a/src/mongo/db/dbmessage.h b/src/mongo/db/dbmessage.h
index 63c78c261cb..822bb29ecee 100644
--- a/src/mongo/db/dbmessage.h
+++ b/src/mongo/db/dbmessage.h
@@ -384,6 +384,20 @@ public:
}
};
+template <typename Func>
+Message makeMessage(NetworkOp op, Func&& bodyBuilder) {
+ BufBuilder b;
+ b.skip(sizeof(MSGHEADER::Layout));
+
+ bodyBuilder(b);
+
+ const int size = b.len();
+ auto out = Message(b.release());
+ out.header().setOperation(op);
+ out.header().setLen(size);
+ return out;
+}
+
/**
* Builds a legacy OP_QUERY message.
*/
@@ -419,11 +433,6 @@ enum UpdateOptions {
UpdateOption_Broadcast = 1 << 2
};
-/**
- * Builds a legacy OP_UPDATE message.
- */
-Message makeDeprecatedUpdateMessage(StringData ns, BSONObj query, BSONObj update, int flags = 0);
-
enum RemoveOptions {
/** only delete one option */
RemoveOption_JustOne = 1 << 0,
@@ -433,24 +442,6 @@ enum RemoveOptions {
};
/**
- * Builds a legacy OP_REMOVE message.
- */
-Message makeDeprecatedRemoveMessage(StringData ns, BSONObj query, int flags = 0);
-
-/**
- * Builds a legacy OP_KILLCURSORS message.
- */
-Message makeDeprecatedKillCursorsMessage(long long cursorId);
-
-/**
- * Builds a legacy OP_GET_MORE message.
- */
-Message makeDeprecatedGetMoreMessage(StringData ns,
- long long cursorId,
- int nToReturn,
- int flags = 0);
-
-/**
* A response to a DbMessage.
*
* Order of fields makes DbResponse{funcReturningMessage()} valid.