Version: 8.3.0
Receivers.hxx
Go to the documentation of this file.
1 // Copyright (C) 2007-2016 CEA/DEN, EDF R&D, OPEN CASCADE
2 //
3 // Copyright (C) 2003-2007 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
5 //
6 // This library is free software; you can redistribute it and/or
7 // modify it under the terms of the GNU Lesser General Public
8 // License as published by the Free Software Foundation; either
9 // version 2.1 of the License, or (at your option) any later version.
10 //
11 // This library is distributed in the hope that it will be useful,
12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 // Lesser General Public License for more details.
15 //
16 // You should have received a copy of the GNU Lesser General Public
17 // License along with this library; if not, write to the Free Software
18 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19 //
20 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
21 //
22 
23 #ifndef _RECEIVERS_HXX_
24 #define _RECEIVERS_HXX_
25 
26 #ifdef HAVE_MPI2
27 #include "mpi.h"
28 #endif
29 #include "SALOME_Comm_i.hxx"
30 #include "Receiver.hxx"
31 
35 template<class T,class TCorba,class TSeqCorba,class CorbaSender,class servForT,class ptrForT>
36 class CorbaNCNoCopyReceiver : public Receiver<T,servForT,ptrForT>
37 {
38 private:
39  CorbaSender _mySender;
40 public:
41  CorbaNCNoCopyReceiver(CorbaSender mySender);
42  ~CorbaNCNoCopyReceiver();
43  T *getValue(long &size);
44 private:
45  T *getDistValue(long &size);
46 };
47 
51 template<class T,class TCorba,class TSeqCorba,class CorbaSender,class servForT,class ptrForT>
52 class CorbaNCWithCopyReceiver : public Receiver<T,servForT,ptrForT>
53 {
54 private:
55  CorbaSender _mySender;
56 public:
57  CorbaNCWithCopyReceiver(CorbaSender mySender);
58  ~CorbaNCWithCopyReceiver();
59  T *getValue(long &size);
60 private:
61  T *getDistValue(long &size);
62 };
63 
67 template<class T,class TCorba,class TSeqCorba,class CorbaSender,class servForT,class ptrForT>
68 class CorbaWCNoCopyReceiver : public Receiver<T,servForT,ptrForT>
69 {
70 private:
71  CorbaSender _mySender;
72 public:
73  CorbaWCNoCopyReceiver(CorbaSender mySender);
74  ~CorbaWCNoCopyReceiver();
75  T *getValue(long &size);
76 private:
77  T *getDistValue(long &size);
78 };
79 
83 template<class T,class TCorba,class TSeqCorba,class CorbaSender,class servForT,class ptrForT>
84 class CorbaWCWithCopyReceiver : public Receiver<T,servForT,ptrForT>
85 {
86 private:
87  CorbaSender _mySender;
88 public:
89  CorbaWCWithCopyReceiver(CorbaSender mySender);
90  ~CorbaWCWithCopyReceiver();
91  T *getValue(long &size);
92 private:
93  T *getDistValue(long &size);
94 };
95 
96 #ifdef HAVE_MPI2
97 
100 template<class T>
101 struct MPITRAITS
102 {
103  static MPI_Datatype MpiType;
104 };
105 
106 template<>
107 MPI_Datatype MPITRAITS<double>::MpiType=MPI_DOUBLE;
108 
109 template<>
110 MPI_Datatype MPITRAITS<int>::MpiType=MPI_INT;
111 
112 template<class T,class CorbaSender,class servForT,class ptrForT>
113 class MPIReceiver : public Receiver<T,servForT,ptrForT>
114 {
115 private:
116  CorbaSender _mySender;
117 public:
118  MPIReceiver(CorbaSender mySender);
119  ~MPIReceiver();
120  T *getValue(long &size);
121 private:
122  T *getDistValue(long &size);
123 };
124 #endif
125 
126 #ifdef HAVE_SOCKET
127 
128 class XDR;
129 
133 template<class T,int (*myFunc)(XDR*,T*),class CorbaSender,class servForT,class ptrForT>
134 class SocketReceiver : public Receiver<T,servForT,ptrForT>
135 {
136 private:
137  CorbaSender _mySender;
138  int _clientSockfd;
139  bool _senderDestruc;
140 public:
141  SocketReceiver(CorbaSender mySender);
142  ~SocketReceiver();
143  T *getValue(long &size);
144 private:
145  T *getDistValue(long &size);
146  void initCom();
147  void connectCom(const char *, int);
148  void closeCom();
149 };
150 #endif
151 
152 #include "Receivers.cxx"
153 
154 #endif
155