diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/options.c | 2 | ||||
| -rw-r--r-- | src/writer.c | 42 | ||||
| -rw-r--r-- | src/writer.h | 10 |
3 files changed, 52 insertions, 2 deletions
diff --git a/src/options.c b/src/options.c index 3595866..e30e149 100644 --- a/src/options.c +++ b/src/options.c @@ -288,7 +288,7 @@ void options_print_usage() printf(" [-s|--source] <description> a gstreamer pipeline-style description which will be used\n"); printf(" as data source, see gst-launch man-page for syntax\n"); printf(" [-d|--output-dir] <path> path to the output directory\n"); - printf(" [-f|--name-format] <format> the file name format, see manpage of date for the syntax\n"); + printf(" [-f|--name-format] <format> the file name format, see manpage of strftime for the syntax\n"); printf(" [-i|--interval] <value> interval for time checks in ms\n"); printf(" [-o|--offset] <value> time offset for recordings in ms\n"); } diff --git a/src/writer.c b/src/writer.c index c8689f0..633a34e 100644 --- a/src/writer.c +++ b/src/writer.c @@ -38,6 +38,40 @@ #include "datatypes.h" #include "log.h" +static void init_time_boundaries(writer_t* writer) +{ + if(!writer) + return; + + struct timespec now; + clock_gettime(CLOCK_REALTIME, &now); + + struct tm bd_time; + localtime_r(&(now.tv_sec), &bd_time); + + log_printf(INFO, "it's now: %02d:%02d:%02d on %d.%d.%d", bd_time.tm_hour, bd_time.tm_min, bd_time.tm_sec, bd_time.tm_mday, bd_time.tm_mon+1, bd_time.tm_year+1900); + + strftime(writer->current_.name_, sizeof(writer->current_.name_), writer->name_format_, &bd_time); + log_printf(INFO, "current filename is: %s(.?)", writer->current_.name_); + + + bd_time.tm_sec = 0; + bd_time.tm_min = 0; + + time_t T = mktime(&bd_time); + T+=3600; + + localtime_r(&T, &bd_time); + + log_printf(INFO, "next boundary is at: %02d:%02d:%02d on %d.%d.%d", bd_time.tm_hour, bd_time.tm_min, bd_time.tm_sec, bd_time.tm_mday, bd_time.tm_mon+1, bd_time.tm_year+1900); + + strftime(writer->next_.name_, sizeof(writer->next_.name_), writer->name_format_, &bd_time); + log_printf(INFO, "next filename will be: %s(.?)", writer->next_.name_); + + struct timespec b = { T, 0 }; + writer->next_boundary_ = b; +} + int writer_init(writer_t* writer, const char* name_format, const char* output_dir, int interval, int offset) { if(!writer) @@ -57,10 +91,16 @@ int writer_init(writer_t* writer, const char* name_format, const char* output_di writer->output_dir_ = output_dir; writer->interval_ = interval * GST_MSECOND; writer->offset_ = offset * GST_MSECOND; + init_time_boundaries(writer); return 0; } +static int open_file(file_t* file) +{ + +} + static gpointer writer_thread_func(gpointer data) { writer_t *writer = (writer_t*)data; @@ -79,7 +119,7 @@ static gpointer writer_thread_func(gpointer data) struct tm now_bd; localtime_r(&(now.tv_sec), &now_bd); - log_printf(NOTICE, "it's now: %d:%d:%d on %d.%d.%d", now_bd.tm_hour, now_bd.tm_min, now_bd.tm_sec, now_bd.tm_mday, now_bd.tm_mon+1, now_bd.tm_year+1900); + log_printf(DEBUG, "it's now: %02d:%02d:%02d on %d.%d.%d", now_bd.tm_hour, now_bd.tm_min, now_bd.tm_sec, now_bd.tm_mday, now_bd.tm_mon+1, now_bd.tm_year+1900); } log_printf(NOTICE, "writer thread stopped"); diff --git a/src/writer.h b/src/writer.h index 38df718..4619d95 100644 --- a/src/writer.h +++ b/src/writer.h @@ -29,6 +29,13 @@ #define RHARCHIVE_writer_h_INCLUDED #include <gst/gst.h> +#include <time.h> + +struct file_struct { + int fd_; + char name_[100]; +}; +typedef struct file_struct file_t; struct writer_struct { GstElement* sink_; @@ -39,6 +46,9 @@ struct writer_struct { const char* output_dir_; GstClockTime interval_; GstClockTime offset_; + file_t current_; + file_t next_; + struct timespec next_boundary_; }; typedef struct writer_struct writer_t; |