Compare commits

...

28 Commits
v1.6 ... v1.12

Author SHA1 Message Date
Devaev Maxim
60ca92d367 Bump version: 1.11 → 1.12 2020-02-19 16:46:38 +03:00
Devaev Maxim
4f44c5efa1 hint 2020-02-19 16:46:13 +03:00
Devaev Maxim
3504095871 refactoring 2020-02-19 08:56:50 +03:00
Devaev Maxim
6eeb49ef75 merged ctl options 2020-02-19 08:56:50 +03:00
Devaev Maxim
9353b3474a options to reset image settings to default 2020-02-19 08:56:50 +03:00
Maxim Devaev
dfc98a67f2 Update README.ru.md 2020-02-10 06:40:25 +03:00
Maxim Devaev
904c76fa93 Update README.md 2020-02-10 06:39:37 +03:00
Devaev Maxim
f0a7ca5c94 Issue #14: added message about fileserver 2020-01-30 03:53:06 +03:00
Devaev Maxim
bb4e9db7e7 fixed serving of empty static files 2020-01-29 20:20:53 +03:00
Devaev Maxim
61f2bfa00e fixed mime guessing 2020-01-29 20:13:31 +03:00
Devaev Maxim
49eb7f6e51 fixed clang 'linker' input unused 2020-01-19 17:23:41 +03:00
Devaev Maxim
b5375b835a Fixed #11: clang warning 2020-01-19 01:07:57 +03:00
Devaev Maxim
e3e2c5cead Bump version: 1.10 → 1.11 2020-01-14 16:49:50 +03:00
Devaev Maxim
ef4150877b check for 8 bits 2020-01-14 16:46:31 +03:00
Devaev Maxim
cc00d0fea3 Bump version: 1.9 → 1.10 2019-10-21 08:20:45 +03:00
Devaev Maxim
91a1e48a7c refactoring; renamed X-UStreamer-*-Time to X-UStreamer-*-Timestamp 2019-10-21 08:16:19 +03:00
Devaev Maxim
f381113d50 new arch pkg extension 2019-10-17 02:58:56 +03:00
Devaev Maxim
a6304959f4 Bump version: 1.8 → 1.9 2019-10-11 23:37:25 +03:00
Devaev Maxim
57bc6e160d keep original argv 2019-10-11 23:37:05 +03:00
Devaev Maxim
03dd5dfebb Bump version: 1.7 → 1.8 2019-10-11 08:23:40 +03:00
Devaev Maxim
00ef8928b3 temporary disabled setproctitle to avoid memory corruption 2019-10-11 08:23:04 +03:00
Devaev Maxim
2b338cea90 Bump version: 1.6 → 1.7 2019-10-11 06:42:20 +03:00
Devaev Maxim
e64a1a1688 improved readme 2019-10-11 06:42:06 +03:00
Devaev Maxim
2ad196b95e --features 2019-10-11 06:39:15 +03:00
Devaev Maxim
70c7bcc209 --process-name-prefix 2019-10-11 06:23:32 +03:00
Devaev Maxim
890b248563 ifdef 2019-10-10 23:11:15 +03:00
Devaev Maxim
be2de06b09 manual check if the parent process is alive after prctl() 2019-10-10 23:09:24 +03:00
Devaev Maxim
6175e6974c refactoring 2019-10-10 10:44:12 +03:00
23 changed files with 406 additions and 197 deletions

View File

@@ -1,7 +1,7 @@
[bumpversion] [bumpversion]
commit = True commit = True
tag = True tag = True
current_version = 1.6 current_version = 1.12
parse = (?P<major>\d+)\.(?P<minor>\d+)(\.(?P<patch>\d+)(\-(?P<release>[a-z]+))?)? parse = (?P<major>\d+)\.(?P<minor>\d+)(\.(?P<patch>\d+)(\-(?P<release>[a-z]+))?)?
serialize = serialize =
{major}.{minor} {major}.{minor}

1
.gitignore vendored
View File

@@ -2,6 +2,7 @@
/pkg/arch/src/ /pkg/arch/src/
/pkg/arch/v*.tar.gz /pkg/arch/v*.tar.gz
/pkg/arch/ustreamer-*.pkg.tar.xz /pkg/arch/ustreamer-*.pkg.tar.xz
/pkg/arch/ustreamer-*.pkg.tar.zst
/build/ /build/
/config.mk /config.mk
/vgcore.* /vgcore.*

View File

@@ -44,6 +44,15 @@ override CFLAGS += -DWITH_PTHREAD_NP
endif endif
WITH_SETPROCTITLE ?= 1
ifneq ($(call optbool,$(WITH_SETPROCTITLE)),)
ifeq ($(shell uname -s | tr A-Z a-z),linux)
_LIBS += -lbsd
endif
override CFLAGS += -DWITH_SETPROCTITLE
endif
# ===== # =====
all: $(PROG) all: $(PROG)
@@ -78,7 +87,7 @@ $(PROG): $(_SRCS:%.c=$(BUILD)/%.o)
$(BUILD)/%.o: %.c $(BUILD)/%.o: %.c
$(info -- CC $<) $(info -- CC $<)
@ mkdir -p $(dir $@) || true @ mkdir -p $(dir $@) || true
@ $(CC) $< -o $@ $(CFLAGS) $(_LIBS) @ $(CC) $< -o $@ $(CFLAGS)
release: release:
@@ -100,5 +109,5 @@ push:
clean-all: clean clean-all: clean
clean: clean:
rm -rf pkg/arch/pkg pkg/arch/src pkg/arch/v*.tar.gz pkg/arch/ustreamer-*.pkg.tar.xz rm -rf pkg/arch/pkg pkg/arch/src pkg/arch/v*.tar.gz pkg/arch/ustreamer-*.pkg.tar.{xz,zst}
rm -rf $(PROG) $(BUILD) vgcore.* *.sock rm -rf $(PROG) $(BUILD) vgcore.* *.sock

View File

