qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ted Ross <tr...@redhat.com>
Subject Re: Dispatcher crashes on assertion
Date Fri, 27 May 2016 13:10:50 GMT
Alexandre,

I'm looking into this.  I think it may be related to DISPATCH-343.  The 
problem is related to the management of the lifecycle of deliveries. 
When the above is fixed, you should re-test your reproducer.

-Ted

On 05/26/2016 06:05 AM, Alexandre Trufanow wrote:
> Hi guys,
>
> I have a crash which I can reproduce reliably on the dispatcher at trunk.
>
> A dispatcher is configured to pull messages from a QPID-java broker
> queue for subscribing.
>
> qdmanage -b localhost:2727 create --type=connector name=broker
> role=on-demand addr=localhost port=5672
> qdmanage -b localhost:2727 create --type=address prefix=myqueue waypoint=true
> qdmanage -b localhost:2727 create --type=autoLink addr=myqueue dir=in
> connection=broker
>
> The queue on the broker is filled with a large quantity of messages.
> Reading the messages from the dispatcher, while creating a new
> connection for each consumer crashes.
>
> @Test
> public void dispatcherSend() throws JMSException {
>     int consumers = 1000;
>     String remoteURI = "amqp://dispatcher-host:2727";
>
>     for (int i = 0; i < consumers; i++) {
>         System.out.println("On consumer " + i);
>
>         ConnectionFactory connectionFactory = new
> JmsConnectionFactory(remoteURI);
>         Connection connection = connectionFactory.createConnection();
>         connection.start();
>         Session session = connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
>         Queue queue = session.createQueue("atr.queue");
>         MessageConsumer consumer = session.createConsumer(queue);
>         consumer.receive(1000);
>         connection.close();
>     }
> }
>
>
> I have seen two different assertions fail with these crashes:
>
> qdrouterd: /src/new/atrufanow/qpid-env/qpid-dispatch/src/router_core/connections.c:474:
> qdr_link_cleanup_CT: Assertion `(unsettled).size == 1' failed.
>
> qdrouterd: /src/new/atrufanow/qpid-env/qpid-dispatch/src/router_core/transfer.c:114:
> qdr_link_process_deliveries: Assertion `(link->undelivered).size == 1'
> failed.
>
> Host is linux Redhat and compiler is GCC 4.4.7
>
> Alexandre
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>

---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org


Mime
View raw message