Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- > *** error: can't allocate region
- > *** set a breakpoint in malloc_error_break to debug Assertion failed: (msg_->flags | ZMQ_MSG_MASK) == 0xff (zmq.cpp:211)
- > Python(42410,0xaccb8a28) malloc: *** mmap(size=3559424) failed (error
- > code=12)
- import sys
- import resource
- import zmq
- import time
- context = zmq.Context()
- if sys.argv[1] == 'worker':
- # Socket to send messages to
- sender = context.socket(zmq.PUSH)
- sender.connect("tcp://localhost:5558")
- while True:
- msg = 'x' * 3559333
- time.sleep(.01)
- sender.send(msg)
- else:
- # Socket to receive messages on
- receiver = context.socket(zmq.PULL)
- receiver.bind("tcp://*:5558")
- while True:
- msg = receiver.recv()
- print msg[0:5], len(msg), resource.getrusage(resource.RUSAGE_SELF).ru_maxrss
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement