bsSerialServer.c File Reference

BotSense bsProxy server plug-in DLL RS-232 serial device module. More...

#include <stdio.h>
#include <string.h>
#include <errno.h>
#include "rnr/rnrconfig.h"
#include "rnr/log.h"
#include "rnr/new.h"
#include "rnr/netmsgs.h"
#include "rnr/serdev.h"
#include "botsense/BotSense.h"
#include "botsense/libBotSense.h"
#include "botsense/bsProxyModIF.h"
#include "botsense/bsSerial.h"
#include "botsense/bsSerialMsgs.h"

Go to the source code of this file.

Classes
struct	BsModCtlBlk_T
	Module resource control block structure type. More...

Macros
#define	BSMOD_MAX_HANDLES   8
	Maximum number of module supported simultaneous virtual connections.
#define	BSMOD_T_READ   1000000
	default read time out (usec)
#define	BSMOD_T_TRANS   2000000
	default transaction time out (usec)
#define	BSMOD_T_WRITE   1000000
	default write time out (usec)

Functions
static BsModCtlBlk_T *	bsModCtlBlkNew (int fd, const char *sDevUri, BsSerialReqOpenArgs_T *pDevCfg, bool_t bTrace)
	Allocate a new resource control block. More...
static void	bsModCtlBlkDelete (BsModCtlBlk_T *pCtlBlk)
	Delete an allocated resource control block. More...
static int	bsModSerialReqRead (BsVConnHnd_T hndVConn, BsTid_T uTid, BsMsgId_T uMsgIdReq, byte_t bufReq[], size_t uReqLen)
	Service a serial read request. More...
static int	bsModSerialReqWrite (BsVConnHnd_T hndVConn, BsTid_T uTid, BsMsgId_T uMsgIdReq, byte_t bufReq[], size_t uReqLen)
	Service a serial write request. More...
static int	bsModSerialReqTrans (BsVConnHnd_T hndVConn, BsTid_T uTid, BsMsgId_T uMsgIdReq, byte_t bufReq[], size_t uReqLen)
	Service a serial write-read transaction request. More...
int	bsModInit (const char *sModUri, const BsModProxyCb_T *pCallbacks)
	Initialize serial module. More...
void	bsModExit ()
	Exit serial module. More...
int	bsModOpen (BsVConnHnd_T hndVConn, bool_t bTrace, const char *sDevUri, byte_t argbuf[], size_t uArgSize)
	Open a serial device and associate with the given handle. More...
int	bsModClose (BsVConnHnd_T hndVConn)
	Close the serial device and disassociate virtual connection handle. More...
int	bsModRequest (BsVConnHnd_T hndVConn, BsTid_T uTid, BsMsgId_T uMsgIdReq, byte_t bufReq[], size_t uReqLen)
	Service a serial request. More...
int	bsModTrace (BsVConnHnd_T hndVConn, bool_t bTrace)
	Enable/disable message tracing on handle. More...
const BsModInfo_T *	bsModInfo ()
	Query for the static module information. More...

Variables
static BsModInfo_T	BsModInfo
	Module static information. More...
static const char *	BsModUri
	module canonical name
static const BsModProxyCb_T *	BsModCallbacks
	module to bsProxy callbacks
static BsModRsrcTbl_T *	BsModRsrcTbl
	module resource table

Detailed Description

BotSense bsProxy server plug-in DLL RS-232 serial device module.

LastChangedDate

2010-08-20 11:36:38 -0600 (Fri, 20 Aug 2010)

Rev

568

Author

Robin Knight (robin.nosp@m..kni.nosp@m.ght@r.nosp@m.oadn.nosp@m.arrow.nosp@m.s.co.nosp@m.m)

Copyright

© 2010-2017. RoadNarrows LLC.
http://www.roadnarrows.com
All Rights Reserved

Definition in file bsSerialServer.c.

Function Documentation

int bsModClose

(

BsVConnHnd_T

hndVConn

)

Close the serial device and disassociate virtual connection handle.

The specific serial resources are freed.

Parameters

hndVConn

Virtual connection handle.

Returns

On success, BS_OK is returned.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 650 of file bsSerialServer.c.

References BS_ECODE_INTERNAL, BS_ECODE_NO_VCONN, BS_OK, BSMOD_LOG_ERROR, BSMOD_RSRC_IS_INUSE, BSMOD_TRY_VCONN_HND_RANGE, bsModCtlBlkDelete(), BsModProxyCb_T::m_cbModRsrcRemove, and BsModCtlBlk_T::m_fd.

{
  BsModCtlBlk_T  *pCtlBlk;

  // check if handle is in valid range
  BSMOD_TRY_VCONN_HND_RANGE(hndVConn);

  // check is resouce is in-use (i.e. opened)
  if( !BSMOD_RSRC_IS_INUSE(BsModRsrcTbl, hndVConn) )
  {
    BSMOD_LOG_ERROR(hndVConn, BS_ECODE_NO_VCONN,
        "Resources for virtual connection not found.");
    return -BS_ECODE_NO_VCONN;
  }

  // remove resource from module's resource table
  pCtlBlk = (BsModCtlBlk_T *)BsModCallbacks->m_cbModRsrcRemove(BsModRsrcTbl,
                                                               hndVConn);

  if( pCtlBlk == NULL )
  {
    BSMOD_LOG_ERROR(hndVConn, BS_ECODE_INTERNAL, "No module resource found.");
    return -BS_ECODE_INTERNAL;
  }

  if( pCtlBlk->m_fd >= 0 )
  {
    SerDevClose(pCtlBlk->m_fd);
    LOGDIAG2("VConn=%d: SerDevClose(fd=%d).", hndVConn, pCtlBlk->m_fd);
  }

  bsModCtlBlkDelete(pCtlBlk);

  return BS_OK;
}

static void bsModCtlBlkDelete ( BsModCtlBlk_T *  pCtlBlk )

static

Delete an allocated resource control block.

Parameters

pCtlBlk

Pointer to allocated control block.

Definition at line 153 of file bsSerialServer.c.

References BsModCtlBlk_T::m_sDevUri.

Referenced by bsModClose(), and bsModExit().

{
  if( pCtlBlk != NULL )
  {
    delete((void *)(pCtlBlk->m_sDevUri));
    delete(pCtlBlk);
  }
}

static BsModCtlBlk_T* bsModCtlBlkNew ( int  fd, const char *  sDevUri, BsSerialReqOpenArgs_T *  pDevCfg, bool_t  bTrace  )

static

Allocate a new resource control block.

Parameters

fd	Opened device file descriptor ≥ 0.
sDevUri	Device URI.
pDevCfg	Device configuration parameters.
bTrace	Do [not] trace messages.

Returns

Pointer to new allocated control block.

Definition at line 131 of file bsSerialServer.c.

References BsModCtlBlk_T::m_bTrace, BsModCtlBlk_T::m_fd, BsModCtlBlk_T::m_sDevUri, and BsModCtlBlk_T::m_stDevCfg.

Referenced by bsModOpen().

{
  BsModCtlBlk_T *pCtlBlk;

  pCtlBlk = NEW(BsModCtlBlk_T);

  pCtlBlk->m_fd       = fd;
  pCtlBlk->m_sDevUri  = new_strdup(sDevUri);
  pCtlBlk->m_stDevCfg = *pDevCfg;
  pCtlBlk->m_bTrace   = bTrace;

  return pCtlBlk;
}

void bsModExit

(

)

Exit serial module.

Called once prior to module being unloaded.

All open serial devices will be closed.

Definition at line 520 of file bsSerialServer.c.

References BSMOD_MAX_HANDLES, bsModCtlBlkDelete(), BsModUri, BsModProxyCb_T::m_cbModRsrcTblDelete, BsModCtlBlk_T::m_fd, and BsModRsrcTbl_T::m_vecRsrc.

{
  int             index;
  BsModCtlBlk_T  *pCtlBlk;

  // free all module virtual connnection resources.
  for(index=0; index<BSMOD_MAX_HANDLES; ++index)
  {
    if( (pCtlBlk = (BsModCtlBlk_T *)BsModRsrcTbl->m_vecRsrc[index]) != NULL )
    {
      if( pCtlBlk->m_fd >= 0 )
      {
        SerDevClose(pCtlBlk->m_fd);
      }
      bsModCtlBlkDelete(pCtlBlk);
    }
  }

  // free resource table
  BsModCallbacks->m_cbModRsrcTblDelete(BsModRsrcTbl);

  delete((char *)BsModUri);
}

