multiprocessing-send-large-data-via-pipe.py

#!/usr/bin/env python
"""Try to cause MemoryError by sending large data via multiprocessing.Pipe.

Context: http://stackoverflow.com/q/22150703
"""
from multiprocessing import Process, Pipe

def send_big_data(conn):
    data = b"a" * (1 << 30) # 1GB
    conn.send(data)
    conn.close() # eof

if __name__=="__main__":
    parent_conn, child_conn = Pipe()
    child = Process(target=send_big_data, args=(child_conn,))
    child.start()
    child_conn.close() # child must be the only with it opened
    print(len(parent_conn.recv()))