StreamSpec.c

Go to the documentation of this file.

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dlfcn.h>
#include "StreamSpec.h"
#include "FilterData/Policies.h"

// tag 0 is for internal Void messages
// tag 1 is for PvmTaskExit notifications
// tag 2 is for PvmHostDelete notifications
// tag 3 is for filter termination
static int nextTag = 4;

/* Constructor and destroyer *****************************************************/
/// Constructor 
StreamSpec *createEmptyStreamSpec() {
        StreamSpec *s = (StreamSpec *) malloc(sizeof(StreamSpec));
        s->tag = nextTag++;
        return s;
}
/// Destroyer
void destroyStreamSpec(StreamSpec *s){
        //we dont need to free stuff, as they are allocated statically
        free(s);
}
/********************************************************************************/

/* Setting source and destinations **********************************************/
/// Set stream origin, ie, the filter which writes to this stream
int setFrom(StreamSpec *s, FilterSpec *filter, char *portName, char *writePolicyName, char *polibName
#ifdef VOID_TERM
                , int breakLoop
#endif          
){
        writePolicy_t p;
        
        s->fromFilter  = filter;
        strncpy(s->fromPortName, portName, MAX_PTNAME_LENGTH); 
        strncpy(s->writePolicyName, writePolicyName, MAX_PLNAME_LENGTH);
        s->fromFilter->outputs[s->fromFilter->numOutputs++] = s;
        
        //if we are using labeled stream, we need the library name of the functions
        p = getWritePolicyByName(writePolicyName);
        if ((p == LABELED_STREAM) || (p == MULTICAST_LABELED_STREAM)){
                //if we are labeled, we need a policy library name
                if ((polibName == NULL) || (strlen(polibName) == 0))
                        return 0;
                else
                        strncpy(s->lsLibName, polibName, MAX_PLNAME_LENGTH);
        }
        else if (p == W_POLICY_ERROR){
                return 0;
        }
#ifdef VOID_TERM
        s->breakLoop = breakLoop;
#endif
        return 1;
}
///set stream destination, ie, the filter which reads from this stream
int setTo(StreamSpec *s, FilterSpec *filter, char *portName, char *readPolicyName){
        //we are not using read policies...
        
        s->toFilter    = filter;
        s->toFilter->inputs[s->toFilter->numInputs++] = s;
        strncpy(s->toPortName, portName, MAX_PTNAME_LENGTH);
        return 1;
}
/*******************************************************************************/

---