2 * Copyright (C) 2009 Andre Noll <maan@systemlinux.org>
4 * Licensed under the GPL v2. For licencing details see COPYING.
7 /** \file prebuffer_filter.c Paraslash's prebuffering filter. */
13 #include "prebuffer_filter.cmdline.h"
17 #include "buffer_tree.h"
22 /** Data specific to the prebuffer filter. */
23 struct private_prebuffer_data
{
24 /** The configuration data for this instance of the filter. */
25 struct prebuffer_filter_args_info
*conf
;
26 /** Number of bytes prebuffered or -1 if no longer prebuffering. */
28 /** End of prebuffering period. */
29 struct timeval barrier
;
32 static void prebuffer_pre_select(struct sched
*s
, struct task
*t
)
34 struct filter_node
*fn
= container_of(t
, struct filter_node
, task
);
35 struct btr_node
*btrn
= fn
->btrn
;
36 size_t iqs
= btr_get_input_queue_size(btrn
);
37 struct private_prebuffer_data
*ppd
= fn
->private_data
;
38 struct prebuffer_filter_args_info
*conf
= ppd
->conf
;
44 if (ppd
->barrier
.tv_sec
== 0) {
46 PARA_INFO_LOG("prebuffer period %dms\n",
48 ms2tv(conf
->duration_arg
, &tv
);
49 tv_add(&tv
, now
, &ppd
->barrier
);
51 if (tv_diff(&ppd
->barrier
, now
, &diff
) < 0)
52 return sched_min_delay(s
);
53 sched_request_timeout(&diff
, s
);
56 static void prebuffer_close(struct filter_node
*fn
)
58 free(fn
->private_data
);
61 static void prebuffer_post_select(__a_unused
struct sched
*s
, struct task
*t
)
63 struct filter_node
*fn
= container_of(t
, struct filter_node
, task
);
64 struct btr_node
*btrn
= fn
->btrn
;
65 size_t iqs
= btr_get_input_queue_size(btrn
);
66 struct private_prebuffer_data
*ppd
= fn
->private_data
;
67 struct prebuffer_filter_args_info
*conf
= ppd
->conf
;
70 if (ppd
->barrier
.tv_sec
== 0)
72 if (tv_diff(now
, &ppd
->barrier
, NULL
) < 0)
74 if (iqs
< conf
->size_arg
)
76 btr_splice_out_node(btrn
);
78 t
->error
= -E_PREBUFFER_SUCCESS
;
81 static int prebuffer_parse_config(int argc
, char **argv
, void **config
)
83 struct prebuffer_filter_args_info
*prebuffer_conf
84 = para_calloc(sizeof(*prebuffer_conf
));
85 int ret
= -E_PREBUFFER_SYNTAX
;
87 if (prebuffer_cmdline_parser(argc
, argv
, prebuffer_conf
))
89 ret
= -ERRNO_TO_PARA_ERROR(EINVAL
);
90 if (prebuffer_conf
->duration_arg
< 0)
92 if (prebuffer_conf
->size_arg
< 0)
94 PARA_NOTICE_LOG("prebuffering %ims, %i bytes\n",
95 prebuffer_conf
->duration_arg
, prebuffer_conf
->size_arg
);
96 *config
= prebuffer_conf
;
103 static void prebuffer_open(struct filter_node
*fn
)
105 struct private_prebuffer_data
*ppd
= para_calloc(sizeof(*ppd
));
107 ppd
->conf
= fn
->conf
;
108 fn
->private_data
= ppd
;
111 static void prebuffer_free_config(void *conf
)
113 prebuffer_cmdline_parser_free(conf
);
117 * The init function of the prebuffer filter.
119 * \param f Pointer to the struct to initialize.
121 void prebuffer_filter_init(struct filter
*f
)
123 struct prebuffer_filter_args_info dummy
;
125 prebuffer_cmdline_parser_init(&dummy
);
126 f
->open
= prebuffer_open
;
127 f
->close
= prebuffer_close
;
128 f
->parse_config
= prebuffer_parse_config
;
129 f
->free_config
= prebuffer_free_config
;
130 f
->pre_select
= prebuffer_pre_select
;
131 f
->post_select
= prebuffer_post_select
;
132 f
->help
= (struct ggo_help
) {
133 .short_help
= prebuffer_filter_args_info_help
,
134 .detailed_help
= prebuffer_filter_args_info_detailed_help