-// ANNA - Anna is Not Nothingness 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 <anna/diameter.comm/OamModule.hpp>
-#include <anna/diameter.comm/Engine.hpp>
#include <anna/diameter.comm/LocalServer.hpp>
#include <anna/diameter.comm/ServerSession.hpp>
#include <anna/diameter.comm/ServerSocket.hpp>
+#include <anna/diameter.comm/Engine.hpp>
#include <anna/core/functions.hpp>
#include <anna/statistics/Engine.hpp>
#include <anna/diameter.comm/TimerManager.hpp>
a_maxConnections(-1),
a_currentConnections(0),
a_allowedInactivityTime(ServerSession::DefaultAllowedInactivityTime),
- a_engine(NULL),
a_serverSocket(NULL),
a_category(0),
a_lock(false),
a_available(false),
- a_lastUsedResource(NULL) {
- a_statisticsAccumulator.reset();
-}
+ a_lastUsedResource(NULL) {}
-void LocalServer::initializeStatisticConcepts() throw() {
- // Statistics:
- anna::statistics::Engine& statsEngine = anna::statistics::Engine::instantiate();
- // Concepts descriptions:
- std::string serverAsString = anna::functions::socketLiteralAsString(a_key.first, a_key.second);
- std::string c1desc = "Diameter processing time (for requests) at clients connected to "; c1desc += serverAsString;
- std::string c2desc = "Diameter message sizes received from clients connected to "; c2desc += serverAsString;
- // Registering
- a_processing_time__StatisticConceptId = statsEngine.addConcept(c1desc.c_str(), "ms", true/* integer values */);
- a_received_message_size__StatisticConceptId = statsEngine.addConcept(c2desc.c_str(), "bytes", true/* integer values */);
+void LocalServer::initializeStatisticResources() {
+ std::string accName = "local server '";
+ accName += anna::functions::socketLiteralAsString(a_key.first, a_key.second);
+ accName += "'";
+ a_messageStatistics.initialize(accName);
}
-void LocalServer::resetStatistics() throw() {
- a_statisticsAccumulator.reset();
+void LocalServer::resetStatistics() {
+ a_messageStatistics.getAccumulator()->reset();
}
-void LocalServer::updateProcessingTimeStatisticConcept(const double &value) throw() {
- a_statisticsAccumulator.process(a_processing_time__StatisticConceptId, value);
- LOGDEBUG(anna::Logger::debug(a_statisticsAccumulator.asString(), ANNA_FILE_LOCATION));
+void LocalServer::updateProcessingTimeStatisticConcept(const double &value, const anna::diameter::CommandId &cid) {
+ a_messageStatistics.process(MessageStatistics::ConceptType::SentRequestProcessingTime, cid, value);
+ LOGDEBUG(anna::Logger::debug(a_messageStatistics.getAccumulator()->asString(), ANNA_FILE_LOCATION));
}
-void LocalServer::updateReceivedMessageSizeStatisticConcept(const double &value) throw() {
- a_statisticsAccumulator.process(a_received_message_size__StatisticConceptId, value);
- //LOGDEBUG(anna::Logger::debug(a_statisticsAccumulator.asString(), ANNA_FILE_LOCATION));
+void LocalServer::updateReceivedMessageSizeStatisticConcept(const double &value, const anna::diameter::CommandId &cid) {
+ a_messageStatistics.process(MessageStatistics::ConceptType::ReceivedMessageSize, cid, value);
+ LOGDEBUG(anna::Logger::debug(a_messageStatistics.getAccumulator()->asString(), ANNA_FILE_LOCATION));
}
+ServerSession* LocalServer::allocateServerSession() { return a_serverSessionsRecycler.create(); }
+void LocalServer::releaseServerSession(ServerSession *serverSession) { a_serverSessionsRecycler.release(serverSession); }
-ServerSession* LocalServer::allocateServerSession() throw() { return a_serverSessionsRecycler.create(); }
-void LocalServer::releaseServerSession(ServerSession *serverSession) throw() { a_serverSessionsRecycler.release(serverSession); }
-
-LocalServer::serverSession_iterator LocalServer::serverSession_find(const serverSession_key &key) throw() {
+LocalServer::serverSession_iterator LocalServer::serverSession_find(const serverSession_key &key) {
return a_serverSessions.find(key);
}
-LocalServer::serverSession_key LocalServer::getServerSessionKey(const anna::comm::ClientSocket &clientSocket) const throw() {
- return (anna::functions::exclusiveHash(clientSocket.getRemoteAccessPoint().getINetAddress().serialize()));
+LocalServer::serverSession_key LocalServer::getServerSessionKey(const anna::comm::ClientSocket &clientSocket) const {
+ return (anna::functions::hash(clientSocket.getRemoteAccessPoint().getINetAddress().serialize().c_str()));
}
-void LocalServer::availabilityLost() throw() {
+void LocalServer::availabilityLost() {
a_available = false;
std::string socket = anna::functions::socketLiteralAsString(a_key.first, a_key.second);
LOGDEBUG(
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();
}
-void LocalServer::availabilityRecovered() throw() {
+void LocalServer::availabilityRecovered() {
a_available = true;
std::string socket = anna::functions::socketLiteralAsString(a_key.first, a_key.second);
LOGDEBUG(
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();
}
-bool LocalServer::refreshAvailability() throw() {
+bool LocalServer::refreshAvailability() {
// Here available
if(a_available) { // check not-bound state for all server-sessions:
// bool isolate = true;
}
-void LocalServer::enable(bool unlock) throw(anna::RuntimeException) {
+void LocalServer::enable(bool unlock) noexcept(false) {
// Unlock ?
if(unlock) a_lock = false;
attach();
}
-void LocalServer::attach() throw() {
+void LocalServer::attach() {
try {
// Attach to communicator
anna::comm::Communicator * communicator = anna::app::functions::component <anna::comm::Communicator> (ANNA_FILE_LOCATION);
}
}
-void LocalServer::attachPlanning() throw() {
+void LocalServer::attachPlanning() {
LOGMETHOD(anna::TraceMethod tttm("diameter::comm::LocalServer", "attachPlanning", ANNA_FILE_LOCATION));
try {
}
-void LocalServer::disable(bool lock) throw(anna::RuntimeException) {
+void LocalServer::disable(bool lock) noexcept(false) {
// Permanent ?
a_lock = lock;
anna::comm::Communicator * communicator = anna::app::functions::component <anna::comm::Communicator> (ANNA_FILE_LOCATION);
}
-void LocalServer::lostConnection() throw() {
+void LocalServer::lostConnection() {
a_currentConnections--;
enable();
}
-void LocalServer::newConnection() throw(anna::RuntimeException) {
+void LocalServer::newConnection() noexcept(false) {
a_currentConnections++;
// Check capacity
}
// Inform local server (availability changes):
- bool changes = refreshAvailability();
+ refreshAvailability();
+
// OAM
OamModule &oamModule = OamModule::instantiate();
oamModule.count(OamModule::Counter::CreatedConnectionForServerSession);
-ServerSession *LocalServer::createServerSession(const anna::comm::ClientSocket &clientSocket) throw(anna::RuntimeException) {
+ServerSession *LocalServer::createServerSession(const anna::comm::ClientSocket &clientSocket) noexcept(false) {
LOGMETHOD(anna::TraceMethod tttm("diameter::comm::LocalServer", "createServerSession", ANNA_FILE_LOCATION));
ServerSession* result(NULL);
// First erase deprecated ones:
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 (*)
- // (*) 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;
+ result->initializeSequences(); // despues de asignar el LocalServer y el socketId (sequences are seed-based by mean exclusive hash)
a_serverSessions.insert(serverSession_value_type(key, result));
newConnection();
a_deliveryIterator = serverSession_begin();
void LocalServer::closeServerSession(ServerSession* serverSession)
-throw(anna::RuntimeException) {
+noexcept(false) {
if(serverSession == NULL)
return;
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 ... */);
// #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();
ServerSession* LocalServer::findServerSession(int socketId, anna::Exception::Mode::_v emode)
-throw(anna::RuntimeException) {
+noexcept(false) {
serverSession_iterator ii = serverSession_find(socketId);
if(ii != serverSession_end())
}
ServerSession* LocalServer::findServerSession(const anna::comm::ClientSocket &clientSocket, anna::Exception::Mode::_v emode)
-throw(anna::RuntimeException) {
+noexcept(false) {
return findServerSession(getServerSessionKey(clientSocket), emode);
}
-int LocalServer::getOTARequests() const throw() {
+int LocalServer::getOTARequests() const {
int result = 0;
for(const_serverSession_iterator it = serverSession_begin(); it != serverSession_end(); it++)
return result;
}
-void LocalServer::close() throw(anna::RuntimeException) {
+void LocalServer::close() noexcept(false) {
LOGMETHOD(anna::TraceMethod tttm("diameter::comm::LocalServer", "close", ANNA_FILE_LOCATION));
// Close listener (permanently to avoid reopening when local connections are being deleted):
disable(true /* lock */);
closeServerSession(serverSession(it));
}
+void LocalServer::setClassCodeTimeout(const ClassCode::_v v, const anna::Millisecond & millisecond) {
+ LOGMETHOD(anna::TraceMethod tttm("diameter::comm::LocalServer", "setClassCodeTimeout", ANNA_FILE_LOCATION));
-void LocalServer::setMaxConnections(int maxConnections) throw(anna::RuntimeException) {
+ for(serverSession_iterator it = serverSession_begin(); it != serverSession_end(); it++) {
+ try {
+ serverSession(it)->setClassCodeTimeout(v, millisecond);
+ } catch(anna::RuntimeException &ex) {
+ ex.trace();
+ }
+ }
+}
+
+void LocalServer::setMaxConnections(int maxConnections) noexcept(false) {
LOGMETHOD(anna::TraceMethod tttm("anna::diameter::comm::LocalServer", "setMaxConnections", ANNA_FILE_LOCATION));
// Negative & initial
}
-bool LocalServer::send(const Message* message, int socketId) throw(anna::RuntimeException) {
+bool LocalServer::send(const Message* message, int socketId) noexcept(false) {
LOGMETHOD(anna::TraceMethod tttm("diameter::comm::LocalServer", "send", ANNA_FILE_LOCATION));
if(!isAvailable()) {
// Send:
try {
- const Response* response = a_lastUsedResource->send(message);
+ a_lastUsedResource->send(message);
return true; // no matter if response is NULL (answers, i.e.) or not.
} catch(anna::RuntimeException &ex) {
ex.trace();
}
-bool LocalServer::broadcast(const Message* message) throw(anna::RuntimeException) {
+bool LocalServer::broadcast(const Message* message) noexcept(false) {
LOGMETHOD(anna::TraceMethod tttm("diameter::comm::LocalServer", "broadcast", ANNA_FILE_LOCATION));
- const Response* response;
bool allok = true;
for(serverSession_iterator it = serverSession_begin(); it != serverSession_end(); it++) {
try {
- response = serverSession(it)->send(message);
+ serverSession(it)->send(message);
} catch(anna::RuntimeException &ex) {
ex.trace();
allok = false;
return allok;
}
-void LocalServer::eventPeerShutdown(const ServerSession* serverSession) throw() {
+void LocalServer::eventPeerShutdown(const ServerSession* serverSession) {
LOGWARNING(
std::string msg(serverSession->asString());
msg += " | eventPeerShutdown";
);
}
-std::string LocalServer::asString() const throw() {
+void LocalServer::eventRequestRetransmission(const ServerSession* serverSession, Message *request) {
+ LOGWARNING(
+ std::string msg(serverSession->asString());
+ msg += " | eventRequestRetransmission";
+ anna::Logger::warning(msg, ANNA_FILE_LOCATION);
+ );
+}
+
+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";
result += " | Last Outgoing Activity Time: ";
result += a_lastOutgoingActivityTime.asString();
// result += "\n";
-// result += a_statisticsAccumulator.asString();
+// result += a_messageStatistics.getAccumulator()->asString();
// ServerSessions only in xml
return result += " }";
}
-anna::xml::Node* LocalServer::asXML(anna::xml::Node* parent) const throw() {
+anna::xml::Node* LocalServer::asXML(anna::xml::Node* parent) const {
anna::xml::Node* result = parent->createChild("diameter.LocalServer");
result->createAttribute("Description", (a_description != "") ? a_description : "undefined");
result->createAttribute("Available", a_available ? "yes" : "no");
result->createAttribute("LastIncomingActivityTime", a_lastIncomingActivityTime.asString());
result->createAttribute("LastOutgoingActivityTime", a_lastOutgoingActivityTime.asString());
// Statistics
- anna::xml::Node* stats = result->createChild("Statistics");
- a_statisticsAccumulator.asXML(stats);
+ anna::xml::Node* stats = result->createChild("MessageStatistics");
+ a_messageStatistics.getAccumulator()->asXML(stats);
anna::xml::Node* serverSessions = result->createChild("ServerSessions"); // LocalServer.ServerSessions
for(const_serverSession_iterator it = serverSession_begin(); it != serverSession_end(); it++)
//------------------------------------------------------------------------------
//------------------------------------ LocalServer::updateIncomingActivityTime()
//------------------------------------------------------------------------------
-void LocalServer::updateIncomingActivityTime() throw() {
+void LocalServer::updateIncomingActivityTime() {
a_lastIncomingActivityTime = anna::functions::millisecond();
LOGDEBUG
(
//------------------------------------------------------------------------------
//------------------------------------ LocalServer::updateOutgoingActivityTime()
//------------------------------------------------------------------------------
-void LocalServer::updateOutgoingActivityTime(void) throw() {
+void LocalServer::updateOutgoingActivityTime(void) {
a_lastOutgoingActivityTime = anna::functions::millisecond();
LOGDEBUG
(
anna::Logger::debug(msg, ANNA_FILE_LOCATION);
);
}
-
projects / anna.git / blobdiff