set number of channels guess
This commit is contained in:
+6
-4
@@ -103,10 +103,11 @@ const cac::pExcepProtoStubTCP cac::tcpExcepJumpTableCAC [] =
|
||||
//
|
||||
// cac::cac ()
|
||||
//
|
||||
cac::cac ( cacNotify ¬ifyIn, bool enablePreemptiveCallbackIn ) :
|
||||
cac::cac ( cacNotify ¬ifyIn, bool enablePreemptiveCallbackIn,
|
||||
unsigned maxNumberOfChannels ) :
|
||||
ipToAEngine ( "caIPAddrToAsciiEngine" ),
|
||||
chanTable ( 16384 ),
|
||||
ioTable ( 16384 ),
|
||||
chanTable ( maxNumberOfChannels ),
|
||||
ioTable ( maxNumberOfChannels ),
|
||||
sgTable ( 128 ),
|
||||
beaconTable ( 1024 ),
|
||||
pudpiiu ( 0 ),
|
||||
@@ -913,7 +914,8 @@ cacChannel::ioid cac::writeNotifyRequest ( nciu &chan, unsigned type, unsigned n
|
||||
}
|
||||
}
|
||||
|
||||
cacChannel::ioid cac::readNotifyRequest ( nciu &chan, unsigned type, unsigned nElem, cacReadNotify ¬ifyIn )
|
||||
cacChannel::ioid cac::readNotifyRequest ( nciu &chan, unsigned type,
|
||||
unsigned nElem, cacReadNotify ¬ifyIn )
|
||||
{
|
||||
epicsAutoMutex autoMutex ( this->mutex );
|
||||
autoPtrRecycle < netReadNotifyIO > pIO ( *this, netReadNotifyIO::factory (
|
||||
|
||||
+2
-1
@@ -99,7 +99,8 @@ struct caHdrLargeArray;
|
||||
class cac : private cacRecycle
|
||||
{
|
||||
public:
|
||||
cac ( cacNotify &, bool enablePreemptiveCallback = false );
|
||||
cac ( cacNotify &, bool enablePreemptiveCallback = false,
|
||||
unsigned maxNumberOfChannels = 32768 );
|
||||
virtual ~cac ();
|
||||
|
||||
// beacon management
|
||||
|
||||
+2
-1
@@ -194,7 +194,8 @@ epicsShareFunc enum channel_state epicsShareAPI ca_state (chid chan);
|
||||
/* Must be called once before calling any of the other routines */
|
||||
/************************************************************************/
|
||||
epicsShareFunc int epicsShareAPI ca_task_initialize (void);
|
||||
epicsShareFunc int epicsShareAPI ca_context_create ( int preemptiveCallBackEnable );
|
||||
epicsShareFunc int epicsShareAPI ca_context_create (
|
||||
int preemptiveCallBackEnable, unsigned maxNumberOfChannels );
|
||||
|
||||
/************************************************************************/
|
||||
/* Remove CA facility from your task */
|
||||
|
||||
+2
-2
@@ -484,7 +484,7 @@ LOCAL void test (
|
||||
*/
|
||||
int catime ( char *channelName, unsigned channelCount, enum appendNumberFlag appNF )
|
||||
{
|
||||
unsigned i;
|
||||
unsigned i;
|
||||
unsigned strsize;
|
||||
unsigned nBytes;
|
||||
ti *pItemList;
|
||||
@@ -494,7 +494,7 @@ int catime ( char *channelName, unsigned channelCount, enum appendNumberFlag app
|
||||
return -1;
|
||||
}
|
||||
|
||||
SEVCHK ( ca_task_initialize(),"Unable to initialize" );
|
||||
SEVCHK ( ca_context_create ( 0, channelCount * 2 ), "Unable to initialize" );
|
||||
|
||||
if ( appNF == appendNumber ) {
|
||||
printf ( "Testing with %u channels named %snnn\n",
|
||||
|
||||
Reference in New Issue
Block a user