X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=source%2Fdiameter.comm%2FLocalServer.cpp;h=a14b3c6649f94fc992fc5335d9dcba84f3f53f13;hb=c8a0b8a8606f42cd2cc6cd14c7f180319f45bf85;hp=ed7933e345959809a2b9338b043feaebe93116f7;hpb=4e12ac57e93c052f716a6305ad8fc099c45899d1;p=anna.git diff --git a/source/diameter.comm/LocalServer.cpp b/source/diameter.comm/LocalServer.cpp index ed7933e..a14b3c6 100644 --- a/source/diameter.comm/LocalServer.cpp +++ b/source/diameter.comm/LocalServer.cpp @@ -1,37 +1,9 @@ -// ANNA - Anna is Not 'N' Anymore -// -// (c) Copyright 2005-2014 Eduardo Ramos Testillano & Francisco Ruiz Rayo -// -// https://bitbucket.org/testillano/anna -// -// Redistribution and use in source and binary forms, with or without -// modification, are permitted provided that the following conditions -// are met: -// -// * Redistributions of source code must retain the above copyright -// notice, this list of conditions and the following disclaimer. -// * 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. -// * Neither the name of Google Inc. nor the names of its -// contributors may be used to endorse or promote products derived from -// this software without specific prior written permission. -// -// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -// "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 COPYRIGHT -// OWNER 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. -// -// Authors: eduardo.ramos.testillano@gmail.com -// cisco.tierra@gmail.com +// ANNA - Anna is Not Nothingness Anymore // +// // +// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo // +// // +// See project site at http://redmine.teslayout.com/projects/anna-suite // +// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE // #include @@ -305,7 +277,7 @@ ServerSession *LocalServer::createServerSession(const anna::comm::ClientSocket & result->setClientSocket((anna::comm::ClientSocket*)(&clientSocket)); result->a_parent = this; result->a_socketId = key; // de momento... - result->initializeSequences(); // después de asignar el LocalServer y el socketId (*) + result->initializeSequences(); // despu�s de asignar el LocalServer y el socketId (*) // (*) Las secuencias se basan en la semilla: srand(::time(NULL) + anna::functions::exclusiveHash(anna::functions::asString("%s:%d|%d", getAddress().c_str(), getPort(), a_socketId))); result->a_engine = a_engine; a_serverSessions.insert(serverSession_value_type(key, result)); @@ -333,6 +305,10 @@ throw(anna::RuntimeException) { if(ii == serverSession_end()) return; + // Remove origin-realm / origin-host for server session in delivery map + // This is related to http://redmine.teslayout.com/issues/41 + a_engine->manageDrDhServerSession(serverSession, false /* desregister */); + try { //serverSession->setState(ServerSession::State::Closing); NOT MANAGED WITH SERVER SESSIONS serverSession->unbind(true /* always forceDisconnect on server sessions ... */); @@ -357,7 +333,7 @@ throw(anna::RuntimeException) { // #9 0x000000000048d288 in anna::diameter::comm::ServerSession::finalize (this=0xc37a00) at comm.db/diameter.comm.ServerSession.cc:510 // #10 0x0000000000494e4f in anna::diameter::comm::ServerSessionReceiver::eventBreakLocalConnection (this=0xc119c0, clientSocket=@0xb0ea00) // SOLUCION: no borrar aqui, marcar como "deprecated". Este estado no se necesita realmente puesto que nadie volvera a usar este recurso. - // Pero simplemente se podria usar para purgar mediante temporizacion (entonces sí se haría el erase) + // Pero simplemente se podria usar para purgar mediante temporizacion (entonces s� se har�a el erase) serverSession->a_deprecated = true; // WE WILL ERASE AT createServerSession a_deliveryIterator = serverSession_begin(); @@ -560,6 +536,14 @@ void LocalServer::eventPeerShutdown(const ServerSession* serverSession) throw() ); } +void LocalServer::eventRequestRetransmission(const ServerSession* serverSession, Message *request) throw() { + LOGWARNING( + std::string msg(serverSession->asString()); + msg += " | eventRequestRetransmission"; + anna::Logger::warning(msg, ANNA_FILE_LOCATION); + ); +} + std::string LocalServer::asString() const throw() { std::string result("diameter::comm::LocalServer { "); result += "Description: ";