// [License] // The Ariba-Underlay Copyright // // Copyright (c) 2008-2009, Institute of Telematics, Universität Karlsruhe (TH) // // Institute of Telematics // Universität Karlsruhe (TH) // Zirkel 2, 76128 Karlsruhe // Germany // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // 1. Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // 2. Redistributions in binary form must reproduce the above copyright // notice, this list of conditions and the following disclaimer in the // documentation and/or other materials provided with the distribution. // // THIS SOFTWARE IS PROVIDED BY THE INSTITUTE OF TELEMATICS ``AS IS'' AND // ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE // IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR // PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ARIBA PROJECT OR // CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, // EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, // PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR // PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF // LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING // NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS // SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. // // The views and conclusions contained in the software and documentation // are those of the authors and should not be interpreted as representing // official policies, either expressed or implied, of the Institute of // Telematics. // [License] #ifndef ENDPOINTDESCRIPTOR_H_ #define ENDPOINTDESCRIPTOR_H_ #include #include //#include "ariba/utility/serialization.h" #include "ariba/utility/types/PeerID.h" #include "ariba/utility/addressing2/endpoint_set.hpp" // reboost messages #include "ariba/utility/transport/messages/message.hpp" namespace ariba { namespace communication { using_serialization; using namespace std; using ariba::utility::PeerID; /** * This class is used a transitions helper between the old addressing and * serialization to the new addressing2 and the new message classes * * Maybe it will be replaced, or at least modified in the future. */ //class EndpointDescriptor: public VSerializeable { VSERIALIZEABLE // friend class BaseCommunication; class EndpointDescriptor { friend class BaseCommunication; public: /// creates an empty endpoint descriptor with zero endpoints EndpointDescriptor(); /// destructor. virtual ~EndpointDescriptor(); /// copy constructor EndpointDescriptor(const EndpointDescriptor& rh); /// construct end-points from an endpoint set EndpointDescriptor(const PeerID& peer_id, addressing2::EndpointSetPtr endpoints ); // FIXME NOT WORKING !! /// construct end-points from a string EndpointDescriptor(const string& str); /// convert end-points to string string toString() const { return endpoints->to_string(); } static EndpointDescriptor& UNSPECIFIED() { static EndpointDescriptor* unspec = NULL; if(unspec == NULL) unspec = new EndpointDescriptor(); return *unspec; } /// returns true, if this object is the unspecified object bool isUnspecified() const { return (this == &UNSPECIFIED()); } // /// create endpoint // static EndpointDescriptor* fromString(string str) { // return new EndpointDescriptor(str); // } bool operator==(const EndpointDescriptor& rh) const { if (rh.isUnspecified() && isUnspecified()) return true; if (rh.isUnspecified() ^ isUnspecified()) return false; assert( (!rh.isUnspecified()) && (!isUnspecified()) ); return endpoints == rh.endpoints; } bool operator!=(const EndpointDescriptor& rh) const { return ( !operator==(rh) ); } EndpointDescriptor& operator=( const EndpointDescriptor& rhs) { endpoints = rhs.endpoints; return *this; } /// returns the end-points of this descriptor addressing2::const_EndpointSetPtr getEndpoints() const { return endpoints; } void replace_endpoint_set(addressing2::EndpointSetPtr new_endpoints) { endpoints = new_endpoints; } /// returns a reference to the peer id PeerID& getPeerId() { return peerId; } /// returns a reference to the constant peer id const PeerID& getPeerId() const { return peerId; } /// returns a message with peerId and endpoints in it reboost::message_t serialize() const; /// deserialite peerId and endpoints reboost::shared_buffer_t deserialize(reboost::shared_buffer_t buff); private: addressing2::EndpointSetPtr endpoints; PeerID peerId; }; }} // namespace ariba, communication //sznBeginDefault( ariba::communication::EndpointDescriptor, X ){ // // // TODO // assert(false); // // // serialize peer id // X && &peerId; // // // serialize end-points // uint16_t len = endpoints.to_bytes_size(); // X && len; // uint8_t* buffer = X.bytes( len ); // if (buffer!=NULL) { // if (X.isDeserializer()) endpoints.assign(buffer,len); // else endpoints.to_bytes(buffer); // } //}sznEnd(); #endif /*ENDPOINTDESCRIPTOR_H_*/