1 // ANNA - Anna is Not Nothingness Anymore //
3 // (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo //
5 // See project site at http://redmine.teslayout.com/projects/anna-suite //
6 // See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //
9 #include <anna/core/functions.hpp>
10 #include <anna/diameter/defines.hpp>
11 #include <anna/diameter/functions.hpp>
12 #include <anna/diameter/helpers/helpers.hpp>
13 #include <anna/diameter/codec/functions.hpp>
14 #include <anna/diameter/codec/Message.hpp>
15 #include <anna/diameter/helpers/base/functions.hpp>
16 #include <anna/time/functions.hpp>
18 #include <anna/diameter.comm/ClientSession.hpp>
19 #include <anna/diameter.comm/Engine.hpp>
20 #include <anna/diameter.comm/Entity.hpp>
21 #include <anna/diameter.comm/Server.hpp>
22 #include <anna/diameter.comm/Response.hpp>
23 #include <anna/diameter.comm/Message.hpp>
24 #include <anna/diameter.comm/OamModule.hpp>
25 #include <anna/diameter.comm/ApplicationMessageOamModule.hpp>
26 #include <anna/diameter.comm/TimerManager.hpp>
27 #include <anna/diameter.comm/Timer.hpp>
28 #include <anna/diameter.comm/ClientSessionReceiver.hpp>
29 #include <anna/diameter.comm/ReceiverFactoryImpl.hpp>
31 #include <anna/comm/ClientSocket.hpp>
32 #include <anna/app/functions.hpp>
33 #include <anna/core/functions.hpp>
34 #include <anna/core/DataBlock.hpp>
35 #include <anna/core/tracing/Logger.hpp>
36 #include <anna/core/tracing/TraceMethod.hpp>
37 #include <anna/xml/Node.hpp>
38 #include <anna/timex/Engine.hpp>
41 #include <stdlib.h> // rand()
46 using namespace anna::diameter;
47 using namespace anna::diameter::comm;
50 const anna::Millisecond ClientSession::DefaultWatchdogPeriod(30000); // Watchdog messages timeout
53 ClientSession::ClientSession() : Session("diameter::comm::ClientSession", "Diameter Keep-Alive Timer"),
54 a_receiverFactory(this),
55 a_cer(ClassCode::Bind),
56 a_dwr(ClassCode::ApplicationMessage) // realmente no es necesario, los Message son por defecto de aplicacion
60 void ClientSession::initialize() throw() {
61 Session::initialize();
62 a_autoRecovery = true;
65 a_watchdogState = WatchdogState::TimerStopped;
69 //ClientSession::~ClientSession() {;}
72 const std::string& ClientSession::getAddress() const throw() {
73 return a_parent->getAddress();
76 int ClientSession::getPort() const throw() {
77 return a_parent->getPort();
81 void ClientSession::setState(State::_v state) throw() {
82 Session::setState(state);
83 // Inform father server (availability changes):
84 bool changes = a_parent->refreshAvailability();
87 void ClientSession::bind() throw(anna::RuntimeException) {
88 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "bind", ANNA_FILE_LOCATION));
90 if(a_state != State::Closed)
94 string msg("diameter::comm::ClientSession::bind | ");
96 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
101 throw anna::RuntimeException("Server is not yet created", ANNA_FILE_LOCATION);
103 bool serverAvailable = a_server->isAvailable();
106 if(serverAvailable) anna::Logger::debug("Server AVAILABLE", ANNA_FILE_LOCATION);
107 else anna::Logger::debug("Server NOT AVAILABLE. Connecting ...", ANNA_FILE_LOCATION);
110 if(!serverAvailable) {
115 // Some operations could be done before sending CER, for example non-standard Origin-Host manipulation for
117 a_engine->bindingClientSession(this);
119 // OAM Lo comento, porque no se contabilizan los reintentos y por lo tanto no son muy �tiles.
120 // OamModule &oamModule = OamModule::instantiate();
121 // oamModule.count(a_server->isAvailable() ? OamModule::Counter::TCPConnectOK:OamModule::Counter::TCPConnectNOK);
124 LOGDEBUG(anna::Logger::debug("CER sent to the server", ANNA_FILE_LOCATION));
128 void ClientSession::setCERandDWR(const anna::DataBlock & cer, const anna::DataBlock & dwr) throw(anna::RuntimeException) {
129 if(codec::functions::getCommandId(cer) != helpers::base::COMMANDID__Capabilities_Exchange_Request) {
130 throw anna::RuntimeException("The message provided as 'CER' is not a Capabilities-Exchange-Request", ANNA_FILE_LOCATION);
133 if(codec::functions::getCommandId(dwr) != helpers::base::COMMANDID__Device_Watchdog_Request) {
134 throw anna::RuntimeException("The message provided as 'DWR' is not a Device-Watchdog-Request", ANNA_FILE_LOCATION);
137 // La verificacion ya se hace implicitamente antes
138 // if ((a_cer.isEmpty()) || (a_dwr.isEmpty())) {
139 // LOGDEBUG (anna::Logger::debug ("Must define valid CER and DWR messages before use bind !", ANNA_FILE_LOCATION));
147 const Response* ClientSession::send(const Message* message) throw(anna::RuntimeException) {
148 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "send", ANNA_FILE_LOCATION));
151 throw anna::RuntimeException("Cannot send a NULL message", ANNA_FILE_LOCATION);
155 diameter::CommandId cid = message->getCommandId(isRequest);
156 diameter::ApplicationId aid = message->getApplicationId();
159 std::string msg = "Sending diameter message: ";
160 msg += anna::diameter::functions::commandIdAsPairString(cid);
161 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
165 if((cid.first != helpers::base::COMMANDID__Capabilities_Exchange_Request.first) /* not CER/CEA */
166 && (cid.first != helpers::base::COMMANDID__Device_Watchdog_Request.first) /* not DWR/DWA */
167 && (cid.first != helpers::base::COMMANDID__Disconnect_Peer_Request.first)) { /* not DPR/DPA */
169 std::string msg(asString());
170 msg += " | Client-session hidden for application messages delivery";
171 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
178 if((a_state == State::Closed) && (cid != helpers::base::COMMANDID__Capabilities_Exchange_Request)) {
179 string msg(asString());
180 msg += " | ClientSession::bind is not initiated";
181 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
184 if(a_state == State::WaitingBind) {
185 string msg(asString());
186 msg += " | Still waiting for bind ack (CEA)";
187 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
190 if(a_state == State::Failover) {
191 string msg(asString());
192 msg += " | Disabled sent on failover state";
193 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
196 if(a_state == State::Closing) {
197 string msg(asString());
198 msg += " | Disabled sent on closing state";
199 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
203 if(cid == helpers::base::COMMANDID__Capabilities_Exchange_Request) {
204 if(a_state != State::Closed) {
205 string msg(asString());
206 msg += " | Discarding CER on not closed state";
207 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
209 } else if(cid == helpers::base::COMMANDID__Device_Watchdog_Request) {
210 if(a_state == State::WaitingDPA) {
211 string msg(asString());
212 msg += " | DWR is not sent on 'WaitingDPA' state";
213 //throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
214 LOGDEBUG(anna::Logger::debug(msg, ANNA_FILE_LOCATION));
218 if(a_state == State::Disconnecting) {
219 string msg(asString());
220 msg += " | DWR is not sent on 'Disconnecting' state";
221 //throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
222 LOGDEBUG(anna::Logger::debug(msg, ANNA_FILE_LOCATION));
226 if(a_state == State::Closing) {
227 string msg(asString());
228 msg += " | DWR is not sent on 'Closing' state";
229 //throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
230 LOGDEBUG(anna::Logger::debug(msg, ANNA_FILE_LOCATION));
233 } else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Request) {
234 if(a_state == State::WaitingDPA) {
235 string msg(asString());
236 msg += " | Still waiting for DPR ack (DPA)";
237 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
240 if(a_state == State::Disconnecting) {
241 string msg(asString());
242 msg += " | Client disconnection has already been initiated";
243 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
246 if((a_state == State::WaitingDPA) || (a_state == State::Disconnecting)) {
247 if(cid != helpers::base::COMMANDID__Disconnect_Peer_Answer) {
249 string msg("diameter::comm::ClientSession::send | ");
251 msg += " | Sents (request or answer) blocked to diameter server (disconnection in progress). Discarding ...";
252 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
259 // Trace send operation:
261 string msg("diameter::comm::ClientSession::send | ");
264 msg += message->asString();
265 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
267 bool fixed = false; // answers cannot be fixed
268 Message * message_nc = const_cast<Message*>(message);
271 if(/* entity */getParent()->getParent()->isDeprecated()) {
272 string msg(asString());
273 msg += " | Parent entity is deprecated. Request send blocked.";
274 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
278 fixed = message_nc->fixRequestSequence(a_nextHopByHop, a_nextEndToEnd);
279 message_nc->updateRequestTimestampMs(); // statistics purposes (processing time for request type)
284 message->send(*this);
286 // Next hop by hop & end to end identifiers:
287 if(isRequest) generateNextSequences();
290 // The Diameter protocol requires that agents maintain transaction
291 // state, which is used for failover purposes. Transaction state
292 // implies that upon forwarding a request, the Hop-by-Hop identifier
293 // is saved; the field is replaced with a locally unique identifier,
294 // which is restored to its original value when the corresponding
295 // answer is received. The request's state is released upon receipt
296 // of the answer. A stateless agent is one that only maintains
297 // transaction state.
299 updateOutgoingActivityTime();
301 countSendings(cid, aid, true /* send ok */);
302 // Trace non-application messages:
304 if((cid == helpers::base::COMMANDID__Capabilities_Exchange_Request) ||
305 (cid == helpers::base::COMMANDID__Device_Watchdog_Request) ||
306 (cid == helpers::base::COMMANDID__Disconnect_Peer_Request)) {
307 anna::Logger::debug("Sent DataBlock to XML representation:", ANNA_FILE_LOCATION);
309 anna::diameter::codec::Message msg(a_engine->getBaseProtocolCodecEngine()); msg.decode(message->getBody()); /* decode to be traced */
311 catch(anna::RuntimeException &ex) {
312 std::string msg = ex.getText();
313 msg += " | Use diameter::comm::Engine::setBaseProtocolCodecEngine() to allow internal base protocol messages full tracing";
314 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
319 // Restore sequences:
320 if(fixed) message_nc->restoreSequencesAfterFix(); // restore to application sequences after fix
321 } catch(anna::RuntimeException&) {
322 if(fixed) message_nc->restoreSequencesAfterFix(); // restore to application sequences after fix
325 countSendings(cid, aid, false /* send no ok */);
330 if(cid == helpers::base::COMMANDID__Capabilities_Exchange_Request) {
331 setState(State::WaitingBind);
332 } else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Request) {
333 LOGWARNING(anna::Logger::warning("DPR has been sent to the peer (diameter server)", ANNA_FILE_LOCATION));
334 setState(State::WaitingDPA);
341 // Answers are not temporized:
342 if(!isRequest) return NULL;
345 if(cid == helpers::base::COMMANDID__Device_Watchdog_Request) {
346 setWatchdogState(WatchdogState::WaitingDWA);
350 // Request will have context responses:
351 Response* result(NULL);
352 result = Response::instance(message->getClassCode(), a_nextHopByHop - 1 /* current request sent to server */);
353 result->setRequest(message);
354 response_add(result);
358 bool ClientSession::unbind(bool forceDisconnect)
359 throw(anna::RuntimeException) {
360 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "unbind", ANNA_FILE_LOCATION));
362 if(a_state == State::Closed)
366 anna::comm::ClientSocket * cs = const_cast<anna::comm::ClientSocket*>(a_server->getClientSocket());
368 // string msg("Server to be unbound | ");
369 // msg += a_server->asString();
370 // anna::Logger::debug(msg, ANNA_FILE_LOCATION);
373 if(forceDisconnect) {
374 LOGDEBUG(anna::Logger::debug("Immediate disconnection (forceDisconnect)", ANNA_FILE_LOCATION));
376 if(cs) cs->requestClose(); // this will invoke finalize()
381 if(a_state == State::Disconnecting) {
383 string msg("diameter::comm::ClientSession::unbind | ");
385 msg += " | Disconnection already in progress !";
386 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
391 if(a_state == State::Failover) {
393 string msg("diameter::comm::ClientSession::unbind | ");
395 msg += " | Unbind on failover state. Disconnect now.";
396 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
399 if(cs) cs->requestClose(); // this will invoke finalize()
404 if(a_state == State::WaitingBind) {
406 string msg("diameter::comm::ClientSession::unbind | ");
408 msg += " | Unbind on WaitingBind state. Disconnect now.";
409 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
412 if(cs) cs->requestClose(); // this will invoke finalize()
417 if(a_onDisconnect == OnDisconnect::IgnorePendings) {
418 LOGDEBUG(anna::Logger::debug("Immediate disconnection (IgnorePendings)", ANNA_FILE_LOCATION));
420 if(cs) cs->requestClose(); // this will invoke finalize()
425 if(getOTARequests() == 0) { // No pendings
426 LOGDEBUG(anna::Logger::debug("No pending answers. Perform client-session close.", ANNA_FILE_LOCATION));
428 if(cs) cs->requestClose(); // this will invoke finalize()
433 if(a_state == State::Closing) {
435 string msg("diameter::comm::ClientSession::unbind | ");
437 msg += " | Closing already in progress (waiting pendings) !";
438 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
445 void ClientSession::eventPeerShutdown() throw() {
446 // Inform father server:
447 a_parent->eventPeerShutdown(this);
450 void ClientSession::eventRequestRetransmission(Message *request) throw() {
453 OamModule &oamModule = OamModule::instantiate();
454 oamModule.count(OamModule::Counter::RequestRetransmitted);
455 oamModule.count(OamModule::Counter::RequestRetransmittedOnClientSession);
457 // Inform father server:
458 a_parent->eventRequestRetransmission(this, request);
461 void ClientSession::eventResponse(const Response& response) throw(anna::RuntimeException) {
462 // Inform father server:
463 a_parent->eventResponse(response);
466 void ClientSession::eventRequest(const anna::DataBlock &request) throw(anna::RuntimeException) {
467 // Inform father server:
468 a_parent->eventRequest(this, request);
471 void ClientSession::eventUnknownResponse(const anna::DataBlock& response) throw(anna::RuntimeException) {
472 // Inform father server:
473 a_parent->eventUnknownResponse(this, response);
476 void ClientSession::eventDPA(const anna::DataBlock& response) throw(anna::RuntimeException) {
477 // Inform father server:
478 a_parent->eventDPA(this, response);
483 //------------------------------------------------------------------------------------------
484 // Se invoca desde el diameter::comm::Receiver
485 //------------------------------------------------------------------------------------------
486 void ClientSession::receive(const anna::comm::Message& message)
487 throw(anna::RuntimeException) {
488 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "receive", ANNA_FILE_LOCATION));
490 updateIncomingActivityTime();
493 const anna::DataBlock & db = message.getBody();
494 diameter::CommandId cid = codec::functions::getCommandId(db);
495 bool isRequest = cid.second;
497 std::string msg = "Received diameter message: ";
498 msg += anna::diameter::functions::commandIdAsPairString(cid);
499 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
501 if( (cid == helpers::base::COMMANDID__Capabilities_Exchange_Answer) ||
502 (cid.first == helpers::base::COMMANDID__Device_Watchdog_Request.first)) {
504 anna::diameter::codec::Message dmsg(a_engine->getBaseProtocolCodecEngine()); dmsg.decode(db); /* decode to be traced */
506 catch(anna::RuntimeException &ex) {
507 std::string msg = ex.getText();
508 msg += " | Use diameter::comm::Engine::setBaseProtocolCodecEngine() to allow internal base protocol messages full tracing";
509 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
514 OamModule &oamModule = OamModule::instantiate();
515 oamModule.count(isRequest ? OamModule::Counter::RequestReceived : OamModule::Counter::AnswerReceived);
516 oamModule.count(isRequest ? OamModule::Counter::RequestReceivedOnClientSession : OamModule::Counter::AnswerReceivedOnClientSession);
518 a_parent->updateReceivedMessageSizeStatisticConcept(message.getSize()); // only on reception (application could manage sent sizes)
521 /////////////////////////////
522 // Here received a request //
523 /////////////////////////////
526 if(cid == helpers::base::COMMANDID__Capabilities_Exchange_Request) {
527 LOGWARNING(anna::Logger::warning("Received CER: unexpected message at client-side", ANNA_FILE_LOCATION));
531 else if(cid == helpers::base::COMMANDID__Device_Watchdog_Request) {
532 // LOGWARNING(anna::Logger::warning("Received DWR: unexpected message at client-side", ANNA_FILE_LOCATION));
534 // Non-usual but could happen:
535 oamModule.count(OamModule::Counter::DWRReceived);
536 sendDWAToServer(db /* DWR datablock received from server */);
540 else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Request) {
541 oamModule.count(OamModule::Counter::DPRReceived);
543 if(a_state == State::Bound) {
545 setState(State::Disconnecting);
546 LOGWARNING(anna::Logger::warning("DPR has been received from peer (diameter server)", ANNA_FILE_LOCATION));
548 if(getOTARequests() == 0) sendDPA();
550 return; // DPR won't be informed because virtual readDPA is available for this
555 // application message counters
556 ApplicationMessageOamModule::instantiate().count(cid.first, anna::diameter::codec::functions::getApplicationId(db), ApplicationMessageOamModule::Counter::Request_Received_AsClient);
559 } catch(anna::RuntimeException& ex) {
566 /////////////////////////////
567 // Here received an answer //
568 /////////////////////////////
569 bool doUnbind = false;
570 bool immediateUnbind = false;
574 resultCode = helpers::base::functions::getResultCode(db);
575 } catch(anna::RuntimeException& ex) {
580 if(cid == helpers::base::COMMANDID__Capabilities_Exchange_Answer) {
581 oamModule.count(OamModule::Counter::CEAReceived);
583 if(a_state != State::WaitingBind) {
584 LOGWARNING(anna::Logger::warning("Received CEA: unexpected message at not-WaitingBind state", ANNA_FILE_LOCATION));
585 return; // we don't send its request
586 // string msg("diameter::comm::ClientSession::receive | ");
587 // msg += asString();
588 // msg += " | Received CEA on not-WaitingBind state: unexpected Bind-response";
589 // throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
592 if(resultCode != helpers::base::AVPVALUES__Result_Code::DIAMETER_SUCCESS) {
594 std::string msg = anna::functions::asString("Received CEA with non-success Result-Code (%d). Unbinding connection.", resultCode);
595 anna::Logger::warning(msg, ANNA_FILE_LOCATION);
599 setState(State::Bound);
600 //activateTimer(); // Ya se invoca al inicio de este metodo ::receive
601 // Inform father server (availability changes):
602 bool changes = a_parent->refreshAvailability();
607 else if(cid == helpers::base::COMMANDID__Device_Watchdog_Answer) {
608 oamModule.count(OamModule::Counter::DWAReceived);
609 setWatchdogState(WatchdogState::WaitingTimerExpiration);
611 if(resultCode != helpers::base::AVPVALUES__Result_Code::DIAMETER_SUCCESS)
613 std::string msg = anna::functions::asString("Received DWA with non-success Result-Code (%d)... but ASSUME keep-alive is reached", resultCode);
614 anna::Logger::warning(msg, ANNA_FILE_LOCATION);
617 if(a_state == State::Failover) {
618 setState(State::Bound);
620 string msg("diameter::comm::ClientSession::receive | ");
622 msg += " | Received DWA on failover state: recovering Bound state";
623 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
627 // Keep-Alive don't manage context
631 else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Answer) {
632 oamModule.count(OamModule::Counter::DPAReceived);
634 if(a_state == State::WaitingDPA) {
635 if(resultCode != helpers::base::AVPVALUES__Result_Code::DIAMETER_SUCCESS) {
637 std::string msg = anna::functions::asString("Received DPA with non-success Result-Code (%d). Ignoring and recovering Bound state", resultCode);
638 anna::Logger::warning(msg, ANNA_FILE_LOCATION);
640 setState(State::Bound);
642 LOGWARNING(anna::Logger::warning("Received DPA With Result-Code = DIAMETER_SUCCESS. Disconnect now.", ANNA_FILE_LOCATION));
643 immediateUnbind = true;
649 HopByHop hopByHop = codec::functions::getHopByHop(db); // context identification
650 Response* response = response_find(hopByHop);
652 // Out-of-context responses:
655 oamModule.count(OamModule::Counter::AnswerReceivedUnknown);
656 oamModule.count(OamModule::Counter::AnswerReceivedOnClientSessionUnknown);
657 oamModule.activateAlarm(OamModule::Alarm::AnswerReceivedOnClientSessionUnknown);
659 // application message counters
660 ApplicationMessageOamModule::instantiate().count(cid.first, anna::diameter::codec::functions::getApplicationId(db), ApplicationMessageOamModule::Counter::Answer_UnknownReceived_AsClient);
662 eventUnknownResponse(db);
663 string msg(asString());
664 msg += anna::functions::asString(" | Response received from entity, for non registered context (HopByHop: %u)", hopByHop);
665 throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
668 response->setResultCode(Response::ResultCode::Success);
669 response->cancelTimer();
671 string msg("diameter::comm::ClientSession::receive | ");
673 msg += " | Received answer";
674 msg += response->asString();
675 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
678 anna::Millisecond current = (anna::Millisecond)anna::functions::millisecond();
679 anna::Millisecond request = response->getRequest()->getRequestTimestampMs();
680 anna::Millisecond timeToAnswerMs = current - request;
681 a_parent->updateProcessingTimeStatisticConcept(timeToAnswerMs);
684 std::string msg = "This diameter request context lasted ";
685 msg += anna::functions::asString(timeToAnswerMs);
686 msg += " milliseconds at diameter server (included network time)";
687 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
689 // Progress origin for tracking purposes on asyncronous boxes with both diameter interfaces (entities and clients)
690 Message * requestMessage = const_cast<Message*>(response->getRequest());
691 requestMessage->setRequestServerSessionKey(response->getRequest()->getRequestServerSessionKey()); // -1 means unkown/unset
693 if(cid != helpers::base::COMMANDID__Disconnect_Peer_Answer) {
695 response->setMessage(&db);
696 // Restore received datablock
698 string msg("diameter::comm::ClientSession::receive | Restore answer to original request sequences (hop-by-hop = ");
699 msg += anna::functions::asString(response->getRequest()->getRequestHopByHop());
700 msg += ", end-to-end = ";
701 msg += anna::functions::asString(response->getRequest()->getRequestEndToEnd());
703 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
705 diameter::codec::functions::setHopByHop((anna::DataBlock&)db, response->getRequest()->getRequestHopByHop());
706 diameter::codec::functions::setEndToEnd((anna::DataBlock&)db, response->getRequest()->getRequestEndToEnd());
708 // application message counters
709 if(cid != helpers::base::COMMANDID__Capabilities_Exchange_Answer)
710 ApplicationMessageOamModule::instantiate().count(cid.first, anna::diameter::codec::functions::getApplicationId(db), ApplicationMessageOamModule::Counter::Answer_Received_AsClient);
712 eventResponse(*response);
713 } catch(anna::RuntimeException& ex) {
718 // unbind is automatically performed, anyway we can inform to the application just in case some additional
719 // procedure could be issued:
723 response_erase(response);
727 unbind(immediateUnbind);
730 void ClientSession::finalize() throw() {
731 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "finalize", ANNA_FILE_LOCATION));
733 // Check deprecated entity:
734 const Entity *entity = getParent() /* server */ ->getParent() /* entity */;
735 // Inform father server (availability changes):
736 bool changes = a_parent->refreshAvailability();
738 const Server *server = getParent();
739 bool multipleConnections = (server->getMaxClientSessions() > 1);
740 std::string socket = anna::functions::socketLiteralAsString(getAddress(), getPort());
741 OamModule &oamModule = OamModule::instantiate();
743 if(multipleConnections) {
744 oamModule.activateAlarm(OamModule::Alarm::c_LostAvailabilityOverClientSessionWithServer__s__ClientSessionId__d__, socket.c_str(), getSocketId());
745 oamModule.count(OamModule::Counter::LostAvailabilityOverClientSession);
747 oamModule.activateAlarm(OamModule::Alarm::c_LostAvailabilityOverClientSessionWithServer__s__, socket.c_str());
748 oamModule.count(OamModule::Counter::LostAvailabilityOverClientSession);
752 void ClientSession::recover() throw() {
753 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "recover", ANNA_FILE_LOCATION));
757 } catch(anna::RuntimeException &ex) {
759 anna::comm::ClientSocket * cs = const_cast<anna::comm::ClientSocket*>(a_server->getClientSocket());
761 if(cs) cs->requestClose();
766 // Inform father server (availability changes):
767 bool changes = a_parent->refreshAvailability();
769 const Server *server = getParent();
770 bool multipleConnections = (server->getMaxClientSessions() > 1);
771 std::string socket = anna::functions::socketLiteralAsString(getAddress(), getPort());
772 OamModule &oamModule = OamModule::instantiate();
774 if(multipleConnections) {
775 oamModule.cancelAlarm(OamModule::Alarm::c_LostAvailabilityOverClientSessionWithServer__s__ClientSessionId__d__, socket.c_str(), getSocketId());
776 oamModule.count(OamModule::Counter::RecoveredAvailabilityOverClientSession);
778 oamModule.cancelAlarm(OamModule::Alarm::c_LostAvailabilityOverClientSessionWithServer__s__, socket.c_str());
779 oamModule.count(OamModule::Counter::RecoveredAvailabilityOverClientSession);
783 void ClientSession::sendDWAToServer(const anna::DataBlock& dwrDB)
784 throw(anna::RuntimeException) {
785 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "sendDWAToServer", ANNA_FILE_LOCATION));
786 anna::DataBlock dwa(true);
787 a_engine->readDWA(dwa, dwrDB); // Asume that DWA is valid ...
790 throw anna::RuntimeException("This diameter agent defines an empty DWA message. Remote server never will validate this connection health", ANNA_FILE_LOCATION);
797 //-------------------------------------------------------------------------
798 // Se invoca desde diameter::comm::Timer
799 //-------------------------------------------------------------------------
800 void ClientSession::expireResponse(diameter::comm::Response* response)
802 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "expireResponse", ANNA_FILE_LOCATION));
803 Session::expireResponse(response);
805 OamModule &oamModule = OamModule::instantiate();
806 oamModule.count(OamModule::Counter::RequestSentExpired);
807 oamModule.count(OamModule::Counter::RequestSentOnClientSessionExpired);
808 oamModule.activateAlarm(OamModule::Alarm::RequestSentOnClientSessionExpired);
810 // Check father server idleness:
811 if(idle()) a_parent->childIdle();
814 // LOGDEBUG(anna::Logger::debug("ClientSession is idle after an expiration...", ANNA_FILE_LOCATION));
815 // a_parent->childIdle();
818 // LOGDEBUG(anna::Logger::debug("ClientSession is busy after an expiration...", ANNA_FILE_LOCATION));
823 std::string ClientSession::asString() const
825 string result = Session::asString();
826 result += " | Parent Server: ";
827 result += anna::functions::socketLiteralAsString(getAddress(), getPort());
828 result += " | Auto-recovery: ";
829 result += (a_autoRecovery ? "yes" : "no");
830 result += " | WatchdogState: ";
831 result += asText(a_watchdogState);
832 // Diferente del timeout de ApplicationMessage:
833 result += " | Watchdog Period: ";
834 result += getTimeout().asString();
835 result += " | Hidden: ";
836 result += (hidden() ? "yes" : "no");
839 result += " | MaxConnectionDelay: ";
840 result += a_server->getMaxConnectionDelay().asString();
843 return result += " }";
846 anna::xml::Node* ClientSession::asXML(anna::xml::Node* parent) const
848 anna::xml::Node* result = Session::asXML(parent);
849 parent->createChild("diameter.comm.ClientSession");
850 result->createAttribute("ParentServer", anna::functions::socketLiteralAsString(getAddress(), getPort()));
851 result->createAttribute("AutoRecovery", (a_autoRecovery ? "yes" : "no"));
852 result->createAttribute("WatchdogState", asText(a_watchdogState));
853 // Diferente del timeout de ApplicationMessage:
854 result->createAttribute("WatchdogPeriod", getTimeout().asString());
856 if(a_server) result->createAttribute("MaxConnectionDelay", a_server->getMaxConnectionDelay().asString());
858 result->createAttribute("Hidden", hidden() ? "yes" : "no");
863 const char* ClientSession::asText(const WatchdogState::_v watchdogState)
865 static const char* text [] = { "TimerStopped", "WaitingTimerExpiration", "WaitingDWA" };
866 return text [watchdogState];
870 //------------------------------------------------------------------------------
871 //------------------------------------------------------ ClientSession::expire()
872 //------------------------------------------------------------------------------
873 void ClientSession::expire(anna::timex::Engine *timeController) throw(anna::RuntimeException) {
874 LOGMETHOD(anna::TraceMethod traceMethod(a_className, "expire (watchdog timer)", ANNA_FILE_LOCATION));
876 // The client MUST NOT close the primary connection until the
877 // primary's watchdog timer has expired at least twice without a
878 // response (note that the watchdog is not sent a second time,
880 if(a_watchdogState == WatchdogState::WaitingDWA) {
881 if(a_state == State::Failover) {
882 LOGWARNING(anna::Logger::warning("Unbinding client-session: Tw expired after first DWA missing (2*Tw elapsed)", ANNA_FILE_LOCATION));
884 return; // finalize will stop the stopped timer ...
887 setState(State::Failover);
888 LOGWARNING(anna::Logger::warning("Going to Failover state: first DWA missing", ANNA_FILE_LOCATION));
889 activateTimer(); // another chance on failover
893 // WaitingTimerExpiration arrives here:
894 const Response* sent;
898 } catch(anna::RuntimeException&) {
899 LOGDEBUG(anna::Logger::debug("Failed to send DWR to the server: unbinding ...", ANNA_FILE_LOCATION));
900 setState(State::Failover);
905 LOGDEBUG(if(sent) anna::Logger::debug("DWR sent to the server", ANNA_FILE_LOCATION););
910 void ClientSession::setWatchdogPeriod(const anna::Millisecond & watchdogPeriod) throw() {
911 setTimeout(watchdogPeriod);
914 void ClientSession::setWatchdogState(WatchdogState::_v wState) throw() {
917 if(wState != a_watchdogState) {
918 std::string msg("Session watchdog state change: ");
919 msg += asText(a_watchdogState);
921 msg += asText(wState);
922 anna::Logger::debug(msg, ANNA_FILE_LOCATION);
925 a_watchdogState = wState;
929 void ClientSession::timerStopped() throw() {
930 LOGDEBUG(anna::Logger::debug("Watchdog timer stopped", ANNA_FILE_LOCATION));
931 setWatchdogState(WatchdogState::TimerStopped);
934 void ClientSession::timerStarted() throw() {
935 LOGDEBUG(anna::Logger::debug("Watchdog timer started", ANNA_FILE_LOCATION));
937 if(a_watchdogState == WatchdogState::WaitingDWA) return;
939 setWatchdogState(WatchdogState::WaitingTimerExpiration);
943 //------------------------------------------------------------------------------
944 //---------------------------------- ClientSession::updateIncomingActivityTime()
945 //------------------------------------------------------------------------------
946 void ClientSession::updateIncomingActivityTime() throw() {
947 Session::updateIncomingActivityTime();
948 a_parent->updateIncomingActivityTime();
952 //------------------------------------------------------------------------------
953 //---------------------------------- ClientSession::updateOutgoingActivityTime()
954 //------------------------------------------------------------------------------
955 void ClientSession::updateOutgoingActivityTime(void) throw() {
956 Session::updateOutgoingActivityTime();
957 a_parent->updateOutgoingActivityTime();
962 //------------------------------------------------------------------------------
963 //----------------------------------------------- ClientSession::countSendings()
964 //------------------------------------------------------------------------------
965 void ClientSession::countSendings(const diameter::CommandId & cid, unsigned int aid, bool ok)throw() {
966 OamModule &oamModule = OamModule::instantiate();
967 ApplicationMessageOamModule &appMsgOamModule = ApplicationMessageOamModule::instantiate();
969 bool isRequest = cid.second;
973 oamModule.count(isRequest ? OamModule::Counter::RequestSentOK : OamModule::Counter::AnswerSentOK);
974 oamModule.count(isRequest ? OamModule::Counter::RequestSentOnClientSessionOK : OamModule::Counter::AnswerSentOnClientSessionOK);
976 if(cid == helpers::base::COMMANDID__Capabilities_Exchange_Request) oamModule.count(OamModule::Counter::CERSentOK);
977 else if(cid == helpers::base::COMMANDID__Device_Watchdog_Request) oamModule.count(OamModule::Counter::DWRSentOK);
978 else if(cid == helpers::base::COMMANDID__Device_Watchdog_Answer) oamModule.count(OamModule::Counter::DWASentOK); // not usual (dwr was received from server)
979 else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Request) oamModule.count(OamModule::Counter::DPRSentOK);
980 else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Answer) oamModule.count(OamModule::Counter::DPASentOK);
981 // Application messages:
983 appMsgOamModule.count(cid.first, aid, isRequest ? ApplicationMessageOamModule::Counter::Request_SentOK_AsClient : ApplicationMessageOamModule::Counter::Answer_SentOK_AsClient);
987 oamModule.count(isRequest ? OamModule::Counter::RequestSentNOK : OamModule::Counter::AnswerSentNOK);
988 oamModule.count(isRequest ? OamModule::Counter::RequestSentOnClientSessionNOK : OamModule::Counter::AnswerSentOnClientSessionNOK);
990 if(cid == helpers::base::COMMANDID__Capabilities_Exchange_Request) oamModule.count(OamModule::Counter::CERSentNOK);
991 else if(cid == helpers::base::COMMANDID__Device_Watchdog_Request) oamModule.count(OamModule::Counter::DWRSentNOK);
992 else if(cid == helpers::base::COMMANDID__Device_Watchdog_Answer) oamModule.count(OamModule::Counter::DWASentNOK); // not usual (dwr was received from server)
993 else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Request) oamModule.count(OamModule::Counter::DPRSentNOK);
994 else if(cid == helpers::base::COMMANDID__Disconnect_Peer_Answer) oamModule.count(OamModule::Counter::DPASentNOK);
995 // Application messages:
997 appMsgOamModule.count(cid.first, aid, isRequest ? ApplicationMessageOamModule::Counter::Request_SentNOK_AsClient : ApplicationMessageOamModule::Counter::Answer_SentNOK_AsClient);