const BsModInfo_T* bsModInfo

(

)

Query for the static module information.

Returns

Pointer to module static information.

Definition at line 783 of file bsSerialServer.c.

References BsModInfo.

{
  return &BsModInfo;
}

int bsModInit	(	const char *	sModUri,
		const BsModProxyCb_T *	pCallbacks
	)

Initialize serial module.

Called once after module is loaded.

Parameters

sModUri	Expanded, canonical module path name.
pCallbacks	Pointer to a set of module -> bsProxy core callback functions.

Returns

On success, BS_OK is returned.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 500 of file bsSerialServer.c.

References BS_OK, BSMOD_MAX_HANDLES, BsModUri, and BsModProxyCb_T::m_cbModRsrcTblNew.

{
  BsModUri = new_strdup(sModUri);

  // save bsProxy server callbacks
  BsModCallbacks = pCallbacks;

  // create module resource table
  BsModRsrcTbl = BsModCallbacks->m_cbModRsrcTblNew(BSMOD_MAX_HANDLES);

  return BS_OK;
}

int bsModOpen	(	BsVConnHnd_T	hndVConn,
		bool_t	bTrace,
		const char *	sDevUri,
		byte_t	argbuf[],
		size_t	uArgSize
	)

Open a serial device and associate with the given handle.

Subsequent calls to the module use the given handle to associate the specific module-device instance.

The argument buffer contains packed message arguements specific to the device and module.

Note

Each call to this exported function will open the serial device and set the appropriate configuration, even if the device is already opened by this or another module.

It is the responsibile of the client to ensure consistency if more than one virtual connection is established.

Parameters

hndVConn	Virtual connection handle.
bTrace	Do [not] enable message tracing on this handle.
sDevUri	Device URI.
argbuf	Packed specific open configuration arguments submessage.
uArgSize	Size of packed argumets in buffer (number of bytes).

Returns

On success, returns a unique resource descriptor ≥ 0 which is typically an opened file descriptor or socket descriptor, but can be module defined.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 572 of file bsSerialServer.c.

References BS_ECODE_BAD_MSG, BS_ECODE_BUSY, BS_ECODE_NO_RSRC, BS_ECODE_SYS, BSMOD_LOG_ERROR, BSMOD_LOG_NMERROR, BSMOD_LOG_SYSERROR, BSMOD_MAX_HANDLES, BSMOD_RSRC_INUSE_COUNT, BSMOD_RSRC_IS_INUSE, BSMOD_TRY_VCONN_HND_RANGE, bsModCtlBlkNew(), BsSerialUnpackReqOpenArgs(), BsSerialReqOpenArgs_T::m_baudrate, BsSerialReqOpenArgs_T::m_bytesize, BsModProxyCb_T::m_cbModRsrcAdd, BsSerialReqOpenArgs_T::m_parity, BsSerialReqOpenArgs_T::m_rtscts, BsSerialReqOpenArgs_T::m_stopbits, and BsSerialReqOpenArgs_T::m_xonxoff.

