lin-epics-modules/motorBase
0
0
Fork 0
forked from epics_driver_modules/motorBase
Code Pull Requests Activity

Added ReadXPSSocket, which is used to read on the move socket without waiting

Browse Source
This commit is contained in:
MarkRivers
2012-07-06 19:46:39 +00:00
parent 66b62269ea
commit b3739f6ebc
1 changed files with 40 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
motorApp/NewportSrc/asynOctetSocket.cpp
+40
View File
@@ -226,6 +226,46 @@ void SendAndReceive (int SocketIndex, char buffer[], char valueRtrn[], int retur
epicsMutexUnlock(psock->mutexId);
}
/***************************************************************************************/
int ReadXPSSocket (int SocketIndex, char valueRtrn[], int returnSize, double timeout)
{
size_t nbytesIn;
int eomReason;
socketStruct *psock;
int status;
int nread=0;
/* Check to see if the Socket is valid! */
if ((SocketIndex < 0) || (SocketIndex >= nextSocket)) {
printf("ReadXPSSocket: invalid SocketIndex %d\n", SocketIndex);
strcpy(valueRtrn,"-22");
return -1;
}
psock = &socketStructs[SocketIndex];
if (!psock->connected) {
printf("ReadXPSSocket: socket not connected %d\n", SocketIndex);
strcpy(valueRtrn,"-22");
return -1;
}
/* Loop until we the response contains ",EndOfAPI" or we get an error */
while ((status==asynSuccess) &&
(strcmp(valueRtrn + nread - strlen(XPS_TERMINATOR), XPS_TERMINATOR) != 0)) {
status = pasynOctetSyncIO->read(psock->pasynUser,
&valueRtrn[nread],
returnSize-nread,
timeout,
&nbytesIn,
&eomReason);
asynPrint(psock->pasynUser, ASYN_TRACEIO_DRIVER,
"SendAndReceive, received: nread=%d, returnSize-nread=%d, nbytesIn=%d\n",
nread, returnSize-nread, nbytesIn);
nread += nbytesIn;
}
return nread;
}
/***************************************************************************************/
void CloseSocket(int SocketIndex)