root/ossiedev/branches/ssayed/devs/src/system/standardInterfaces-metadata/include/standardinterfaces-metadata/complexShortMD_u.h @ 8424

/****************************************************************************

Copyright 2006, Virginia Polytechnic Institute and State University

This file is part of the OSSIE Core Framework.

OSSIE Core Framework is free software; you can redistribute it and/or modify
it under the terms of the Lesser GNU General Public License as published by
the Free Software Foundation; either version 2.1 of the License, or
(at your option) any later version.

OSSIE Core Framework 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
Lesser GNU General Public License for more details.

You should have received a copy of the Lesser GNU General Public License
along with OSSIE Core Framework; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

****************************************************************************/

#ifndef COMPLEXSHORT_U_H
#define COMPLEXSHORT_U_H

#include <string>
#include <vector>

#ifdef HAVE_OMNIORB4
#include "omniORB4/CORBA.h"
#endif

#include <omnithread.h>

#include <ossie/PortTypes.h>
#include <ossie/cf.h>

#include <standardinterfaces-metadata/complexShortMD.h>
#include "standardinterfaces-metadata/RadioMetaData_impl.h"

// Forward declaration
namespace complexShort {

  class usesPort;
  class ConnectionInfo;
}

namespace standardInterfacesMD_i {

  class complexShort_u {
    friend class complexShort::usesPort;

  public:
    complexShort_u(const char* portName);
    complexShort_u(const char* portName, const char* domainName);
    ~complexShort_u();

    CORBA::Object_ptr getPort(const char* portName);

    void pushPacket(
            const PortTypes::ShortSequence &I,
            const PortTypes::ShortSequence &Q);

    void pushPacket(
            const PortTypes::ShortSequence &I,
            const PortTypes::ShortSequence &Q,
            const standardInterfacesMD::MetaData &packet_data);

  private:
    complexShort_u();
    complexShort_u(const complexShort_u &);

    std::string portName;

    // Uses port
    complexShort::usesPort *data_servant;
    CF::Port_var data_servant_var;
    std::vector <complexShort::ConnectionInfo> dest_ports;
    omni_mutex port_mutex;

    /// Data to be pushed for each packet
    standardInterfacesMD::MetaData metadata;

  };

}

namespace complexShort {

  class usesPort : public virtual POA_CF::Port {
  public:
    usesPort(standardInterfacesMD_i::complexShort_u *_base);
    ~usesPort();

    void connectPort(CORBA::Object_ptr connection, const char* connectionID);
    void disconnectPort(const char* connectionID);

  private:
    standardInterfacesMD_i::complexShort_u *base;
  };


  class ConnectionInfo
    {
    public:
      ConnectionInfo(standardInterfacesMD::complexShortMD_ptr _port, const char* _ID) : port_obj( _port), identifier(_ID) { };
      ConnectionInfo(const ConnectionInfo & c) { port_obj = c.port_obj; identifier = c.identifier;};
      
      void setPort(standardInterfacesMD::complexShortMD_ptr _port) {port_obj = _port; };
      const char *getID() {return identifier.c_str(); };

      standardInterfacesMD::complexShortMD_var port_obj;

    private:
      ConnectionInfo();  // No default constructor

      std::string identifier;
    };

}

#endif