sics/tecs/client.c

#include <assert.h>
#include "client.h"
#include "util.h"

/*-------------------------------------------------------------------------*/

int CocConnect(CocConn *conn, int allowConnRefused) {
  int i;
  struct sockaddr_in sadr;

  ERR_I(CocCreateSockAdr(&sadr, conn->host, conn->port));
  ERR_SI(conn->fd=socket(AF_INET, SOCK_STREAM, 0));
  i = 1;
  ERR_SI(setsockopt(conn->fd,SOL_SOCKET,SO_REUSEADDR,&i,sizeof(int))); /* allow quick port reuse */
  i=connect(conn->fd, (struct sockaddr *)&sadr, sizeof(sadr));
  if (i<0) {
    if (allowConnRefused && errno==ECONNREFUSED) return(1);
    ERR_COD(errno);
  }
  return(0);
  OnError: return(-1);
}

int CocOpen(CocConn *conn)
{
  int i, try, tmo;

  ERR_I(i=CocConnect(conn, conn->startcmd[0]!='\0'));
  if (i==0) return(0);

  printf("%s\n", conn->startcmd);
  ERR_I(system(conn->startcmd));

  try=15;
  tmo=100; /* wait total ca. 10 sec. for 15 tries */
  while (try>0) {
    try--;
    util_delay(tmo); tmo=tmo*5/4;
    ERR_I(i=CocConnect(conn, try>0));
    if (i==0) return(0);
  }
  ERR_MSG("error in CocConnect");
  OnError: return(-1);
}

/*-------------------------------------------------------------------------*/

int CocInitClient(CocConn *conn, char *host, int port, char *magic, int bufsize, char *startcmd) {
  assert(conn!=NULL);
  if (bufsize==0) bufsize=1024;
  conn->cmdbuf=buf_create(bufsize);
  conn->resbuf=buf_create(bufsize);
  conn->port=port;
  str_copy(conn->host, host);
  str_copy(conn->magic, magic);
  str_copy(conn->startcmd, startcmd);
  conn->fd=-1;
  conn->varList=NULL;
  CocVarList(&conn->varList);
  ERR_I(CocOpen(conn));
  ERR_I(CocSendMagic(conn, conn->magic));
  return(0);
  OnError: return(-1);
}

/*-------------------------------------------------------------------------*/

int CocSendMagic(CocConn *conn, char *magic) {
  char *err;

  if (magic[0]!='#') ERR_MSG("magic must start with '#'");
  buf_put_start(conn->resbuf); /* use return buffer for command in order to preserve command buffer */
  buf_put_str(conn->resbuf, magic);
  buf_put_end(conn->resbuf);
  if (conn->resbuf->buf==NULL) ERR_MSG("buffer full");
  ERR_SI(send(conn->fd, conn->resbuf->buf, conn->resbuf->size, 0));
  ERR_I(CocRecv(conn->fd, conn->resbuf));
  err=buf_get_str(conn->resbuf);
  if (*err!='\0') { ErrMsg(err); ErrTxt(": (response from server)",0); goto OnError; }
  if (buf_size(conn->resbuf)!=0) ERR_MSG("syntax error");
  return(0);
  OnError: return(-1);
}

/*-------------------------------------------------------------------------*/

int CocTryCmd(CocConn *conn)
{ if (conn->fd<0) {
    ERR_I(CocOpen(conn));
    ERR_I(CocSendMagic(conn, conn->magic));
  }
  ERR_SI(send(conn->fd, conn->cmdbuf->buf, conn->cmdbuf->size, 0));
  ERR_I(CocRecv(conn->fd, conn->resbuf));
  return(0);
  OnError: return(-1);
}

/*-------------------------------------------------------------------------*/

int CocCmd(CocConn *conn, const char *rwList)
{ int iret, cnt, setmode, i;
  char *err;
  const char *t, *s;
  char nam[32];
  CocVar *var;

  assert(conn!=NULL);
  buf_put_start(conn->cmdbuf);
  s=rwList;
  setmode=0;
  do {
    t=strchr(s, ',');
    if (t==NULL) t=s+strlen(s);
    if (*s=='[') {
      if (!setmode) buf_put_str(conn->cmdbuf, "[");
      s++;
      setmode=1;
    }
    i=t-s;
    assert(i<32);
    str_ncpy(nam, s, i+1);
    if (setmode) {
      if (nam[i-1]==']') { i--; nam[i]='\0'; setmode=0; }
      buf_put_str(conn->cmdbuf, nam);
      ERR_I(CocPutVar(conn->varList, conn->cmdbuf, nam));
      if (!setmode) buf_put_str(conn->cmdbuf, "]");
    } else {
      var=CocFindVar(conn->varList, nam);
      if (var==NULL) ERR_MSG("variable not found");
      buf_put_str(conn->cmdbuf, nam);
    }
    s=t+1;
  } while (*t!='\0');

  buf_put_end(conn->cmdbuf);
  if (conn->cmdbuf->buf==NULL) ERR_MSG("out buffer full");
  cnt=3;
  while (1) {
    cnt--;
    if (cnt<=0) {
      ERR_I(CocTryCmd(conn));
      break;
    }
    iret=CocTryCmd(conn);
    if (iret>=0) break;
    close(conn->fd);
    conn->fd=-1;
    if (ErrCode!=ECONNRESET && ErrCode!=EPIPE) goto OnError;
    ErrShow("try again, error was");
  }
  err=buf_get_str(conn->resbuf);
  if (*err!='\0') { ErrMsg(err); ErrTxt(": (response from server)",0 ); goto OnError; }

  /* read values */
  s=rwList;
  setmode=0;
  do {
    t=strchr(s, ',');
    if (t==NULL) t=s+strlen(s);
    if (*s=='[') {
      s++;
      setmode=1;
    }
    i=t-s;
    if (setmode) {
      if (*(t-1)==']') setmode=0;
    } else {
      str_ncpy(nam, s, i+1);
      ERR_I(CocGetVar(conn->varList, conn->resbuf, nam));
    }
    s=t+1;
  } while (*t!='\0');
  if (buf_size(conn->resbuf)!=0) ERR_MSG("syntax error");
  return(0);

  OnError: return(-1);
}

void CocCloseClient(CocConn *conn) {
  assert(conn!=NULL);
  close(conn->fd);
  buf_free(conn->cmdbuf);
  buf_free(conn->resbuf);
  CocFreeVarList(&conn->varList);
}