acsncSupplier.h

Go to the documentation of this file.

#ifndef SUPPLIER_H
#define SUPPLIER_H

/* @(#) $Id: acsncSupplier.h,v 1.67 2011/11/17 23:31:54 javarias Exp $
 *
 *    Supplier Abstract base class for notification channel push structured event
 *    supplier.
 *    ALMA - Atacama Large Millimiter Array
 *    (c) Associated Universities Inc., 2002 
 *    (c) European Southern Observatory, 2002
 *    Copyright by ESO (in the framework of the ALMA collaboration)
 *    and Cosylab 2002, All rights reserved
 *
 *    This library is free software; you can redistribute it and/or
 *    modify it under the terms of the GNU Lesser General Public
 *    License as published by the Free Software Foundation; either
 *    version 2.1 of the License, or (at your option) any later version.
 *
 *    This library is distributed in the hope that it will be useful,
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 *    Lesser General Public License for more details.
 *
 *    You should have received a copy of the GNU Lesser General Public
 *    License along with this library; if not, write to the Free Software
 *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 */

#include "acsncHelper.h"
#include <acscomponentImpl.h>
#include "RepeatGuardLogger.h"
#include "acsncCircularQueue.h"

namespace nc {
class Supplier : 
    protected Helper, 
    public POA_CosNotifyComm::StructuredPushSupplier,
    protected virtual PortableServer::RefCountServantBase
{
  public:
    Supplier(const char* channelName, 
             acscomponent::ACSComponentImpl* component,
                 const char* acsNCDomainName = 0);

    Supplier(const char* channelName, 
             CORBA::ORB_ptr orb_mp, 
             acscomponent::ACSComponentImpl* component,
                 const char* acsNCDomainName = 0);
    
    Supplier(const char* channelName, 
             int argc, 
             char *argv[],
             acscomponent::ACSComponentImpl* component,
                 const char* acsNCDomainName = 0);

    virtual void 
    disconnect();

    void 
    publishEvent(const CosNotification::StructuredEvent &event)
        ;

    virtual void 
    publishEvent(const CORBA::Any &eventData)
        ;

    virtual void 
    disconnect_structured_push_supplier();
    
    virtual void 
    subscription_change(const CosNotification::EventTypeSeq &eventsAdded,
                        const CosNotification::EventTypeSeq &eventsRemoved);

    void reconnect(::NotifyMonitoringExt::EventChannelFactory *ecf);

    void setAntennaName(std::string antennaName);

    void setAutoreconnect(bool autoreconnect);

    bool increaseEventBufferSize(unsigned int bufferSize);

    unsigned int getEventBufferSize() const;

  protected:
    virtual ~Supplier();
    
    void
    populateHeader(CosNotification::StructuredEvent &event)
        ;

    virtual void
    populateHeader(const CORBA::Any &any)
        ;

    void 
    setEventType(const char *);



    void
    createSupplier()
        ;
    
    void 
    destroyNotificationChannel()
        ;

    void
    init(CORBA::ORB_ptr orb)
        ;


    void
    reinit();
    
    CosNotifyChannelAdmin::SupplierAdmin_var SupplierAdmin_m;
    
    CosNotifyChannelAdmin::StructuredProxyPushConsumer_var proxyConsumer_m;

    CosNotifyComm::StructuredPushSupplier_var reference_m;

    

    acscomponent::ACSComponentImpl* component_mp;

    char* typeName_mp;

    unsigned long long count_m;
    Logging::RepeatGuardLogger<Logging::BaseLog> guardbl;
    CosNotification::StructuredEvent event_m;
    
    std::string antennaName;

    bool autoreconnect_m;

    ACE_Recursive_Thread_Mutex m_publishMutex;

  private:
    
    static const uint32_t SLEEP_TIME_BEFORE_SENDING_BUFFERED_EVENTS;

    void operator=(const Supplier&);

    Supplier(const Supplier&);

    CosNotifyChannelAdmin::AdminID adminid;
    CosNotifyChannelAdmin::ProxyID proxyConsumerID;

    CircularQueue eventBuff;

};
 }; 
#endif