source/comm/Service.cpp

   1 // ANNA - Anna is Not Nothingness Anymore
   2 //
   3 // (c) Copyright 2005-2014 Eduardo Ramos Testillano & Francisco Ruiz Rayo
   4 //
   5 // https://bitbucket.org/testillano/anna
   6 //
   7 // Redistribution and use in source and binary forms, with or without
   8 // modification, are permitted provided that the following conditions
   9 // are met:
  10 //
  11 //     * Redistributions of source code must retain the above copyright
  12 // notice, this list of conditions and the following disclaimer.
  13 //     * Redistributions in binary form must reproduce the above
  14 // copyright notice, this list of conditions and the following disclaimer
  15 // in the documentation and/or other materials provided with the
  16 // distribution.
  17 //     * Neither the name of Google Inc. nor the names of its
  18 // contributors may be used to endorse or promote products derived from
  19 // this software without specific prior written permission.
  20 //
  21 // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  22 // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  23 // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  24 // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  25 // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  26 // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  27 // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  28 // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  29 // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  30 // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  31 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  32 //
  33 // Authors: eduardo.ramos.testillano@gmail.com
  34 //          cisco.tierra@gmail.com
  35
  36
  37 #include <anna/core/tracing/TraceMethod.hpp>
  38 #include <anna/core/tracing/Logger.hpp>
  39
  40 #include <anna/xml/Node.hpp>
  41
  42 #include <anna/comm/Service.hpp>
  43 #include <anna/comm/Server.hpp>
  44
  45 using namespace std;
  46 using namespace anna;
  47
  48 void comm::Service::attach(comm::Server* server)
  49 throw(RuntimeException) {
  50   LOGMETHOD(TraceMethod tm(Logger::Local7, "comm::Service", "attach", ANNA_FILE_LOCATION));
  51   comm::Delivery::add(server);
  52   server->attach(this);
  53 }
  54
  55 //----------------------------------------------------------------------------------
  56 // (1) Cuando no queda ningun recurso disponible se devuelve una excepcion
  57 //----------------------------------------------------------------------------------
  58 comm::Server* comm::Service::send(comm::Message& message)
  59 throw(RuntimeException) {
  60   LOGMETHOD(TraceMethod tm(Logger::Local7, "comm::Service", "send", ANNA_FILE_LOCATION));
  61   comm::Server* tryServer = NULL;
  62   comm::Server* init = NULL;
  63   bool stop = false;
  64   bool sent = false;
  65
  66   while(stop == false) {
  67     tryServer = static_cast <Server*>(Delivery::apply());                 // (1)
  68
  69     try {
  70       if(init == NULL)
  71         init = tryServer;
  72       else if(init == tryServer)
  73         stop = true;
  74
  75       tryServer->send(message);
  76       sent = true;
  77       break;
  78     } catch(RuntimeException& ex) {
  79       ex.trace();
  80       stop = Delivery::fault(tryServer);
  81     }
  82   }
  83
  84   if(sent == false) {
  85     string msg(asString());
  86     msg += " | Service unavailable";
  87     throw RuntimeException(msg, ANNA_FILE_LOCATION);
  88   }
  89
  90   return tryServer;
  91 }
  92
  93 comm::Server* comm::Service::send(comm::Message* message)
  94 throw(RuntimeException) {
  95   if(message == NULL)
  96     throw RuntimeException("comm::Service::send | Cannot send a NULL message", ANNA_FILE_LOCATION);
  97
  98   return (send(*message));
  99 }
 100
 101 int comm::Service::broadcast(comm::Message& message)
 102 throw() {
 103   using namespace anna::comm;
 104   int result = 0;
 105
 106   for(iterator ii = begin(), maxii = end(); ii != maxii; ii ++) {
 107     try {
 108       server(ii)->send(message);
 109       result ++;
 110     } catch(RuntimeException& ex) {
 111       ex.trace();
 112     }
 113   }
 114
 115   LOGDEBUG(
 116     string msg("comm::Service::broadcast | ");
 117     msg += asString();
 118     msg += functions::asText(" | Sents number: ", result);
 119     Logger::debug(msg, ANNA_FILE_LOCATION);
 120   );
 121   return result;
 122 }
 123
 124 int comm::Service::broadcast(comm::Message* message)
 125 throw() {
 126   if(message == NULL) {
 127     Logger::write(Logger::Error, "comm::Service::broadcast | Cannot broadcast a NULL message", ANNA_FILE_LOCATION);
 128     return 0;
 129   }
 130
 131   return broadcast(*message);
 132 }
 133
 134 string comm::Service::asString() const
 135 throw() {
 136   string result("comm::Service { ");
 137   result += Delivery::asString();
 138   result += " | Critical: ";
 139   result += functions::asString(a_isCritical);
 140   return result += " }";
 141 }
 142
 143 xml::Node* comm::Service::asXML(xml::Node* parent) const
 144 throw() {
 145   xml::Node* service = parent->createChild("comm.Service");
 146   Delivery::asXML(service);
 147   service->createAttribute("Critical", functions::asString(a_isCritical));
 148   return service;
 149 }
 150
 151 /*static*/
 152 comm::Server* comm::Service::server(comm::Delivery::iterator& ii)
 153 throw() {
 154   return static_cast <Server*>(Delivery::resource(ii));
 155 }
 156
 157 /*static*/
 158 const comm::Server* comm::Service::server(comm::Delivery::const_iterator& ii)
 159 throw() {
 160   return static_cast <const Server*>(Delivery::resource(ii));
 161 }
 162