This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* Test majority reads on the recipient. | |
* | |
* 1. Before migration, insert docs on donor D. | |
* 2. Enable fpAfterCollectionClonerDone failpoint on R. | |
* 3. Run the migration until it hits fpAfterCollectionClonerDone. | |
* 4. Hold back R's stable timestamp. | |
* 5. Insert newDoc on D, applied on R at recipient timestamp 90. | |
* 6. Disable fpAfterCollectionClonerDone. | |
* 7. Wait for the migration to commit, it commits at ts 100. |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* WARNING: This is a generated file. Do not modify. | |
* | |
* Source: buildscripts/idl/idlc.py --include src --base_dir build/mac --target_arch x86_64 --header build/mac/mongo/idl/generic_argument_gen.h --output build/mac/mongo/idl/generic_argument_gen.cpp src/mongo/idl/generic_argument.idl | |
*/ | |
#include "mongo/platform/basic.h" | |
#include "mongo/idl/generic_argument_gen.h" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import heapq | |
import re | |
import sys | |
from datetime import datetime | |
from operator import itemgetter | |
def parse_lines(file_name): | |
ts = datetime.min | |
ts_str = "" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python3 | |
import re | |
import subprocess | |
import sys | |
proc = subprocess.Popen(sys.argv[1:], stdout=subprocess.PIPE) | |
for line in iter(proc.stdout.readline, b''): | |
match = re.match(rb'src/[\w_/.]+:\d+.*', line) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python3 | |
import os | |
import sys | |
if len(sys.argv) != 2: | |
print("Usage: %s FILE" % (sys.argv[0],)) | |
sys.exit(1) | |
path = os.path.abspath(sys.argv[1]) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# "pip install pytablewriter" | |
from pytablewriter import MarkdownTableWriter | |
writer = MarkdownTableWriter() | |
writer.headers = ["datum", "before rollback", "after rollback"] | |
writer.value_matrix = [ | |
["last fetched", "> source's lastApplied", "<= source's lastApplied"], | |
["rollback ID", "N", "N + 1"], | |
["prepared txns", "in progress", "aborted"], | |
["stable timestamp", "???", "oplog common point??"], |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
MongoDB shell version v0.0.0 | |
connecting to: mongodb://127.0.0.1:27017/?compressors=disabled&gssapiServiceName=mongodb | |
WARNING: No implicit session: Logical Sessions are only supported on server versions 3.6 and greater. | |
Implicit session: dummy session | |
MongoDB server version: 3.4.20 | |
WARNING: shell and server versions do not match | |
{ | |
"numClientConnections" : 9, | |
"numAScopedConnections" : 0, | |
"totalInUse" : 0, |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8"?> | |
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd"> | |
<plist version="1.0"> | |
<dict> | |
<key>Label</key> | |
<string>local.mirror-client</string> | |
<key>Program</key> | |
<string>/usr/bin/java</string> | |
<key>ProgramArguments</key> | |
<array> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
class TimeoutInGetOldestTransactionTimestamp : public MultiDocumentTransactionTest { | |
public: | |
TimeoutInGetOldestTransactionTimestamp() | |
: MultiDocumentTransactionTest("timeoutInGetOldestTransactionTimestamp") {} | |
void run() { | |
auto txnParticipant = TransactionParticipant::get(_opCtx); | |
ASSERT(txnParticipant); | |
AutoGetCollection txns( |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
class AsyncSocketWrapper: | |
# Sockets are wrapped in this simplified class and passed down | |
# to the pymongo <=> libmongocrypt integration layer. | |
def __init__(self, sockinfo): | |
self._sockinfo = sockinfo | |
def send(self, buffer): | |
# libmongocrypt calls this function on one of its worker threads. | |
event = threading.Event() |
NewerOlder