A_invalidQueueId using messageq_get

Julian,

What is the NDK, PDK, MCSDK version you used? What is the DSP platform? A simliar error was reported in http://e2e.ti.com/support/embedded/bios/f/355/p/282999/990537.aspx. Maybe this is release related.

Regards,Eric

Eric,

platform I am using is demos.image_processing.ipc.evmc6678l.platform,

CCS 5.3.0.00090 . This are the versions of products I am using:

Actually I am working with image processing demo, I just add

ndk newdaemon with a task function that  receives data.

because this demos works with messageq I think I am doing something wrong.

I added the code from master and slave if you could see somenthing wrong or that 
I am missing.

1) HeapBufMP params definition in master is as follow

/* Create the heap that will be used to allocate messages. */
    HeapBufMP_Params_init(&heapBufParams);
    heapBufParams.regionId       = 0;
    heapBufParams.name           = IMAGE_PROCESSING_HEAP_NAME;
    heapBufParams.numBlocks      = NCORES; //8 cores
    heapBufParams.blockSize      = sizeof(MyMessage);
    heapHandle = HeapBufMP_create(&heapBufParams);
    if (heapHandle == NULL) {
        platform_write("Main: HeapBufMP_create failed\n" );
        goto close_n_exit;
    }

    /* Register this heap with MessageQ */
    status = MessageQ_registerHeap((IHeap_Handle)heapHandle, IMAGE_PROCESSING_HEAPID);
    if(status != MessageQ_S_SUCCESS) {
        platform_write("Main: MessageQ_registerHeap failed\n" );
        goto close_n_exit;
    }

2) and in master ndk task function reception  I have the follow code for 
messageq communication

//Create local message
        messageQ = (MessageQ_Handle )MessageQ_create(localQueueName, NULL);
        if (messageQ == NULL) {
            System_abort("MessageQ_create failed\n" );
        }
// MessageQueues are opened
    int i, status;
    for(i=1;i<NCORES;i++) {
        do {
            status = MessageQ_open(QueueName[i], &QueueID[i] );
        } while(status<0);
    }
// Messages are allocated
    for( i=1; i<NCORES; i++ ) {
        str_message[i] = ( MyMessage *)MessageQ_alloc(IMAGE_PROCESSING_HEAPID, sizeof(MyMessage));
        if (str_message[i] == NULL) {
            System_abort("MessageQ_alloc failed\n" );
        }
    }

//Broadcast messages to remote cores
    for(i=1;i<NCORES;i++) {
        msgId++;
        MessageQ_setMsgId(str_message[i], msgId);
        }
    for(j=0;j<NCORES;j++) {
                for(i=0;i<NCHARS;i++) {
                    str_message[j]->buf_str[i]= 'a';
                }
    }
    for(j=1;j<NCORES;j++) {
        MessageQ_setReplyQueue(messageQ, (MessageQ_Msg)str_message[j]);
        status = MessageQ_put(QueueID[j], (MessageQ_Msg)str_message[j]);
        if (status < 0) { System_abort("MessageQ_put had a failure/error\n"); }
    }
    if (status < 0) {
       System_abort("MessageQ_put had a failure/error\n");
    }

//Get all messages from remote cores
    for(i=1;i<NCORES;i++) {
        status = MessageQ_get(messageQ, (MessageQ_Msg*)&str_message[i], MessageQ_FOREVER);
        if (status < 0) { System_abort("This should not happen since timeout is forever\n"); }
    }
//Free resources

        for( i=1; i<NCORES; i++ ) {
            MessageQ_free((MessageQ_Msg)str_message[i]);
        }
        for (i = 1; i < NCORES; i++) {
            if(QueueID[i]) MessageQ_close(&QueueID[i]);
        }

        if(messageQ) MessageQ_delete(&messageQ);

3) Slaves core main task function  do this


    GET_SLAVE_QUEUE_NAME(receive_queue_name, DNUM);

    /* Open the heap created by the other processor. Loop until opened. */
    do {
        status = HeapBufMP_open(IMAGE_PROCESSING_HEAP_NAME, &heapHandle);
        if (status < 0) {
            Task_sleep(1);
        }
    } while (status < 0);

    /* Register this heap with MessageQ */
    MessageQ_registerHeap((IHeap_Handle)heapHandle, IMAGE_PROCESSING_HEAPID);

    /* Create the local message queue */
    h_receive_queue = MessageQ_create(receive_queue_name, NULL);
    if (h_receive_queue == NULL) {
        printf("MessageQ_create failed\n" );
        goto close_n_exit;
    }
    sprintf(remoteCoreName,"core%d_queue",0);
    do { status = MessageQ_open(remoteCoreName,&core0QueueID); }while( status < 0 );
    for (;;) {

        if (MessageQ_get(h_receive_queue, (MessageQ_Msg *)&p_msg, MessageQ_FOREVER) < 0) {
            printf("%s: This should not happen since timeout is forever\n", receive_queue_name);
            goto close_n_exit;
        }
        for(j=0;j<NCORES;j++) {
            for(i=0;i<NCHARS;i++) {
                p_msg[j].buf_str[i]= 'b';
            }
        }
        MessageQ_setReplyQueue(h_receive_queue, (MessageQ_Msg)p_msg);
        /* send the message to the remote processor */
        if (MessageQ_put(core0QueueID, (MessageQ_Msg)p_msg) < 0) {
            printf("%s: MessageQ_put had a failure error\n", receive_queue_name);
        }


    }

close_n_exit:
    if(h_receive_queue) MessageQ_delete(&h_receive_queue);

Julian