{
  BsModCtlBlk_T        *pCtlBlk;
  BsSerialReqOpenArgs_T devcfg;
  int                   fd;
  int                   rc;

  // Check if handle is in valid range.
  BSMOD_TRY_VCONN_HND_RANGE(hndVConn);

  // Check if resources are available.
  if( BSMOD_RSRC_INUSE_COUNT(BsModRsrcTbl) >= BSMOD_MAX_HANDLES )
  {
    BSMOD_LOG_ERROR(hndVConn, BS_ECODE_NO_RSRC,
        "InUseCount=%u: No more resources available.",
        BSMOD_RSRC_INUSE_COUNT(BsModRsrcTbl));
    return -BS_ECODE_NO_RSRC;
  }
  
  // Check if the resource in resource table is not already in-use.
  else if( BSMOD_RSRC_IS_INUSE(BsModRsrcTbl, hndVConn) )
  {
    BSMOD_LOG_ERROR(hndVConn, BS_ECODE_BUSY, 
        "Module virtual connection handle already in use");
    return -BS_ECODE_BUSY;
  }

  // unpack device configuration arguments submessage
  rc = BsSerialUnpackReqOpenArgs(argbuf, uArgSize, &devcfg, bTrace);

  if( rc < 0 )
  {
    BSMOD_LOG_NMERROR(hndVConn, rc,
        "Unpacking failed on BsSerialReqOpenArgs submessage");
    return -BS_ECODE_BAD_MSG;
  }

  // open serial device
  fd = SerDevOpen(sDevUri, (int)devcfg.m_baudrate, (int)devcfg.m_bytesize,
                  (int)devcfg.m_parity, (int)devcfg.m_stopbits,
                  devcfg.m_rtscts, devcfg.m_xonxoff);

  if( fd < 0 )
  {
    BSMOD_LOG_SYSERROR(hndVConn, "SerDevOpen(%s,...).", sDevUri);
    return -BS_ECODE_SYS;
  }

  // allocate a new control block and initialize
  pCtlBlk = bsModCtlBlkNew(fd, sDevUri, &devcfg, bTrace);

  // add to module resource table
  BsModCallbacks->m_cbModRsrcAdd(BsModRsrcTbl, hndVConn, pCtlBlk);

  LOGDIAG2("VConn=%d: %d=SerDevOpen(dev=%s, %d,%d,%c,%d, rts=%s, xon=%s).",
      hndVConn, fd, sDevUri,
      (int)devcfg.m_baudrate, (int)devcfg.m_bytesize,
      devcfg.m_parity, (int)devcfg.m_stopbits,
      (devcfg.m_rtscts? "true": "false"), 
      (devcfg.m_xonxoff? "true": "false"));

  return fd;
}

int bsModRequest	(	BsVConnHnd_T	hndVConn,
		BsTid_T	uTid,
		BsMsgId_T	uMsgIdReq,
		byte_t	bufReq[],
		size_t	uReqLen
	)

Service a serial request.

Note

A module-specific request service must send a response.

Parameters

hndVConn	Virtual connection handle.
uTid	Request-Response transaction id.
uMsgIdReq	Request message id.
bufReq	Packed request message buffer.
uReqLen	Size of request in buffer (number of bytes).

Returns

On success, BS_OK is returned.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 699 of file bsSerialServer.c.

References BS_ECODE_BAD_VCONN_HND, BS_ECODE_NO_VCONN, BS_ECODE_UNKNOWN_REQ, BSMOD_IS_VCONN_HANDLE, BSMOD_RSRC, BSMOD_SEND_ERROR_RSP, bsModSerialReqRead(), bsModSerialReqTrans(), bsModSerialReqWrite(), BsSerialMsgIdReqRead, BsSerialMsgIdReqTrans, and BsSerialMsgIdReqWrite.

{
  BsModCtlBlk_T  *pCtlBlk;

  // check if handle is in valid range
  if( !BSMOD_IS_VCONN_HANDLE(hndVConn) )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_BAD_VCONN_HND,
          "Module vconn handle out-of-range.");
    return -BS_ECODE_BAD_VCONN_HND; \
  }

  // retrieve resource control block
  pCtlBlk = (BsModCtlBlk_T *)BSMOD_RSRC(BsModRsrcTbl, hndVConn);

  // check resource
  if( pCtlBlk == NULL )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_NO_VCONN,
        "No resources for virtual connection found.");
    return -BS_ECODE_NO_VCONN;
  }

  switch( uMsgIdReq )
  {
    case BsSerialMsgIdReqRead:
      return bsModSerialReqRead(hndVConn, uTid, uMsgIdReq, bufReq, uReqLen);
    case BsSerialMsgIdReqTrans:
      return bsModSerialReqTrans(hndVConn, uTid, uMsgIdReq, bufReq, uReqLen);
    case BsSerialMsgIdReqWrite:
      return bsModSerialReqWrite(hndVConn, uTid, uMsgIdReq, bufReq, uReqLen);
    default:
      BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_UNKNOWN_REQ,
          "MsgId=%u.", uMsgIdReq);
      return -BS_ECODE_UNKNOWN_REQ;
  }
}

static int bsModSerialReqRead ( BsVConnHnd_T  hndVConn, BsTid_T  uTid, BsMsgId_T  uMsgIdReq, byte_t  bufReq[], size_t  uReqLen  )

