[zeromq-dev] cannot send big chunk via PUSH/PULL by pyzmq

[Li Ma]

On Thu, Apr 23, 2015 at 7:50 PM, Pieter Hintjens <ph at imatix.com> 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 <skywalker.nick at gmail.com> 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: skywalker.nick at gmail.com
>> _______________________________________________
>> zeromq-dev mailing list
>> zeromq-dev at lists.zeromq.org
>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev



-- 

Li Ma (Nick)
Email: skywalker.nick at gmail.com