ajdavis

/**
 * 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.

ajdavis

/**
 * 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"

ajdavis

import heapq
import re
import sys
from datetime import datetime
from operator import itemgetter


def parse_lines(file_name):
    ts = datetime.min
    ts_str = ""

ajdavis

#!/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)

ajdavis

#!/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])

ajdavis

# "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??"],

ajdavis

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,

ajdavis

<?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>

ajdavis

class TimeoutInGetOldestTransactionTimestamp : public MultiDocumentTransactionTest {
public:
    TimeoutInGetOldestTransactionTimestamp()
        : MultiDocumentTransactionTest("timeoutInGetOldestTransactionTimestamp") {}

    void run() {
        auto txnParticipant = TransactionParticipant::get(_opCtx);
        ASSERT(txnParticipant);

        AutoGetCollection txns(

ajdavis

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()