Avoid service overhead about checking netstat ports
[anna.git] / source / comm / ReceiverFactory.cpp
1 // ANNA - Anna is Not Nothingness Anymore                                                         //
2 //                                                                                                //
3 // (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
4 //                                                                                                //
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 //
7
8
9 #include <anna/core/mt/Guard.hpp>
10
11 #include <anna/xml/Node.hpp>
12 #include <anna/xml/Attribute.hpp>
13
14 #include <anna/comm/ReceiverFactory.hpp>
15 #include <anna/comm/Receiver.hpp>
16
17 using namespace std;
18 using namespace anna;
19
20 comm::ReceiverFactory::ReceiverFactory(const char* name) :
21   a_name(name) {
22   WHEN_SINGLETHREAD(
23     a_receiver = NULL;
24   )
25 }
26
27 //---------------------------------------------------------------------------------------------
28 // En entornos ST solo habra una unica instancia compartida por todos los comm::ClientSocket
29 //---------------------------------------------------------------------------------------------
30 comm::Receiver* comm::ReceiverFactory::create()
31 throw(RuntimeException) {
32   comm::Receiver* result(NULL);
33   WHEN_SINGLETHREAD(
34
35   if((result = a_receiver) == NULL) {
36   result = a_receiver = do_create();
37     result->initialize();
38   }
39   )
40   WHEN_MULTITHREAD(
41     Guard guard(*this, "comm::ReceiverFactory::create");
42     result = do_create();
43     result->initialize();
44   )
45   return result;
46 }
47
48 void comm::ReceiverFactory::release(comm::Receiver* receiver)
49 throw() {
50   WHEN_MULTITHREAD(
51
52   try {
53     Guard guard(*this, "comm::ReceiverFactory::release");
54     do_release(receiver);
55   } catch(RuntimeException& ex) {
56   ex.trace();
57   }
58   );
59 }
60
61 xml::Node* comm::ReceiverFactory::asXML(xml::Node* parent) const
62 throw() {
63   xml::Node* result = parent->createChild("Receiver");
64   result->createAttribute("Name", a_name);
65   return result;
66 }
67
68
69