static

Service a serial read request.

Note

A module-specific request service must send a response.

Parameters

hndVConn	Virtual connection handle.
uTid	Request-Response transaction id.
uMsgIdReq	Request message id.
bufReq	Packed request message buffer.
uReqLen	Size of request in buffer (number of bytes).

Returns

On success, BS_OK is returned.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 175 of file bsSerialServer.c.

References BS_ECODE_BAD_MSG, BS_ECODE_BAD_VCONN_HND, BS_ECODE_NO_VCONN, BS_ECODE_SYS, BS_OK, BSMOD_IS_VCONN_HANDLE, BSMOD_RSRC, BSMOD_SEND_ERROR_RSP, BSMOD_SEND_NMERROR_RSP, BSMOD_SEND_SYSERROR_RSP, BSMOD_T_READ, BSPROXY_BUF_BODY, BSPROXY_MSG_MAX_LEN, BsSerialMsgIdRspRead, BsSerialPackRspRead(), BsSerialUnpackReqRead(), BsModCtlBlk_T::m_bTrace, BsModProxyCb_T::m_cbSendRsp, BsSerialRspRead_T::m_count, BsModCtlBlk_T::m_fd, BsSerialRspRead_T::m_readbuf, BsSerialReqRead_T::m_readlen, and BsSerialRspRead_T::u.

Referenced by bsModRequest().

{
  static BsSerialMsgId_T  uMsgIdRsp = BsSerialMsgIdRspRead;

  BsModCtlBlk_T      *pCtlBlk;                    // resource control block
  BsSerialReqRead_T   msgReq;                     // request message 
  BsSerialRspRead_T   msgRsp;                     // response message 
  byte_t              bufRsp[BSPROXY_MSG_MAX_LEN]; // req/rsp buffer
  int                 n;                          // number of bytes/return code

  //
  // Parameter checks
  //
  if( !BSMOD_IS_VCONN_HANDLE(hndVConn) )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_BAD_VCONN_HND,
          "Module vconn handle out-of-range.");
    return -BS_ECODE_BAD_VCONN_HND; \
  }

  // retrieve the resource control block
  pCtlBlk = (BsModCtlBlk_T *)BSMOD_RSRC(BsModRsrcTbl, hndVConn);

  if( pCtlBlk == NULL )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_NO_VCONN,
        "No resources for virtual connection found.");
    return -BS_ECODE_NO_VCONN;
  }

  //
  // Unpack client request.
  //
  n = BsSerialUnpackReqRead(bufReq, uReqLen, &msgReq, pCtlBlk->m_bTrace);

  // check unpacking return code
  if( n < 0 )
  {
    BSMOD_SEND_NMERROR_RSP(BsModCallbacks, hndVConn, uTid, n,
        "MsgId=%u", uMsgIdReq);
    return -BS_ECODE_BAD_MSG;
  }

  //
  // Execute client request.
  //
  n = (int)SerDevRead(pCtlBlk->m_fd, msgRsp.m_readbuf.u.m_buf,
                        (size_t)msgReq.m_readlen, BSMOD_T_READ);

  // check operation return code
  if( n < 0 )
  {
    BSMOD_SEND_SYSERROR_RSP(BsModCallbacks, hndVConn, uTid,
        "SerDevRead(%d,...).", pCtlBlk->m_fd);
    return -BS_ECODE_SYS;
  }

  LOGDIAG3("VConn=%d: %d=SerDevRead(fd=%d, buf=%p, count=%zu, usec=%u).",
      hndVConn, n, pCtlBlk->m_fd, msgRsp.m_readbuf.u.m_buf,
      (size_t)msgReq.m_readlen, BSMOD_T_READ);

  //
  // Pack server response.
  //
  msgRsp.m_readbuf.m_count = (byte_t)n;
    
  // pack
  n = BsSerialPackRspRead(&msgRsp, BSPROXY_BUF_BODY(bufRsp), pCtlBlk->m_bTrace);

  // check packing return code
  if( n < 0 )
  {
    BSMOD_SEND_NMERROR_RSP(BsModCallbacks, hndVConn, uTid, n,
        "MsgId=%u", uMsgIdRsp);
    return -BS_ECODE_BAD_MSG;
  }

  //
  // Send response.
  //
  BsModCallbacks->m_cbSendRsp(hndVConn, uTid, uMsgIdRsp, bufRsp, (size_t)n);

  return BS_OK;
}

