X-Git-Url: https://git.teslayout.com/public/public/public/?p=anna.git;a=blobdiff_plain;f=source%2Fdiameter.comm%2FServer.cpp;h=4721b10b4c659a9c96808396951ffa3f7fe1e6e7;hp=32b3efa2daee15f9fcc6c78176cfcee42c495d0c;hb=5a6cba5fde2b2f538a7515f8293cc0a8d9589dfa;hpb=af9c86ffb0e28d35ad94d99c5f77e41578c972b4

diff --git a/source/diameter.comm/Server.cpp b/source/diameter.comm/Server.cpp
index 32b3efa..4721b10 100644
--- a/source/diameter.comm/Server.cpp
+++ b/source/diameter.comm/Server.cpp
@@ -28,7 +28,7 @@ using namespace anna::diameter;
 using namespace anna::diameter::comm;
 
 
-void Server::initialize() throw() {
+void Server::initialize() {
   a_parent = NULL;
   a_engine = NULL;
   a_clientSessions.clear(); // importante (el recycler creo que no lo tocaba)
@@ -39,7 +39,7 @@ void Server::initialize() throw() {
   a_lastUsedResource = NULL;
 }
 
-void Server::initializeStatisticResources() throw() {
+void Server::initializeStatisticResources() {
   std::string accName = "remote server '";
   accName += anna::functions::socketLiteralAsString(a_socket.first, a_socket.second);
   accName += "' from origin-realm '";
@@ -50,22 +50,22 @@ void Server::initializeStatisticResources() throw() {
   a_messageStatistics.initialize(accName);
 }
 
-void Server::resetStatistics() throw() {
+void Server::resetStatistics() {
   a_messageStatistics.getAccumulator()->reset();
 }
 
-void Server::updateProcessingTimeStatisticConcept(const double &value, const anna::diameter::CommandId &cid) throw() {
+void Server::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 Server::updateReceivedMessageSizeStatisticConcept(const double &value, const anna::diameter::CommandId &cid) throw() {
+void Server::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));
 }
 
 
-void Server::assertReady() throw(anna::RuntimeException) {
+void Server::assertReady() noexcept(false) {
   if(a_clientSessions.size() != a_maxClientSessions) {
     std::string msg(asString());
     msg += " | Non-configured server: you must add the remaining client-sessions before any operation (bind, send, etc.)";
@@ -75,7 +75,7 @@ void Server::assertReady() throw(anna::RuntimeException) {
 
 
 void Server::addClientSession(int socketId)
-throw(anna::RuntimeException) {
+noexcept(false) {
   if(a_clientSessions.size() == a_maxClientSessions) {
     LOGDEBUG
     (
@@ -94,7 +94,7 @@ throw(anna::RuntimeException) {
   a_clientSessions.push_back(s);
 }
 
-int Server::getOTARequests() const throw() {
+int Server::getOTARequests() const {
   int result = 0;
 
   for(std::vector<ClientSession*>::const_iterator it = begin(); it != end(); it++)
@@ -104,7 +104,7 @@ int Server::getOTARequests() const throw() {
 }
 
 
-bool Server::send(const Message* message, int socketId) throw(anna::RuntimeException) {
+bool Server::send(const Message* message, int socketId) noexcept(false) {
   LOGMETHOD(anna::TraceMethod tttm("diameter::comm::Server", "send", ANNA_FILE_LOCATION));
   assertReady();
   bool fixedSocket = (socketId != -1);
@@ -143,7 +143,7 @@ bool Server::send(const Message* message, int socketId) throw(anna::RuntimeExcep
 }
 
 
-bool Server::broadcast(const Message* message) throw(anna::RuntimeException) {
+bool Server::broadcast(const Message* message) noexcept(false) {
   LOGMETHOD(anna::TraceMethod tttm("diameter::comm::Server", "broadcast", ANNA_FILE_LOCATION));
   assertReady();
   bool allok = true;
@@ -161,7 +161,7 @@ bool Server::broadcast(const Message* message) throw(anna::RuntimeException) {
 }
 
 
-bool Server::bind() throw(anna::RuntimeException) {
+bool Server::bind() noexcept(false) {
   LOGMETHOD(anna::TraceMethod tttm("diameter::comm::Server", "bind", ANNA_FILE_LOCATION));
   assertReady();
   a_deliveryIterator = begin();
@@ -179,7 +179,7 @@ bool Server::bind() throw(anna::RuntimeException) {
   return result;
 }
 
-void Server::raiseAutoRecovery(bool autoRecovery) throw(anna::RuntimeException) {
+void Server::raiseAutoRecovery(bool autoRecovery) noexcept(false) {
   LOGMETHOD(anna::TraceMethod tttm("diameter::comm::Server", "raiseAutoRecovery", ANNA_FILE_LOCATION));
   assertReady();
   a_deliveryIterator = begin();
@@ -188,7 +188,7 @@ void Server::raiseAutoRecovery(bool autoRecovery) throw(anna::RuntimeException)
     (*it)->setAutoRecovery(autoRecovery);
 }
 
-void Server::setClassCodeTimeout(const ClassCode::_v v, const anna::Millisecond & millisecond) throw() {
+void Server::setClassCodeTimeout(const ClassCode::_v v, const anna::Millisecond & millisecond) {
   LOGMETHOD(anna::TraceMethod tttm("diameter::comm::Server", "setClassCodeTimeout", ANNA_FILE_LOCATION));
   assertReady();
 
@@ -203,7 +203,7 @@ void Server::setClassCodeTimeout(const ClassCode::_v v, const anna::Millisecond
 
 
 // Private close/destroy method
-void Server::close(bool destroy) throw(anna::RuntimeException) {
+void Server::close(bool destroy) noexcept(false) {
   LOGMETHOD(anna::TraceMethod tttm("diameter::comm::Server", "close", ANNA_FILE_LOCATION));
 
   if(!a_engine)
@@ -216,29 +216,29 @@ void Server::close(bool destroy) throw(anna::RuntimeException) {
 }
 
 
-void Server::childIdle() const throw() {
+void Server::childIdle() const {
   // Check father entity idleness:
   if(idle()) a_parent->childIdle();
 }
 
 
-void Server::hide() throw() {
+void Server::hide() {
   for(std::vector<ClientSession*>::iterator it = begin(); it != end(); it++)
     (*it)->hide();
 }
 
-void Server::show() throw() {
+void Server::show() {
   for(std::vector<ClientSession*>::iterator it = begin(); it != end(); it++)
     (*it)->show();
 }
 
-bool Server::hidden() const throw() {
+bool Server::hidden() const {
   for(std::vector<ClientSession*>::const_iterator it = begin(); it != end(); it++)
     if((*it)->shown()) return false;
 
   return true;
 }
-bool Server::shown() const throw() {
+bool Server::shown() const {
   for(std::vector<ClientSession*>::const_iterator it = begin(); it != end(); it++)
     if((*it)->hidden()) return false;
 
@@ -247,7 +247,7 @@ bool Server::shown() const throw() {
 
 
 
-std::string Server::socketAsString() const throw() {
+std::string Server::socketAsString() const {
   std::string result = getAddress();
   result += ":";
   result += anna::functions::asString(getPort());
@@ -255,7 +255,7 @@ std::string Server::socketAsString() const throw() {
 }
 
 
-std::string Server::asString() const throw() {
+std::string Server::asString() const {
   std::string result("diameter::comm::Server { ");
   result += " | Parent Entity: ";
   result += a_parent->getDescription();
@@ -287,7 +287,7 @@ std::string Server::asString() const throw() {
   return result;
 }
 
-anna::xml::Node* Server::asXML(anna::xml::Node* parent) const throw() {
+anna::xml::Node* Server::asXML(anna::xml::Node* parent) const {
   anna::xml::Node* result = parent->createChild("diameter.Server");
   result->createAttribute("ParentEntity", a_parent->getDescription());
   result->createAttribute("ServerAddress", a_socket.first);
@@ -311,38 +311,38 @@ anna::xml::Node* Server::asXML(anna::xml::Node* parent) const throw() {
 }
 
 
-void Server::eventPeerShutdown(const ClientSession *clientSession) throw() {
+void Server::eventPeerShutdown(const ClientSession *clientSession) {
   // Inform father entity:
   a_parent->eventPeerShutdown(clientSession);
 }
 
-void Server::eventRequestRetransmission(const ClientSession* clientSession, Message *request) throw() {
+void Server::eventRequestRetransmission(const ClientSession* clientSession, Message *request) {
   // Inform father entity:
   a_parent->eventRequestRetransmission(clientSession, request);
 }
 
-void Server::eventResponse(const Response& response) throw(anna::RuntimeException) {
+void Server::eventResponse(const Response& response) noexcept(false) {
   // Inform father entity:
   a_parent->eventResponse(response);
 }
 
-void Server::eventRequest(ClientSession *clientSession, const anna::DataBlock & request) throw(anna::RuntimeException) {
+void Server::eventRequest(ClientSession *clientSession, const anna::DataBlock & request) noexcept(false) {
   // Inform father entity:
   a_parent->eventRequest(clientSession, request);
 }
 
-void Server::eventUnknownResponse(ClientSession *clientSession, const anna::DataBlock & response) throw(anna::RuntimeException) {
+void Server::eventUnknownResponse(ClientSession *clientSession, const anna::DataBlock & response) noexcept(false) {
   // Inform father entity:
   a_parent->eventUnknownResponse(clientSession, response);
 }
 
-void Server::eventDPA(ClientSession *clientSession, const anna::DataBlock & response) throw(anna::RuntimeException) {
+void Server::eventDPA(ClientSession *clientSession, const anna::DataBlock & response) noexcept(false) {
   // Inform father entity:
   a_parent->eventDPA(clientSession, response);
 }
 
 
-void Server::availabilityLost() throw() {
+void Server::availabilityLost() {
   a_available = false;
   std::string socket = anna::functions::socketLiteralAsString(a_socket.first, a_socket.second);
   LOGDEBUG(
@@ -360,7 +360,7 @@ void Server::availabilityLost() throw() {
 }
 
 
-void Server::availabilityRecovered() throw() {
+void Server::availabilityRecovered() {
   a_available = true;
   std::string socket = anna::functions::socketLiteralAsString(a_socket.first, a_socket.second);
   LOGDEBUG(
@@ -379,7 +379,7 @@ void Server::availabilityRecovered() throw() {
 
 
 
-bool Server::refreshAvailability() throw() {
+bool Server::refreshAvailability() {
   // Here available
   if(a_available) {  // check not-bound state for all client-sessions:
     bool isolate = true;
@@ -411,7 +411,7 @@ bool Server::refreshAvailability() throw() {
 //------------------------------------------------------------------------------
 //---------------------------------------- Server::updateIncomingActivityTime()
 //------------------------------------------------------------------------------
-void Server::updateIncomingActivityTime() throw() {
+void Server::updateIncomingActivityTime() {
   a_lastIncomingActivityTime = anna::functions::millisecond();
   LOGDEBUG
   (
@@ -426,7 +426,7 @@ void Server::updateIncomingActivityTime() throw() {
 //------------------------------------------------------------------------------
 //---------------------------------------- Server::updateOutgoingActivityTime()
 //------------------------------------------------------------------------------
-void Server::updateOutgoingActivityTime(void) throw() {
+void Server::updateOutgoingActivityTime(void) {
   a_lastOutgoingActivityTime = anna::functions::millisecond();
   LOGDEBUG
   (