I implemented the VXI-11 function for both RPC (support port mapper i.e. Unix, Linux) and TCP raw socket (port mapper is not available i.e. Windows)
//Convert Bytes to/from Big/Little Endian or vise versa
#define BYTES_ORDER(b) (s_bIsNetworkOrdered) ? (b) : EndianConvertInt32((b))
struct DeviceSrqParms
{
struct
{
u_int handle_len;
char handle_val[40];
} handle;
};
typedef struct DeviceSrqParms DeviceSrqParms;
typedef struct rcphdr
{
uint32_t length; /*with MSB must be set 0x80 00 00 00*/
uint32_t xid; /* Transaction Identifier */
uint32_t msg_type; /* Message Type */
uint32_t rpcvers; /* RPC Version No. */
uint32_t prog; /* Program No. */
uint32_t vers; /* Program Version No. */
uint32_t proc; /* Procedure No. */
uint32_t auth[4]; /*authentication data*/
} RPCHDR;
typedef struct intr_srq_data
{
RPCHDR tdsRPC_Header;
DeviceSrqParms tdsDevSrqData;
} INTR_SRQ_DATA;
void *
device_intr_srq_1(Device_SrqParms *argp, CLIENT *clnt)
{
static char *clnt_res;
static uint32_t ui32XId = 1;
//For RPC
if ( s_ptdsRpcClientInterrupt ) //CLIENT handle created from clnt_creat()
{
memset((char *)&clnt_res, 0, sizeof(clnt_res));
if (clnt_call (clnt, device_intr_srq,
(xdrproc_t) xdr_Device_SrqParms, (caddr_t) argp,
(xdrproc_t) xdr_void, (caddr_t) &clnt_res,
s_tdsTimeValTimeout) != RPC_SUCCESS)
{
DEBUG_INFO("device_intr_srq_1: Fail to sent package Device_SrqParms");
return (NULL);
}
DEBUG_INFO("device_intr_srq_1: clnt_call() success");
}
//For TCP Raw Socket
if ( s_pobjTcpClientInterrupt ) //Socket object created earlier
{
INTR_SRQ_DATA tdsIntrSrqData;
uint32_t ui32Length = (sizeof( INTR_SRQ_DATA ) - 4) | 0X80000000;
//Create RPC Header
tdsIntrSrqData.tdsRPC_Header.length = BYTES_ORDER(ui32Length);
tdsIntrSrqData.tdsRPC_Header.xid = BYTES_ORDER(ui32XId++);
tdsIntrSrqData.tdsRPC_Header.msg_type = 0;
tdsIntrSrqData.tdsRPC_Header.rpcvers = BYTES_ORDER(2);
tdsIntrSrqData.tdsRPC_Header.prog = BYTES_ORDER(DEVICE_INTR);
tdsIntrSrqData.tdsRPC_Header.vers = BYTES_ORDER(DEVICE_INTR_VERSION);
tdsIntrSrqData.tdsRPC_Header.proc = BYTES_ORDER(device_intr_srq);
memset(tdsIntrSrqData.tdsRPC_Header.auth, 0, sizeof(tdsIntrSrqData.tdsRPC_Header.auth));
//Append stored SRQ data
memcpy(&tdsIntrSrqData.tdsDevSrqData.handle.handle_val, argp->handle.handle_val, sizeof(DeviceSrqParms));
tdsIntrSrqData.tdsDevSrqData.handle.handle_len = BYTES_ORDER(argp->handle.handle_len);
//TCP Socket accept data as std::string, so convert data structure to std::string
char *pcData = (char *) &tdsIntrSrqData;
try
{
std::string sData = "", sHexData = "";
char acTemp[10];
for ( int i = 0; i < (int) sizeof(tdsIntrSrqData); i++)
{
sData += pcData[i];
sprintf(acTemp, "%02X", pcData[i]);
if ( i % 4 == 0 )
sHexData += "\n\t";
sHexData += acTemp;
}
DEBUG_INFO("device_intr_srq_1: sData to send to NI-VISA: >>>>>>>>>>>>>>>>>>>>>>>>>>>>%s",
sHexData.c_str());
//Send data to TCP Socket
*s_pobjTcpClientInterrupt << sData;
}
catch ( SocketException& )
{
std::cout << "Send data failed\n";
}
clnt_res = tdsIntrSrqData.tdsDevSrqData.handle.handle_val;
}
return ((void *)&clnt_res);
} // End device_intr_srq_1
Any suggestions, please let me know
Dominator.
