/*
vnarec3d.c

Measurement server for the EMCAR system.

This code employs code from the:
Simplest possible DI-194(RS) test program
Paul Hubbard   4/2/03

2006-11-27 Bob Freeman
Hacked Pauls code to read faster for making recordings from
the hp8410b network analyzer (removed time_t calls)

2007-12-30 Bob Freeman
Extended hack to add IPC functions needed to synchronize with the Ham Antenna Range
system being developed on the EMC2 system.  Notes are included below as planning proceeds.  Sure hope a real programmer gets ahold of this. raf

2007-01-29 Bob Freeman
Added some functionality for calls to a realtime plot via gnuplot

   "This software uses the gnuplot_i library written by
    N.Devillard <ndevilla@free.fr> 
and updating the plot via a replot command at each IPC call
*/

#include <sys/types.h>
#include <stdlib.h>
#include <math.h>
#include <unistd.h>
#include <stdint.h>
#include "di194.h"
#include "vnarec3d.h"
#include "gnuplot_i.h"          // include interactive gnuplot interface

// from server.c (Mark Watson)
#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>      

// Global boolean set by signal handler to force exit

bool do_exit;

// socket programming variables

  int    port = 8000;		// socket port number
  struct sockaddr_in srv;
  struct sockaddr_in pin;
  int    sock_descriptor;
  int    temp_sock_descriptor;
  int    address_size;
  char   buf[BUFSIZE];
  int    i, len;

  int   rc;
  daq_reading_t data;
  int   DI_FD = -1;
  int   num_bits = 8;    

  void sighandler(int signal);

/* Open files pointers */

FILE *fp_1;


// ======================================================================

int main(int argc, char *argv[])
{

// initialize gnulot_i
	gnuplot_ctrl * g ;
	g = gnuplot_init();
//char vnafile[]="/home/bob/vna.dat";
char myfile[]="/home/bob/polar40dB.gnu";
char stepfile[]="/home/bob/polar40dB_step.gnu";

// Open the Signal Handler

    printf("\nInstalling signal handler.\n");
    do_exit = false;
    signal(SIGINT, sighandler);
    signal(SIGPIPE, sighandler);

//  Open the data file for output, specifying full path.
 
	openfile();

// Loop until signal handler sets 'do_exit' flag on ctrl-c
// This exit relates to the completion of the entire measurement

// Open a live plot using gnuplot
	
	gnuplot_cmd(g, "load '%s'", myfile);	

while(do_exit == false)
    {

// Open a socket for I/O and subsequent requests/triggers from EMC

        opensocket();

// We'll wait here for a trigger or message from EMC
// This segment is intended for routine data points (not the first)

  while(1) {
    temp_sock_descriptor =
      accept(sock_descriptor, (struct sockaddr *)&pin, &address_size);
    if (temp_sock_descriptor == -1) {
      perror("call to accept");
      exit(1);
    }

    if (recv(temp_sock_descriptor, buf, BUFSIZE, 0) == -1) {
      perror("call to recv");
      exit(1);
    }

    printf("received from client:%s\n", buf);

// Message received, call up another measurement sequence here.
// Read data from DI-194 (this is relatively slow with init each time)

	opendaq();
       	readdaq();
	di_close(DI_FD);
       
// Update the plot for realtime display
    
	gnuplot_cmd(g, "load '%s'", stepfile);	

// test buf for signal indicating last trigger.  if so, exit program
// until we get more elegant or readable we presume an "X" is sent
// to indicate the end of the process is requested

    len = strlen(buf);
    for (i=0; i<len; i++) buf[i] = toupper(buf[i]);

//  Respond my returning the message to the calling program

    if (send(temp_sock_descriptor, buf, len, 0) == -1) {
      perror("call to send");
      exit(1);
    }

// +++++++++  This needs fixin' by cool programmer
    
    if(buf[0] == 'X' ) {
    printf("received from client signal to end process:%s\n", buf);
    exit(1);}
    
    }

    return(0);
    }

    close(temp_sock_descriptor);
    di_close(DI_FD);
    fclose(fp_1);

// last data point so close plot

    gnuplot_close(g);

    return(0);
}

// ======================================================================

void sighandler(int signal)
{
    char    me[] = "sighandler";

    fprintf(stderr, "\n%s: Got signal %d, exiting\n", me, signal);
    fflush(stderr);
    
    do_exit = true;

    exit(1);
}

int opendaq(){

    printf("\nOpening device");
    fflush(stdout);

    DI_FD = di_open(NULL, &num_bits);
    if(DI_FD <= 0)
    {
        fprintf(stderr, "\nError %d opening device\n", rc);
        di_close(DI_FD);
        return(rc);
    }

    printf("\nStarting DAQ running, we have %d bits of precision\n", 
	   num_bits);
    rc = di_start(DI_FD);

    if(rc != 0)
    {
        fprintf(stderr, "\nError %d starting DAQ\n", rc);
        di_close(DI_FD);
        return(rc);
    }

    // Paranoia, not really required
    rc = di_daq_sync(DI_FD);
    if(rc != 0)
    {
        fprintf(stderr, "\nError %d syncing DAQ\n", rc);
        di_close(DI_FD);
        return(rc);
    }

	return(0);
}

int openfile(){

 if((fp_1 = fopen("/home/bob/vna.dat", "w")) == NULL)
 {
  fprintf(stderr,"cant open file %s\n","vna.dat"); exit(0);
 }
return(0);
}


void readdaq(){

        // Read data from DI-194
        rc = di_read(DI_FD, &data, num_bits);
        if(rc != 0)
        {
            fprintf(stderr, "\nError %d reading data\n", rc);
//            break;
        }

// Print the angle or message data received from EMC to file, too.

	    printf("%s\n",buf);

	    printf("%6.3f %6.3f %6.3f %6.3f %1d %1d %1d\n",
		   data.analog[0],
		   data.analog[1],
		   data.analog[2],
		   data.analog[3],
		   data.digital[0],
		   data.digital[1],
		   data.digital[2]);
		   
// Print the angle or message data received from EMC to file, too.

	    fprintf(fp_1,"%s  ",buf);

	    fprintf(fp_1,"%6.3f %6.3f %6.3f %6.3f %1d %1d %1d\n",
		   data.analog[0],
		   data.analog[1],
		   data.analog[2],
		   data.analog[3],
		   data.digital[0],
		   data.digital[1],
		   data.digital[2]);
	    fflush(fp_1);

	    fflush(stdout);

	return;
   }

void opensocket(){
int on, ret;
  sock_descriptor = socket(AF_INET, SOCK_STREAM, 0);
  if (sock_descriptor == -1) {
    perror("call to socket");
    exit(1);
  }

// Enable address reuse
  on=1;
  ret = setsockopt(sock_descriptor, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));

  bzero(&srv, sizeof(srv));
  srv.sin_family = AF_INET;
  srv.sin_addr.s_addr = INADDR_ANY;
  srv.sin_port = htons(port);

  if (bind(sock_descriptor, (struct sockaddr *)&srv, sizeof(srv)) == -1) {
    perror("call to bind");
    exit(1);
  }

  if (listen(sock_descriptor, 20) == -1) {
    perror("call to listen");
    exit(1);
  }

  printf("Accepting connections ...\n"); 
  return;
}