comparison core/UdpClient.cpp @ 217:c42a6b4dc2d4 mergingClockSync

Recovered some files from ClockSync

  * 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){

 		if (n < 0){
 			return n;
 		}
 		return 1;
 	};
-
+	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;
+  }