@@ -30,9 +30,9 @@ If you're going to live-stream from your backyard webcam and need to control it,
----- -----
# Building # Building
You'll need ```make```, ```gcc```, ```libevent``` with ```pthreads``` support, ```libjpeg8```/```libjpeg-turbo``` and ```libuuid```. You'll need ```make```, ```gcc```, ```libevent``` with ```pthreads``` support, ```libjpeg8```/```libjpeg-turbo```, ```libuuid``` and ```libbsd``` (only for Linux).
On Raspberry Pi you can build the program with OpenMAX IL. To do this pass option ```WITH_OMX=1``` to ```make```. To enable GPIO support install [wiringPi](http://wiringpi.com) and pass option ```WITH_GPIO=1```. If the compiler reports about a missing function ```pthread_get_name_np()``` (or similar), add option ```WITH_PTHREAD_NP=0``` (it's enabled by default). On Raspberry Pi you can build the program with OpenMAX IL. To do this pass option ```WITH_OMX=1``` to ```make```. To enable GPIO support install [wiringPi](http://wiringpi.com) and pass option ```WITH_GPIO=1```. If the compiler reports about a missing function ```pthread_get_name_np()``` (or similar), add option ```WITH_PTHREAD_NP=0``` (it's enabled by default). For the similar error with ```setproctitle()``` add option ```WITH_SETPROCTITLE=0```.
``` ```
$ git clone --depth=1 https://github.com/pikvm/ustreamer $ git clone --depth=1 https://github.com/pikvm/ustreamer
@@ -64,6 +64,10 @@ $ ./ustreamer \
You can always view the full list of options with ```ustreamer --help```. You can always view the full list of options with ```ustreamer --help```.
-----
# Tips
* [Running uStreamer via systemd service](https://github.com/pikvm/ustreamer/issues/16)
----- -----
# License # License
Copyright (C) 2018 by Maxim Devaev mdevaev@gmail.com Copyright (C) 2018 by Maxim Devaev mdevaev@gmail.com

View File

@@ -30,9 +30,9 @@
----- -----
# Сборка # Сборка
Для сборки вам понадобятся ```make```, ```gcc```, ```libevent``` с поддержкой ```pthreads```, ```libjpeg8```/```libjpeg-turbo``` и ```libuuid```. Для сборки вам понадобятся ```make```, ```gcc```, ```libevent``` с поддержкой ```pthreads```, ```libjpeg8```/```libjpeg-turbo```, ```libuuid``` и ```libbsd``` (только для Linux).
На Raspberry Pi программу можно собрать с поддержкой OpenMAX IL. Для этого передайте ```make``` параметр ```WITH_OMX=1```. Для включения сборки с поддержкой GPIO установите [wiringPi](http://wiringpi.com) и добавьте параметр ```WITH_GPIO=1```. Если при сборке компилятор ругается на отсутствие функции ```pthread_get_name_np()``` или другой подобной, добавьте параметр ```WITH_PTHREAD_NP=0``` (по умолчанию он включен). На Raspberry Pi программу можно собрать с поддержкой OpenMAX IL. Для этого передайте ```make``` параметр ```WITH_OMX=1```. Для включения сборки с поддержкой GPIO установите [wiringPi](http://wiringpi.com) и добавьте параметр ```WITH_GPIO=1```. Если при сборке компилятор ругается на отсутствие функции ```pthread_get_name_np()``` или другой подобной, добавьте параметр ```WITH_PTHREAD_NP=0``` (по умолчанию он включен). При аналогичной ошибке с функцией ```setproctitle()``` добавьте параметр ```WITH_SETPROCTITLE=0```.
``` ```
$ git clone --depth=1 https://github.com/pikvm/ustreamer $ git clone --depth=1 https://github.com/pikvm/ustreamer
@@ -64,6 +64,10 @@ $ ./ustreamer \
За полным списком опций обращайтесь ко встроенной справке: ```ustreamer --help```. За полным списком опций обращайтесь ко встроенной справке: ```ustreamer --help```.
-----
# Советы
* [Запуск с помощью systemd-сервиса](https://github.com/pikvm/ustreamer/issues/16)
----- -----
# Лицензия # Лицензия
Copyright (C) 2018 by Maxim Devaev mdevaev@gmail.com Copyright (C) 2018 by Maxim Devaev mdevaev@gmail.com

View File

@@ -3,13 +3,13 @@
pkgname=ustreamer pkgname=ustreamer
pkgver=1.6 pkgver=1.12
pkgrel=1 pkgrel=1
pkgdesc="Lightweight and fast MJPG-HTTP streamer" pkgdesc="Lightweight and fast MJPG-HTTP streamer"
url="https://github.com/pikvm/ustreamer" url="https://github.com/pikvm/ustreamer"
license=(GPL) license=(GPL)
arch=(i686 x86_64 armv6h armv7h) arch=(i686 x86_64 armv6h armv7h)
depends=(libjpeg libevent libutil-linux) depends=(libjpeg libevent libutil-linux libbsd)
# optional: raspberrypi-firmware for OMX encoder # optional: raspberrypi-firmware for OMX encoder
# optional: wiringpi for GPIO support # optional: wiringpi for GPIO support
makedepends=(gcc make) makedepends=(gcc make)

View File

@@ -18,6 +18,7 @@ DEPEND="
>=dev-libs/libevent-2.1.8 >=dev-libs/libevent-2.1.8
>=media-libs/libjpeg-turbo-1.5.3 >=media-libs/libjpeg-turbo-1.5.3
>=sys-apps/util-linux-2.33 >=sys-apps/util-linux-2.33
>=dev-libs/libbsd-0.9.1
" "
RDEPEND="${DEPEND}" RDEPEND="${DEPEND}"
BDEPEND="" BDEPEND=""

View File

@@ -6,7 +6,7 @@
include $(TOPDIR)/rules.mk include $(TOPDIR)/rules.mk
PKG_NAME:=ustreamer PKG_NAME:=ustreamer
PKG_VERSION:=1.6 PKG_VERSION:=1.12
PKG_RELEASE:=1 PKG_RELEASE:=1
PKG_MAINTAINER:=Maxim Devaev <mdevaev@gmail.com> PKG_MAINTAINER:=Maxim Devaev <mdevaev@gmail.com>
@@ -25,7 +25,7 @@ define Package/ustreamer
SECTION:=multimedia SECTION:=multimedia
CATEGORY:=Multimedia CATEGORY:=Multimedia
TITLE:=uStreamer TITLE:=uStreamer
DEPENDS:=+libpthread +libjpeg +libv4l +libuuid +libevent2 +libevent2-core +libevent2-extra +libevent2-pthreads DEPENDS:=+libpthread +libjpeg +libv4l +libuuid +libbsd +libevent2 +libevent2-core +libevent2-extra +libevent2-pthreads
URL:=https://github.com/pikvm/ustreamer URL:=https://github.com/pikvm/ustreamer
endef endef

View File

@@ -23,5 +23,5 @@
#pragma once #pragma once
#ifndef VERSION #ifndef VERSION
# define VERSION "1.6" # define VERSION "1.12"
#endif #endif

View File

@@ -77,9 +77,10 @@ static int _device_open_mmap(struct device_t *dev);
static int _device_open_queue_buffers(struct device_t *dev); static int _device_open_queue_buffers(struct device_t *dev);
static void _device_open_alloc_picbufs(struct device_t *dev); static void _device_open_alloc_picbufs(struct device_t *dev);
static int _device_apply_resolution(struct device_t *dev, unsigned width, unsigned height); static int _device_apply_resolution(struct device_t *dev, unsigned width, unsigned height);
static void _device_apply_controls(struct device_t *dev); static void _device_apply_controls(struct device_t *dev);
static int _device_check_control(struct device_t *dev, const char *name, unsigned cid, int value, bool quiet); static int _device_query_control(struct device_t *dev, struct v4l2_queryctrl *query, const char *name, unsigned cid, bool quiet);
static void _device_set_control(struct device_t *dev, const char *name, unsigned cid, int value, bool quiet); static void _device_set_control(struct device_t *dev, struct v4l2_queryctrl *query, const char *name, unsigned cid, int value, bool quiet);
static const char *_format_to_string_fourcc(char *buf, size_t size, unsigned format); static const char *_format_to_string_fourcc(char *buf, size_t size, unsigned format);
static const char *_format_to_string_nullable(unsigned format); static const char *_format_to_string_nullable(unsigned format);
@@ -286,7 +287,7 @@ int device_grab_buffer(struct device_t *dev) {
dev->run->hw_buffers[buf_info.index].used = buf_info.bytesused; dev->run->hw_buffers[buf_info.index].used = buf_info.bytesused;
memcpy(&dev->run->hw_buffers[buf_info.index].buf_info, &buf_info, sizeof(struct v4l2_buffer)); memcpy(&dev->run->hw_buffers[buf_info.index].buf_info, &buf_info, sizeof(struct v4l2_buffer));
dev->run->pictures[buf_info.index]->grab_time = get_now_monotonic(); dev->run->pictures[buf_info.index]->grab_ts = get_now_monotonic();
return buf_info.index; return buf_info.index;
} }
@@ -390,7 +391,7 @@ static int _device_apply_dv_timings(struct device_t *dev) {
LOG_DEBUG("Calling ioctl(VIDIOC_QUERY_DV_TIMINGS) ..."); LOG_DEBUG("Calling ioctl(VIDIOC_QUERY_DV_TIMINGS) ...");
if (xioctl(dev->run->fd, VIDIOC_QUERY_DV_TIMINGS, &dv) == 0) { if (xioctl(dev->run->fd, VIDIOC_QUERY_DV_TIMINGS, &dv) == 0) {
LOG_INFO("Got new DV timings: resolution=%ux%u, pixclk=%llu", LOG_INFO("Got new DV timings: resolution=%ux%u, pixclk=%llu",
dv.bt.width, dv.bt.height, dv.bt.pixelclock); dv.bt.width, dv.bt.height, (unsigned long long)dv.bt.pixelclock); // Issue #11
LOG_DEBUG("Calling ioctl(VIDIOC_S_DV_TIMINGS) ..."); LOG_DEBUG("Calling ioctl(VIDIOC_S_DV_TIMINGS) ...");
if (xioctl(dev->run->fd, VIDIOC_S_DV_TIMINGS, &dv) < 0) { if (xioctl(dev->run->fd, VIDIOC_S_DV_TIMINGS, &dv) < 0) {
@@ -610,65 +611,81 @@ static int _device_apply_resolution(struct device_t *dev, unsigned width, unsign
} }
static void _device_apply_controls(struct device_t *dev) { static void _device_apply_controls(struct device_t *dev) {
# define SET_CID(_cid, _dest, _value, _quiet) { \ # define SET_CID_VALUE(_cid, _field, _value, _quiet) { \
if (_device_check_control(dev, #_dest, _cid, _value, _quiet) == 0) { \ struct v4l2_queryctrl query; \
_device_set_control(dev, #_dest, _cid, _value, _quiet); \ if (_device_query_control(dev, &query, #_field, _cid, _quiet) == 0) { \
_device_set_control(dev, &query, #_field, _cid, _value, _quiet); \
} \ } \
} }
# define SET_CID_MANUAL(_cid, _dest) { \ # define SET_CID_DEFAULT(_cid, _field, _quiet) { \
if (dev->ctl._dest.value_set) { \ struct v4l2_queryctrl query; \
SET_CID(_cid, _dest, dev->ctl._dest.value, false); \ if (_device_query_control(dev, &query, #_field, _cid, _quiet) == 0) { \
_device_set_control(dev, &query, #_field, _cid, query.default_value, _quiet); \
} \ } \
} }
# define SET_CID_AUTO(_cid_auto, _cid_manual, _dest) { \ # define CONTROL_MANUAL_CID(_cid, _field) { \
if (dev->ctl._dest.value_set || dev->ctl._dest.auto_set) { \ if (dev->ctl._field.mode == CTL_MODE_VALUE) { \
SET_CID(_cid_auto, _dest##_auto, dev->ctl._dest.auto_set, dev->ctl._dest.value_set); \ SET_CID_VALUE(_cid, _field, dev->ctl._field.value, false); \
SET_CID_MANUAL(_cid_manual, _dest); \ } else if (dev->ctl._field.mode == CTL_MODE_DEFAULT) { \
SET_CID_DEFAULT(_cid, _field, false); \
} \ } \
} }
SET_CID_AUTO (V4L2_CID_AUTOBRIGHTNESS, V4L2_CID_BRIGHTNESS, brightness); # define CONTROL_AUTO_CID(_cid_auto, _cid_manual, _field) { \
SET_CID_MANUAL ( V4L2_CID_CONTRAST, contrast); if (dev->ctl._field.mode == CTL_MODE_VALUE) { \
SET_CID_MANUAL ( V4L2_CID_SATURATION, saturation); SET_CID_VALUE(_cid_auto, _field##_auto, 0, true); \
SET_CID_AUTO (V4L2_CID_HUE_AUTO, V4L2_CID_HUE, hue); SET_CID_VALUE(_cid_manual, _field, dev->ctl._field.value, false); \
SET_CID_MANUAL ( V4L2_CID_GAMMA, gamma); } else if (dev->ctl._field.mode == CTL_MODE_AUTO) { \
SET_CID_MANUAL ( V4L2_CID_SHARPNESS, sharpness); SET_CID_VALUE(_cid_auto, _field##_auto, 1, false); \
SET_CID_MANUAL ( V4L2_CID_BACKLIGHT_COMPENSATION, backlight_compensation); } else if (dev->ctl._field.mode == CTL_MODE_DEFAULT) { \
SET_CID_AUTO (V4L2_CID_AUTO_WHITE_BALANCE, V4L2_CID_WHITE_BALANCE_TEMPERATURE, white_balance); SET_CID_VALUE(_cid_auto, _field##_auto, 0, true); /* Reset inactive flag */ \
SET_CID_AUTO (V4L2_CID_AUTOGAIN, V4L2_CID_GAIN, gain); SET_CID_DEFAULT(_cid_manual, _field, false); \
SET_CID_DEFAULT(_cid_auto, _field##_auto, false); \
} \
}
# undef SET_CID_AUTO CONTROL_AUTO_CID (V4L2_CID_AUTOBRIGHTNESS, V4L2_CID_BRIGHTNESS, brightness);
# undef SET_CID_MANUAL CONTROL_MANUAL_CID ( V4L2_CID_CONTRAST, contrast);
# undef SET_CID CONTROL_MANUAL_CID ( V4L2_CID_SATURATION, saturation);
CONTROL_AUTO_CID (V4L2_CID_HUE_AUTO, V4L2_CID_HUE, hue);
CONTROL_MANUAL_CID ( V4L2_CID_GAMMA, gamma);
CONTROL_MANUAL_CID ( V4L2_CID_SHARPNESS, sharpness);
CONTROL_MANUAL_CID ( V4L2_CID_BACKLIGHT_COMPENSATION, backlight_compensation);
CONTROL_AUTO_CID (V4L2_CID_AUTO_WHITE_BALANCE, V4L2_CID_WHITE_BALANCE_TEMPERATURE, white_balance);
CONTROL_AUTO_CID (V4L2_CID_AUTOGAIN, V4L2_CID_GAIN, gain);
# undef CONTROL_AUTO_CID
# undef CONTROL_MANUAL_CID
# undef SET_CID_DEFAULT
# undef SET_CID_VALUE
} }
static int _device_check_control(struct device_t *dev, const char *name, unsigned cid, int value, bool quiet) { static int _device_query_control(struct device_t *dev, struct v4l2_queryctrl *query, const char *name, unsigned cid, bool quiet) {
struct v4l2_queryctrl query; MEMSET_ZERO(*query);
query->id = cid;
MEMSET_ZERO(query); if (xioctl(dev->run->fd, VIDIOC_QUERYCTRL, query) < 0 || query->flags & V4L2_CTRL_FLAG_DISABLED) {
query.id = cid;
if (xioctl(dev->run->fd, VIDIOC_QUERYCTRL, &query) < 0 || query.flags & V4L2_CTRL_FLAG_DISABLED) {
if (!quiet) { if (!quiet) {
LOG_ERROR("Changing control %s is unsupported", name); LOG_ERROR("Changing control %s is unsupported", name);
} }
return -1; return -1;
} }
if (value < query.minimum || value > query.maximum || value % query.step != 0) {
if (!quiet) {
LOG_ERROR("Invalid value %d of control %s: min=%d, max=%d, default=%d, step=%u",
value, name, query.minimum, query.maximum, query.default_value, query.step);
}
return -2;
}
return 0; return 0;
} }
static void _device_set_control(struct device_t *dev, const char *name, unsigned cid, int value, bool quiet) { static void _device_set_control(struct device_t *dev, struct v4l2_queryctrl *query, const char *name, unsigned cid, int value, bool quiet) {
struct v4l2_control ctl; struct v4l2_control ctl;
if (value < query->minimum || value > query->maximum || value % query->step != 0) {
if (!quiet) {
LOG_ERROR("Invalid value %d of control %s: min=%d, max=%d, default=%d, step=%u",
value, name, query->minimum, query->maximum, query->default_value, query->step);
}
return;
}
MEMSET_ZERO(ctl); MEMSET_ZERO(ctl);
ctl.id = cid; ctl.id = cid;
ctl.value = value; ctl.value = value;
@@ -678,7 +695,7 @@ static void _device_set_control(struct device_t *dev, const char *name, unsigned
LOG_PERROR("Can't set control %s", name); LOG_PERROR("Can't set control %s", name);
} }
} else if (!quiet) { } else if (!quiet) {
LOG_INFO("Using control %s: %d", name, ctl.value); LOG_INFO("Applying control %s: %d", name, ctl.value);
} }
} }

View File

@@ -64,10 +64,16 @@ struct device_runtime_t {
bool capturing; bool capturing;
}; };
enum control_mode_t {
CTL_MODE_NONE = 0,
CTL_MODE_VALUE,
CTL_MODE_AUTO,
CTL_MODE_DEFAULT,
};
struct control_t { struct control_t {
int value; enum control_mode_t mode;
bool value_set; int value;
bool auto_set;
}; };
struct controls_t { struct controls_t {

View File

@@ -201,7 +201,7 @@ int encoder_compress_buffer(struct encoder_t *encoder, struct device_t *dev, uns
assert(encoder->run->type != ENCODER_TYPE_UNKNOWN); assert(encoder->run->type != ENCODER_TYPE_UNKNOWN);
dev->run->pictures[buf_index]->encode_begin_time = get_now_monotonic(); dev->run->pictures[buf_index]->encode_begin_ts = get_now_monotonic();
if (encoder->run->type == ENCODER_TYPE_CPU) { if (encoder->run->type == ENCODER_TYPE_CPU) {
cpu_encoder_compress_buffer(dev, buf_index, encoder->run->quality); cpu_encoder_compress_buffer(dev, buf_index, encoder->run->quality);
@@ -216,7 +216,7 @@ int encoder_compress_buffer(struct encoder_t *encoder, struct device_t *dev, uns
} }
# endif # endif
dev->run->pictures[buf_index]->encode_end_time = get_now_monotonic(); dev->run->pictures[buf_index]->encode_end_ts = get_now_monotonic();
dev->run->pictures[buf_index]->width = dev->run->width; dev->run->pictures[buf_index]->width = dev->run->width;
dev->run->pictures[buf_index]->height = dev->run->height; dev->run->pictures[buf_index]->height = dev->run->height;

View File

@@ -56,7 +56,7 @@ const char *guess_mime_type(const char *path) {
char *dot; char *dot;
char *ext; char *ext;
dot = strchr(path, '.'); dot = strrchr(path, '.');
if (dot == NULL || strchr(dot, '/') != NULL) { if (dot == NULL || strchr(dot, '/') != NULL) {
goto misc; goto misc;
} }

View File

@@ -117,7 +117,7 @@ char *simplify_request_path(const char *str) {
return simplified; return simplified;
} }
#if TEST_HTTP_PATH #ifdef TEST_HTTP_PATH
int test_simplify_request_path(const char *sample, const char *expected) { int test_simplify_request_path(const char *sample, const char *expected) {
char *result = simplify_request_path(sample); char *result = simplify_request_path(sample);

View File

@@ -157,6 +157,7 @@ void http_server_destroy(struct http_server_t *server) {
int http_server_listen(struct http_server_t *server) { int http_server_listen(struct http_server_t *server) {
{ {
if (server->static_path[0] != '\0') { if (server->static_path[0] != '\0') {
LOG_INFO("Enabling HTTP file server: %s", server->static_path);
evhttp_set_gencb(server->run->http, _http_callback_static, (void *)server); evhttp_set_gencb(server->run->http, _http_callback_static, (void *)server);
} else { } else {
assert(!evhttp_set_cb(server->run->http, "/", _http_callback_root, (void *)server)); assert(!evhttp_set_cb(server->run->http, "/", _http_callback_root, (void *)server));
@@ -172,9 +173,9 @@ int http_server_listen(struct http_server_t *server) {
# define EXPOSED(_next) server->run->exposed->_next # define EXPOSED(_next) server->run->exposed->_next
// See _expose_blank_picture() // See _expose_blank_picture()
picture_copy(server->run->blank, EXPOSED(picture)); picture_copy(server->run->blank, EXPOSED(picture));
EXPOSED(expose_begin_time) = get_now_monotonic(); EXPOSED(expose_begin_ts) = get_now_monotonic();
EXPOSED(expose_cmp_time) = EXPOSED(expose_begin_time); EXPOSED(expose_cmp_ts) = EXPOSED(expose_begin_ts);
EXPOSED(expose_end_time) = EXPOSED(expose_begin_time); EXPOSED(expose_end_ts) = EXPOSED(expose_begin_ts);
# undef EXPOSED # undef EXPOSED
{ {
@@ -326,7 +327,7 @@ static void _http_callback_static(struct evhttp_request *request, void *v_server
goto not_found; goto not_found;
} }
if (evbuffer_add_file(buf, fd, 0, st.st_size) < 0) { if (st.st_size > 0 && evbuffer_add_file(buf, fd, 0, st.st_size) < 0) {
LOG_ERROR("HTTP: Can't serve static file %s", static_path); LOG_ERROR("HTTP: Can't serve static file %s", static_path);
goto not_found; goto not_found;
} }
@@ -446,17 +447,17 @@ static void _http_callback_snapshot(struct evhttp_request *request, void *v_serv
ADD_TIME_HEADER("X-Timestamp", get_now_real()); ADD_TIME_HEADER("X-Timestamp", get_now_real());
ADD_HEADER("X-UStreamer-Online", bool_to_string(EXPOSED(online))); ADD_HEADER("X-UStreamer-Online", bool_to_string(EXPOSED(online)));
ADD_UNSIGNED_HEADER("X-UStreamer-Dropped", EXPOSED(dropped)); ADD_UNSIGNED_HEADER("X-UStreamer-Dropped", EXPOSED(dropped));
ADD_UNSIGNED_HEADER("X-UStreamer-Width", EXPOSED(picture->width)); ADD_UNSIGNED_HEADER("X-UStreamer-Width", EXPOSED(picture->width));
ADD_UNSIGNED_HEADER("X-UStreamer-Height", EXPOSED(picture->height)); ADD_UNSIGNED_HEADER("X-UStreamer-Height", EXPOSED(picture->height));
ADD_TIME_HEADER("X-UStreamer-Grab-Time", EXPOSED(picture->grab_time)); ADD_TIME_HEADER("X-UStreamer-Grab-Timestamp", EXPOSED(picture->grab_ts));
ADD_TIME_HEADER("X-UStreamer-Encode-Begin-Time", EXPOSED(picture->encode_begin_time)); ADD_TIME_HEADER("X-UStreamer-Encode-Begin-Timestamp", EXPOSED(picture->encode_begin_ts));
ADD_TIME_HEADER("X-UStreamer-Encode-End-Time", EXPOSED(picture->encode_end_time)); ADD_TIME_HEADER("X-UStreamer-Encode-End-Timestamp", EXPOSED(picture->encode_end_ts));
ADD_TIME_HEADER("X-UStreamer-Expose-Begin-Time", EXPOSED(expose_begin_time)); ADD_TIME_HEADER("X-UStreamer-Expose-Begin-Timestamp", EXPOSED(expose_begin_ts));
ADD_TIME_HEADER("X-UStreamer-Expose-Cmp-Time", EXPOSED(expose_cmp_time)); ADD_TIME_HEADER("X-UStreamer-Expose-Cmp-Timestamp", EXPOSED(expose_cmp_ts));
ADD_TIME_HEADER("X-UStreamer-Expose-End-Time", EXPOSED(expose_end_time)); ADD_TIME_HEADER("X-UStreamer-Expose-End-Timestamp", EXPOSED(expose_end_ts));
ADD_TIME_HEADER("X-UStreamer-Send-Time", get_now_monotonic()); ADD_TIME_HEADER("X-UStreamer-Send-Timestamp", get_now_monotonic());
# undef ADD_UNSUGNED_HEADER # undef ADD_UNSUGNED_HEADER
# undef ADD_TIME_HEADER # undef ADD_TIME_HEADER
@@ -637,12 +638,12 @@ static void _http_callback_stream_write(struct bufferevent *buf_event, void *v_c
EXPOSED(picture->width), EXPOSED(picture->width),
EXPOSED(picture->height), EXPOSED(picture->height),
client->fps, client->fps,
EXPOSED(picture->grab_time), EXPOSED(picture->grab_ts),
EXPOSED(picture->encode_begin_time), EXPOSED(picture->encode_begin_ts),
EXPOSED(picture->encode_end_time), EXPOSED(picture->encode_end_ts),
EXPOSED(expose_begin_time), EXPOSED(expose_begin_ts),
EXPOSED(expose_cmp_time), EXPOSED(expose_cmp_ts),
EXPOSED(expose_end_time), EXPOSED(expose_end_ts),
now now
)); ));
} }
@@ -797,7 +798,7 @@ static bool _expose_new_picture_unsafe(struct http_server_t *server) {
# define STREAM(_next) server->run->stream->_next # define STREAM(_next) server->run->stream->_next
EXPOSED(captured_fps) = STREAM(captured_fps); EXPOSED(captured_fps) = STREAM(captured_fps);
EXPOSED(expose_begin_time) = get_now_monotonic(); EXPOSED(expose_begin_ts) = get_now_monotonic();
if (server->drop_same_frames) { if (server->drop_same_frames) {
if ( if (
@@ -805,16 +806,16 @@ static bool _expose_new_picture_unsafe(struct http_server_t *server) {
&& EXPOSED(dropped) < server->drop_same_frames && EXPOSED(dropped) < server->drop_same_frames
&& picture_compare(EXPOSED(picture), STREAM(picture)) && picture_compare(EXPOSED(picture), STREAM(picture))
) { ) {
EXPOSED(expose_cmp_time) = get_now_monotonic(); EXPOSED(expose_cmp_ts) = get_now_monotonic();
EXPOSED(expose_end_time) = EXPOSED(expose_cmp_time); EXPOSED(expose_end_ts) = EXPOSED(expose_cmp_ts);
LOG_VERBOSE("HTTP: Dropped same frame number %u; cmp_time=%.06Lf", LOG_VERBOSE("HTTP: Dropped same frame number %u; cmp_time=%.06Lf",
EXPOSED(dropped), EXPOSED(expose_cmp_time) - EXPOSED(expose_begin_time)); EXPOSED(dropped), EXPOSED(expose_cmp_ts) - EXPOSED(expose_begin_ts));
EXPOSED(dropped) += 1; EXPOSED(dropped) += 1;
return false; // Not updated return false; // Not updated
} else { } else {
EXPOSED(expose_cmp_time) = get_now_monotonic(); EXPOSED(expose_cmp_ts) = get_now_monotonic();
LOG_VERBOSE("HTTP: Passed same frame check (frames are differ); cmp_time=%.06Lf", LOG_VERBOSE("HTTP: Passed same frame check (frames are differ); cmp_time=%.06Lf",
EXPOSED(expose_cmp_time) - EXPOSED(expose_begin_time)); EXPOSED(expose_cmp_ts) - EXPOSED(expose_begin_ts));
} }
} }
@@ -824,11 +825,11 @@ static bool _expose_new_picture_unsafe(struct http_server_t *server) {
EXPOSED(online) = true; EXPOSED(online) = true;
EXPOSED(dropped) = 0; EXPOSED(dropped) = 0;
EXPOSED(expose_cmp_time) = EXPOSED(expose_begin_time); EXPOSED(expose_cmp_ts) = EXPOSED(expose_begin_ts);
EXPOSED(expose_end_time) = get_now_monotonic(); EXPOSED(expose_end_ts) = get_now_monotonic();
LOG_VERBOSE("HTTP: Exposed new frame; full exposition time = %.06Lf", LOG_VERBOSE("HTTP: Exposed new frame; full exposition time = %.06Lf",
EXPOSED(expose_end_time) - EXPOSED(expose_begin_time)); EXPOSED(expose_end_ts) - EXPOSED(expose_begin_ts));
# undef EXPOSED # undef EXPOSED
return true; // Updated return true; // Updated
@@ -837,8 +838,8 @@ static bool _expose_new_picture_unsafe(struct http_server_t *server) {
static bool _expose_blank_picture(struct http_server_t *server) { static bool _expose_blank_picture(struct http_server_t *server) {
# define EXPOSED(_next) server->run->exposed->_next # define EXPOSED(_next) server->run->exposed->_next
EXPOSED(expose_begin_time) = get_now_monotonic(); EXPOSED(expose_begin_ts) = get_now_monotonic();
EXPOSED(expose_cmp_time) = EXPOSED(expose_begin_time); EXPOSED(expose_cmp_ts) = EXPOSED(expose_begin_ts);
# define EXPOSE_BLANK picture_copy(server->run->blank, EXPOSED(picture)) # define EXPOSE_BLANK picture_copy(server->run->blank, EXPOSED(picture))
@@ -848,7 +849,7 @@ static bool _expose_blank_picture(struct http_server_t *server) {
EXPOSE_BLANK; EXPOSE_BLANK;
} else if (server->last_as_blank > 0) { // Если нужен таймер - запустим } else if (server->last_as_blank > 0) { // Если нужен таймер - запустим
LOG_INFO("HTTP: Freezing last alive frame for %d seconds", server->last_as_blank); LOG_INFO("HTTP: Freezing last alive frame for %d seconds", server->last_as_blank);
EXPOSED(last_as_blank_time) = get_now_monotonic(); EXPOSED(last_as_blank_ts) = get_now_monotonic();
} else { // last_as_blank == 0 - показываем последний фрейм вечно } else { // last_as_blank == 0 - показываем последний фрейм вечно
LOG_INFO("HTTP: Freezing last alive frame forever"); LOG_INFO("HTTP: Freezing last alive frame forever");
} }
@@ -857,12 +858,12 @@ static bool _expose_blank_picture(struct http_server_t *server) {
if ( // Если уже оффлайн, включена фича last_as_blank с таймером и он запущен if ( // Если уже оффлайн, включена фича last_as_blank с таймером и он запущен
server->last_as_blank > 0 server->last_as_blank > 0
&& EXPOSED(last_as_blank_time) > 0 && EXPOSED(last_as_blank_ts) > 0
&& EXPOSED(last_as_blank_time) + server->last_as_blank < EXPOSED(expose_begin_time) && EXPOSED(last_as_blank_ts) + server->last_as_blank < EXPOSED(expose_begin_ts)
) { ) {
LOG_INFO("HTTP: Changed last alive frame to BLANK"); LOG_INFO("HTTP: Changed last alive frame to BLANK");
EXPOSE_BLANK; EXPOSE_BLANK;
EXPOSED(last_as_blank_time) = 0; // Останавливаем таймер EXPOSED(last_as_blank_ts) = 0; // Останавливаем таймер
goto updated; goto updated;
} }
@@ -871,7 +872,7 @@ static bool _expose_blank_picture(struct http_server_t *server) {
if (EXPOSED(dropped) < server->run->drop_same_frames_blank) { if (EXPOSED(dropped) < server->run->drop_same_frames_blank) {
LOG_PERF("HTTP: Dropped same frame (BLANK) number %u", EXPOSED(dropped)); LOG_PERF("HTTP: Dropped same frame (BLANK) number %u", EXPOSED(dropped));
EXPOSED(dropped) += 1; EXPOSED(dropped) += 1;
EXPOSED(expose_end_time) = get_now_monotonic(); EXPOSED(expose_end_ts) = get_now_monotonic();
return false; // Not updated return false; // Not updated
} }
@@ -879,7 +880,7 @@ static bool _expose_blank_picture(struct http_server_t *server) {
EXPOSED(captured_fps) = 0; EXPOSED(captured_fps) = 0;
EXPOSED(online) = false; EXPOSED(online) = false;
EXPOSED(dropped) = 0; EXPOSED(dropped) = 0;
EXPOSED(expose_end_time) = get_now_monotonic(); EXPOSED(expose_end_ts) = get_now_monotonic();
return true; // Updated return true; // Updated
# undef EXPOSED # undef EXPOSED

View File

@@ -61,10 +61,10 @@ struct exposed_t {
unsigned queued_fps; unsigned queued_fps;
bool online; bool online;
unsigned dropped; unsigned dropped;
long double expose_begin_time; long double expose_begin_ts;
long double expose_cmp_time; long double expose_cmp_ts;
long double expose_end_time; long double expose_end_ts;
long double last_as_blank_time; long double last_as_blank_ts;
}; };
struct http_server_runtime_t { struct http_server_runtime_t {

View File

@@ -25,6 +25,11 @@
# error WTF dude? Asserts are good things! # error WTF dude? Asserts are good things!
#endif #endif
#include <limits.h>
#if CHAR_BIT != 8
# error There are not 8 bits in a char!
#endif
#include <stdio.h> #include <stdio.h>
#include <signal.h> #include <signal.h>
@@ -98,6 +103,7 @@ static void _install_signal_handlers(void) {
} }
int main(int argc, char *argv[]) { int main(int argc, char *argv[]) {
struct options_t *options;
struct device_t *dev; struct device_t *dev;
struct encoder_t *encoder; struct encoder_t *encoder;
struct stream_t *stream; struct stream_t *stream;
@@ -105,8 +111,8 @@ int main(int argc, char *argv[]) {
int exit_code = 0; int exit_code = 0;
LOGGING_INIT; LOGGING_INIT;
A_THREAD_RENAME("main"); A_THREAD_RENAME("main");
options = options_init(argc, argv);
# ifdef WITH_GPIO # ifdef WITH_GPIO
GPIO_INIT; GPIO_INIT;
@@ -117,7 +123,7 @@ int main(int argc, char *argv[]) {
stream = stream_init(dev, encoder); stream = stream_init(dev, encoder);
server = http_server_init(stream); server = http_server_init(stream);
if ((exit_code = parse_options(argc, argv, dev, encoder, server)) == 0) { if ((exit_code = options_parse(options, dev, encoder, server)) == 0) {
# ifdef WITH_GPIO # ifdef WITH_GPIO
GPIO_INIT_PINOUT; GPIO_INIT_PINOUT;
# endif # endif
@@ -153,6 +159,7 @@ int main(int argc, char *argv[]) {
GPIO_SET_LOW(prog_running); GPIO_SET_LOW(prog_running);
# endif # endif
options_destroy(options);
if (exit_code == 0) { if (exit_code == 0) {
LOG_INFO("Bye-bye"); LOG_INFO("Bye-bye");
} }

View File

@@ -25,9 +25,8 @@
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <stdbool.h> #include <stdbool.h>
#ifdef WITH_OMX #include <string.h>
# include <string.h> #include <strings.h>
#endif
#include <ctype.h> #include <ctype.h>
#include <limits.h> #include <limits.h>
#include <getopt.h> #include <getopt.h>
@@ -82,19 +81,16 @@ enum _OPT_VALUES {
_O_DEVICE_TIMEOUT = 10000, _O_DEVICE_TIMEOUT = 10000,
_O_DEVICE_ERROR_DELAY, _O_DEVICE_ERROR_DELAY,
_O_IMAGE_DEFAULT,
_O_BRIGHTNESS, _O_BRIGHTNESS,
_O_BRIGHTNESS_AUTO,
_O_CONTRAST, _O_CONTRAST,
_O_SATURATION, _O_SATURATION,
_O_HUE, _O_HUE,
_O_HUE_AUTO,
_O_GAMMA, _O_GAMMA,
_O_SHARPNESS, _O_SHARPNESS,
_O_BACKLIGHT_COMPENSATION, _O_BACKLIGHT_COMPENSATION,
_O_WHITE_BALANCE, _O_WHITE_BALANCE,
_O_WHITE_BALANCE_AUTO,
_O_GAIN, _O_GAIN,
_O_GAIN_AUTO,
_O_USER, _O_USER,
_O_PASSWD, _O_PASSWD,
@@ -111,6 +107,9 @@ enum _OPT_VALUES {
#ifdef HAS_PDEATHSIG #ifdef HAS_PDEATHSIG
_O_EXIT_ON_PARENT_DEATH, _O_EXIT_ON_PARENT_DEATH,
#endif #endif
#ifdef WITH_SETPROCTITLE
_O_PROCESS_NAME_PREFIX,
#endif
_O_LOG_LEVEL, _O_LOG_LEVEL,
_O_PERF, _O_PERF,
@@ -118,6 +117,8 @@ enum _OPT_VALUES {
_O_DEBUG, _O_DEBUG,
_O_FORCE_LOG_COLORS, _O_FORCE_LOG_COLORS,
_O_NO_LOG_COLORS, _O_NO_LOG_COLORS,
_O_FEATURES,
}; };
static const struct option _LONG_OPTS[] = { static const struct option _LONG_OPTS[] = {
@@ -140,19 +141,16 @@ static const struct option _LONG_OPTS[] = {
{"device-timeout", required_argument, NULL, _O_DEVICE_TIMEOUT}, {"device-timeout", required_argument, NULL, _O_DEVICE_TIMEOUT},
{"device-error-delay", required_argument, NULL, _O_DEVICE_ERROR_DELAY}, {"device-error-delay", required_argument, NULL, _O_DEVICE_ERROR_DELAY},
{"image-default", no_argument, NULL, _O_IMAGE_DEFAULT},
{"brightness", required_argument, NULL, _O_BRIGHTNESS}, {"brightness", required_argument, NULL, _O_BRIGHTNESS},
{"brightness-auto", no_argument, NULL, _O_BRIGHTNESS_AUTO},
{"contrast", required_argument, NULL, _O_CONTRAST}, {"contrast", required_argument, NULL, _O_CONTRAST},
{"saturation", required_argument, NULL, _O_SATURATION}, {"saturation", required_argument, NULL, _O_SATURATION},
{"hue", required_argument, NULL, _O_HUE}, {"hue", required_argument, NULL, _O_HUE},
{"hue-auto", no_argument, NULL, _O_HUE_AUTO},
{"gamma", required_argument, NULL, _O_GAMMA}, {"gamma", required_argument, NULL, _O_GAMMA},
{"sharpness", required_argument, NULL, _O_SHARPNESS}, {"sharpness", required_argument, NULL, _O_SHARPNESS},
{"backlight-compensation", required_argument, NULL, _O_BACKLIGHT_COMPENSATION}, {"backlight-compensation", required_argument, NULL, _O_BACKLIGHT_COMPENSATION},
{"white-balance", required_argument, NULL, _O_WHITE_BALANCE}, {"white-balance", required_argument, NULL, _O_WHITE_BALANCE},
{"white-balance-auto", no_argument, NULL, _O_WHITE_BALANCE_AUTO},
{"gain", required_argument, NULL, _O_GAIN}, {"gain", required_argument, NULL, _O_GAIN},
{"gain-auto", no_argument, NULL, _O_GAIN_AUTO},
{"host", required_argument, NULL, _O_HOST}, {"host", required_argument, NULL, _O_HOST},
{"port", required_argument, NULL, _O_PORT}, {"port", required_argument, NULL, _O_PORT},
@@ -179,6 +177,9 @@ static const struct option _LONG_OPTS[] = {
#ifdef HAS_PDEATHSIG #ifdef HAS_PDEATHSIG
{"exit-on-parent-death", no_argument, NULL, _O_EXIT_ON_PARENT_DEATH}, {"exit-on-parent-death", no_argument, NULL, _O_EXIT_ON_PARENT_DEATH},
#endif #endif
#ifdef WITH_SETPROCTITLE
{"process-name-prefix", required_argument, NULL, _O_PROCESS_NAME_PREFIX},
#endif
{"log-level", required_argument, NULL, _O_LOG_LEVEL}, {"log-level", required_argument, NULL, _O_LOG_LEVEL},
{"perf", no_argument, NULL, _O_PERF}, {"perf", no_argument, NULL, _O_PERF},
@@ -189,6 +190,7 @@ static const struct option _LONG_OPTS[] = {
{"help", no_argument, NULL, _O_HELP}, {"help", no_argument, NULL, _O_HELP},
{"version", no_argument, NULL, _O_VERSION}, {"version", no_argument, NULL, _O_VERSION},
{"features", no_argument, NULL, _O_FEATURES},
{NULL, 0, NULL, 0}, {NULL, 0, NULL, 0},
}; };
@@ -199,11 +201,35 @@ static int _parse_resolution(const char *str, unsigned *width, unsigned *height,
static int _parse_glitched_resolutions(const char *str, struct encoder_t *encoder); static int _parse_glitched_resolutions(const char *str, struct encoder_t *encoder);
#endif #endif
static void _version(bool nl); static void _features(void);
static void _help(struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server); static void _help(struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server);
int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server) { struct options_t *options_init(int argc, char *argv[]) {
struct options_t *options;
A_CALLOC(options, 1);
options->argc = argc;
options->argv = argv;
A_CALLOC(options->argv_copy, argc);
for (int index = 0; index < argc; ++index) {
assert(options->argv_copy[index] = strdup(argv[index]));
}
return options;
}
void options_destroy(struct options_t *options) {
for (int index = 0; index < options->argc; ++index) {
free(options->argv_copy[index]);
}
free(options->argv_copy);
free(options);
}
int options_parse(struct options_t *options, struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server) {
# define OPT_SET(_dest, _value) { \ # define OPT_SET(_dest, _value) { \
_dest = _value; \ _dest = _value; \
break; \ break; \
@@ -236,15 +262,6 @@ int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t
break; \ break; \
} }
# ifdef WITH_OMX
# define OPT_GLITCHED_RESOLUTIONS { \
if (_parse_glitched_resolutions(optarg, encoder) < 0) { \
return -1; \
} \
break; \
}
# endif
# define OPT_PARSE(_name, _dest, _func, _invalid, _available) { \ # define OPT_PARSE(_name, _dest, _func, _invalid, _available) { \
if ((_dest = _func(optarg)) == _invalid) { \ if ((_dest = _func(optarg)) == _invalid) { \
printf("Unknown " _name ": %s; available: %s\n", optarg, _available); \ printf("Unknown " _name ": %s; available: %s\n", optarg, _available); \
@@ -253,16 +270,29 @@ int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t
break; \ break; \
} }
# define OPT_CTL(_dest) { \ # define OPT_CTL_DEFAULT_NOBREAK(_dest) { \
dev->ctl._dest.value_set = true; \ dev->ctl._dest.mode = CTL_MODE_DEFAULT; \
dev->ctl._dest.auto_set = false; \ }
OPT_NUMBER("--"#_dest, dev->ctl._dest.value, INT_MIN, INT_MAX, 0); \
# define OPT_CTL_MANUAL(_dest) { \
if (!strcasecmp(optarg, "default")) { \
OPT_CTL_DEFAULT_NOBREAK(_dest); \
} else { \
dev->ctl._dest.mode = CTL_MODE_VALUE; \
OPT_NUMBER("--"#_dest, dev->ctl._dest.value, INT_MIN, INT_MAX, 0); \
} \
break; \ break; \
} }
# define OPT_CTL_AUTO(_dest) { \ # define OPT_CTL_AUTO(_dest) { \
dev->ctl._dest.value_set = false; \ if (!strcasecmp(optarg, "default")) { \
dev->ctl._dest.auto_set = true; \ OPT_CTL_DEFAULT_NOBREAK(_dest); \
} else if (!strcasecmp(optarg, "auto")) { \
dev->ctl._dest.mode = CTL_MODE_AUTO; \
} else { \
dev->ctl._dest.mode = CTL_MODE_VALUE; \
OPT_NUMBER("--"#_dest, dev->ctl._dest.value, INT_MIN, INT_MAX, 0); \
} \
break; \ break; \
} }
@@ -270,6 +300,9 @@ int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t
int short_index; int short_index;
int opt_index; int opt_index;
char short_opts[1024] = {0}; char short_opts[1024] = {0};
# ifdef WITH_SETPROCTITLE
char *process_name_prefix = NULL;
# endif
for (short_index = 0, opt_index = 0; _LONG_OPTS[opt_index].name != NULL; ++opt_index) { for (short_index = 0, opt_index = 0; _LONG_OPTS[opt_index].name != NULL; ++opt_index) {
if (isalpha(_LONG_OPTS[opt_index].val)) { if (isalpha(_LONG_OPTS[opt_index].val)) {
@@ -282,7 +315,7 @@ int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t
} }
} }
while ((ch = getopt_long(argc, argv, short_opts, _LONG_OPTS, NULL)) >= 0) { while ((ch = getopt_long(options->argc, options->argv_copy, short_opts, _LONG_OPTS, NULL)) >= 0) {
switch (ch) { switch (ch) {
case _O_DEVICE: OPT_SET(dev->path, optarg); case _O_DEVICE: OPT_SET(dev->path, optarg);
case _O_INPUT: OPT_NUMBER("--input", dev->input, 0, 128, 0); case _O_INPUT: OPT_NUMBER("--input", dev->input, 0, 128, 0);
@@ -301,24 +334,35 @@ int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t
case _O_QUALITY: OPT_NUMBER("--quality", encoder->quality, 1, 100, 0); case _O_QUALITY: OPT_NUMBER("--quality", encoder->quality, 1, 100, 0);
case _O_ENCODER: OPT_PARSE("encoder type", encoder->type, encoder_parse_type, ENCODER_TYPE_UNKNOWN, ENCODER_TYPES_STR); case _O_ENCODER: OPT_PARSE("encoder type", encoder->type, encoder_parse_type, ENCODER_TYPE_UNKNOWN, ENCODER_TYPES_STR);
# ifdef WITH_OMX # ifdef WITH_OMX
case _O_GLITCHED_RESOLUTIONS: OPT_GLITCHED_RESOLUTIONS; case _O_GLITCHED_RESOLUTIONS:
if (_parse_glitched_resolutions(optarg, encoder) < 0) {
return -1;
}
break;
# endif # endif
case _O_DEVICE_TIMEOUT: OPT_NUMBER("--device-timeout", dev->timeout, 1, 60, 0); case _O_DEVICE_TIMEOUT: OPT_NUMBER("--device-timeout", dev->timeout, 1, 60, 0);
case _O_DEVICE_ERROR_DELAY: OPT_NUMBER("--device-error-delay", dev->error_delay, 1, 60, 0); case _O_DEVICE_ERROR_DELAY: OPT_NUMBER("--device-error-delay", dev->error_delay, 1, 60, 0);
case _O_BRIGHTNESS: OPT_CTL(brightness); case _O_IMAGE_DEFAULT:
case _O_BRIGHTNESS_AUTO: OPT_CTL_AUTO(brightness); OPT_CTL_DEFAULT_NOBREAK(brightness);
case _O_CONTRAST: OPT_CTL(contrast); OPT_CTL_DEFAULT_NOBREAK(contrast);
case _O_SATURATION: OPT_CTL(saturation); OPT_CTL_DEFAULT_NOBREAK(saturation);
case _O_HUE: OPT_CTL(hue); OPT_CTL_DEFAULT_NOBREAK(hue);
case _O_HUE_AUTO: OPT_CTL_AUTO(hue); OPT_CTL_DEFAULT_NOBREAK(gamma);
case _O_GAMMA: OPT_CTL(gamma); OPT_CTL_DEFAULT_NOBREAK(sharpness);
case _O_SHARPNESS: OPT_CTL(sharpness); OPT_CTL_DEFAULT_NOBREAK(backlight_compensation);
case _O_BACKLIGHT_COMPENSATION: OPT_CTL(backlight_compensation); OPT_CTL_DEFAULT_NOBREAK(white_balance);
case _O_WHITE_BALANCE: OPT_CTL(white_balance); OPT_CTL_DEFAULT_NOBREAK(gain);
case _O_WHITE_BALANCE_AUTO: OPT_CTL_AUTO(white_balance); break;
case _O_GAIN: OPT_CTL(gain); case _O_BRIGHTNESS: OPT_CTL_AUTO(brightness);
case _O_GAIN_AUTO: OPT_CTL_AUTO(gain); case _O_CONTRAST: OPT_CTL_MANUAL(contrast);
case _O_SATURATION: OPT_CTL_MANUAL(saturation);
case _O_HUE: OPT_CTL_AUTO(hue);
case _O_GAMMA: OPT_CTL_MANUAL(gamma);
case _O_SHARPNESS: OPT_CTL_MANUAL(sharpness);
case _O_BACKLIGHT_COMPENSATION: OPT_CTL_MANUAL(backlight_compensation);
case _O_WHITE_BALANCE: OPT_CTL_AUTO(white_balance);
case _O_GAIN: OPT_CTL_AUTO(gain);
case _O_HOST: OPT_SET(server->host, optarg); case _O_HOST: OPT_SET(server->host, optarg);
case _O_PORT: OPT_NUMBER("--port", server->port, 1, 65535, 0); case _O_PORT: OPT_NUMBER("--port", server->port, 1, 65535, 0);
@@ -343,7 +387,14 @@ int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t
# endif # endif
# ifdef HAS_PDEATHSIG # ifdef HAS_PDEATHSIG
case _O_EXIT_ON_PARENT_DEATH: process_set_pdeathsig_sigterm(); break; case _O_EXIT_ON_PARENT_DEATH:
if (process_track_parent_death() < 0) {
return -1;
};
break;
# endif
# ifdef WITH_SETPROCTITLE
case _O_PROCESS_NAME_PREFIX: OPT_SET(process_name_prefix, optarg);
# endif # endif
case _O_LOG_LEVEL: OPT_NUMBER("--log-level", log_level, LOG_LEVEL_INFO, LOG_LEVEL_DEBUG, 0); case _O_LOG_LEVEL: OPT_NUMBER("--log-level", log_level, LOG_LEVEL_INFO, LOG_LEVEL_DEBUG, 0);
@@ -354,19 +405,24 @@ int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t
case _O_NO_LOG_COLORS: OPT_SET(log_colored, false); case _O_NO_LOG_COLORS: OPT_SET(log_colored, false);
case _O_HELP: _help(dev, encoder, server); return 1; case _O_HELP: _help(dev, encoder, server); return 1;
case _O_VERSION: _version(true); return 1; case _O_VERSION: puts(VERSION); return 1;
case _O_FEATURES: _features(); return 1;
case 0: break; case 0: break;
default: _help(dev, encoder, server); return -1; default: _help(dev, encoder, server); return -1;
} }
} }
# undef OPT_CTL_AUTO # ifdef WITH_SETPROCTITLE
# undef OPT_CTL if (process_name_prefix != NULL) {
# undef OPT_PARSE process_set_name_prefix(options->argc, options->argv, process_name_prefix);
# ifdef WITH_OMX }
# undef OPT_GLITCHED_RESOLUTIONS
# endif # endif
# undef OPT_CTL_AUTO
# undef OPT_CTL_MANUAL
# undef OPT_CTL_DEFAULT_NOBREAK
# undef OPT_PARSE
# undef OPT_RESOLUTION # undef OPT_RESOLUTION
# undef OPT_NUMBER # undef OPT_NUMBER
# undef OPT_SET # undef OPT_SET
@@ -443,25 +499,42 @@ static int _parse_glitched_resolutions(const char *str, struct encoder_t *encode
} }
#endif #endif
static void _version(bool nl) { static void _features(void) {
printf(VERSION);
# ifdef WITH_OMX # ifdef WITH_OMX
printf(" + OMX"); puts("+ WITH_OMX");
# else
puts("- WITH_OMX");
# endif # endif
# ifdef WITH_GPIO # ifdef WITH_GPIO
printf(" + GPIO"); puts("+ WITH_GPIO");
# else
puts("- WITH_GPIO");
# endif
# ifdef WITH_PTHREAD_NP
puts("+ WITH_PTHREAD_NP");
# else
puts("- WITH_PTHREAD_NP");
# endif
# ifdef WITH_SETPROCTITLE
puts("+ WITH_SETPROCTITLE");
# else
puts("- WITH_SETPROCTITLE");
# endif
# ifdef HAS_PDEATHSIG
puts("+ HAS_PDEATHSIG");
# else
puts("- HAS_PDEATHSIG");
# endif # endif
if (nl) {
putchar('\n');
}
} }
static void _help(struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server) { static void _help(struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server) {
printf("\nuStreamer - Lightweight and fast MJPG-HTTP streamer\n"); printf("\nuStreamer - Lightweight and fast MJPG-HTTP streamer\n");
printf("═══════════════════════════════════════════════════\n\n"); printf("═══════════════════════════════════════════════════\n\n");
printf("Version: "); printf("Version: %s; license: GPLv3\n", VERSION);
_version(false);
printf("; license: GPLv3\n");
printf("Copyright (C) 2018 Maxim Devaev <mdevaev@gmail.com>\n\n"); printf("Copyright (C) 2018 Maxim Devaev <mdevaev@gmail.com>\n\n");
printf("Capturing options:\n"); printf("Capturing options:\n");
printf("══════════════════\n"); printf("══════════════════\n");
@@ -505,19 +578,17 @@ static void _help(struct device_t *dev, struct encoder_t *encoder, struct http_s
printf(" after an error (timeout for example). Default: %u.\n\n", dev->error_delay); printf(" after an error (timeout for example). Default: %u.\n\n", dev->error_delay);
printf("Image control options:\n"); printf("Image control options:\n");
printf("══════════════════════\n"); printf("══════════════════════\n");
printf(" --brightness <N> ───────────── Set brightness. Default: no change.\n\n"); printf(" --image-default ────────────────────── Reset all image settings bellow to default. Default: no change.\n\n");
printf(" --brightness-auto ──────────── Enable automatic brightness control. Default: no change.\n\n"); printf(" --brightness <N|auto|default> ──────── Set brightness. Default: no change.\n\n");
printf(" --contrast <N> ─────────────── Set contrast. Default: no change.\n\n"); printf(" --contrast <N|default> ─────────────── Set contrast. Default: no change.\n\n");
printf(" --saturation <N> ───────────── Set saturation. Default: no change.\n\n"); printf(" --saturation <N|default> ───────────── Set saturation. Default: no change.\n\n");
printf(" --hue <N> ──────────────────── Set hue. Default: no change.\n\n"); printf(" --hue <N|auto|default> ─────────────── Set hue. Default: no change.\n\n");
printf(" --hue-auto ─────────────────── Enable automatic hue control. Default: no change.\n\n"); printf(" --gamma <N|default> ─────────────────── Set gamma. Default: no change.\n\n");
printf(" --gamma <N> ────────────────── Set gamma. Default: no change.\n\n"); printf(" --sharpness <N|default> ────────────── Set sharpness. Default: no change.\n\n");
printf(" --sharpness <N> ────────────── Set sharpness. Default: no change.\n\n"); printf(" --backlight-compensation <N|default> ─ Set backlight compensation. Default: no change.\n\n");
printf(" --backlight-compensation <N> ─ Set backlight compensation. Default: no change.\n\n"); printf(" --white-balance <N|auto|default> ───── Set white balance. Default: no change.\n\n");
printf(" --white-balance <N> ────────── Set white balance. Default: no change.\n\n"); printf(" --gain <N|auto|default> ────────────── Set gain. Default: no change.\n\n");
printf(" --white-balance-auto ───────── Enable automatic white balance control. Default: no change.\n\n"); printf(" Hint: use v4l2-ctl --list-ctrls-menus to query available controls of the device.\n\n");
printf(" --gain <N> ─────────────────── Set gain. Default: no change.\n\n");
printf(" --gain-auto ────────────────── Enable automatic gain control. Default: no change.\n\n");
printf("HTTP server options:\n"); printf("HTTP server options:\n");
printf("════════════════════\n"); printf("════════════════════\n");
printf(" -s|--host <address> ──────── Listen on Hostname or IP. Default: %s.\n\n", server->host); printf(" -s|--host <address> ──────── Listen on Hostname or IP. Default: %s.\n\n", server->host);
@@ -552,10 +623,16 @@ static void _help(struct device_t *dev, struct encoder_t *encoder, struct http_s
printf(" --gpio-workers-busy-at <pin> ── Set 1 on (pin + N) while worker with number N has a job.\n"); printf(" --gpio-workers-busy-at <pin> ── Set 1 on (pin + N) while worker with number N has a job.\n");
printf(" The worker's numbering starts from 0. Default: disabled\n\n"); printf(" The worker's numbering starts from 0. Default: disabled\n\n");
#endif #endif
#ifdef HAS_PDEATHSIG #if (defined(HAS_PDEATHSIG) || defined(WITH_SETPROCTITLE))
printf("Process options:\n"); printf("Process options:\n");
printf("════════════════\n"); printf("════════════════\n");
printf(" --exit-on-parent-death ─ Exit the program if the parent process is dead. Default: disabled.\n\n"); #endif
#ifdef HAS_PDEATHSIG
printf(" --exit-on-parent-death ─────── Exit the program if the parent process is dead. Default: disabled.\n\n");
#endif
#ifdef WITH_SETPROCTITLE
printf(" --process-name-prefix <str> ── Set process name prefix which will be displayed in the process list\n");
printf(" like '<str>: ustreamer --blah-blah-blah'. Default: disabled.\n\n");
#endif #endif
printf("Logging options:\n"); printf("Logging options:\n");
printf("════════════════\n"); printf("════════════════\n");
@@ -572,4 +649,5 @@ static void _help(struct device_t *dev, struct encoder_t *encoder, struct http_s
printf("═════════════\n"); printf("═════════════\n");
printf(" -h|--help ─────── Print this text and exit.\n\n"); printf(" -h|--help ─────── Print this text and exit.\n\n");
printf(" -v|--version ──── Print version and exit.\n\n"); printf(" -v|--version ──── Print version and exit.\n\n");
printf(" --features ────── Print list of supporeted features.\n\n");
} }

View File

@@ -27,4 +27,14 @@
#include "http/server.h" #include "http/server.h"
int parse_options(int argc, char *argv[], struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server); struct options_t {
int argc;
char **argv;
char **argv_copy;
};
struct options_t *options_init(int argc, char *argv[]);
void options_destroy(struct options_t *options);
int options_parse(struct options_t *options, struct device_t *dev, struct encoder_t *encoder, struct http_server_t *server);

View File

@@ -84,9 +84,9 @@ void picture_copy(const struct picture_t *src, struct picture_t *dest) {
COPY(width); COPY(width);
COPY(height); COPY(height);
COPY(grab_time); COPY(grab_ts);
COPY(encode_begin_time); COPY(encode_begin_ts);
COPY(encode_end_time); COPY(encode_end_ts);
# undef COPY # undef COPY
} }

View File

@@ -32,9 +32,9 @@ struct picture_t {
size_t allocated; size_t allocated;
unsigned width; unsigned width;
unsigned height; unsigned height;
long double grab_time; long double grab_ts;
long double encode_begin_time; long double encode_begin_ts;
long double encode_end_time; long double encode_end_ts;
}; };

View File

@@ -31,29 +31,100 @@
# endif # endif
#endif #endif
#ifdef HAS_PDEATHSIG #ifdef HAS_PDEATHSIG
# include <signal.h> # include <signal.h>
# include <unistd.h>
#endif
#ifdef WITH_SETPROCTITLE
# include <stdlib.h>
# include <string.h>
# if defined(__linux__)
# include <bsd/unistd.h>
# include <sys/types.h>
# elif (defined(__FreeBSD__) || defined(__DragonFly__))
# include <unistd.h>
# include <sys/types.h>
# elif (defined(__NetBSD__) || defined(__OpenBSD__)) // setproctitle() placed in stdlib.h
# else
# error setproctitle() not implemented, you can disable it using WITH_SETPROCTITLE=0
# endif
#endif
#ifdef HAS_PDEATHSIG
# if defined(__linux__) # if defined(__linux__)
# include <sys/prctl.h> # include <sys/prctl.h>
# elif defined(__FreeBSD__) # elif defined(__FreeBSD__)
# include <sys/procctl.h> # include <sys/procctl.h>
# endif # endif
#endif
#ifdef WITH_SETPROCTITLE
# include "tools.h"
#endif
#ifdef HAS_PDEATHSIG
# include "logging.h" # include "logging.h"
#endif
INLINE void process_set_pdeathsig_sigterm(void) {
#ifdef WITH_SETPROCTITLE
extern char **environ;
#endif
#ifdef HAS_PDEATHSIG
INLINE int process_track_parent_death(void) {
int signum = SIGTERM; int signum = SIGTERM;
# ifdef __linux__ # if defined(__linux__)
int retval = prctl(PR_SET_PDEATHSIG, signum); int retval = prctl(PR_SET_PDEATHSIG, signum);
# elif __FreeBSD__ # elif defined(__FreeBSD__)
int retval = procctl(P_PID, 0, PROC_PDEATHSIG_CTL, &signum); int retval = procctl(P_PID, 0, PROC_PDEATHSIG_CTL, &signum);
# else # else
# error WTF? # error WTF?
# endif # endif
if (retval < 0) { if (retval < 0) {
LOG_PERROR("Can't set to receive SIGTERM on parent process death"); LOG_PERROR("Can't set to receive SIGTERM on parent process death");
return -1;
} }
}
#endif // HAS_PDEATHSIG if (kill(getppid(), 0) < 0) {
LOG_PERROR("The parent process is already dead");
return -1;
}
return 0;
}
#endif
#ifdef WITH_SETPROCTITLE
# pragma GCC diagnostic ignored "-Wunused-parameter"
# pragma GCC diagnostic push
INLINE void process_set_name_prefix(int argc, char *argv[], const char *prefix) {
# pragma GCC diagnostic pop
char *cmdline = NULL;
size_t allocated = 2048;
size_t used = 0;
size_t arg_len = 0;
A_REALLOC(cmdline, allocated);
cmdline[0] = '\0';
for (int index = 0; index < argc; ++index) {
arg_len = strlen(argv[index]);
if (used + arg_len + 16 >= allocated) {
allocated += arg_len + 2048;
A_REALLOC(cmdline, allocated);
}
strcat(cmdline, " ");
strcat(cmdline, argv[index]);
used = strlen(cmdline); // Не считаем вручную, так надежнее
}
# ifdef __linux__
setproctitle_init(argc, argv, environ);
# endif
setproctitle("-%s:%s", prefix, cmdline);
free(cmdline);
}
#endif

View File

@@ -55,7 +55,7 @@ struct _worker_t {
atomic_bool has_job; atomic_bool has_job;
bool job_timely; bool job_timely;
bool job_failed; bool job_failed;
long double job_start_time; long double job_start_ts;
pthread_cond_t has_job_cond; pthread_cond_t has_job_cond;
pthread_mutex_t *free_workers_mutex; pthread_mutex_t *free_workers_mutex;
@@ -454,10 +454,10 @@ static void *_worker_thread(void *v_worker) {
} }
if (device_release_buffer(worker->dev, worker->buf_index) == 0) { if (device_release_buffer(worker->dev, worker->buf_index) == 0) {
worker->job_start_time = PICTURE(encode_begin_time); worker->job_start_ts = PICTURE(encode_begin_ts);
atomic_store(&worker->has_job, false); atomic_store(&worker->has_job, false);
worker->last_comp_time = PICTURE(encode_end_time) - worker->job_start_time; worker->last_comp_time = PICTURE(encode_end_ts) - worker->job_start_ts;
LOG_VERBOSE("Compressed new JPEG: size=%zu, time=%0.3Lf, worker=%u, buffer=%u", LOG_VERBOSE("Compressed new JPEG: size=%zu, time=%0.3Lf, worker=%u, buffer=%u",
PICTURE(used), worker->last_comp_time, worker->number, worker->buf_index); PICTURE(used), worker->last_comp_time, worker->number, worker->buf_index);
@@ -498,7 +498,7 @@ static struct _worker_t *_workers_pool_wait(struct _workers_pool_t *pool) {
if ( if (
!atomic_load(&pool->workers[number].has_job) && ( !atomic_load(&pool->workers[number].has_job) && (
ready_worker == NULL ready_worker == NULL
|| ready_worker->job_start_time < pool->workers[number].job_start_time || ready_worker->job_start_ts < pool->workers[number].job_start_ts
) )
) { ) {
ready_worker = &pool->workers[number]; ready_worker = &pool->workers[number];