crwbmg.c

Go to the documentation of this file.

 
#include "bufrlib.h"
 
#define MXFNLEN 200
 
FILE *pbf[2];
 
int
rbytes(char *bmg, int mxmb, int isloc, int newbytes)
{
    int iret;
 
    if ((isloc + newbytes) > mxmb) {
        iret = 1;
    }
    else if (fread(&bmg[isloc], 1, newbytes, pbf[0]) != newbytes) {
        iret = (feof(pbf[0]) ? -1 : -2);
    }
    else {
        iret = 0;
    }
 
    return iret;
}
 
void
cobfl(char *bfl, char io)
{
    char lbf[MXFNLEN+1];
    char lio;
 
    char errstr[MXFNLEN+50];
 
    char foparg[3] = " b";  /* 3rd character will automatically initialize to NULL */
    unsigned short i, j;
 
    /*
    ** Copy the input arguments into local variables and check them for validity. This is especially
    ** important in case either of the arguments was passed in as a string literal by the calling
    ** program or else doesn't have a trailing NULL character.
    */
    for (i = 0; (! isspace(bfl[i]) && ! iscntrl(bfl[i])); i++) {
        if (i == MXFNLEN) {
            sprintf(errstr, "BUFRLIB: COBFL - INPUT FILENAME CONTAINS"
                    " MORE THAN %hu CHARACTERS", (unsigned short) MXFNLEN);
            bort_f(errstr);
        }
        lbf[i] = bfl[i];
    }
    lbf[i] = '\0';
 
    lio = io;
    if ((foparg[0] = (char) tolower(lio)) == 'r') {
        j = 0;
    }
    else if (foparg[0] == 'w') {
        j = 1;
    }
    else {
        sprintf(errstr, "BUFRLIB: COBFL - SECOND ARGUMENT WAS (%c),"
                " WHICH IS AN ILLEGAL VALUE", lio);
        bort_f(errstr);
    }
 
    /*
    ** If a file of this type is already open, then close it before opening the new one.
    */
    if (pbf[j] != NULL) fclose(pbf[j]);
 
    /*
    ** Open the requested file.
    */
    if ((pbf[j] = fopen(lbf, foparg)) == NULL) {
        sprintf(errstr, "BUFRLIB: COBFL - COULD NOT OPEN FILE %s", lbf);
        bort_f(errstr);
    }
 
    /*
    ** Call wrdlen to initialize some important information about the local machine, just in case
    ** it hasn't already been called.
    */
    wrdlen_f();
 
    return;
}
 
void
crbmg(char *bmg, int mxmb, int *nmb, int *iret)
{
    int wkint[2];
 
    char errstr[129];
    char blanks[5] = "    ";
 
    /*
    ** Make sure that a file is open for reading.
    */
    if (pbf[0] == NULL) {
        sprintf(errstr, "BUFRLIB: CRBMG - NO FILE IS OPEN FOR READING");
        bort_f(errstr);
    }
 
    /*
    ** Initialize the first 4 characters of the output array to blanks.
    */
    if (mxmb < 5) {
        *iret = 1;
        return;
    }
    strcpy(bmg, blanks);
 
    /*
    ** Look for the start of the next BUFR message.
    */
    while (strncmp("BUFR", bmg, 4) != 0) {
        memmove(bmg, &bmg[1], 3);
        if ((*iret = rbytes(bmg, mxmb, 3, 1)) != 0) return;
    }
 
    /*
    ** Read the next 4 bytes of the BUFR message and get the length of the message.
    */
    if ((*iret = rbytes(bmg, mxmb, 4, 4)) != 0) return;
    memcpy(wkint, bmg, 8);
    *nmb = iupbs01_f(wkint, "LENM");
 
    /*
    ** Read the remainder of the BUFR message.
    */
    if ((*iret = rbytes(bmg, mxmb, 8, *nmb-8)) != 0) return;
 
    /*
    ** Check that the "7777" is in the expected location.
    */
    *iret = ((strncmp("7777", &bmg[*nmb-4], 4) == 0) ? 0 : 2);
 
    return;
}
 
void
cwbmg(char *bmg, int nmb, int *iret)
{
    char errstr[129];
 
    /*
    ** Make sure that a file is open for writing.
    */
    if (pbf[1] == NULL) {
        sprintf(errstr, "BUFRLIB: CWBMG - NO FILE IS OPEN FOR WRITING");
        bort_f(errstr);
    }
 
    /*
    ** Write the BUFR message to the file.
    */
    *iret = ((fwrite(bmg, 1, nmb, pbf[1]) == nmb) ? 0 : -1);
 
    return;
}
 
void
ccbfl(void)
{
    unsigned short i;
 
    for (i = 0; i < 2; i++) {
        if (pbf[i] != NULL) fclose(pbf[i]);
    }
 
    return;
}