Update liblcb

Author: rozhuk-im

conf/msd_channels.conf

@@ -92,21 +92,21 @@
 
 
 <channel>
-	<name>cam_angara.ts</name>
+	<name>test.tstest.ts</name>
 	<hubProfileName>default-HD</hubProfileName>
 	<precache>8192</precache>
 	<sourceList>
 		<source>
 			<type>tcp-http</type>
 			<MPEG2TS> <!-- Overwrite hub param same name flag if set. -->
-				<fEnable>yes</fEnable> <!-- Enable MPEG2-TS analyzer. Overwrite hub param same name flag if set. -->
+				<fEnable>no</fEnable> <!-- Enable MPEG2-TS analyzer. Overwrite hub param same name flag if set. -->
 			</MPEG2TS>
 			<sourceProfileName>tcp-http-default</sourceProfileName> <!-- Profile template. -->
 			<tcp> <!-- For: tcp- and tcp-http. -->
-				<remonteHostname>194.143.148.19:8081</remonteHostname>
+				<remonteHostname>127.0.0.1:7088</remonteHostname>
 			</tcp>
 			<http>
-				<urlPath>udp/239.16.150.1:1234</urlPath>
+				<urlPath>udp/239.0.0.1:1234</urlPath>
 			</http>
 		</source>
 	</sourceList>

readme.md

