Open MPI logo

Open MPI Development Mailing List Archives

  |   Home   |   Support   |   FAQ   |   all Development mailing list

Subject: [OMPI devel] Client connection lost
From: Caciano Machado (caciano_at_[hidden])
Date: 2008-06-26 22:52:11


Hi,

After publishing and consuming some messages (greater than 128KB)
suddenly my application loses its connections to the server and prints
the following log. If I use only smaller messages then nothing wrong
happens.

18:14:44: E: Socket error: Bad address, connection to server lost
(10.135.250.16:5672)

the server prints this one:

2008-06-26 18:14:44: E: Socket closing: End of file found, connection
to client lost (10.135.250.16:34733, OpenAMQ Kernel Client, 1.2d0, 0)

Any ideas of what could be wrong?

####################################################################

Here is a "resume" of my configuration:

  /* QUEUE DECLARE */
    amq_client_session_queue_declare (
        mom_endpoint_addr.sess, /* session */
        0, /* ticket */
        mom_addr.queue, /* queue name */
        FALSE, /* passive */
        FALSE, /* durable */
        TRUE, /* exclusive */
        TRUE, /* auto-delete */
        NULL); /* arguments */

    /* QUEUE BIND */
    amq_client_session_queue_bind (
        mom_endpoint_addr.sess, /* session */
        0, /* ticket */
        mom_addr.queue, /* queue */
        "amq.direct", /* exchange */
        mom_addr.key, /* routing-key */
        NULL); /* arguments */

    /* QUEUE CONSUME */
    amq_client_session_basic_consume (
        mom_endpoint_addr.sess, /* session */
        0, /* ticket */
        mom_addr.queue, /* queue */
        NULL, /* consumer-tag */
        TRUE, /* no-local */
        TRUE, /* no-ack */
        TRUE, /* exclusive */
        NULL); /* arguments */
...
    /* RECEIVE MESSAGES */
    amq_client_session_wait(mom_endpoint_addr.sess, 30000);
    amq_content_basic_get_body(content_recv, (byte*) buf, length));
    amq_content_basic_unlink (&content_recv);
...
    /* PUBLISH MESSAGE*/
    mom_return = amq_client_session_basic_publish (
        mom_endpoint->mom_peer_addr.sess, /* session */
        content, /* content to send */
        0, /* ticket */
        "amq.direct",
        mom_endpoint->mom_peer->key, /* routing-key */
        FALSE, /* mandatory */
        FALSE); /* immediate */

####################################################################

And here is a trace log of the server:

cmachado_at_xiru-6:~$ amq_server --trace 1
OpenAMQ/1.2d0
Production release

Copyright (c) 2007-2008 iMatix Corporation
This is free software; see the source for copying conditions. There is NO
warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

2008-06-26 21:29:10: W: security warning - logins use default passwords
2008-06-26 21:29:10: I: hostname is xiru-6 (10.135.250.16)
2008-06-26 21:29:10: I: listening on port 5672, all network interfaces
2008-06-26 21:29:10: I: no failover defined, READY as stand-alone
2008-06-26 21:29:11: I: server ready for incoming AMQ connections
2008-06-26 21:29:21: I: send connection.start: version_major=0
version_minor=9 server_properties=184B mechanisms=5B locales=5B
2008-06-26 21:29:21: I: recv connection.start-ok:
client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
2008-06-26 21:29:21: I: send connection.tune: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
capabilities="" insist=0
2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
2008-06-26 21:29:21: I: recv queue.declare: ticket=0 queue="0"
passive=0 durable=0 exclusive=1 auto_delete=1 nowait=0 arguments=0B
2008-06-26 21:29:21: I: send queue.declare-ok: queue="0"
message_count=0 consumer_count=0
2008-06-26 21:29:21: I: recv queue.bind: ticket=0 queue="0"
exchange="amq.direct" routing_key="0" nowait=0 arguments=0B
2008-06-26 21:29:21: I: send queue.bind-ok:
2008-06-26 21:29:21: I: recv basic.consume: ticket=0 queue="0"
consumer_tag="" no_local=1 no_ack=1 exclusive=1 nowait=0 arguments=0B
2008-06-26 21:29:21: I: send basic.consume-ok: consumer_tag="0"
2008-06-26 21:29:21: I: send connection.start: version_major=0
version_minor=9 server_properties=184B mechanisms=5B locales=5B
2008-06-26 21:29:21: I: recv connection.start-ok:
client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
2008-06-26 21:29:21: I: send connection.tune: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
capabilities="" insist=0
2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
2008-06-26 21:29:21: I: recv queue.declare: ticket=0 queue="1"
passive=0 durable=0 exclusive=1 auto_delete=1 nowait=0 arguments=0B
2008-06-26 21:29:21: I: send queue.declare-ok: queue="1"
message_count=0 consumer_count=0
2008-06-26 21:29:21: I: recv queue.bind: ticket=0 queue="1"
exchange="amq.direct" routing_key="1" nowait=0 arguments=0B
2008-06-26 21:29:21: I: send queue.bind-ok:
2008-06-26 21:29:21: I: recv basic.consume: ticket=0 queue="1"
consumer_tag="" no_local=1 no_ack=1 exclusive=1 nowait=0 arguments=0B
2008-06-26 21:29:21: I: send basic.consume-ok: consumer_tag="0"
2008-06-26 21:29:21: I: send connection.start: version_major=0
version_minor=9 server_properties=184B mechanisms=5B locales=5B
2008-06-26 21:29:21: I: send connection.start: version_major=0
version_minor=9 server_properties=184B mechanisms=5B locales=5B
2008-06-26 21:29:21: I: recv connection.start-ok:
client_properties=184B mechanism="PLAIN" response=12B
locale="en_US"2008-06-26 21:29:21: I: recv connection.start-ok:
client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
2008-06-26 21:29:21: I: send connection.tune: channel_max=1
frame_max=32768 heartbeat=2

2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
capabilities="" insist=0
2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
2008-06-26 21:29:21: I: send connection.tune: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
capabilities="" insist=0
2008-06-26 21:29:21: I: send connection.start: version_major=0
version_minor=9 server_properties=184B mechanisms=5B locales=5B
2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
2008-06-26 21:29:21: I: recv connection.start-ok:
client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
2008-06-26 21:29:21: I: send connection.tune: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
capabilities="" insist=0
2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
2008-06-26 21:29:21: I: send connection.start: version_major=0
version_minor=9 server_properties=184B mechanisms=5B locales=5B
2008-06-26 21:29:21: I: recv connection.start-ok:
client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
2008-06-26 21:29:21: I: send connection.tune: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
frame_max=32768 heartbeat=2
2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
capabilities="" insist=0
2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
2008-06-26 21:29:21: I: recv basic.publish: ticket=0
exchange="amq.direct" routing_key="1" mandatory=0 immediate=0
2008-06-26 21:29:21: I: send basic.deliver: consumer_tag="0"
delivery_tag=0 redelivered=0 exchange="amq.direct" routing_key="1"
2008-06-26 21:29:21: I: recv basic.publish: ticket=0
exchange="amq.direct" routing_key="0" mandatory=0 immediate=0
2008-06-26 21:29:21: E: Socket closing: End of file found, connection
to client lost (10.135.250.17:51695, OpenAMQ Kernel Client, 1.2d0, 0)

####################################################################

Regards,
Caciano Machado