| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/query/ |
| H A D | killcursors_request.cpp | 48 : nss(nsString), cursorIds(ids) {} in KillCursorsRequest()
75 std::vector<CursorId> cursorIds; in parseFromBSON() local
83 cursorIds.push_back(cursorEl.numberLong()); in parseFromBSON()
86 if (cursorIds.empty()) { in parseFromBSON()
91 return KillCursorsRequest(nss, cursorIds); in parseFromBSON()
99 for (CursorId id : cursorIds) { in toBSON()
|
| H A D | killcursors_request_test.cpp | 52 ASSERT_EQ(request.cursorIds.size(), 2U); in TEST()
53 ASSERT_EQ(request.cursorIds[0], CursorId(123)); in TEST()
54 ASSERT_EQ(request.cursorIds[1], CursorId(456)); in TEST()
131 std::vector<CursorId> cursorIds = {CursorId(123), CursorId(456)}; in TEST() local
132 KillCursorsRequest request(nss, cursorIds); in TEST()
|
| H A D | killcursors_response.cpp | 50 std::vector<CursorId>* cursorIds) { in fillOutCursorArray() argument
66 cursorIds->push_back(cursorElt.numberLong()); in fillOutCursorArray()
72 void addCursorArrayToBSON(const std::vector<CursorId>& cursorIds, in addCursorArrayToBSON() argument
76 for (CursorId id : cursorIds) { in addCursorArrayToBSON()
|
| H A D | killcursors_request.h | 54 const std::vector<CursorId> cursorIds; member
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/s/ |
| H A D | metadata_manager.cpp | 160 std::vector<CursorId> cursorIds; in logRangeDeletionWaitingOnOpenCursors() local
165 cursorIds.insert(cursorIds.end(), in logRangeDeletionWaitingOnOpenCursors()
178 cursorIds.insert(cursorIds.end(), in logRangeDeletionWaitingOnOpenCursors()
185 cursorIds.empty() ? "" : std::accumulate(std::next(cursorIds.begin()), in logRangeDeletionWaitingOnOpenCursors()
186 cursorIds.end(), in logRangeDeletionWaitingOnOpenCursors()
187 std::to_string(cursorIds[0]), in logRangeDeletionWaitingOnOpenCursors()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/commands/ |
| H A D | killcursors_common.cpp | 54 for (CursorId id : killCursorsRequest.cursorIds) { in checkAuthForCommand()
85 for (CursorId id : killCursorsRequest.cursorIds) { in run()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/query/ |
| H A D | cluster_cursor_manager_test.cpp | 193 std::vector<CursorId> cursorIds(numCursors); in TEST_F() local
197 cursorIds[i] = in TEST_F()
205 auto pinnedCursor = getManager()->checkOutCursor(nss, cursorIds[i], _opCtx.get()); in TEST_F()
338 std::vector<CursorId> cursorIds(numCursors); in TEST_F() local
341 cursorIds[i] = in TEST_F()
350 ASSERT_OK(getManager()->killCursor(nss, cursorIds[i])); in TEST_F()
735 std::vector<CursorId> cursorIds(numCursors); in TEST_F() local
737 cursorIds[i] = in TEST_F()
746 getManager()->getNamespaceForCursorId(cursorIds[i]); in TEST_F()
|
| /dports/mail/mailhog/MailHog-1.0.0/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/security/vault/vault-1.8.2/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/sysutils/helmfile/vault-f6547fa8e820/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/gopkg.in/mgo.v2-unstable/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/misc/concourse/vault-bdd38fca2cff/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/misc/perkeep/perkeep-0.11/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/sysutils/helmfile/helmfile-0.138.7/vendor/github.com/hashicorp/vault/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/sysutils/gomplate/vault-sdk-v0.1.13/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/hashicorp/vault/vault-api-v1.0.4/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/devel/gitlab-runner/vault-sdk-v0.1.13/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/sysutils/istio/vault-sdk-v0.1.12/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/vendor/gopkg.in/mgo.v2/ |
| H A D | socket.go | 172 cursorIds []int64 member
469 buf = addInt32(buf, int32(len(op.cursorIds)))
470 for _, cursorId := range op.cursorIds {
|