@@ -4,7 +4,7 @@
 [![Build-Ubuntu-latest Actions Status](https://github.com/rozhuk-im/msd/workflows/build-ubuntu-latest/badge.svg)](https://github.com/rozhuk-im/msd/actions)
 
 
-Rozhuk Ivan <rozhuk.im@gmail.com> 2011-2025
+Rozhuk Ivan <rozhuk.im@gmail.com> 2011-2026
 
 msd - Multi stream daemon.
 Program for organizing IP TV streaming on the network via HTTP.

src/liblcb

@@ -1,5 +1,5 @@
 /*-
- * Copyright (c) 2011-2025 Rozhuk Ivan <rozhuk.im@gmail.com>
+ * Copyright (c) 2011-2026 Rozhuk Ivan <rozhuk.im@gmail.com>
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -520,6 +520,7 @@ main(int argc, char *argv[]) {
 	const uint8_t *data;
 	size_t data_size;
 	tp_settings_t tp_s;
+	tp_params_t tp_prms;
 	http_srv_settings_t http_s;
 
 	error = read_file(cmd_line_data.cfg_file_name, 0, 0, 0,
@@ -556,18 +557,29 @@ main(int argc, char *argv[]) {
 		sys_res_limits_xml(data, data_size);
 	}
 
+	/* Thread pool. */
 	/* Thread pool settings. */
 	tp_settings_def(&tp_s);
 	if (0 == MSD_CFG_GET_VAL_DATA(NULL, &data, &data_size,
 	    "threadPool", NULL)) {
 		tp_settings_load_xml(data, data_size, &tp_s);
 	}
-	error = tp_create(&tp_s, &tp);
+	/* Params. */
+	memset(&tp_prms, 0x00, sizeof(tp_prms));
+	strlcpy(tp_prms.name, "Events pool", sizeof(tp_prms.name));
+	tp_prms.flags = TP_P_F_CLOEXEC;
+	error = tp_create(&tp_s, &tp_prms, &tp);
 	if (0 != error) {
 		SYSLOG_ERR(LOG_CRIT, error, "tp_create().");
 		goto err_out;
 	}
-	tp_threads_create(tp, 1);// XXX exit rewrite
+
+	/* Create and start threads. */
+	error = tp_threads_create(tp);
+	if (0 != error) {
+		SYSLOG_ERR(LOG_CRIT, error, "tp_threads_create().");
+		goto err_out;
+	}
 
 
 	error = str_hubs_bckt_create(tp, PACKAGE_NAME"/"PACKAGE_VERSION, &shbskt);
@@ -682,8 +694,10 @@ main(int argc, char *argv[]) {
 #endif
 
 	/* Receive and process packets. */
-	tp_thread_attach_first(g_data.tp);
-	tp_shutdown_wait(g_data.tp);
+	error = tp_shutdown_wait(g_data.tp);
+	if (0 != error) {
+		SYSLOG_ERR(LOG_ERR, error, "tp_shutdown_wait().");
+	}
 
 	/* Deinitialization... */
 	http_srv_shutdown(g_data.http_srv); /* No more new clients. */

src/msd.c

@@ -1,5 +1,5 @@
 /*-
- * Copyright (c) 2012-2024 Rozhuk Ivan <rozhuk.im@gmail.com>
+ * Copyright (c) 2012-2026 Rozhuk Ivan <rozhuk.im@gmail.com>
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -894,9 +894,9 @@ str_hub_cli_attach(str_hub_p str_hub, str_hub_cli_p strh_cli) {
 
 	sa_addr_port_to_str(&strh_cli->remonte_addr, straddr, sizeof(straddr), NULL);
 	/* Tune socket. */
-	error = skt_opts_apply_ex(tp_task_ident_get(strh_cli->tptask),
+	error = skt_opts_apply(tp_task_ident_get(strh_cli->tptask),
 	    SO_F_TCP_ES_CONN_MASK, &str_hub->s.skt_opts, 0, NULL);
-	SYSLOG_ERR(LOG_WARNING, error, "%s - %s: skt_opts_apply_ex().",
+	SYSLOG_ERR(LOG_WARNING, error, "%s - %s: skt_opts_apply().",
 	    str_hub->name, straddr);
 	syslog(LOG_INFO,
 	    "%s - %s: attached, cli_count = %zu, snd_block_min_size = %zu, precache = %zu.",

src/stream_hub.c

@@ -1,5 +1,5 @@
 /*-
- * Copyright (c) 2012-2025 Rozhuk Ivan <rozhuk.im@gmail.com>
+ * Copyright (c) 2012-2026 Rozhuk Ivan <rozhuk.im@gmail.com>
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -59,6 +59,7 @@
 #include "proto/http.h"
 #include "crypto/hash/md5.h"
 #include "utils/xml.h"
+#include "utils/strh2num.h"
 
 #include "stream_mpeg2ts.h"
 #include "stream_src.h"
@@ -729,11 +730,11 @@ str_src_start(str_src_p src) {
 			}
 		}
 		/* Tune socket. */
-		error = skt_opts_apply_ex(skt, SO_F_UDP_BIND_AF_MASK,
+		error = skt_opts_apply(skt, SO_F_UDP_BIND_AF_MASK,
 		    &s->skt_opts, conn_udp->addr.ss_family, NULL);
 		if (0 != error) {
 			SYSLOG_ERR(LOG_ERR, error,
-			    "skt_opts_apply_ex(SO_F_UDP_BIND_AF_MASK) fail.");
+			    "skt_opts_apply(SO_F_UDP_BIND_AF_MASK) fail.");
 			goto err_out;
 		}
 		/* Create IO task for socket. */
@@ -940,12 +941,12 @@ str_src_connected(tp_task_p tptask, int error, void *arg) {
 	}
 	/* Connected! */
 	/* Tune socket. */
-	error = skt_opts_apply_ex(tp_task_ident_get(tptask),
+	error = skt_opts_apply(tp_task_ident_get(tptask),
 	    (SO_F_TCP_ES_CONN_MASK & ~SO_F_HALFCLOSE_RDWR),
 	    &src->s.skt_opts, 0, NULL);
 	if (0 != error) {
 		SYSLOG_ERR(LOG_NOTICE, error,
-		    "skt_opts_apply_ex(SO_F_TCP_ES_CONN_MASK & ~SO_F_HALFCLOSE_RDWR) fail.");
+		    "skt_opts_apply(SO_F_TCP_ES_CONN_MASK & ~SO_F_HALFCLOSE_RDWR) fail.");
 		goto err_out;
 	}
 
@@ -1003,10 +1004,10 @@ str_src_send_http_req_done_cb(tp_task_p tptask, int error, io_buf_p buf __unused
 
 	tp_task_stop(tptask);
 
-	error = skt_opts_apply_ex(tp_task_ident_get(tptask),
+	error = skt_opts_apply(tp_task_ident_get(tptask),
 	    SO_F_HALFCLOSE_WR, &src->s.skt_opts, 0, NULL);
 	SYSLOG_ERR(LOG_NOTICE, error,
-	    "skt_opts_apply_ex(SO_F_HALFCLOSE_WR) fail, not fatal.");
+	    "skt_opts_apply(SO_F_HALFCLOSE_WR) fail, not fatal.");
 
 	/* Convert to "ready to read notifier". */
 	tp_task_tp_cb_func_set(tptask, tp_task_notify_handler);
@@ -1134,6 +1135,35 @@ str_src_recv_http_cb(tp_task_p tptask, int error, uint32_t eof,
 	return (TP_TASK_CB_CONTINUE);
 }
 
+/* 
+ * HexNumCRLF
+ * dataCRLF
+ * HexNum
+ */
+static int
+http_data_chunked_size(const uint8_t *buf, const size_t buf_size,
+    size_t *chunk_size, size_t *chunk_marker_size) {
+	uint8_t *ptr_end;
+
+	if (NULL == buf || 5 > buf_size) /* 5 - min size: CRLF + num + CRLF */
+		return (EINVAL);
+	if ('\r' != buf[0] || '\n' != buf[1])
+		return (EINVAL);
+	ptr_end = mem_find_off(2, buf, buf_size, CRLF, 2);
+	if (NULL == ptr_end ||
+	    3 > (ptr_end - buf))
+		return (EINVAL);
+
+	if (NULL != chunk_size) {
+		(*chunk_size) = ustrh2usize((buf + 2), (size_t)((ptr_end - (buf + 2))));
+	}
+	if (NULL != chunk_marker_size) {
+		(*chunk_marker_size) = (size_t)((ptr_end - buf) + 2);
+	}
+
+	return (0);
+}
+
 static int
 str_src_recv_tcp_cb(tp_task_p tptask, int error, uint32_t eof,
     size_t data2transfer_size, void *arg) {