/* testChannelSearcManager.cpp */

#include <channelSearchManager.h>
#include <sstream>

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);
}