cms_dup.cc

Source code for an Numeric Cmputer

/********************************************************************
* Description: cms_dup.cc
*   Provides the interface to CMS used by NML update functions
*   including a CMS update function for all the basic C data types
*   to convert NMLmsgs to XDR.
*
*   Derived from a work by Fred Proctor & Will Shackleford
*
* Author:
* License: LGPL Version 2
* System: Linux
*    
* Copyright (c) 2004 All rights reserved.
*
* Last change: 
* $Revision: 1.6 $
* $Author: paul_c $
* $Date: 2005/06/26 17:53:35 $
********************************************************************/

#ifdef __cplusplus
extern "C" {
#endif

#include <errno.h>		/* errno global variable */
#include <limits.h>		/* SHORT_MIN, SHOR_MAX, . . . */
#include <float.h>		/* FLT_MIN, FLT_MAX */
#include <string.h>		/* memcpy(), strerror() */
#include <stdlib.h>		/* strtol(), strtoul(), strtod() */
#include <stdio.h>		/* sprintf() */
#include <ctype.h>		/* isspace() */

#ifdef __cplusplus
}
#endif
#include "cms.hh"		/* class CMS */
#include "cms_dup.hh"		/* class CMS_DISPLAY_ASCII_UPDATER */
#include "rcs_print.hh"		/* rcs_print_error() */
#define DEFAULT_WARNING_COUNT_MAX 100
/* Member functions for CMS_DISPLAY_ASCII_UPDATER Class */
    CMS_DISPLAY_ASCII_UPDATER::CMS_DISPLAY_ASCII_UPDATER(CMS * _cms_parent):
CMS_UPDATER(_cms_parent)
{
    /* Set pointers to NULL. */
    begin_current_string = (char *) NULL;
    end_current_string = (char *) NULL;
    max_length_current_string = 0;
    updating_string = 0;

    /* Store and validate constructors arguments. */
    cms_parent = _cms_parent;
    if (NULL == cms_parent) {
	rcs_print_error("CMS parent for updater is NULL.\n");
	return;
    }

    /* Allocate the encoded header too large, and find out what size it
       really is. */
    encoded_header = malloc(neutral_size_factor * sizeof(CMS_HEADER));
    if (encoded_header == NULL) {
	rcs_print_error("CMS:can't malloc encoded_header");
	status = CMS_CREATE_ERROR;
	return;
    }

    /* If queuing is enabled, then initialize streams for encoding and
       decoding the header with the queue information. */
    if (cms_parent->queuing_enabled) {
	/* Allocate the encoded header too large, and find out what size it
	   really is. */
	encoded_queuing_header =
	    malloc(neutral_size_factor * sizeof(CMS_QUEUING_HEADER));
    }
    using_external_encoded_data = 0;
    warning_count = 0;
    warning_count_max = DEFAULT_WARNING_COUNT_MAX;
}

CMS_DISPLAY_ASCII_UPDATER::~CMS_DISPLAY_ASCII_UPDATER()
{
    if (NULL != encoded_data && !using_external_encoded_data) {
	free(encoded_data);
	encoded_data = NULL;
    }
    if (NULL != encoded_header) {
	free(encoded_header);
	encoded_header = NULL;
    }
    if (NULL != encoded_queuing_header) {
	free(encoded_queuing_header);
	encoded_queuing_header = NULL;
    }
}

void CMS_DISPLAY_ASCII_UPDATER::find_next_comma()
{
    while (*end_current_string != ',' && *end_current_string) {
	if (length_current_string >= max_length_current_string) {
	    rcs_print_error("Maximum string length exceeded.\n");
	    status = CMS_UPDATE_ERROR;
	    return;
	}
	length_current_string++;
	end_current_string++;
    }
    end_current_string++;
    length_current_string++;
}