static int bsModSerialReqTrans ( BsVConnHnd_T  hndVConn, BsTid_T  uTid, BsMsgId_T  uMsgIdReq, byte_t  bufReq[], size_t  uReqLen  )

static

Service a serial write-read transaction request.

Note

A module-specific request service must send a response.

Parameters

hndVConn	Virtual connection handle.
uTid	Request-Response transaction id.
uMsgIdReq	Request message id.
bufReq	Packed request message buffer.
uReqLen	Size of request in buffer (number of bytes).

Returns

On success, BS_OK is returned.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 380 of file bsSerialServer.c.

References BS_ECODE_BAD_MSG, BS_ECODE_BAD_VCONN_HND, BS_ECODE_NO_VCONN, BS_ECODE_SYS, BS_OK, BSMOD_IS_VCONN_HANDLE, BSMOD_RSRC, BSMOD_SEND_ERROR_RSP, BSMOD_SEND_NMERROR_RSP, BSMOD_SEND_SYSERROR_RSP, BSMOD_T_READ, BSMOD_T_WRITE, BSPROXY_BUF_BODY, BSPROXY_MSG_MAX_LEN, BsSerialMsgIdRspRead, BsSerialPackRspRead(), BsSerialUnpackReqTrans(), BsModCtlBlk_T::m_bTrace, BsModProxyCb_T::m_cbSendRsp, BsSerialReqTrans_T::m_count, BsSerialRspRead_T::m_count, BsModCtlBlk_T::m_fd, BsSerialRspRead_T::m_readbuf, BsSerialReqTrans_T::m_readlen, BsSerialReqTrans_T::m_writebuf, BsSerialReqTrans_T::u, and BsSerialRspRead_T::u.

Referenced by bsModRequest().

{
  static BsSerialMsgId_T  uMsgIdRsp = BsSerialMsgIdRspRead;

  BsModCtlBlk_T      *pCtlBlk;                    // resource control block
  BsSerialReqTrans_T  msgReq;                     // request message 
  BsSerialRspRead_T   msgRsp;                     // response message 
  byte_t              bufRsp[BSPROXY_MSG_MAX_LEN]; // req/rsp buffer
  int                 n;                          // number of bytes/return code

  //
  // Parameter checks
  //
  if( !BSMOD_IS_VCONN_HANDLE(hndVConn) )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_BAD_VCONN_HND,
          "Module vconn handle out-of-range.");
    return -BS_ECODE_BAD_VCONN_HND; \
  }

  // retrieve the resource control block
  pCtlBlk = (BsModCtlBlk_T *)BSMOD_RSRC(BsModRsrcTbl, hndVConn);

  if( pCtlBlk == NULL )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_NO_VCONN,
        "No resources for virtual connection found.");
    return -BS_ECODE_NO_VCONN;
  }

  //
  // Unpack client request.
  //
  n = BsSerialUnpackReqTrans(bufReq, uReqLen, &msgReq, pCtlBlk->m_bTrace);

  // check unpacking return code
  if( n < 0 )
  {
    BSMOD_SEND_NMERROR_RSP(BsModCallbacks, hndVConn, uTid, n,
        "MsgId=%u", uMsgIdReq);
    return -BS_ECODE_BAD_MSG;
  }

  //
  // Execute client request.
  //
  n = (int)SerDevWrite(pCtlBlk->m_fd, msgReq.m_writebuf.u.m_buf,
                      (size_t)msgReq.m_writebuf.m_count, BSMOD_T_WRITE);

  // check operation return code
  if( n < 0 )
  {
    BSMOD_SEND_SYSERROR_RSP(BsModCallbacks, hndVConn, uTid,
        "SerDevWrite(%d,...).", pCtlBlk->m_fd);
    return -BS_ECODE_SYS;
  }

  LOGDIAG3("VConn=%d: %d=SerDevWrite(fd=%d, buf=%p, count=%zu, usec=%u).",
      hndVConn, n, pCtlBlk->m_fd, msgReq.m_writebuf.u.m_buf,
      (size_t)msgReq.m_writebuf.m_count, BSMOD_T_WRITE);

  n = (int)SerDevRead(pCtlBlk->m_fd, msgRsp.m_readbuf.u.m_buf,
                        (size_t)msgReq.m_readlen, BSMOD_T_READ);

  // check operation return code
  if( n < 0 )
  {
    BSMOD_SEND_SYSERROR_RSP(BsModCallbacks, hndVConn, uTid,
        "SerDevRead(%d,...).", pCtlBlk->m_fd);
    return -BS_ECODE_SYS;
  }

  LOGDIAG3("VConn=%d: %d=SerDevRead(fd=%d, buf=%p, count=%zu, usec=%u)).",
      hndVConn, n, pCtlBlk->m_fd, msgRsp.m_readbuf.u.m_buf,
      (size_t)msgReq.m_readlen, BSMOD_T_READ);

  //
  // Pack server response.
  //
  msgRsp.m_readbuf.m_count = (byte_t)n;
    
  // pack
  n = BsSerialPackRspRead(&msgRsp, BSPROXY_BUF_BODY(bufRsp), pCtlBlk->m_bTrace);

  // check packing return code
  if( n < 0 )
  {
    BSMOD_SEND_NMERROR_RSP(BsModCallbacks, hndVConn, uTid, n,
        "MsgId=%u", uMsgIdRsp);
    return -BS_ECODE_BAD_MSG;
  }

  //
  // Send response.
  //
  BsModCallbacks->m_cbSendRsp(hndVConn, uTid, uMsgIdRsp, bufRsp, (size_t)n);

  return BS_OK;
}

