[zeromq-dev] rc == 0 (./zmq/mutex.hpp:94)

[Martin Hurton]

Hi Aamir,

Can you please try the patch attached.

Regards,
Martin

On Mon, Jul 13, 2009 at 9:00 PM, Aamir M<aamirjvm at gmail.com> wrote:
> The attachment got scrubbed out again... Here is the code:
>
> // BEGIN CODE
>
> #include <zmq.hpp>
> #include <pthread.h>
> #include <assert.h>
> #include <stdio.h>
> #include <unistd.h>
>
> pthread_t listener_thread;
> pthread_t broker_thread;
>
> void* listener_loop( void* arg )
> {
>        zmq::dispatcher_t* dispatcher = (zmq::dispatcher_t*)arg;
>        zmq::locator_t locator( NULL );
>        zmq::api_thread_t* api = zmq::api_thread_t::create( dispatcher, &locator );
>
>        api->create_queue("Q2", zmq::scope_local);
>        api->bind( "E2", "Q2", NULL, NULL );
>
>        zmq::message_t msg;
>
>        int qid;
>        while(true)
>        {
>                qid = api->receive( &msg, true );
>                printf("%s", (char*)msg.data());
>        }
> }
>
> void* broker_loop( void* arg )
> {
>
>        zmq::dispatcher_t* dispatcher = (zmq::dispatcher_t*)arg;
>        zmq::locator_t locator( NULL );
>        zmq::api_thread_t* api = zmq::api_thread_t::create( dispatcher, &locator );
>
>
>        int eid2 = api->create_exchange("E2", zmq::scope_process,
>                                                                   NULL, NULL, 0, NULL, zmq::style_data_distribution );
>
>        api->create_queue("Q1", zmq::scope_local);
>        api->bind( "E1", "Q1", NULL, NULL );
>
>        int qid;
>        zmq::message_t msg_in;
>        //zmq::message_t msg_out( 64 );
>    while(true)
>        {
>                qid = api->receive( &msg_in, true );
>
>                zmq::message_t msg_out( 64 );
>                api->send( eid2, msg_out, false );
>        }
>
> }
>
>
> int main()
> {
>        zmq::locator_t locator( NULL );
>        zmq::dispatcher_t dispatcher( 4 );
>        zmq::api_thread_t* api = zmq::api_thread_t::create( &dispatcher, &locator );
>
>        int eid1 = api->create_exchange("E1", zmq::scope_process,
>                                                                   NULL, NULL, 0, NULL, zmq::style_data_distribution );
>
>        int rc;
>
>        rc = pthread_create( &broker_thread, NULL, &broker_loop, &dispatcher );
>        assert( rc == 0 );
>        sleep(1); /// wait for exchange E2 to be created
>
>        rc = pthread_create( &listener_thread, NULL, &listener_loop, &dispatcher );
>        assert( rc == 0 );
>
>        rc = pthread_create( &listener_thread, NULL, &listener_loop, &dispatcher );
>        assert( rc == 0 );
>
>        printf("go\n");
>        while(true)
>        {
>                zmq::message_t msg( 8 );
>                sprintf( (char*)msg.data(), "%s\n", "hello");
>                api->send( eid1, msg );
>        }
>
> }
>
> // END CODE
>
> On Mon, Jul 13, 2009 at 2:57 PM, Aamir M<aamirjvm at gmail.com> wrote:
>> Hi Martin & Martin,
>>
>> I've come up with some stand-alone code that I think reproduces the
>> mutex error I was describing (please see attached C++ code). If you
>> compile and run this code (requires Linux, 0MQ 1.0.0), you should
>> eventually see this output:
>>
>> go
>> Invalid argument (./zmq/mutex.hpp:97)
>> Invalid argument (./zmq/mutex.hpp:97)
>> Aborted
>>
>> The offending line of code appears to be zmq_mutex_error.cpp:50:
>>
>> zmq::message_t msg_out( 64 );
>>
>> If I comment out this line and instead uncomment line 45 (which simply
>> moves the declaration of msg_out to outside of the while loop) then
>> the mutex error does not occur. I'm a little hazy on why this is
>> happening and what the proper 0MQ library usage should be in this
>> case.
>>
>> Thanks,
>> Aamir
>>
>>
>>
>> On Mon, Jul 13, 2009 at 11:34 AM, Martin Sustrik<sustrik at fastmq.com> wrote:
>>> Martin Hurton wrote:
>>>>
>>>> Hi Aamir,
>>>>
>>>> Please apply the attached patch to 0.6.1 tree and let us know what's
>>>> printed when the assertion fails.
>>>
>>> Actually, I've applied similar patch to v1.0.0, so you may alternatively use
>>> version 1.0.0 instead of 0.6.1.
>>>
>>> Martin
>>>
>>>
>>
>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: refcount_initialization.patch
Type: text/x-diff
Size: 2137 bytes
Desc: not available
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20090713/7c2b6b63/attachment.patch>