summaryrefslogtreecommitdiff
path: root/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/execute_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/execute_test.go')
-rw-r--r--src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/execute_test.go67
1 files changed, 0 insertions, 67 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/execute_test.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/execute_test.go
deleted file mode 100644
index 2a56f679c77..00000000000
--- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/execute_test.go
+++ /dev/null
@@ -1,67 +0,0 @@
-// Copyright (C) MongoDB, Inc. 2014-present.
-//
-// Licensed under the Apache License, Version 2.0 (the "License"); you may
-// not use this file except in compliance with the License. You may obtain
-// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
-
-package mongoreplay
-
-import (
- "testing"
-
- mgo "github.com/10gen/llmgo"
- "github.com/mongodb/mongo-tools/legacy/testtype"
-)
-
-func TestCompleteReply(t *testing.T) {
- testtype.SkipUnlessTestType(t, testtype.MongoReplayTestType)
- context := NewExecutionContext(&StatCollector{}, nil, &ExecutionOptions{})
-
- // AddFromWire takes a recorded request and a live reply to the re-execution
- // of that reply
- reply1 := &ReplyOp{}
- reply1.ReplyOp = mgo.ReplyOp{
- CursorId: 2500,
- }
- recordedOp1 := &RecordedOp{
- DstEndpoint: "a",
- SrcEndpoint: "b",
- RawOp: RawOp{
- Header: MsgHeader{
- RequestID: 1000,
- },
- },
- Generation: 0,
- }
- context.AddFromWire(reply1, recordedOp1)
-
- // AddFromFile takes a recorded reply and the contained reply
- reply2 := &ReplyOp{}
- reply2.ReplyOp = mgo.ReplyOp{
- CursorId: 1500,
- }
-
- recordedOp2 := &RecordedOp{
- DstEndpoint: "b",
- SrcEndpoint: "a",
- RawOp: RawOp{
- Header: MsgHeader{
- ResponseTo: 1000,
- },
- },
- Generation: 0,
- }
- context.AddFromFile(reply2, recordedOp2)
- if len(context.CompleteReplies) != 1 {
- t.Error("replies not completed")
- }
- context.handleCompletedReplies()
-
- cursorIDLookup, ok := context.CursorIDMap.GetCursor(1500, -1)
- if !ok {
- t.Error("can't find cursorID in map")
- }
- if cursorIDLookup != 2500 {
- t.Errorf("looked up cursorID is wrong: %v, should be 2500", cursorIDLookup)
- }
-}