On Thu, Apr 23, 2015 at 7:50 PM, Pieter Hintjens <[email protected]> wrote:
> - please provide your test case as a minimal program
Sure.
Server part:
context = zmq.Context(1)
socket = context.socket(zmq.PULL)
socket.bind("tcp://*:5555")
while True:
# Wait for next request from client
message = socket.recv_multipart()
print "hello: %s, time: %s\n" % (len(message), datetime.utcnow())
Client part:
context = zmq.Context(1)
def send(size):
buffer = []
for i in range(size):
buffer.append('0')
socket = context.socket(zmq.PUSH)
socket.connect("tcp://localhost:5555")
print("Sending request %s ..." % datetime.utcnow())
tracker = socket.send_multipart(buffer, copy=False, track=True)
while(True):
if tracker.done:
socket.close(-1)
return '\nDONE, %s\n' % datetime.utcnow()
else:
time.sleep(.01)
for i in range(3):
print send(2000000)
> - don't do any TCP tuning unless you know why you're doing it
>
I use the distro-default configuration, but it doesn't work.
> On Thu, Apr 23, 2015 at 8:35 AM, Li Ma <[email protected]> wrote:
>> Hi all,
>>
>> I wanna test a simple application using PUSH/PULL to send a big chunk of
>> data.
>> The application is straightforward.
>>
>> Server part is to open a PULL socket while client part is sending >1MB
>> message per time via PUSH.
>>
>> The socket is listened on the localhost only.
>>
>> Any messages less than 200KB are working well, but messages greater
>> than 500KB is not working. The socket is stuck after handshake without
>> any exceptions.
>>
>> By the way, I set a large size (>1MB) for SND/RCV BUF and tcp window
>> scaling is set to 1.
>>
>> I'd appreciate any hints to make it work.
>>
>> --
>>
>> Li Ma (Nick)
>> Email: [email protected]
>> _______________________________________________
>> zeromq-dev mailing list
>> [email protected]
>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
> _______________________________________________
> zeromq-dev mailing list
> [email protected]
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
--
Li Ma (Nick)
Email: [email protected]
_______________________________________________
zeromq-dev mailing list
[email protected]
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
