clayg

import logging
import eventlet.patcher
eventlet.patcher.monkey_patch(thread=True)
import threading


def take_and_release():
    try:
        logging._lock.acquire()
    finally:

clayg

vagrant@saio:~$ curl http://127.0.0.4:6041/sdb4/47/AUTH_test/container-6fb8e61f-f131-4037-9219-83c400ba81e7 -v
*   Trying 127.0.0.4:6041...
* TCP_NODELAY set
* Connected to 127.0.0.4 (127.0.0.4) port 6041 (#0)
> GET /sdb4/47/AUTH_test/container-6fb8e61f-f131-4037-9219-83c400ba81e7 HTTP/1.1
> Host: 127.0.0.4:6041
> User-Agent: curl/7.68.0
> Accept: */*
> 
* Mark bundle as not supporting multiuse

clayg

#!/usr/bin/env python
import sys
import os
import errno
from argparse import ArgumentParser
from collections import defaultdict
import pickle
import logging
try:
    import thread

clayg

grpc/examples/python/helloworld$ python async_greeter_server.py 
DEBUG:asyncio:Using selector: EpollSelector
DEBUG:grpc._cython.cygrpc:Using AsyncIOEngine.POLLER as I/O engine
INFO:root:Starting server on [::]:50051
^CDEBUG:grpc._cython.cygrpc:__dealloc__ called on running server <grpc._cython.cygrpc.AioServer object at 0x7f49685adc10> with status 4
Traceback (most recent call last):
  File "async_greeter_server.py", line 50, in <module>
    asyncio.run(serve())
  File "/usr/lib/python3.8/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)

clayg

#!/usr/bin/env python
from argparse import ArgumentParser
import sys
import json

import boto3


parser = ArgumentParser()
parser.add_argument('bucket', help='Bucket to make')

clayg

from swift.common.utils import Watchdog, WatchdogTimeout, GreenAsyncPile
from eventlet.greenthread import spawn
from eventlet import sleep, Timeout
import random

watchdog = Watchdog()
watchdog.spawn()


def range_iter(start=0):

clayg

#!/usr/bin/env python
from argparse import ArgumentParser
import json
from swift.common.memcached import MemcacheRing
from swift.proxy.controllers.base import get_cache_key

import sys

parser = ArgumentParser()
parser.add_argument('container', help='Name of container to check')

clayg

from argparse import ArgumentParser
import sys
import time

import boto3


parser = ArgumentParser()
parser.add_argument('bucket', help='bucket to make the upload')
parser.add_argument('key', nargs='?', help='key name for large object')

clayg

import sys
import subprocess
from swift.common.utils import get_logger
from threading import Thread
import time
import socket
import os
import ssl

clayg

from swiftclient import get_auth, client
import time
url, token = get_auth('http://saio:8080/auth/v1.0', 'test:tester', 'testing')
TIMEOUT = 30.0
finish = time.time() + TIMEOUT
while True:
    sc = client.head_account(url, token)
    print(sc)
    time.sleep(1.0)
    if time.time() > finish: