config.c

Go to the documentation of this file.

/*
 * Config.c
 *
 * This program file contains procedures for getting and setting configuration
 * options.
 *
 * External interface:
 *
 *     set_config(argc, argv);  
 *
 *     This function gets configuration options from program arguments and
 *     a configuration file.
 *
 * 
 * 
 */
#include "standard.h"
#include "al.h"
#include "config.h"
#include "ansi.h"
#include "input.h"
#include "video_codec.h"
#include "channel.h"
#include "mux.h"
#include "demux.h"
#include "audio.h"
#include "vid_wrapper.h"
#include "bch.h"

extern _session session;
extern int debug;

#define STRLEN 256
#define DEF_CONFIG_FILE "sim.cfg"

#define DEF_NUM_CHANNELS 3     /* i.e., LCN0=Control, LCN1=Video, LCN2=Audio */

static void usage(void)
{
  printf("\n");
  printf("Usage: sim [-d debug_level] [-c config_file]\n");
  printf("       sim -h\n");
  printf("\n");
  printf("-c config_file  = set config file [%s]\n", DEF_CONFIG_FILE); 
  printf("-d debug_level  = set debug_level\n");
  printf("-h              = print this message\n");
  printf("\n");
}


static void add_alse(mux *m, al_sending_entity *alse)
{
  m->al_senders[m->num_al_senders++] = alse;
}

static void add_alre(demux *d, al_receiving_entity *alre)
{
  d->al_receivers[d->num_al_receivers++] = alre;
}


control *new_control(void)
{
  control *bob = malloc(sizeof(control));
  if (bob != NULL) {

  }
  return(bob);
}


static void parse_line(char *s, char *name, char *arg)
{
  int i,n,a;
  
  i=n=a=0;
  
  /* skip whitespace */
  while (s[i] && (s[i]==' ' || s[i]=='\t'))
    i++;
  /* copy name */
  while (s[i] && !(s[i]==' ' || s[i]=='\t'))
    name[n++]=s[i++];
  name[n]=0;
  /* skip more whitespace */
  while (s[i] && (s[i]==' ' || s[i]=='\t'))
    i++;
  /* copy argument */
  while (s[i])
    arg[a++]=s[i++];
  arg[a]=0;
}


void video_config(video_codec *video)
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  int done=0;
  FILE *fp;

  while (!done && !eof_input_file()) {

    get_str(str);

    parse_line(str, name, arg);

    if (equals(name, "end")) {
      done = 1;
    }
    else if (equals(name, "inputfile")) {
      strcpy(video->input_file, arg);
    }
    else if (equals(name, "no_coding")) {
      video->no_coding = 1;
    }
    else if (equals(name, "outputfile")) {
      strcpy(video->output_file, arg);
      
      /* clear the output file */
      fp = fopen(video->output_file,"w"); 
      if (fp==NULL) error("video_config","Can't open output file");
      fclose(fp);
    }
    else if (equals(name, "streamfile")) {
      strcpy(video->streamname, arg);
    }
    else if (equals(name, "bitrate")) {
      video->targetrate = atoi(arg);
    }

    /* the rest of these are logical channel params */

    else if (equals(name, "sequenced")) {
      video->sequenced=1;
    }
    else if (equals(name, "retransmit")) {
      video->retransmit=1;
    }
    else if (equals(name, "tmndecode")) {
      video->tmndecode=1;
    }
  }
}


void audio_config(audio_codec *A)
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  int done=0;
  FILE *fp;

  while (!done && !eof_input_file()) {

    get_str(str);

    parse_line(str, name, arg);

    if (equals(name, "end")) {
      done = 1;
    }
    else if (equals(name, "inputfile")) {
      strcpy(A->input_filename, arg);
    }
    else if (equals(name, "outputfile")) {
      strcpy(A->output_filename, arg);
      
      /* clear the output file */
      fp = fopen(A->output_filename,"w"); 
      if (fp==NULL) error("audio_config","Can't open output file");
      fclose(fp);
    }
  }
}


void control_config(control *C)
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  int done=0;

  while (!done && !eof_input_file()) {

    get_str(str);

    parse_line(str, name, arg);

    if (equals(name, "end")) {
      done = 1;
    }
    else if (equals(name, "")) {

    }
  }
}


void mux_table_config(mux *M)
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  int done=0;

  while (!done && !eof_input_file()) {
    get_str(str);
    parse_line(str, name, arg);
    if (equals(name, "end")) {
      done = 1;
    }
    else if (equals(name, "entry")) {
      if (M->params->mux_table_size < MAX_MUX_TABLE_SIZE) 
        add_to_mux_table(M->params->mux_table,
                         &(M->params->mux_table_size), arg);
    }
  }
}


void mux_config(mux *M)
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  int done=0;

  FILE *fp;
  while (!done && !eof_input_file()) {
    get_str(str);
    parse_line(str, name, arg);

    if (equals(name, "end")) {
      done = 1;
    }
    else if (equals(name, "table")) {
      mux_table_config(M);
    }
    else if (equals(name, "sync_flag_length")) {
      if (equals(arg,"16d"))
        M->params->sync_flag_length = 32;
      else
        M->params->sync_flag_length = atoi(arg);
    }
    else if (equals(name, "sync_threshold")) {
      M->params->sync_threshold = atoi(arg);
    }
    else if (equals(name, "header_code")) {
      M->params->header_code = strtobch_type(arg);
    }
    else if (equals(name, "level2")) {
      M->params->use_mpl = 1;
      M->params->level = 2;
      /* hard code some level 2 things.  could remove */
      M->params->header_code = GOLAY23_12;
      M->params->use_mpl = 0;
    }
    else if (equals(name, "level1")) {
      M->params->use_mpl = 0;
      M->params->level = 1;
    }
    else if (equals(name, "level0")) {
      M->params->use_mpl = 0;
      M->params->level = 1;  /* uses same logic as level 1 */
    }
    else if (equals(name, "mpl_code")) {
      M->params->mpl_code = strtobch_type(arg);
    }
    else if (equals(name, "payload_min")) {
      M->params->payload_min = atoi(arg);
    }
    else if (equals(name, "payload_max")) {
      M->params->payload_max = atoi(arg);
    }
    else if (equals(name, "stat_file")) {
      strcpy(M->params->stat_file,arg);
      fp = fopen(M->params->stat_file,"w"); /* delete this file if exists */
      assert(fp!=NULL);
      fclose(fp);
    }
    else if (equals(name, "mpl_t")) {
      M->params->mpl_t = atoi(arg);
    }
    else if (equals(name, "head_t")) {
      M->params->head_t = atoi(arg);
    }
    else if (equals(name, "mpl_sync_threshold")) {
      M->params->mpl_sync_threshold = atoi(arg);
    }
  }
}


void channel_config(channel *C)
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  int done=0;

  while (!done && !eof_input_file()) {
    get_str(str);
    parse_line(str, name, arg);
    if (equals(name, "end")) {
      done = 1;
    }
    else if (equals(name, "errortype")) {
      if (equals(arg, "none"))
        C->error=NoErrors;
      else if (equals(arg, "random"))
        C->error=Random;
      else if (equals(arg, "file"))
        C->error=File;
    }
    else if (equals(name, "errorrate")) {
      C->bit_error_rate = atof(arg);
    }
    else if (equals(name, "errorfile")) {
      strcpy(C->filename, arg);
    }
    else if (equals(name, "speed")) {
      C->transmission_speed = atoi(arg);
    }
    else if (equals(name, "delay")) {
      C->transmission_delay = atoi(arg);
    }
    else if (equals(name, "error_offset")) {
      C->error_offset = atoi(arg);
    }
  }
}


void side_config(_side *side)
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  
  int done=0;

  while (!done && !eof_input_file()) {
  
    get_str(str);
    parse_line(str, name, arg);

    if (equals(name, "end")) {
      done = 1;
    }
    else if (equals(name, "video")) {
      if (debug)
        printf("\t# entering %s section\n", name);
      video_config(side->Video);
    }
    else if (equals(name, "audio")) {
      if (debug)
        printf("\t# entering %s section\n", name);
      audio_config(side->Audio);
    }
    else if (equals(name, "control")) {
      if (debug)
        printf("\t# entering %s section\n", name);
      control_config(side->Control);
    }
    else if (equals(name, "mux")) {
      if (debug)
        printf("\t# entering %s section\n", name);
      mux_config(side->Mux);
    }
    else if (equals(name, "channel")) {
      if (debug)
        printf("\t# entering %s section\n", name);
      channel_config(side->Channel);
    }
  }
}


void get_config()
{
  char str[STRLEN];
  char name[STRLEN];
  char arg[STRLEN];
  void *data;

  while (!eof_input_file()) {
    
    get_str(str);

    parse_line(str, name, arg);

    if (equals(name, "local")) {
      if (debug) {
        printf("# %s side config \n", name);
      }
      side_config(&session.local);
    }
    else if (equals(name, "remote")) {
      if (debug) {
        printf("# %s side config\n", name);
      }
      side_config(&session.remote);
    }
  }
}


void start_config()
{
  /*
   * local side stuff. 
   */
  session.local.Video = new_video_codec("Local Video");
  session.local.Audio = new_audio_codec("Local Audio");
  session.local.Control = new_control();
  session.local.Mux = new_mux("Local Mux");
  session.local.Mux->params = new_mux_parameters("local -> remote");
  session.local.Demux = new_demux("Local Demux");
  session.local.Channel = new_channel("Local -> Remote channel");

  session.local.ciControl.type = AL1;
  session.local.ciAudio.type = AL2;
  session.local.ciVideo.type = AL3;

  /*
   * same stuff basically over here.
   */
  session.remote.Video = new_video_codec("Remote Video");
  session.remote.Audio = new_audio_codec("Remote Audio");
  session.remote.Control = new_control();
  session.remote.Mux = new_mux("Remote Mux");
  session.remote.Mux->params = new_mux_parameters("remote -> local");
  session.remote.Demux = new_demux("Remote Demux");
  session.remote.Channel = new_channel("Remote -> Local channel");

  session.remote.ciControl.type = AL1;
  session.remote.ciAudio.type = AL2;
  session.remote.ciVideo.type = AL3;
  
  /*
   * share parameters between local mux & remote demux 
   * and remote mux and local demux.
   */
  session.local.Demux->params = session.remote.Mux->params;
  session.remote.Demux->params = session.local.Mux->params;


  session.local.Mux->output = session.local.Channel;
  session.local.Demux->input = session.remote.Channel;
  session.remote.Mux->output = session.remote.Channel;
  session.remote.Demux->input = session.local.Channel;

}

void finish_config()
     /*
      * The order these things appear in determines the LC numbers, which
      * here hard codes audio to lcn 1 and video to lcn 2.  
      */
{
  al_sending_entity *alse;
  al_receiving_entity *alre;

  /* local side */

  alre = new_al_receiving_entity(&session.local.ciControl);
  alse = new_al_sending_entity(&session.local.ciControl);
  alre->back_channel = alse;
  session.local.Control->output = alse;
  session.local.Control->input = alre;
  add_alse(session.local.Mux, alse);
  add_alre(session.local.Demux, alre);

  alre = new_al_receiving_entity(&session.local.ciAudio);
  alse = new_al_sending_entity(&session.local.ciAudio);
  alre->back_channel = alse;
  session.local.Audio->output = alse;
  session.local.Audio->input = alre;
  add_alse(session.local.Mux, alse);
  add_alre(session.local.Demux, alre);

  alre = new_al_receiving_entity(&session.local.ciVideo);
  alse = new_al_sending_entity(&session.local.ciVideo);
  alre->back_channel = alse;
  session.local.Video->output = alse;
  session.local.Video->input = alre;
  add_alse(session.local.Mux, alse);
  add_alre(session.local.Demux, alre);

  /* remote side */

  alre = new_al_receiving_entity(&session.remote.ciControl);
  alse = new_al_sending_entity(&session.remote.ciControl);
  alre->back_channel = alse;
  session.remote.Control->output = alse;
  session.remote.Control->input = alre;
  add_alse(session.remote.Mux, alse);
  add_alre(session.remote.Demux, alre);

  alre = new_al_receiving_entity(&session.remote.ciAudio);
  alse = new_al_sending_entity(&session.remote.ciAudio);
  alre->back_channel = alse;
  session.remote.Audio->output = alse;
  session.remote.Audio->input = alre;
  add_alse(session.remote.Mux, alse);
  add_alre(session.remote.Demux, alre);

  alre = new_al_receiving_entity(&session.remote.ciVideo);
  alse = new_al_sending_entity(&session.remote.ciVideo);
  alre->back_channel = alse;
  session.remote.Video->output = alse;
  session.remote.Video->input = alre;
  add_alse(session.remote.Mux, alse);
  add_alre(session.remote.Demux, alre);

  /* compute the number of frames in for video codecs */
  set_frames(session.local.Video);
  set_frames(session.remote.Video);
}


void set_config(int argc, char *argv[])
/* 
 * This function is called by the main function to set up the system.  
 * It makes changes to the session structure.
 */
{
  int i;
  char config_file[STRLEN];

  strcpy(config_file, DEF_CONFIG_FILE);

  /*
   * Check if we should print out usage thing.
   */

  if (argc > 1 && prefix("-h", argv[1])) {
    usage();
    exit(0);
  }

  if (argc > 1 && strcmp(argv[1], "-advice")==0) {
    printf("\aDon't Panic!\n");
    exit(42);
  }

  /* 
   * Process command line arguments.
   */

  for (i = 1; i < argc; i++) {
    if (argv[i][0]=='-') {
      if (strcmp(argv[i], "-c")==0) {
        i++;
        if (i < argc) {
          config_file[STRLEN-1]='\0';
          strncpy(config_file, argv[i], STRLEN-1);
        }
      } 
      else if (equals(argv[i], "-d")) {
        if (i < (argc - 1)) {
          if (argv[i+1][0]!='-') {
            i++;
            debug = atoi(argv[i]);
          }
        }
        else {
          debug = 0;
        }
      }
    } 
    else {
      fprintf(stderr, "Invalid command line option: %s\n", argv[i]); 
      exit(1);
    }
  }

  /*
   * Open the config file.
   */

  open_input_file(config_file);

  start_config();
  get_config();
  finish_config();

  close_input_file();
}
  

---