SCPI on a Linux Board - Letter of Intent

Some more progress: first contact from LabVIEW

I don't have the reply working in the LabVIEW flow yet - it works different than serial/usb. But things look good.

Yay!

It works. Above is the capture of a LabVIEW back and forth communication - with the Raspberry Pi as a VISA TCP/IP device.

*IDN? command sent, and the reply from the Pi arrived at LabVIEW.

Yay!

It works. Above is the capture of a LabVIEW back and forth communication - with the Raspberry Pi as a VISA TCP/IP device.

*IDN? command sent, and the reply from the Pi arrived at LabVIEW.

what's not working ok:

• even though I get a reply, the Visa Read block in LabVIEW throws a timeout error.
• when I close a connection (regardless of telnet, LabVIEW), the service on the Raspberry Pi goes into a spin.

I want to tackle these before writing implementation posts.

Hi Jan!

I can't help on the LabView portion, but if you've got the Pi portion of the code somewhere, I'd be happy to examine it in case something sticks out. In terms of general ideas for debugging, you're already using gdb so that's great, it might be worth compiling on the Pi directly once, just to 100% confirm you're linking to the same versions of libraries. Also, 'strace' is sometimes useful too, although it chucks out a lot of debug.

The code as it stands now. It's a server side socket program that listens and serves info to a tcp/ip client knocking on its port:

/*
 ============================================================================
 Name        : main.c
 Author      : Jan Cumps
 Version     :
 Copyright   : free for all
 Description :
 ============================================================================
 */


/* A simple server in the internet domain using TCP
   The port number is passed as an argument */
#include 
#include 
#include 
#include 


#include "scpi/scpi.h"
#include "scpi-def.h"


int newsockfd;


/** SCPI utilities
 *
 */


size_t SCPI_Write(scpi_t * context, const char * data, size_t len) {
    (void) context;
    int n = write(newsockfd, data, len);
    if (n < 0) error("ERROR writing to socket");
    return n;
}


scpi_result_t SCPI_Flush(scpi_t * context) {
    (void) context;


    return SCPI_RES_OK;
}


int SCPI_Error(scpi_t * context, int_fast16_t err) {
    (void) context;


    fprintf(stderr, "**ERROR: %d, \"%s\"\r\n", (int16_t) err, SCPI_ErrorTranslate(err));
    return 0;
}


scpi_result_t SCPI_Control(scpi_t * context, scpi_ctrl_name_t ctrl, scpi_reg_val_t val) {
    (void) context;


    if (SCPI_CTRL_SRQ == ctrl) {
        fprintf(stderr, "**SRQ: 0x%X (%d)\r\n", val, val);
    } else {
        fprintf(stderr, "**CTRL %02x: 0x%X (%d)\r\n", ctrl, val, val);
    }
    return SCPI_RES_OK;
}


scpi_result_t SCPI_Reset(scpi_t * context) {
    (void) context;


    fprintf(stderr, "**Reset\r\n");
    return SCPI_RES_OK;
}


scpi_result_t SCPI_SystemCommTcpipControlQ(scpi_t * context) {
    (void) context;


    return SCPI_RES_ERR;
}






void error(char *msg)
{
    perror(msg);
    exit(1);
}


int main(int argc, char *argv[])
{
     int sockfd, portno, clilen;
     char buffer[256];
     struct sockaddr_in serv_addr, cli_addr;
     int n;


     SCPI_Init(&scpi_context,
             scpi_commands,
             &scpi_interface,
             scpi_units_def,
             SCPI_IDN1, SCPI_IDN2, SCPI_IDN3, SCPI_IDN4,
             scpi_input_buffer, SCPI_INPUT_BUFFER_LENGTH,
             scpi_error_queue_data, SCPI_ERROR_QUEUE_SIZE);
     if (argc < 2) {
         fprintf(stderr,"ERROR, no port provided\n");
         exit(1);
     }
     sockfd = socket(AF_INET, SOCK_STREAM, 0);
     if (sockfd < 0)
        error("ERROR opening socket");
     bzero((char *) &serv_addr, sizeof(serv_addr));
     portno = atoi(argv[1]);
     serv_addr.sin_family = AF_INET;
     serv_addr.sin_addr.s_addr = INADDR_ANY;
     serv_addr.sin_port = htons(portno);
     if (bind(sockfd, (struct sockaddr *) &serv_addr,
              sizeof(serv_addr)) < 0)
              error("ERROR on binding");
     listen(sockfd,5);
     clilen = sizeof(cli_addr);
     newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
     if (newsockfd < 0)
          error("ERROR on accept");
     while (1) {
         bzero(buffer,256);
         n = read(newsockfd,buffer,255);
         if (n < 0) {
        error("ERROR reading from socket");
         } else if (n > 0) {
             printf("Here is the message: %s\n",buffer);
             scpi_instrument_input(buffer, n);


         }


     }


     return 0;
}

My issue is in this small part:

     while (1) {
         bzero(buffer,256);
         n = read(newsockfd,buffer,255);
         if (n < 0) {
        error("ERROR reading from socket");
         } else if (n > 0) {
             printf("Here is the message: %s\n",buffer);
             scpi_instrument_input(buffer, n);
         }
     }

As long as the client is connected, n = 0 when no data received from the client. All good

When the client (example unix telnet session) closes, the read() function always returns the value 32.

Before I define a fix for that, I want to try and understand why that is.

Before anyone thinks that I'm a server side network socket expert: I borrowed this from http://www.cs.rpi.edu/~moorthy/Courses/os98/Pgms/server.c

Because that program doesn't loop (it waits for traffic, notifies and dies), it doesn't have the issue.

I need to do some more studying ...

Hi Jan,

It's a while since I looked at the POSIX socket API, so I'm not sure either, but it might be worth also testing that newsockfd does not equal 0 before trying the read operation, e.g.

if (newsockfd) {
  n=read(newsockfd, buffer, 255);
}

From memory I think using 'select' API is a good method to handle acting as a TCP server, but I need to read up on it. I'll try to dig up some useful links. There are some good patterns to handling socket reads, I just need to find them.

You may be on to something. I only call newsockfd() once at the start and assign it to a global variable (blush). So it will never be 0, but it may very well be invalid.

I'll check if I have to reallocate each time, or if I have to check that handle's validity ...