tape/player.c

Go to the documentation of this file.

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <ctype.h>
#include "gridlabd.h"
#include "object.h"
#include "aggregate.h"

#include "tape.h"
#include "file.h"
#include "odbc.h"

CLASS *player_class = NULL;
static OBJECT *last_player = NULL;

EXPORT int create_player(OBJECT **obj, OBJECT *parent)
{
    *obj = gl_create_object(player_class,sizeof(struct player));
    if (*obj!=NULL)
    {
        struct player *my = OBJECTDATA(*obj,struct player);
        last_player = *obj;
        gl_set_parent(*obj,parent);
        strcpy(my->file,"");
        strcpy(my->filetype,"txt");
        strcpy(my->property,"(undefined)");
        my->next.ts = TS_ZERO;
        strcpy(my->next.value,"");
        my->loopnum = 0;
        my->loop = 0;
        my->status = TS_INIT;
        my->target = gl_get_property(*obj,my->property);
        return 1;
    }
    return 0;
}

static int player_open(OBJECT *obj)
{
    char32 type="file";
    char1024 fname="";
    char32 flags="r";
    struct player *my = OBJECTDATA(obj,struct player);
    
    /* if prefix is omitted (no colons found) */
    if (sscanf(my->file,"%32[^:]:%1024[^:]:%[^:]",type,fname,flags)==1)
    {
        /* filename is file by default */
        strcpy(fname,my->file);
        strcpy(type,"file");
    }

    /* if no filename given */
    if (strcmp(fname,"")==0)

        /* use object name-id as default file name */
        sprintf(fname,"%s-%d.%s",obj->parent->oclass->name,obj->parent->id, my->filetype);

    /* if type is file or file is stdin */
    my->ops = get_ftable(type)->player;
    if(my->ops == NULL)
        return 0;
    else return (my->ops->open)(my, fname, flags);
}

static void rewind_player(struct player *my)
{
    (*my->ops->rewind)(my);
}

static void close_player(struct player *my)
{
    (my->ops->close)(my);
}

static TIMESTAMP player_read(OBJECT *obj)
{
    char buffer[64];
    int Y,m,d,H,M,S;
    struct player *my = OBJECTDATA(obj,struct player);
    char unit[2];
    TIMESTAMP t1;
    char *result=NULL;
Retry:
    result = my->ops->read(my, buffer, sizeof(buffer));

    if (result==NULL)
    {
        if (my->loopnum>0)
        {
            rewind_player(my);
            my->loopnum--;
            goto Retry;
        }
        else {
            close_player(my);
            my->status=TS_DONE;
            my->next.ts = TS_NEVER;
            goto Done;
        }
    }
    if (result[0]=='#' || result[0]=='\n') /* ignore comments and blank lines */
        goto Retry;
    if (sscanf(result,"%" FMT_INT64 "d,%31[^\n]", &t1,my->next.value)==2)
    {
        if (my->loop==my->loopnum) 
            my->next.ts = t1;
    }
    else if (sscanf(result,"%" FMT_INT64 "d%1[^,],%31[^\n]", &t1, unit, my->next.value)==3)
    {
        {
            int64 scale=1;
            switch(unit[0]) {
            case 's': scale=TS_SECOND; break;
            case 'm': scale=60*TS_SECOND; break;
            case 'h': scale=3600*TS_SECOND; break;
            case 'd': scale=86400*TS_SECOND; break;
            default: break;
            }
            t1 *= scale; 
            if (result[0]=='+') /* timeshifts have leading + */
                my->next.ts += t1;
            else if (my->loop==my->loopnum) /* absolute times are ignored on all but first loops */
                my->next.ts = t1;
        }
    }
    else if (sscanf(result,"%d-%d-%d %d:%d:%d,%31[^\n]",&Y,&m,&d,&H,&M,&S,my->next.value)==7)
    {
        struct tm dt = {S,M,H,d,m-1,Y-1900,0,0,0};
        t1 = (TIMESTAMP)mktime(&dt);
        if (t1!=TS_INVALID && my->loop==my->loopnum)
            my->next.ts = t1;
    }
Done:
    return my->next.ts;
}

EXPORT TIMESTAMP sync_player(OBJECT *obj, TIMESTAMP t0, PASSCONFIG pass)
{
    struct player *my = OBJECTDATA(obj,struct player);
    TIMESTAMP t1 = my->next.ts;
    if (my->status==TS_INIT && player_open(obj))
        t1 = player_read(obj);
    while (my->status==TS_OPEN && t1<=t0)
    {   /* post this value */
        if (my->target==NULL)
            my->target = gl_get_property(obj->parent,my->property);
        if (my->target!=NULL)
            gl_set_value(obj->parent,GETADDR(obj->parent,my->target),my->next.value,my->target); /* pointer => int64 */
        t1 = player_read(obj);
    }
    obj->clock = t0;
    return t1;
}

---

GridLAB-D^TM Version 1.0

An open-source project initiated by the US Department of Energy