comparison core/UdpClient.cpp @ 135:e77e2e712fbc ClockSync

To work with the ClockSync plugin

  * udpClient.cpp
  *
  *  Created on: 19 May 2015
  *      Author: giulio moro
  */
-#include "../include/UdpClient.h"
+#include "UdpClient.h"
 
 	UdpClient::UdpClient(){
 		outSocket=socket(AF_INET, SOCK_DGRAM, 0);
 		isSetPort=false;
 		isSetServer=false;

 		setPort(aPort);
 		setServer(aServerName);
 		isSetPort=true;
 		isSetServer=true;
 		enabled=true;
+    memset(&stTimeOut, 0, sizeof(struct timeval));
 	}
 	UdpClient::~UdpClient(){
 	   close(outSocket);
 	}
 	void UdpClient::setPort(int aPort){

 	int UdpClient::write(const char* remoteHostname, int remotePortNumber, void* sourceBuffer, int numBytesToWrite){
 		setServer(remoteHostname);
 		setPort(remotePortNumber);
 		send(sourceBuffer, numBytesToWrite);
 	}
-
+  int UdpClient::waitUntilReady(bool readyForReading, int timeoutMsecs){
+//	If the socket is ready on return, this returns 1. If it times-out before the socket becomes ready, it returns 0. If an error occurs, it returns -1.
+    if(enabled==false)
+		return -1;
+    if(timeoutMsecs<0)
+		return select(outSocket+1, NULL, &stWriteFDS, NULL, NULL); //calling this with a NULL timeout will block indefinitely
+    FD_ZERO(&stWriteFDS);
+    FD_SET(outSocket, &stWriteFDS);
+	float timeOutSecs=timeoutMsecs*0.001;
+	stTimeOut.tv_sec=(int)timeOutSecs;
+	timeOutSecs-=(int)timeOutSecs;
+	stTimeOut.tv_usec=(int)(timeOutSecs*1000000);
+    int descriptorReady= select(outSocket+1, NULL, &stWriteFDS, NULL, &stTimeOut);
+    return descriptorReady>0? 1 : descriptorReady;
+  }