Add support for double-typed buflen to interface.

Author: cboulay

include/lsl/inlet.h

@@ -39,6 +39,8 @@
  * @return A newly created lsl_inlet handle or NULL in the event that an error occurred.
  */
 extern LIBLSL_C_API lsl_inlet lsl_create_inlet(lsl_streaminfo info, int32_t max_buflen, int32_t max_chunklen, int32_t recover);
+extern LIBLSL_C_API lsl_inlet lsl_create_inlet_d(
+	lsl_streaminfo info, double max_buflen, int32_t max_chunklen, int32_t recover);
 
 /**
 * Destructor.

include/lsl/outlet.h

@@ -34,6 +34,8 @@
  * @return A newly created lsl_outlet handle or NULL in the event that an error occurred.
  */
 extern LIBLSL_C_API lsl_outlet lsl_create_outlet(lsl_streaminfo info, int32_t chunk_size, int32_t max_buffered);
+extern LIBLSL_C_API lsl_outlet lsl_create_outlet_d(
+	lsl_streaminfo info, int32_t chunk_size, double max_buffered);
 
 /**
  * Destroy an outlet.

include/lsl_cpp.h

@@ -400,6 +400,10 @@ class stream_outlet {
 		: channel_count(info.channel_count()),
 		  sample_rate(info.nominal_srate()),
 		  obj(lsl_create_outlet(info.handle().get(), chunk_size, max_buffered), &lsl_destroy_outlet) {}
+	stream_outlet(const stream_info &info, int32_t chunk_size, double max_buffered)
+		: channel_count(info.channel_count()), sample_rate(info.nominal_srate()),
+		  obj(lsl_create_outlet_d(info.handle().get(), chunk_size, max_buffered),
+			  &lsl_destroy_outlet) {}
 
 	// ========================================
 	// === Pushing a sample into the outlet ===
@@ -903,6 +907,11 @@ class stream_inlet {
 		bool recover = true)
 		: channel_count(info.channel_count()),
 		  obj(lsl_create_inlet(info.handle().get(), max_buflen, max_chunklen, recover), &lsl_destroy_inlet) {}
+	stream_inlet(const stream_info &info, double max_buflen, int32_t max_chunklen = 0,
+		bool recover = true)
+		: channel_count(info.channel_count()),
+		  obj(lsl_create_inlet_d(info.handle().get(), max_buflen, max_chunklen, recover),
+			  &lsl_destroy_inlet) {}
 
 	/// Return a shared pointer to pass to C-API functions that aren't wrapped yet
 	///

src/lsl_inlet_c.cpp

@@ -14,13 +14,19 @@ extern "C" {
 
 using namespace lsl;
 
-LIBLSL_C_API lsl_inlet lsl_create_inlet(
-	lsl_streaminfo info, int32_t max_buflen, int32_t max_chunklen, int32_t recover) {
+LIBLSL_C_API lsl_inlet lsl_create_inlet_d(
+	lsl_streaminfo info, double max_buflen, int32_t max_chunklen, int32_t recover) {
+	if ((info->nominal_srate() * max_buflen) < 1) max_buflen = 1.5 / info->nominal_srate();
 	return create_object_noexcept<stream_inlet_impl>(*info,
 		(info->nominal_srate() ? (int)(info->nominal_srate() * max_buflen) : max_buflen * 100) + 1,
 		max_chunklen, recover != 0);
 }
 
+LIBLSL_C_API lsl_inlet lsl_create_inlet(
+	lsl_streaminfo info, int32_t max_buflen, int32_t max_chunklen, int32_t recover) {
+	return lsl_create_inlet_d(info, (double)max_buflen, max_chunklen, recover);
+}
+
 LIBLSL_C_API void lsl_destroy_inlet(lsl_inlet in) {
 	try {
 		delete in;

src/lsl_outlet_c.cpp

@@ -15,14 +15,20 @@ extern "C" {
 using namespace lsl;
 
 // boilerplate wrapper code
-LIBLSL_C_API lsl_outlet lsl_create_outlet(
-	lsl_streaminfo info, int32_t chunk_size, int32_t max_buffered) {
+LIBLSL_C_API lsl_outlet lsl_create_outlet_d(
+	lsl_streaminfo info, int32_t chunk_size, double max_buffered) {
 	double buftime = info->nominal_srate();
 	if (buftime <= 0) buftime = 100;
+	if ((buftime * max_buffered) < 1) max_buffered = 1.5 / buftime;
 	return create_object_noexcept<stream_outlet_impl>(
 		*info, chunk_size, static_cast<int>(buftime * max_buffered));
 }
 
+LIBLSL_C_API lsl_outlet lsl_create_outlet(
+	lsl_streaminfo info, int32_t chunk_size, int32_t max_buffered) {
+	return lsl_create_outlet_d(info, chunk_size, (double)max_buffered);
+}
+
 LIBLSL_C_API void lsl_destroy_outlet(lsl_outlet out) {
 	try {
 		delete out;