sockettest.py

import os
import socket
from threading import Thread


def serve():
    global accepted_client
    accepted_client = server.accept()


accepted_client = None
server = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
server.bind('/tmp/blah.sock')
try:
    server.listen()
    t = Thread(target=serve)
    t.start()
    client = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
    client.connect('/tmp/blah.sock')
    client.settimeout(None)
    n = client.send(b'\x00' * 1024_000)
    print('sent: %d' % n)
    t.join()
finally:
    server.close()
    os.unlink('/tmp/blah.sock')