37 #include <visp3/core/vpConfig.h>
38 #include <visp3/core/vpDebug.h>
39 #include <visp3/core/vpRequest.h>
45 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
46 #include <sys/select.h>
50 #ifdef VISP_HAVE_FUNC_INET_NTOP
52 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
53 #include <arpa/inet.h>
55 #include <netinet/in.h>
56 #include <sys/socket.h>
65 #if defined(__APPLE__) && defined(__MACH__)
66 #include <TargetConditionals.h>
90 #ifndef DOXYGEN_SHOULD_SKIP_THIS
93 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
94 int socketFileDescriptorReceptor;
95 socklen_t receptorAddressSize;
97 SOCKET socketFileDescriptorReceptor;
98 int receptorAddressSize;
100 struct sockaddr_in receptorAddress;
101 std::string receptorIP;
103 vpReceptor() : socketFileDescriptorReceptor(0), receptorAddressSize(), receptorAddress(), receptorIP() { }
108 struct sockaddr_in emitterAddress;
109 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
110 int socketFileDescriptorEmitter;
112 SOCKET socketFileDescriptorEmitter;
114 vpEmitter() : emitterAddress(), socketFileDescriptorEmitter(0)
116 emitterAddress.sin_family = AF_INET;
117 emitterAddress.sin_addr.s_addr = INADDR_ANY;
118 emitterAddress.sin_port = 0;
119 socketFileDescriptorEmitter = 0;
131 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
155 std::vector<int> privHandleRequests();
156 int privHandleFirstRequest();
158 void privReceiveRequest();
159 void privReceiveRequestFrom(
const unsigned int &receptorEmitting);
160 int privReceiveRequestOnce();
161 int privReceiveRequestOnceFrom(
const unsigned int &receptorEmitting);
169 int getReceptorIndex(
const char *name);
180 if (ind >= (
int)request_list.size() || ind < 0)
182 return request_list[(unsigned)ind]->getId();
194 void print(
const char *
id =
"");
196 template <
typename T>
int receive(T *
object,
const unsigned int &sizeOfObject =
sizeof(T));
197 template <
typename T>
198 int receiveFrom(T *
object,
const unsigned int &receptorEmitting,
const unsigned int &sizeOfObject =
sizeof(T));
200 std::vector<int> receiveRequest();
201 std::vector<int> receiveRequestFrom(
const unsigned int &receptorEmitting);
202 int receiveRequestOnce();
203 int receiveRequestOnceFrom(
const unsigned int &receptorEmitting);
205 std::vector<int> receiveAndDecodeRequest();
206 std::vector<int> receiveAndDecodeRequestFrom(
const unsigned int &receptorEmitting);
207 int receiveAndDecodeRequestOnce();
208 int receiveAndDecodeRequestOnceFrom(
const unsigned int &receptorEmitting);
210 void removeDecodingRequest(
const char *);
212 template <
typename T>
int send(T *
object,
const int unsigned &sizeOfObject =
sizeof(T));
213 template <
typename T>
int sendTo(T *
object,
const unsigned int &dest,
const unsigned int &sizeOfObject =
sizeof(T));
216 int sendRequestTo(
vpRequest &req,
const unsigned int &dest);
218 int sendAndEncodeRequest(
vpRequest &req);
219 int sendAndEncodeRequestTo(
vpRequest &req,
const unsigned int &dest);
291 #ifdef TARGET_OS_IPHONE
317 else if (value == 0) {
324 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
325 numbytes = recv(
receptor_list[i].socketFileDescriptorReceptor, (
char *)(
void *)
object, sizeOfObject, 0);
327 numbytes = recv((
unsigned int)
receptor_list[i].socketFileDescriptorReceptor, (
char *)(
void *)
object,
328 (
int)sizeOfObject, 0);
331 std::cout <<
"Disconnected : " << inet_ntoa(
receptor_list[i].receptorAddress.sin_addr) << std::endl;
365 template <
typename T>
370 vpTRACE(
"No receptor at the specified index");
375 #ifdef TARGET_OS_IPHONE
394 else if (value == 0) {
400 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
402 recv(
receptor_list[receptorEmitting].socketFileDescriptorReceptor, (
char *)(
void *)
object, sizeOfObject, 0);
404 numbytes = recv((
unsigned int)
receptor_list[receptorEmitting].socketFileDescriptorReceptor,
405 (
char *)(
void *)
object, (
int)sizeOfObject, 0);
408 std::cout <<
"Disconnected : " << inet_ntoa(
receptor_list[receptorEmitting].receptorAddress.sin_addr)
440 template <
typename T>
int vpNetwork::send(T *
object,
const unsigned int &sizeOfObject)
450 #if defined(__linux__)
451 flags = MSG_NOSIGNAL;
454 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
455 return sendto(
receptor_list[0].socketFileDescriptorReceptor, (
const char *)(
void *)
object, sizeOfObject, flags,
458 return sendto(
receptor_list[0].socketFileDescriptorReceptor, (
const char *)(
void *)
object, (
int)sizeOfObject, flags,
484 template <
typename T>
int vpNetwork::sendTo(T *
object,
const unsigned int &dest,
const unsigned int &sizeOfObject)
488 vpTRACE(
"No receptor at the specified index.");
494 #if defined(__linux__)
495 flags = MSG_NOSIGNAL;
498 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__)))
499 return sendto(
receptor_list[dest].socketFileDescriptorReceptor, (
const char *)(
void *)
object, sizeOfObject, flags,
502 return sendto(
receptor_list[dest].socketFileDescriptorReceptor, (
const char *)(
void *)
object, (
int)sizeOfObject,
This class represents a Transmission Control Protocol (TCP) network.
int sendTo(T *object, const unsigned int &dest, const unsigned int &sizeOfObject=sizeof(T))
std::string getRequestIdFromIndex(const int &ind)
fd_set readFileDescriptor
void setTimeoutUSec(const long &usec)
int receiveFrom(T *object, const unsigned int &receptorEmitting, const unsigned int &sizeOfObject=sizeof(T))
void setVerbose(const bool &mode)
std::string currentMessageReceived
std::vector< vpRequest * > request_list
int send(T *object, const int unsigned &sizeOfObject=sizeof(T))
std::vector< vpReceptor > receptor_list
void setTimeoutSec(const long &sec)
int receive(T *object, const unsigned int &sizeOfObject=sizeof(T))
unsigned int getMaxSizeReceivedMessage()
unsigned int max_size_message
void setMaxSizeReceivedMessage(const unsigned int &s)
This the request that will transit on the network.