rectalogic

import threading
import socket
import Queue

def accept():
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.bind(("", 65021))
    s.listen(5)
    s.accept()

rectalogic

import signal
import Queue

def handler(signum, frame):
    global shutdown
    # Don't log here, not reentrant
    shutdown = True

signal.signal(signal.SIGTERM, handler)
signal.signal(signal.SIGINT, handler)

rectalogic

import signal
import Queue

def handler(signum, frame):
    q.put(None)

signal.signal(signal.SIGTERM, handler)
signal.signal(signal.SIGINT, handler)

q = Queue.Queue()

rectalogic

import socket
import threading
from StringIO import StringIO
import paramiko

HOST, PORT = 'localhost', 2222
HOSTKEY = """
-----BEGIN EC PRIVATE KEY-----
MHcCAQEEINnMNKzog0Cbnun+EKuFu4kcpc0iKJALw5LkC1E1x+9EoAoGCCqGSM49
AwEHoUQDQgAEt11fabDR77CPL/1OUfayQ/m3C1uRI/039pBmYagk4zQ4Mxwow6L6

rectalogic

    pipeline = [
        {
            "$match": {
                "$and": query
            }
        },
        {"$group": {"_id": "$user_id", "user_id": {"$sum": 1}}}
    ]

rectalogic

sh-session hiliting

user@vpn$ dd if=/dev/random count=32 bs=1 2>/dev/null | base64
N/5y0EkgCFevc9uvJv1GsMG14BwbknCERoyJKZatoh0=
user@vpn$ dd if=/dev/random count=32 bs=1 2>/dev/null | base64
eb3W4WYXuHsnc0KVzg65G3XFQUD/I69/pYqFCYb5+iQ=

console hiliting

rectalogic

cureatr:PRIMARY> use test
cureatr:PRIMARY> db.foo.createIndex({prefix: 1, unique: 1}, {unique: true})
cureatr:PRIMARY> db.foo.createIndex({prefix : 1, nonunique: 1})

cureatr:PRIMARY> db.foo.explain().find({prefix: "a", nonunique: /^a/i})
{
    "queryPlanner" : {
        "plannerVersion" : 1,
        "namespace" : "test.foo",
        "indexFilterSet" : false,

rectalogic

class MetadataValue:
    field1 = Field(order=1)
    field2 = Field(order=3)

rectalogic

<?xml version='1.0' encoding='UTF-8'?>
<mlt>
  <producer id='background'>
    <property name='mlt_type'>producer</property>
    <property name='mlt_service'>colour</property>
    <property name='colour'>0x000000ff</property>
  </producer>
  <producer id='producer-red-4x3.mov-0'>
    <property name='mlt_type'>producer</property>
    <property name='resource'>media/red-4x3.mov.r0.lossless.mov</property>

rectalogic

class QueryDebugger(object):
    def __init__(self, engine, query):
        with engine.connect() as connection:
            try:
                sqlalchemy.event.listen(engine, "do_execute", self.receive_do_execute)
                connection.execute(query)
            finally:
                sqlalchemy.event.remove(engine, "do_execute", self.receive_do_execute)

    def receive_do_execute(self, cursor, statement, parameters, context):