lsl-sys 0.1.1

Low-level bindings to the system liblsl library (lab streaming layer).
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

#include "socket_utils.h"
#include "common.h"
#include <boost/endian/conversion.hpp>
#include <boost/system/system_error.hpp>

// === Implementation of the socket utils ===

using namespace lsl;

/// Measure the endian conversion performance of this machine.
double lsl::measure_endian_performance() {
	const double measure_duration = 0.01;
	const double t_end=lsl_clock() + measure_duration;
	uint64_t data=0x01020304;
	double k;
	for (k=0; ((int)k & 0xFF) != 0 || lsl_clock()<t_end; k++)
		lslboost::endian::endian_reverse_inplace(data);
	return k;
}

template <typename Socket, typename Protocol>
uint16_t bind_port_in_range_(Socket &sock, Protocol protocol) {
	const api_config *cfg = api_config::get_instance();
	lslboost::system::error_code ec;
	for (uint16_t port = cfg->base_port(), e = port + cfg->port_range(); port < e; port++) {
		sock.bind(typename Protocol::endpoint(protocol, port), ec);
		if (ec == lslboost::system::errc::address_in_use) continue;
		if (!ec) return port;
	}
	if (cfg->allow_random_ports()) {
		for (int k = 0; k < 100; ++k) {
			uint16_t port = 1025 + rand() % 64000;
			sock.bind(typename Protocol::endpoint(protocol, port), ec);
			if (ec == lslboost::system::errc::address_in_use) continue;
			if (!ec) return port;
		}
	}
	return 0;
}

const std::string all_ports_bound_msg(
	"All local ports were found occupied. You may have more open outlets on this machine than your "
	"PortRange setting allows (see "
	"https://labstreaminglayer.readthedocs.io/info/network-connectivity.html"
	") or you have a problem with your network configuration.");

uint16_t lsl::bind_port_in_range(udp::socket &acc, udp protocol) {
	uint16_t port = bind_port_in_range_(acc, protocol);
	if (!port) throw std::runtime_error(all_ports_bound_msg);
	return port;
}

uint16_t lsl::bind_and_listen_to_port_in_range(tcp::acceptor &sock, tcp protocol, int backlog) {
	uint16_t port = bind_port_in_range_(sock, protocol);
	if (!port) throw std::runtime_error(all_ports_bound_msg);
	sock.listen(backlog);
	return port;
}