diff --git a/Makefile b/Makefile index ded5c18c..6feb3f9a 100644 --- a/Makefile +++ b/Makefile @@ -54,6 +54,9 @@ wfb_tx_cmd: src/tx_cmd.o wfb_tun: src/wfb_tun.o $(CC) -o $@ $^ $(LDFLAGS) -levent_core +wfb_rtsp: src/rtsp_server.c + $(CC) $(shell pkg-config --cflags gstreamer-rtsp-server-1.0) -o $@ $^ $(shell pkg-config --libs gstreamer-rtsp-server-1.0) + test: all_bin PYTHONPATH=`pwd` trial3 wfb_ng.tests diff --git a/scripts/systemd/rtsp@.service b/scripts/systemd/rtsp@.service new file mode 100644 index 00000000..86ee7cc1 --- /dev/null +++ b/scripts/systemd/rtsp@.service @@ -0,0 +1,14 @@ +[Unit] +Description=WFB-ng %i RTSP server +After=network-online.target + +[Service] +ExecStart=/usr/bin/wfb_rtsp %i +Type=simple +Restart=always +RestartSec=1s +TimeoutStopSec=10s +KillMode=control-group + +[Install] +WantedBy=multi-user.target diff --git a/src/rtsp_server.c b/src/rtsp_server.c new file mode 100644 index 00000000..a8824d92 --- /dev/null +++ b/src/rtsp_server.c @@ -0,0 +1,106 @@ +/* + * Copyright (C) 2008 Wim Taymans + * Copyright (C) 2025 Vasily Evseenko + + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; version 3. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + */ + +#include +#include +#include + +/* this timeout is periodically run to clean up the expired sessions from the + * pool. This needs to be run explicitly currently but might be done + * automatically as part of the mainloop. */ + +static gboolean +timeout (GstRTSPServer * server) +{ + GstRTSPSessionPool *pool; + + pool = gst_rtsp_server_get_session_pool (server); + gst_rtsp_session_pool_cleanup (pool); + g_object_unref (pool); + + return TRUE; +} + +int +main (int argc, char *argv[]) +{ + GMainLoop *loop; + GstRTSPServer *server; + GstRTSPMountPoints *mounts; + GstRTSPMediaFactory *factory; + int mode; + char buf[2048]; + + gst_init (&argc, &argv); + + if(argc != 2 || (strcmp(argv[1], "h264") != 0 && strcmp(argv[1], "h265") != 0)) + { + fprintf(stderr, "Usage: %s (h264 | h265)\n", argv[0]); + exit(1); + } + + mode = atoi(argv[1] + 1); + loop = g_main_loop_new (NULL, FALSE); + + /* create a server instance */ + server = gst_rtsp_server_new (); + + /* get the mount points for this server, every server has a default object + * that be used to map uri mount points to media factories */ + mounts = gst_rtsp_server_get_mount_points (server); + + /* make a media factory for a test stream. The default media factory can use + * gst-launch syntax to create pipelines. + * any launch line works as long as it contains elements named pay%d. Each + * element with pay%d names will be a stream */ + + factory = gst_rtsp_media_factory_new (); + + snprintf(buf, sizeof(buf), + "( udpsrc port=5600 ! application/x-rtp,media=video,clock-rate=90000,encoding-name=H%d ! rtph%ddepay ! rtph%dpay name=pay0 pt=96 )", + mode, mode, mode); + + gst_rtsp_media_factory_set_launch (factory, buf); + gst_rtsp_media_factory_set_shared (factory, TRUE); + + /* attach the test factory to the /test url */ + gst_rtsp_mount_points_add_factory (mounts, "/wfb", factory); + + /* don't need the ref to the mapper anymore */ + g_object_unref (mounts); + + /* attach the server to the default maincontext */ + if (gst_rtsp_server_attach (server, NULL) == 0) + goto failed; + + /* add a timeout for the session cleanup */ + g_timeout_add_seconds (2, (GSourceFunc) timeout, server); + + /* start serving, this never stops */ + g_print ("H%d stream ready at rtsp://127.0.0.1:8554/wfb\n", mode); + g_main_loop_run (loop); + + return 0; + + /* ERRORS */ +failed: + { + g_print ("failed to attach the server\n"); + return -1; + } +}