src/noarch/internal/communication/imoc_get_entry.c

Go to the documentation of this file.

#include <stdio.h>

#include <moc.h>
#include <internal/imoc.h>
#include <internal/imoc_macros.h>
#ifdef __SPU__
#include <internal/spu/imoc_core_spu.h>
#else
#include <internal/ppu/imoc_core_ppu.h>
#endif  

/*method looks for valid entries in the message queue*/
moc_message_envelope_t* IMOC_get_entry(int source, int tag, MOC_Comm comm,
        int isSpecial, MOC_Status *status)
    {
    moc_message_envelope_t *startQueue;
    int count;

    /*check if source is ANY_SOURCE*/
    if (source == MOC_ANY_SOURCE)
        {
        /*set start to base adress of the message queue*/
        startQueue =( moc_message_envelope_t*) node_handle.message_queue_base;
        /*check if tag is ANY_TAG*/
        if(tag == MOC_ANY_TAG)
            {
            for(count=0;count<(node_handle.queue_size*(node_handle.comm_size-1));count++)
                {
                /*search for a valid entry*/
                if(startQueue[count].flags.bits.valid && startQueue[count].communicator == comm
                                                && startQueue[count].flags.bits.special == isSpecial)
                                        {
                                                /*calculate source*/
                                                if(count/(node_handle.queue_size) >= node_handle.rank)
                                                    status->MOC_SOURCE = count/(node_handle.queue_size)+1;
                                                else    
                                                    status->MOC_SOURCE = count/(node_handle.queue_size);
                                                return &startQueue[count]; 
                                        }
                                }
                        }
                else
                        {
                        for(count=0;count<(node_handle.queue_size*(node_handle.comm_size-1));count++)
                                {
                                /*search for a valid entry with right tag*/
                                if(startQueue[count].flags.bits.valid && startQueue[count].tag == tag 
                                                && startQueue[count].communicator == comm
                                                && startQueue[count].flags.bits.special == isSpecial)
                                        {
                                        /*calculate source*/    
                                        if(count/(node_handle.queue_size) >= node_handle.rank)
                                            status->MOC_SOURCE = count/(node_handle.queue_size)+1;
                                        else    
                                            status->MOC_SOURCE = count/(node_handle.queue_size);
                                        
                                        return &startQueue[count]; 
                                        }
                                }
                        }
                }
        else
                {
                /*set start to the base adress of the message queue of source process*/
                startQueue = (moc_message_envelope_t*) IMOC_LOCAL_QUEUE(source);
                /*check if tag is ANY_TAG*/
                if(tag == MOC_ANY_TAG)
                        {
                        for(count=0;count<node_handle.queue_size;count++)
                                {
                                /*search for a valid entry from source*/
                                if(startQueue[count].flags.bits.valid && startQueue[count].communicator == comm
                                                && startQueue[count].flags.bits.special == isSpecial)
                                        return &startQueue[count]; 
                                }
                        }
                else
                        {
                        for(count=0;count<node_handle.queue_size;count++)
                                {
                                /*search for a valid entry from source with right tag*/
                                if(startQueue[count].flags.bits.valid && startQueue[count].tag == tag 
                                                && startQueue[count].communicator == comm
                                                && startQueue[count].flags.bits.special == isSpecial)
                                        return &startQueue[count]; 
                                }
                        }
                }
                
        return NULL;
        }

---