X-Git-Url: https://git.teslayout.com/public/public/public/?p=anna.git;a=blobdiff_plain;f=source%2Fdiameter.comm%2FLocalServer.cpp;h=703dc6640ab0f4d27e9444c56f9c6c5e6ad02e56;hp=a44524500a89797d71c46b0a8f03028b28f52b58;hb=HEAD;hpb=7681cb4079366eb6908dd5d0dc0124c3fcef4b6b diff --git a/source/diameter.comm/LocalServer.cpp b/source/diameter.comm/LocalServer.cpp index a445245..703dc66 100644 --- a/source/diameter.comm/LocalServer.cpp +++ b/source/diameter.comm/LocalServer.cpp @@ -7,10 +7,10 @@ #include -#include #include #include #include +#include #include #include #include @@ -38,7 +38,6 @@ LocalServer::LocalServer() : a_maxConnections(-1), a_currentConnections(0), a_allowedInactivityTime(ServerSession::DefaultAllowedInactivityTime), - a_engine(NULL), a_serverSocket(NULL), a_category(0), a_lock(false), @@ -49,10 +48,6 @@ LocalServer::LocalServer() : void LocalServer::initializeStatisticResources() { std::string accName = "local server '"; accName += anna::functions::socketLiteralAsString(a_key.first, a_key.second); - accName += "' on origin-realm '"; - accName += a_engine ? a_engine->getOriginRealmName() : "unknown"; // it should be known (createServer) - accName += "' and origin-host '"; - accName += a_engine ? a_engine->getOriginHostName() : "unknown"; // it should be known (createServer) accName += "'"; a_messageStatistics.initialize(accName); } @@ -98,7 +93,6 @@ void LocalServer::availabilityLost() { OamModule &oamModule = OamModule::instantiate(); oamModule.activateAlarm(OamModule::Alarm::c_LostAvailabilityOverLocalServerDefinedAs__s__, socket.c_str()); oamModule.count(OamModule::Counter::LostAvailabilityOverLocalServer); - a_engine->availabilityLost(this); a_engine->refreshAvailabilityForLocalServers(); } @@ -116,7 +110,6 @@ void LocalServer::availabilityRecovered() { OamModule &oamModule = OamModule::instantiate(); oamModule.cancelAlarm(OamModule::Alarm::c_LostAvailabilityOverLocalServerDefinedAs__s__, socket.c_str()); oamModule.count(OamModule::Counter::RecoveredAvailabilityOverLocalServer); - a_engine->availabilityRecovered(this); a_engine->refreshAvailabilityForLocalServers(); } @@ -275,7 +268,6 @@ ServerSession *LocalServer::createServerSession(const anna::comm::ClientSocket & result->a_parent = this; result->a_socketId = key; // de momento... result->initializeSequences(); // despues de asignar el LocalServer y el socketId (sequences are seed-based by mean exclusive hash) - result->a_engine = a_engine; a_serverSessions.insert(serverSession_value_type(key, result)); newConnection(); a_deliveryIterator = serverSession_begin(); @@ -552,7 +544,9 @@ void LocalServer::eventRequestRetransmission(const ServerSession* serverSession, std::string LocalServer::asString() const { std::string result("diameter::comm::LocalServer { "); - result += "Description: "; + result += "Key: "; + result += anna::functions::socketLiteralAsString(getKey().first, getKey().second); + result += " | Description: "; result += (a_description != "") ? a_description : "undefined"; result += " | Available (any server session bound): "; result += a_available ? "yes" : "no";