int CMS_DISPLAY_ASCII_UPDATER::set_mode(CMS_UPDATER_MODE _mode)
{
    mode = _mode;
    CMS_UPDATER::set_mode(_mode);
    switch (mode) {
    case CMS_NO_UPDATE:
	begin_current_string = end_current_string = (char *) NULL;
	max_length_current_string = 0;
	length_current_string = 0;
	break;

    case CMS_ENCODE_DATA:
	begin_current_string = end_current_string = (char *) encoded_data;
	max_length_current_string = neutral_size_factor * size;
	if (max_length_current_string > cms_parent->max_encoded_message_size) {
	    max_length_current_string = cms_parent->max_encoded_message_size;
	}
	length_current_string = 0;
	encoding = 1;
	break;

    case CMS_DECODE_DATA:
	begin_current_string = end_current_string = (char *) encoded_data;
	max_length_current_string = neutral_size_factor * size;
	if (max_length_current_string > cms_parent->max_encoded_message_size) {
	    max_length_current_string = cms_parent->max_encoded_message_size;
	}
	length_current_string = 0;
	encoding = 0;
	break;

    case CMS_ENCODE_HEADER:
	begin_current_string = end_current_string = (char *) encoded_header;
	max_length_current_string = neutral_size_factor * sizeof(CMS_HEADER);
	length_current_string = 0;
	encoding = 1;
	break;

    case CMS_DECODE_HEADER:
	begin_current_string = end_current_string = (char *) encoded_header;
	max_length_current_string = neutral_size_factor * sizeof(CMS_HEADER);
	length_current_string = 0;
	encoding = 0;
	break;

    case CMS_ENCODE_QUEUING_HEADER:
	begin_current_string = end_current_string =
	    (char *) encoded_queuing_header;
	max_length_current_string =
	    neutral_size_factor * sizeof(CMS_QUEUING_HEADER);
	length_current_string = 0;
	encoding = 1;
	break;

    case CMS_DECODE_QUEUING_HEADER:
	begin_current_string = end_current_string =
	    (char *) encoded_queuing_header;
	max_length_current_string =
	    neutral_size_factor * sizeof(CMS_QUEUING_HEADER);
	length_current_string = 0;
	encoding = 0;
	break;

    default:
	rcs_print_error("CMS updater in invalid mode.\n");
	return (-1);
    }
    return (0);
}

int CMS_DISPLAY_ASCII_UPDATER::check_pointer(char *_pointer, long _bytes)
{
    if (NULL == cms_parent || NULL == begin_current_string
	|| NULL == end_current_string) {
	rcs_print_error
	    ("CMS_DISPLAY_ASCII_UPDATER: Required pointer is NULL.\n");
	return (-1);
    }
    if (length_current_string + _bytes * 4 > max_length_current_string) {
	rcs_print_error
	    ("CMS_DISPLAY_ASCII_UPDATER: length of current string(%ld) + bytes to add of(%d) exceeds maximum of %ld.\n",
	    length_current_string, _bytes * 4, max_length_current_string);
	return (-1);
    }
    return (cms_parent->check_pointer(_pointer, _bytes));
}

/* Repositions the data buffer to the very beginning */
void CMS_DISPLAY_ASCII_UPDATER::rewind()
{
    CMS_UPDATER::rewind();
    end_current_string = begin_current_string;
    if (encoding) {
	memset(begin_current_string, 0, max_length_current_string);
    }
    length_current_string = 0;
    if (NULL != cms_parent) {
	cms_parent->format_size = 0;
    }
}

int CMS_DISPLAY_ASCII_UPDATER::get_encoded_msg_size()
{
    return (length_current_string);
}

/* Char functions */

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update_char(char &x)
{

    if (encoding) {
	if (x == ',') {
	    strcat(end_current_string, "\\c");
	    end_current_string += 2;
	    length_current_string += 2;
	} else if (x == '\\') {
	    strcat(end_current_string, "\\\\");
	    end_current_string += 2;
	    length_current_string += 2;
	} else if (x == '\n') {
	    strcat(end_current_string, "\\n");
	    end_current_string += 2;
	    length_current_string += 2;
	} else if (x == 0 && updating_string) {
	} else if (!isgraph(x)) {
	    sprintf(end_current_string, "\\%3.3d", x);
	    end_current_string += 4;
	    length_current_string += 4;
	} else {
	    end_current_string[0] = x;
	    end_current_string++;
	    length_current_string++;
	}
    } else {
	if (end_current_string[0] == ',' || end_current_string[0] == 0) {
	    x = 0;
	} else if (end_current_string[0] == '\\') {
	    if (end_current_string[1] == 'c') {
		x = ',';
		end_current_string += 2;
		length_current_string += 2;
	    } else if (end_current_string[1] == '\\') {
		x = end_current_string[1];
		length_current_string += 2;
		end_current_string += 2;
	    } else if (end_current_string[1] == 'n') {
		x = '\n';
		length_current_string += 2;
		end_current_string += 2;
	    } else {
		char temp[4];
		memcpy(temp, end_current_string + 1, 3);
		temp[3] = 0;
		x = (char) strtol(temp, (char **) NULL, 10);
		length_current_string += 4;
		end_current_string += 4;
	    }
	} else {
	    x = end_current_string[0];
	    end_current_string += 1;
	    length_current_string++;
	}
    }
    return status;
}

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(bool &x)
{
    /* Check to see if the pointers are in the proper range. */
    if (-1 == check_pointer((char *) &x, sizeof(char))) {
	return (CMS_UPDATE_ERROR);
    }

    update_char((char &)x);
    end_current_string[0] = ',';
    find_next_comma();
    return (status);
}

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(char &x)
{
    /* Check to see if the pointers are in the proper range. */
    if (-1 == check_pointer((char *) &x, sizeof(char))) {
	return (CMS_UPDATE_ERROR);
    }

    update_char(x);
    end_current_string[0] = ',';
    find_next_comma();
    return (status);
}

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(char *x, unsigned int len)
{
    /* Check to see if the pointers are in the proper range. */
    if (-1 == check_pointer((char *) x, sizeof(char) * len)) {
	return (CMS_UPDATE_ERROR);
    }
    unsigned int i;
    updating_string = 1;

    for (i = 0; i < len; i++) {
	update_char(x[i]);
	if (x[i] == 0) {
	    break;
	}
    }
    end_current_string[0] = ',';
    find_next_comma();
    updating_string = 0;
    return (status);
}

/* Char functions */

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(unsigned char &x)
{
    /* Check to see if the pointers are in the proper range. */
    if (-1 == check_pointer((char *) &x, sizeof(unsigned char))) {
	return (CMS_UPDATE_ERROR);
    }
    char cx;
    cx = (char) x;
    update_char(cx);
    x = (unsigned char) x;
    end_current_string[0] = ',';
    find_next_comma();

    return (status);
}

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(unsigned char *x,
    unsigned int len)
{
    /* Check to see if the pointers are in the proper range. */
    if (-1 == check_pointer((char *) x, sizeof(unsigned char) * len)) {
	return (CMS_UPDATE_ERROR);
    }
    char cx;
    unsigned int i;

    for (i = 0; i < len; i++) {
	cx = (char) x[i];
	update_char(cx);
	x[i] = (unsigned char) cx;
    }
    end_current_string[0] = ',';
    find_next_comma();
    return (status);
}

/* Short functions */

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(short int &x)
{
    /* Check to see if the pointers are in the proper range. */
    if (-1 == check_pointer((char *) &x, sizeof(short))) {
	return (CMS_UPDATE_ERROR);
    }

    if (encoding) {
	sprintf(end_current_string, "%+d,", x);
    } else {
	errno = 0;
	long number = strtol(end_current_string, (char **) NULL, 10);
	if (errno != 0) {
	    rcs_print_error
		("CMS_DISPLAY_ASCII_UPDATER: Error %ld: %s occured during strtol of(%s).\n",
		errno, strerror(errno), end_current_string);
	    return (status = CMS_UPDATE_ERROR);
	}
	if ((number < SHRT_MIN || SHRT_MAX < number)
	    && warning_count < warning_count_max) {
	    warning_count++;
	    rcs_print_error
		("CMS_DISPLAY_ASCII_UPDATER:  (warning) Number %d out of range for short(%d,%d)\n",
		number, SHRT_MIN, SHRT_MAX);
	}
	x = (short) number;
    }
    find_next_comma();

    return (status);
}

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(short *x, unsigned int len)
{
    /* Check to see if the pointers are in the proper range. */
    if (-1 == check_pointer((char *) x, sizeof(short) * len)) {
	return (CMS_UPDATE_ERROR);
    }

    for (unsigned int i = 0; i < len; i++) {
	if (CMS_UPDATE_ERROR == update(x[i])) {
	    return (CMS_UPDATE_ERROR);
	}
    }
    return (status);
}

CMS_STATUS CMS_DISPLAY_ASCII_UPDATER::update(unsigned short int &x)
{
    /* Check to see if the pointers are in the proper range. */