epics/pcas
0
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

always arm the send independent of how many messages are placed

Browse Source 
in the out buf. The send will not arm if the out buf is empty.
This commit is contained in:
Jeff Hill
2009-08-13 23:51:40 +00:00
parent e4075da4d7
commit 9fc48c9a6b
1 changed files with 16 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cas/generic/st/casDGIntfOS.cc
+16 -21
View File
@@ -137,20 +137,18 @@ void casDGEvWakeup::show ( unsigned level ) const
//
epicsTimerNotify::expireStatus casDGEvWakeup::expire ( const epicsTime & /* currentTime */ )
{
casEventSys::processStatus ps = this->pOS->eventSysProcess ();
if ( ps.nAccepted > 0u ) {
// We do not wait for any impartial, or complete,
// messages in the input queue to be processed
// because.
// A) IO postponement might be preventing the
// input queue processing from proceeding.
// B) Since both reads and events get processed
// before going back to select to find out if we
// can do a write then we naturally tend to
// combine get responses and subscription responses
// into one write.
this->pOS->armSend ();
}
this->pOS->eventSysProcess ();
// We do not wait for any impartial, or complete,
// messages in the input queue to be processed
// because.
// A) IO postponement might be preventing the
// input queue processing from proceeding.
// B) Since both reads and events get processed
// before going back to select to find out if we
// can do a write then we naturally tend to
// combine get responses and subscription responses
// into one write.
this->pOS->armSend ();
this->pOS = 0;
return noRestart;
}
@@ -183,8 +181,7 @@ epicsTimerNotify :: expireStatus
{
caStatus status = this->pOS->processDG ();
if ( status != S_cas_success &&
status != S_cas_sendBlocked &&
status != S_casApp_postponeAsyncIO ) {
status != S_cas_sendBlocked ) {
char pName[64u];
this->pOS->hostName (pName, sizeof (pName));
errPrintf (status, __FILE__, __LINE__,
@@ -423,11 +420,10 @@ void casDGIntfOS::sendCB()
//
caStatus status = this->processDG ();
if ( status != S_cas_success &&
status != S_cas_sendBlocked &&
status != S_casApp_postponeAsyncIO ) {
status != S_cas_sendBlocked ) {
char pName[64u];
this->hostName (pName, sizeof (pName));
errPrintf (status, __FILE__, __LINE__,
errPrintf ( status, __FILE__, __LINE__,
"unexpected problem with UDP input from \"%s\"", pName);
}
}
@@ -463,8 +459,7 @@ void casDGIntfOS :: recvCB ( inBufClient::fillParameter parm )
this->inBufFill ( parm );
caStatus status = this->processDG ();
if ( status != S_cas_success &&
status != S_cas_sendBlocked &&
status != S_casApp_postponeAsyncIO ) {
status != S_cas_sendBlocked ) {
char pName[64u];
this->hostName (pName, sizeof (pName));
errPrintf (status, __FILE__, __LINE__,