Fix local server for multiple applications

[anna.git] / source / diameter.comm / Server.cpp

diff --git a/source/diameter.comm/Server.cpp b/source/diameter.comm/Server.cpp
index 4721b10..9cbeb74 100644 (file)
--- a/source/diameter.comm/Server.cpp
+++ b/source/diameter.comm/Server.cpp
@@ -321,24 +321,24 @@ void Server::eventRequestRetransmission(const ClientSession* clientSession, Mess
   a_parent->eventRequestRetransmission(clientSession, request);
 }
 
-void Server::eventResponse(const Response& response) noexcept(false) {
+void Server::eventResponse(const Response& response, const anna::diameter::comm::OriginHost *myNode) noexcept(false) {
   // Inform father entity:
-  a_parent->eventResponse(response);
+  a_parent->eventResponse(response, myNode);
 }
 
-void Server::eventRequest(ClientSession *clientSession, const anna::DataBlock & request) noexcept(false) {
+void Server::eventRequest(ClientSession *clientSession, const anna::DataBlock & request, const anna::diameter::comm::OriginHost *myNode) noexcept(false) {
   // Inform father entity:
-  a_parent->eventRequest(clientSession, request);
+  a_parent->eventRequest(clientSession, request, myNode);
 }
 
-void Server::eventUnknownResponse(ClientSession *clientSession, const anna::DataBlock & response) noexcept(false) {
+void Server::eventUnknownResponse(ClientSession *clientSession, const anna::DataBlock & response, const anna::diameter::comm::OriginHost *myNode) noexcept(false) {
   // Inform father entity:
-  a_parent->eventUnknownResponse(clientSession, response);
+  a_parent->eventUnknownResponse(clientSession, response, myNode);
 }
 
-void Server::eventDPA(ClientSession *clientSession, const anna::DataBlock & response) noexcept(false) {
+void Server::eventDPA(ClientSession *clientSession, const anna::DataBlock & response, const anna::diameter::comm::OriginHost *myNode) noexcept(false) {
   // Inform father entity:
-  a_parent->eventDPA(clientSession, response);
+  a_parent->eventDPA(clientSession, response, myNode);
 }
 
 
@@ -355,7 +355,6 @@ void Server::availabilityLost() {
   OamModule &oamModule = OamModule::instantiate();
   oamModule.activateAlarm(OamModule::Alarm::c_LostAvailabilityOverServerDefinedAs__s__, socket.c_str());
   oamModule.count(OamModule::Counter::LostAvailabilityOverServer);
-  a_engine->availabilityLost(this);
   a_parent->refreshAvailability();
 }
 
@@ -373,7 +372,6 @@ void Server::availabilityRecovered() {
   OamModule &oamModule = OamModule::instantiate();
   oamModule.cancelAlarm(OamModule::Alarm::c_LostAvailabilityOverServerDefinedAs__s__, socket.c_str());
   oamModule.count(OamModule::Counter::RecoveredAvailabilityOverServer);
-  a_engine->availabilityRecovered(this);
   a_parent->refreshAvailability();
 }