/*
 * $Id: vdiflat.c 3815 2016-02-25 18:04:37Z gbc $
 *
 * This file provides support for the fuse interface.
 * This version is rather primitive in many respects.
 *
 * This file provides support for flat vdif files.
 */

#include <errno.h>
#include <stdio.h>
#include <string.h>

#include "vdifuse.h"

/*
 * Work out the size of flat vdif sequences and update
 * vp->u.vfuse.st_size from the bogus starter value (0).
 * For each fragment we increment the total size by
 * total_pkts * pkt_size of that fragment.
 * nlink is the total count of fragments, and we check
 * it and a few other things for consistency.
 *
 * FIXME: update remaining vp->u.vfuse entries
 * + blksize_t st_blksize; // packet size
 * + blkcnt_t  st_blocks;  // number of packets
 * + time_t    st_mtime;   // data start time
 * + time_t    st_ctime;   // data end time (inc. last packet)
 * + time_t    st_atime;   // total scan duration
 */
int finalize_vdif_sequence(VDIFUSEntry *vp)
{
    int vdcne = current_cache_entries();
    VDIFUSEntry *vdccs = current_cache_start(), *vsanc, *vfrag;
    nlink_t nlink = 0;
    int errs = 0, ccount = 0;

    if (vp->u.vfuse.st_size != 0) {
        fprintf(stderr, "Seq entry %d already has size %lu\n",
            vp->index, vp->u.vfuse.st_size);
        errs ++;
    }
    if (vp->u.vfuse.st_nlink == 0) {
        fprintf(stderr, "Seq entry %d has no links\n", vp->index);
        errs ++;
    }
    if (vp->cindex == 0 && vp->cindex >= vdcne) {
        fprintf(stderr, "Seq continuation oob %u\n", vp->cindex);
        errs ++;
    }

    vsanc = vdccs + vp->cindex;
    while (!errs && (nlink < vp->u.vfuse.st_nlink)) {
        if (ccount == VDIFUSE_MAX_SEQI) {
            if (vsanc->cindex == 0 || vsanc->cindex >= vdcne) break;
            vsanc = vdccs + vsanc->cindex;
            ccount = 0;
        }
        vfrag = vdccs + vsanc->u.vseqi[ccount++];
        vp->u.vfuse.st_size += vfrag->u.vfuse.st_size;
        nlink++;
    }

    if (nlink != vp->u.vfuse.st_nlink) {
        fprintf(stderr, "Missing seq entries (%lu != %lu; %u >= %u)\n",
            nlink, vp->u.vfuse.st_nlink, vsanc->cindex, vdcne);
        errs ++;
    }
    return(errs);
}

/*
 * vorr support
 */

/* FIXME: private structures */
/* FIXME: un-stub flat case */

int open_flat_seq(VDIFUSEntry *vs, FFInfo *ffi)
{
    return(vorrfd);
}
void release_flat_seq(FFInfo *ffi)
{
    return;
}
int read_flat_seq(char *buf, FFInfo *ffi)
{
    return(-ENOENT);    /* stub */
}

/*
 * eof
 */