X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPackets%2FPacketImpl.cc;h=522ba8794012fed02f94c1b1a7f3ddc4e81adac5;hb=ddb2132be4265f8a0d7d4c954c7c9401e59d027c;hp=4639a05182fed395aae5ac412bcc4d110a3e869c;hpb=9cb871b939efe93e35dd96808d25089399acfc46;p=senf.git diff --git a/senf/Packets/PacketImpl.cc b/senf/Packets/PacketImpl.cc index 4639a05..522ba87 100644 --- a/senf/Packets/PacketImpl.cc +++ b/senf/Packets/PacketImpl.cc @@ -2,51 +2,47 @@ // // Copyright (C) 2007 // Fraunhofer Institute for Open Communication Systems (FOKUS) -// Competence Center NETwork research (NET), St. Augustin, GERMANY -// Stefan Bund // -// This program is free software; you can redistribute it and/or modify -// it under the terms of the GNU General Public License as published by -// the Free Software Foundation; either version 2 of the License, or -// (at your option) any later version. +// The contents of this file are subject to the Fraunhofer FOKUS Public License +// Version 1.0 (the "License"); you may not use this file except in compliance +// with the License. You may obtain a copy of the License at +// http://senf.berlios.de/license.html // -// This program 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 General Public License for more details. +// The Fraunhofer FOKUS Public License Version 1.0 is based on, +// but modifies the Mozilla Public License Version 1.1. +// See the full license text for the amendments. // -// You should have received a copy of the GNU General Public License -// along with this program; if not, write to the -// Free Software Foundation, Inc., -// 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. +// Software distributed under the License is distributed on an "AS IS" basis, +// WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License +// for the specific language governing rights and limitations under the License. +// +// The Original Code is Fraunhofer FOKUS code. +// +// The Initial Developer of the Original Code is Fraunhofer-Gesellschaft e.V. +// (registered association), Hansastraße 27 c, 80686 Munich, Germany. +// All Rights Reserved. +// +// Contributor(s): +// Stefan Bund /** \file \brief PacketImpl non-inline non-template implementation */ -//#include "PacketImpl.ih" +#include "PacketImpl.ih" // Custom includes #include +#include +#include +#include +#include #include "Packets.hh" //#include "PacketImpl.mpp" #define prefix_ -///////////////////////////////cc.p//////////////////////////////////////// - -/////////////////////////////////////////////////////////////////////////// -// senf::detail::AnnotationIndexerBase - -unsigned senf::detail::AnnotationIndexerBase::maxAnnotations (0); +//-///////////////////////////////////////////////////////////////////////////////////////////////// -prefix_ void senf::detail::AnnotationIndexerBase::dump(PacketImpl * p, std::ostream & os) -{ - for(std::vector::const_iterator - i (registry().begin()), i_end (registry().end()); - i != i_end; ++i) - (*i)->v_dump(p,os); -} - -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::detail::PacketImpl prefix_ senf::detail::PacketImpl::~PacketImpl() @@ -54,12 +50,19 @@ prefix_ senf::detail::PacketImpl::~PacketImpl() // We increment refcount_ to ensure, release() won't call delete again ++refcount_; eraseInterpreters(interpreters_.begin(), interpreters_.end()); - Annotations::const_iterator i (annotations_.begin()); - Annotations::const_iterator const i_end (annotations_.end()); - std::vector::iterator small (AnnotationIndexerBase::small().begin()); - for (; i != i_end; ++i, ++small) - if (! *small && i->p) - delete i->p; +} + +prefix_ void senf::detail::PacketImpl::release() +{ + SENF_ASSERT(refcount_ >= 1, "Internal failure: Releasing dead PacketImpl ??"); + // uah ... we need to be extremely careful here. If refcount_ is 1, we want to commit suicide, + // however the destructor will remove all PacketInterpreters from the list and will thereby + // decrement refcount -> only decrement refcount_ when *not* calling delete (otherwise + // the assert above will fail) + if (refcount_ == 1) + delete this; + else + -- refcount_; } // interpreter chain @@ -123,7 +126,7 @@ prefix_ void senf::detail::PacketImpl::updateIterators(PacketData * self, differ // b) 'self' // c) Those that come afterwards // For a), the change must be inside the packet since 'self' must be within those packets - // For b), the change must also be within since that's the packet we are changeing + // For b), the change must also be within since that's the packet we are changing // For c), the change must be outside the packet (we don't allow an upper packet to mess with // the the data owned by a packet further down the chain). It can be before or after the // packet. @@ -138,7 +141,7 @@ prefix_ void senf::detail::PacketImpl::updateIterators(PacketData * self, differ interpreter_list::iterator const i_end (interpreters_.end()); if (++i != i_end) if (pos <= difference_type(i->begin_)) - // pos is before the packet, it must then be before all futher packets ... + // pos is before the packet, it must then be before all further packets ... for (; i != i_end; ++i) { i->begin_ += n; i->end_ += n; @@ -146,7 +149,80 @@ prefix_ void senf::detail::PacketImpl::updateIterators(PacketData * self, differ // else pos is after the packet and we don't need to change anything ... } -///////////////////////////////cc.e//////////////////////////////////////// +// Annotations + +prefix_ void senf::detail::PacketImpl::dumpAnnotations(std::ostream & os) +{ + for (AnnotationRegistry::iterator i (AnnotationRegistry::instance().begin()); + i != AnnotationRegistry::instance().end(); ++i) { + void * antn (annotation(*i)); + if (antn) + AnnotationRegistry::instance().dump(*i, os, antn); + } +} + +prefix_ void senf::detail::PacketImpl::clearAnnotations() +{ + ::memset(simpleAnnotations_, 0, sizeof(simpleAnnotations_)); + complexAnnotations_.clear(); +} + +prefix_ void senf::detail::PacketImpl::assignAnnotations(PacketImpl const & other) +{ + std::copy(&other.simpleAnnotations_[0], &other.simpleAnnotations_[0] + + sizeof(simpleAnnotations_)/sizeof(simpleAnnotations_[0]), simpleAnnotations_); + complexAnnotations_.assign( + other.complexAnnotations_.begin(), other.complexAnnotations_.end()); +} + +prefix_ void * senf::detail::PacketImpl::complexAnnotation(AnnotationRegistry::key_type key) +{ + SENF_ASSERT( key < 0, "complexAnnotation called with invalid key"); + return (ComplexAnnotations::size_type(-key-1) >= complexAnnotations_.size() + || complexAnnotations_.is_null(-key-1)) + ? 0 : complexAnnotations_[-key-1].get(); +} + +//-///////////////////////////////////////////////////////////////////////////////////////////////// +// senf::detail::AnnotationRegistry + +prefix_ void senf::detail::AnnotationRegistry::dump(key_type key, std::ostream & os, + void * annotation) + const +{ + Registry::const_iterator i (registry_.find(key)); + if (i != registry_.end()) { + os << fieldName(i->second->v_name()); + i->second->v_dump(os, annotation); + os << "\n"; + } +} + +prefix_ void senf::detail::AnnotationRegistry::dumpRegistrations(std::ostream & os) +{ + boost::format fmt ("%-56.56s %-4.4s %-7.7s %5d\n"); + os << "SENF_PACKET_ANNOTATION_SLOTS = " << SENF_PACKET_ANNOTATION_SLOTS << "\n" + << "SENF_PACKET_ANNOTATION_SLOTSIZE = " << SENF_PACKET_ANNOTATION_SLOTSIZE << "\n"; + os << fmt % "TYPE" % "FAST" % "COMPLEX" % "SIZE"; + + for (Index::const_iterator i (index_.begin()), i_end (index_.end()); i != i_end; ++i) { + key_type key (i->second); + std::string nm (i->first); + if (nm.size() > 56) nm.erase(nm.begin(), nm.begin()+nm.size()-32); + os << fmt + % nm + % (key >= 0 ? "yes" : "no") + % (isComplex(key) ? "yes" : "no") + % size(key); + } +} + +prefix_ void senf::dumpPacketAnnotationRegistry(std::ostream & os) +{ + senf::detail::AnnotationRegistry::instance().dumpRegistrations(os); +} + +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_ //#include "PacketImpl.mpp"