static int bsModSerialReqWrite ( BsVConnHnd_T  hndVConn, BsTid_T  uTid, BsMsgId_T  uMsgIdReq, byte_t  bufReq[], size_t  uReqLen  )

static

Service a serial write request.

Note

A module-specific request service must send a response.

Parameters

hndVConn	Virtual connection handle.
uTid	Request-Response transaction id.
uMsgIdReq	Request message id.
bufReq	Packed request message buffer.
uReqLen	Size of request in buffer (number of bytes).

Returns

On success, BS_OK is returned.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 277 of file bsSerialServer.c.

References BS_ECODE_BAD_MSG, BS_ECODE_BAD_VCONN_HND, BS_ECODE_NO_VCONN, BS_ECODE_SYS, BS_OK, BSMOD_IS_VCONN_HANDLE, BSMOD_RSRC, BSMOD_SEND_ERROR_RSP, BSMOD_SEND_NMERROR_RSP, BSMOD_SEND_SYSERROR_RSP, BSMOD_T_WRITE, BSPROXY_BUF_BODY, BSPROXY_MSG_MAX_LEN, BsSerialMsgIdRspWrite, BsSerialPackRspWrite(), BsSerialUnpackReqWrite(), BsModCtlBlk_T::m_bTrace, BsSerialRspWrite_T::m_byteswritten, BsModProxyCb_T::m_cbSendRsp, BsSerialReqWrite_T::m_count, BsModCtlBlk_T::m_fd, BsSerialReqWrite_T::m_writebuf, and BsSerialReqWrite_T::u.

Referenced by bsModRequest().

