X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=source%2Fdiameter.comm%2FLocalServer.cpp;h=985e4a8fc7a89749b0c51b998414f4afab75ad7f;hb=129af2a9a7c287843be5bd443c5b1ad9b08438a8;hp=293cc83576582fe5c01ab319b78b10bcc23739af;hpb=6f990d26c49e6f5bbb31cb1a2a47615918b6c339;p=anna.git diff --git a/source/diameter.comm/LocalServer.cpp b/source/diameter.comm/LocalServer.cpp index 293cc83..985e4a8 100644 --- a/source/diameter.comm/LocalServer.cpp +++ b/source/diameter.comm/LocalServer.cpp @@ -277,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)); @@ -329,7 +329,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(); @@ -532,6 +532,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: ";