X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=src%2Fbase.cpp;h=17c619fbe28e99a2ae0d6b4b15360cc0f6256d14;hb=d494fa6e094e85cd29235e995fb2b447d6e1f168;hp=e79d336b70ed6f36976557ad206051b040e88ae0;hpb=9ea40ce2f7f7c5d55bf22e4b39e9903509925f1a;p=user%2Fhenk%2Fcode%2Finspircd.git diff --git a/src/base.cpp b/src/base.cpp index e79d336b7..17c619fbe 100644 --- a/src/base.cpp +++ b/src/base.cpp @@ -1,112 +1,393 @@ -/* +------------------------------------+ - * | Inspire Internet Relay Chat Daemon | - * +------------------------------------+ +/* + * InspIRCd -- Internet Relay Chat Daemon * - * InspIRCd is copyright (C) 2002-2006 ChatSpike-Dev. - * E-mail: - * - * - * - * Written by Craig Edwards, Craig McLure, and others. - * This program is free but copyrighted software; see - * the file COPYING for details. + * Copyright (C) 2013, 2018-2019 Sadie Powell + * Copyright (C) 2012, 2014-2015 Attila Molnar + * Copyright (C) 2012 Robby + * Copyright (C) 2010 Craig Edwards + * Copyright (C) 2009 Daniel De Graaf + * Copyright (C) 2007 Dennis Friis + * Copyright (C) 2006 Oliver Lupton * - * --------------------------------------------------- + * This file is part of InspIRCd. InspIRCd 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, version 2. + * + * 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. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . */ -#include "inspircd_config.h" -#include "base.h" -#include -#include -#include -#include + #include "inspircd.h" -#include "modules.h" -#include "helperfuncs.h" +#include "base.h" -const int bitfields[] = {1,2,4,8,16,32,64,128}; -const int inverted_bitfields[] = {~1,~2,~4,~8,~16,~32,~64,~128}; +#ifdef INSPIRCD_ENABLE_RTTI +#include +#endif classbase::classbase() { - this->age = time(NULL); +#ifdef INSPIRCD_ENABLE_RTTI + if (ServerInstance) + ServerInstance->Logs->Log("CULLLIST", LOG_DEBUG, "classbase::+%s @%p", typeid(*this).name(), (void*)this); +#endif +} + +CullResult classbase::cull() +{ +#ifdef INSPIRCD_ENABLE_RTTI + if (ServerInstance) + ServerInstance->Logs->Log("CULLLIST", LOG_DEBUG, "classbase::-%s @%p", typeid(*this).name(), (void*)this); +#endif + return CullResult(); +} + +classbase::~classbase() +{ +#ifdef INSPIRCD_ENABLE_RTTI + if (ServerInstance) + ServerInstance->Logs->Log("CULLLIST", LOG_DEBUG, "classbase::~%s @%p", typeid(*this).name(), (void*)this); +#endif +} + +CullResult::CullResult() +{ +} + +// This trick detects heap allocations of refcountbase objects +static void* last_heap = NULL; + +void* refcountbase::operator new(size_t size) +{ + last_heap = ::operator new(size); + return last_heap; +} + +void refcountbase::operator delete(void* obj) +{ + if (last_heap == obj) + last_heap = NULL; + ::operator delete(obj); +} + +refcountbase::refcountbase() : refcount(0) +{ + if (this != last_heap) + throw CoreException("Reference allocate on the stack!"); +} + +refcountbase::~refcountbase() +{ + if (refcount && ServerInstance) + ServerInstance->Logs->Log("CULLLIST", LOG_DEBUG, "refcountbase::~ @%p with refcount %d", + (void*)this, refcount); +} + +usecountbase::~usecountbase() +{ + if (usecount && ServerInstance) + ServerInstance->Logs->Log("CULLLIST", LOG_DEBUG, "usecountbase::~ @%p with refcount %d", + (void*)this, usecount); +} + +ServiceProvider::~ServiceProvider() +{ +} + +void ServiceProvider::RegisterService() +{ +} + +ExtensionItem::ExtensionItem(const std::string& Key, ExtensibleType exttype, Module* mod) + : ServiceProvider(mod, Key, SERVICE_METADATA) + , type(exttype) +{ } -bool Extensible::Shrink(const std::string &key) +ExtensionItem::~ExtensionItem() { - /* map::size_type map::erase( const key_type& key ); - * returns the number of elements removed, std::map - * is single-associative so this should only be 0 or 1 - */ - if(this->Extension_Items.erase(key)) +} + +void* ExtensionItem::get_raw(const Extensible* container) const +{ + Extensible::ExtensibleStore::const_iterator i = + container->extensions.find(const_cast(this)); + if (i == container->extensions.end()) + return NULL; + return i->second; +} + +void* ExtensionItem::set_raw(Extensible* container, void* value) +{ + std::pair rv = + container->extensions.insert(std::make_pair(this, value)); + if (rv.second) { - log(DEBUG, "Shrinking object with item %s",key.c_str()); - return true; + return NULL; } else { - log(DEBUG, "Tried to shrink object with item %s but no items removed", key.c_str()); - return false; + void* old = rv.first->second; + rv.first->second = value; + return old; + } +} + +void* ExtensionItem::unset_raw(Extensible* container) +{ + Extensible::ExtensibleStore::iterator i = container->extensions.find(this); + if (i == container->extensions.end()) + return NULL; + void* rv = i->second; + container->extensions.erase(i); + return rv; +} + +void ExtensionItem::RegisterService() +{ + if (!ServerInstance->Extensions.Register(this)) + throw ModuleException("Extension already exists: " + name); +} + +bool ExtensionManager::Register(ExtensionItem* item) +{ + return types.insert(std::make_pair(item->name, item)).second; +} + +void ExtensionManager::BeginUnregister(Module* module, std::vector >& list) +{ + ExtMap::iterator i = types.begin(); + while (i != types.end()) + { + ExtMap::iterator me = i++; + ExtensionItem* item = me->second; + if (item->creator == module) + { + list.push_back(item); + types.erase(me); + } + } +} + +ExtensionItem* ExtensionManager::GetItem(const std::string& name) +{ + ExtMap::iterator i = types.find(name); + if (i == types.end()) + return NULL; + return i->second; +} + +void Extensible::doUnhookExtensions(const std::vector >& toRemove) +{ + for(std::vector >::const_iterator i = toRemove.begin(); i != toRemove.end(); ++i) + { + ExtensionItem* item = *i; + ExtensibleStore::iterator e = extensions.find(item); + if (e != extensions.end()) + { + item->free(this, e->second); + extensions.erase(e); + } + } +} + +Extensible::Extensible() + : culled(false) +{ +} + +CullResult Extensible::cull() +{ + FreeAllExtItems(); + culled = true; + return classbase::cull(); +} + +void Extensible::FreeAllExtItems() +{ + for(ExtensibleStore::iterator i = extensions.begin(); i != extensions.end(); ++i) + { + i->first->free(this, i->second); + } + extensions.clear(); +} + +Extensible::~Extensible() +{ + if ((!extensions.empty() || !culled) && ServerInstance) + ServerInstance->Logs->Log("CULLLIST", LOG_DEBUG, "Extensible destructor called without cull @%p", (void*)this); +} + +void ExtensionItem::FromInternal(Extensible* container, const std::string& value) +{ + FromNetwork(container, value); +} + +void ExtensionItem::FromNetwork(Extensible* container, const std::string& value) +{ +} + +std::string ExtensionItem::ToHuman(const Extensible* container, void* item) const +{ + // Try to use the network form by default. + std::string ret = ToNetwork(container, item); + + // If there's no network form then fall back to the internal form. + if (ret.empty()) + ret = ToInternal(container, item); + + return ret; +} + +std::string ExtensionItem::ToInternal(const Extensible* container, void* item) const +{ + return ToNetwork(container, item); +} + +std::string ExtensionItem::ToNetwork(const Extensible* container, void* item) const +{ + return std::string(); +} + +std::string ExtensionItem::serialize(SerializeFormat format, const Extensible* container, void* item) const +{ + // Wrap the deprecated API with the new API. + switch (format) + { + case FORMAT_USER: + return ToHuman(container, item); + case FORMAT_INTERNAL: + case FORMAT_PERSIST: + return ToInternal(container, item); + case FORMAT_NETWORK: + return ToNetwork(container, item); } + return ""; } -void Extensible::GetExtList(std::deque &list) + +void ExtensionItem::unserialize(SerializeFormat format, Extensible* container, const std::string& value) { - for (ExtensibleStore::iterator u = Extension_Items.begin(); u != Extension_Items.end(); u++) + // Wrap the deprecated API with the new API. + switch (format) { - list.push_back(u->first); + case FORMAT_USER: + break; + case FORMAT_INTERNAL: + case FORMAT_PERSIST: + FromInternal(container, value); + break; + case FORMAT_NETWORK: + FromNetwork(container, value); + break; } } -void BoolSet::Set(int number) +LocalStringExt::LocalStringExt(const std::string& Key, ExtensibleType exttype, Module* Owner) + : SimpleExtItem(Key, exttype, Owner) +{ +} + +LocalStringExt::~LocalStringExt() +{ +} + +std::string LocalStringExt::ToInternal(const Extensible* container, void* item) const +{ + return item ? *static_cast(item) : std::string(); +} + +void LocalStringExt::FromInternal(Extensible* container, const std::string& value) +{ + set(container, value); +} + +LocalIntExt::LocalIntExt(const std::string& Key, ExtensibleType exttype, Module* mod) + : ExtensionItem(Key, exttype, mod) +{ +} + +LocalIntExt::~LocalIntExt() { - this->bits |= bitfields[number]; } -void BoolSet::Unset(int number) +std::string LocalIntExt::ToInternal(const Extensible* container, void* item) const { - this->bits &= inverted_bitfields[number]; + return ConvToStr(reinterpret_cast(item)); } -void BoolSet::Invert(int number) +void LocalIntExt::FromInternal(Extensible* container, const std::string& value) { - this->bits ^= bitfields[number]; + set(container, ConvToNum(value)); } -bool BoolSet::Get(int number) +intptr_t LocalIntExt::get(const Extensible* container) const { - return ((this->bits | bitfields[number]) > 0); + return reinterpret_cast(get_raw(container)); } -bool BoolSet::operator==(BoolSet other) +intptr_t LocalIntExt::set(Extensible* container, intptr_t value) { - return (this->bits == other.bits); + if (value) + return reinterpret_cast(set_raw(container, reinterpret_cast(value))); + else + return reinterpret_cast(unset_raw(container)); } -BoolSet BoolSet::operator|(BoolSet other) +void LocalIntExt::free(Extensible* container, void* item) { - BoolSet x(this->bits | other.bits); - return x; } -BoolSet BoolSet::operator&(BoolSet other) +StringExtItem::StringExtItem(const std::string& Key, ExtensibleType exttype, Module* mod) + : ExtensionItem(Key, exttype, mod) +{ +} + +StringExtItem::~StringExtItem() +{ +} + +std::string* StringExtItem::get(const Extensible* container) const +{ + return static_cast(get_raw(container)); +} + +std::string StringExtItem::ToNetwork(const Extensible* container, void* item) const +{ + return item ? *static_cast(item) : std::string(); +} + +void StringExtItem::FromNetwork(Extensible* container, const std::string& value) +{ + if (value.empty()) + unset(container); + else + set(container, value); +} + +void StringExtItem::set(Extensible* container, const std::string& value) { - BoolSet x(this->bits & other.bits); - return x; + void* old = set_raw(container, new std::string(value)); + free(container, old); } -BoolSet::BoolSet() +void StringExtItem::unset(Extensible* container) { - this->bits = 0; + void* old = unset_raw(container); + free(container, old); } -BoolSet::BoolSet(char bitmask) +void StringExtItem::free(Extensible* container, void* item) { - this->bits = bitmask; + delete static_cast(item); } -bool BoolSet::operator=(BoolSet other) +ModuleException::ModuleException(const std::string &message, Module* who) + : CoreException(message, who ? who->ModuleSourceFile : "A Module") { - this->bits = other.bits; - return true; }