{
  static BsSerialMsgId_T  uMsgIdRsp = BsSerialMsgIdRspWrite;

  BsModCtlBlk_T      *pCtlBlk;                    // resource control block
  BsSerialReqWrite_T  msgReq;                     // request message 
  BsSerialRspWrite_T  msgRsp;                     // response message 
  byte_t              bufRsp[BSPROXY_MSG_MAX_LEN]; // req/rsp buffer
  int                 n;                          // number of bytes/return code

  //
  // Parameter checks
  //
  if( !BSMOD_IS_VCONN_HANDLE(hndVConn) )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_BAD_VCONN_HND,
          "Module vconn handle out-of-range.");
    return -BS_ECODE_BAD_VCONN_HND; \
  }

  // retrieve the resource control block
  pCtlBlk = (BsModCtlBlk_T *)BSMOD_RSRC(BsModRsrcTbl, hndVConn);

  if( pCtlBlk == NULL )
  {
    BSMOD_SEND_ERROR_RSP(BsModCallbacks, hndVConn, uTid, BS_ECODE_NO_VCONN,
        "No resources for virtual connection found.");
    return -BS_ECODE_NO_VCONN;
  }

  //
  // Unpack client request.
  //
  n = BsSerialUnpackReqWrite(bufReq, uReqLen, &msgReq, pCtlBlk->m_bTrace);

  // check unpacking return code
  if( n < 0 )
  {
    BSMOD_SEND_NMERROR_RSP(BsModCallbacks, hndVConn, uTid, n,
        "MsgId=%u", uMsgIdReq);
    return -BS_ECODE_BAD_MSG;
  }

  //
  // Execute client request.
  //
  n = (int)SerDevWrite(pCtlBlk->m_fd, msgReq.m_writebuf.u.m_buf,
                      (size_t)msgReq.m_writebuf.m_count, BSMOD_T_WRITE);

  // check operation return code
  if( n < 0 )
  {
    BSMOD_SEND_SYSERROR_RSP(BsModCallbacks, hndVConn, uTid,
        "SerDevWrite(%d,...).", pCtlBlk->m_fd);
    return -BS_ECODE_SYS;
  }

  LOGDIAG3("VConn=%d: %d=SerDevWrite(fd=%d, buf=%p, count=%zu, usec=%u).",
      hndVConn, n, pCtlBlk->m_fd, msgReq.m_writebuf.u.m_buf,
      (size_t)msgReq.m_writebuf.m_count, BSMOD_T_WRITE);

  //
  // Pack server response.
  //
  msgRsp.m_byteswritten = (byte_t)n;
    
  // pack
  n = BsSerialPackRspWrite(&msgRsp, BSPROXY_BUF_BODY(bufRsp),
                            pCtlBlk->m_bTrace);

  // check packing return code
  if( n < 0 )
  {
    BSMOD_SEND_NMERROR_RSP(BsModCallbacks, hndVConn, uTid, n,
        "MsgId=%u", uMsgIdRsp);
    return -BS_ECODE_BAD_MSG;
  }

  //
  // Send response.
  //
  BsModCallbacks->m_cbSendRsp(hndVConn, uTid, uMsgIdRsp, bufRsp, (size_t)n);

  return BS_OK;
}

int bsModTrace	(	BsVConnHnd_T	hndVConn,
		bool_t	bTrace
	)

Enable/disable message tracing on handle.

Parameters

hndVConn	Virtual connection handle.
bTrace	Do [not] enable message tracing on this handle.

Returns

On success, BS_OK is returned.
On error, the appropriate < 0 negated BotSense Error Code is returned.

Definition at line 749 of file bsSerialServer.c.

References BS_ECODE_BAD_VCONN_HND, BS_ECODE_NO_VCONN, BS_OK, BSMOD_IS_VCONN_HANDLE, BSMOD_LOG_ERROR, BSMOD_RSRC, and BsModCtlBlk_T::m_bTrace.

{
  BsModCtlBlk_T  *pCtlBlk;

  // check if handle is in valid range
  if( !BSMOD_IS_VCONN_HANDLE(hndVConn) )
  {
    BSMOD_LOG_ERROR(hndVConn, BS_ECODE_BAD_VCONN_HND,
          "Module vconn handle out-of-range.");
    return -BS_ECODE_BAD_VCONN_HND;
  }

  // retrieve resource control block
  pCtlBlk = (BsModCtlBlk_T *)BSMOD_RSRC(BsModRsrcTbl, hndVConn);

  // check resource
  if( pCtlBlk == NULL )
  {
    BSMOD_LOG_ERROR(hndVConn, BS_ECODE_NO_VCONN,
        "No resources for virtual connection found.");
    return -BS_ECODE_NO_VCONN;
  }

  pCtlBlk->m_bTrace = bTrace;

  return BS_OK;
}

Variable Documentation

BsModInfo_T BsModInfo

static

Initial value:

= 
{
  .mod_name   = BS_SER_SERVER_MOD,
  .brief      = "Raw R2-232 serial proxied device.",
  .version    = "2.0.0",
  .date       = "2010.03.09",
  .maintainer = "RaodNarrows LLC",
  .license    = "(C) 2010 RoadNarrows LLC. All rights reserved."
}

Module static information.

Definition at line 72 of file bsSerialServer.c.

Referenced by bsModInfo().