443 lines
5.8 KiB
C++
443 lines
5.8 KiB
C++
/* testChannelSearcManager.cpp */
|
|
|
|
#include <channelSearchManager.h>
|
|
#include <sstream>
|
|
#include <showConstructDestruct.h>
|
|
|
|
using namespace epics::pvData;
|
|
using namespace epics::pvAccess;
|
|
|
|
//TODO this will be deleted
|
|
class ChannelImpl;
|
|
|
|
class ContextImpl : public Context
|
|
|
|
{
|
|
|
|
private:
|
|
|
|
Timer* _timer;
|
|
|
|
public:
|
|
|
|
|
|
|
|
ContextImpl()
|
|
|
|
{
|
|
|
|
_timer = new Timer("krneki",lowPriority);
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual Version* getVersion() {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual ChannelProvider* getProvider() {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
Timer* getTimer()
|
|
|
|
{
|
|
|
|
return _timer;
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual void initialize() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual void printInfo() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual void printInfo(epics::pvData::StringBuilder out) {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual void destroy()
|
|
|
|
{
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual void dispose()
|
|
|
|
{
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
BlockingUDPTransport* getSearchTransport()
|
|
|
|
{
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Searches for a channel with given channel ID.
|
|
|
|
* @param channelID CID.
|
|
|
|
* @return channel with given CID, <code></code> if non-existent.
|
|
|
|
*/
|
|
|
|
Channel* getChannel(pvAccessID channelID)
|
|
|
|
{
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
Configuration* getConfiguration() {return NULL;}
|
|
|
|
TransportRegistry* getTransportRegistry() {return NULL;}
|
|
|
|
~ContextImpl() { delete _timer;};
|
|
|
|
private:
|
|
|
|
|
|
|
|
|
|
|
|
void loadConfiguration() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
void internalInitialize() {
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
void initializeUDPTransport() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
void internalDestroy() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
void destroyAllChannels() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Check channel name.
|
|
|
|
*/
|
|
|
|
void checkChannelName(String& name) {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Check context state and tries to establish necessary state.
|
|
|
|
*/
|
|
|
|
void checkState() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Generate Client channel ID (CID).
|
|
|
|
* @return Client channel ID (CID).
|
|
|
|
*/
|
|
|
|
pvAccessID generateCID()
|
|
|
|
{
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Free generated channel ID (CID).
|
|
|
|
*/
|
|
|
|
void freeCID(int cid)
|
|
|
|
{
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Get, or create if necessary, transport of given server address.
|
|
|
|
* @param serverAddress required transport address
|
|
|
|
* @param priority process priority.
|
|
|
|
* @return transport for given address
|
|
|
|
*/
|
|
|
|
Transport* getTransport(TransportClient* client, osiSockAddr* serverAddress, int minorRevision, int priority)
|
|
|
|
{
|
|
|
|
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Internal create channel.
|
|
|
|
*/
|
|
|
|
// TODO no minor version with the addresses
|
|
|
|
// TODO what if there is an channel with the same name, but on different host!
|
|
|
|
Channel* createChannelInternal(String name, ChannelRequester* requester, short priority,
|
|
|
|
InetAddrVector* addresses) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Destroy channel.
|
|
|
|
* @param channel
|
|
|
|
* @param force
|
|
|
|
* @throws CAException
|
|
|
|
* @throws IllegalStateException
|
|
|
|
*/
|
|
|
|
void destroyChannel(ChannelImpl* channel, bool force) {
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Get channel search manager.
|
|
|
|
* @return channel search manager.
|
|
|
|
*/
|
|
|
|
ChannelSearchManager* getChannelSearchManager() {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
};
|
|
|
|
class TestSearcInstance : public BaseSearchInstance
|
|
{
|
|
public:
|
|
TestSearcInstance(string channelName, pvAccessID channelID): _channelID(channelID), _channelName(channelName) {}
|
|
pvAccessID getSearchInstanceID() { return _channelID;};
|
|
string getSearchInstanceName() {return _channelName;};
|
|
void searchResponse(int8 minorRevision, osiSockAddr* serverAddress) {};
|
|
private:
|
|
pvAccessID _channelID;
|
|
string _channelName;
|
|
};
|
|
|
|
static const int max_channels = 100;
|
|
ContextImpl* context = new ContextImpl();
|
|
ChannelSearchManager* manager = new ChannelSearchManager(static_cast<Context*>(context));
|
|
TestSearcInstance** chanArray = new TestSearcInstance*[max_channels];
|
|
|
|
void* testWorker1(void* p)
|
|
{
|
|
for(int i = 0; i < 1000; i++)
|
|
{
|
|
for(int j = 0; j < max_channels/2; j++)
|
|
{
|
|
manager->unregisterChannel(chanArray[j]);
|
|
usleep(100);
|
|
manager->registerChannel(chanArray[j]);
|
|
}
|
|
}
|
|
|
|
return NULL;
|
|
}
|
|
|
|
|
|
void* testWorker2(void* p)
|
|
{
|
|
for(int i = 0; i < 1000; i++)
|
|
{
|
|
for(int j = max_channels/2; j < max_channels; j++)
|
|
{
|
|
manager->unregisterChannel(chanArray[j]);
|
|
usleep(100);
|
|
manager->registerChannel(chanArray[j]);
|
|
manager->beaconAnomalyNotify();
|
|
}
|
|
}
|
|
|
|
return NULL;
|
|
}
|
|
|
|
int main(int argc,char *argv[])
|
|
{
|
|
pthread_t _worker1Id;
|
|
pthread_t _worker2Id;
|
|
|
|
ostringstream obuffer;
|
|
for(int i = 0; i < max_channels; i++)
|
|
{
|
|
obuffer.clear();
|
|
obuffer.str("");
|
|
obuffer << i;
|
|
string name = "chan" + obuffer.str();
|
|
chanArray[i] = new TestSearcInstance(name.c_str(), i);
|
|
manager->registerChannel(chanArray[i]);
|
|
}
|
|
|
|
//create two threads
|
|
int32 retval = pthread_create(&_worker1Id, NULL, testWorker1, NULL);
|
|
if(retval != 0)
|
|
{
|
|
assert(true);
|
|
}
|
|
|
|
retval = pthread_create(&_worker2Id, NULL, testWorker2, NULL);
|
|
if(retval != 0)
|
|
{
|
|
assert(true);
|
|
}
|
|
|
|
retval = pthread_join(_worker1Id, NULL);
|
|
if(retval != 0)
|
|
{
|
|
assert(true);
|
|
}
|
|
|
|
retval = pthread_join(_worker2Id, NULL);
|
|
if(retval != 0)
|
|
{
|
|
assert(true);
|
|
}
|
|
|
|
manager->cancel();
|
|
|
|
context->destroy();
|
|
getShowConstructDestruct()->constuctDestructTotals(stdout);
|
|
|
|
for(int i = 0; i < max_channels; i++)
|
|
{
|
|
if(chanArray[i]) delete chanArray[i];
|
|
}
|
|
if(chanArray) delete [] chanArray;
|
|
if(manager) delete manager;
|
|
if(context) delete context;
|
|
return(0);
|
|
}
|