somewhere

This commit is contained in:
Dhanya Maliakal 2017-11-23 14:53:40 +01:00
parent 8c45f94496
commit ad64df01c7
3 changed files with 14 additions and 17 deletions

View File

@ -170,12 +170,6 @@ class UDPStandardImplementation: private virtual slsReceiverDefs, public UDPBase
*/
void closeFiles();
/**
* Set streaming port and restart sockets if streaming was enabled
* @param i streaming port
*/
void setStreamingPort(const uint32_t i);
private:

View File

@ -160,6 +160,20 @@ public:
void* GetsocketDescriptor () { return socketDescriptor; };
/**
* Connect client socket to server socket
* @returns 1 for fail, 0 for success
*/
int Connect() {
if (zmq_connect(socketDescriptor, serverAddress) < 0) {
PrintError ();
Close ();
return 1;
}
return 0;
}
/**
* Unbinds the Socket
*/

View File

@ -571,17 +571,6 @@ void UDPStandardImplementation::closeFiles() {
}
void UDPStandardImplementation::setStreamingPort(const uint32_t i) {
streamingPort = i;
FILE_LOG(logINFO) << "Streaming Port: " << streamingPort;
if (dataStreamEnable) {
setDataStreamEnable(false);
setDataStreamEnable(true);
}
}
void UDPStandardImplementation::SetLocalNetworkParameters() {
//to increase socket receiver buffer size and max length of input queue by changing kernel settings