1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
/*
* dmxdev.h
*
* Copyright (C) 2000 Ralph Metzler <ralph@convergence.de>
* & Marcus Metzler <marcus@convergence.de>
for convergence integrated media GmbH
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation; either version 2.1
* of the License, or (at your option) any later version.
*
* 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 Lesser General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
*/
#ifndef _DMXDEV_H_
#define _DMXDEV_H_
#ifndef __KERNEL__
#define __KERNEL__
#endif
#ifdef __DVB_PACK__
#include <ost/demux.h>
#include <ost/dmx.h>
#else
#include <linux/ost/demux.h>
#include <linux/ost/dmx.h>
#endif
#include <linux/version.h>
#include <linux/wait.h>
#include <linux/types.h>
#include <linux/fs.h>
#if LINUX_VERSION_CODE < 0x020300
#define WAIT_QUEUE struct wait_queue*
#define init_waitqueue_head(wq) *(wq) = NULL;
#define DECLARE_WAITQUEUE(wait, current) struct wait_queue wait = { current, NULL }
#define list_for_each(pos, head) \
for (pos = (head)->next; pos != (head); pos = pos->next)
#else
#define WAIT_QUEUE wait_queue_head_t
#endif
typedef enum {
DMXDEV_TYPE_NONE,
DMXDEV_TYPE_SEC,
DMXDEV_TYPE_PES,
} dmxdev_type_t;
typedef enum {
DMXDEV_STATE_FREE,
DMXDEV_STATE_ALLOCATED,
DMXDEV_STATE_SET,
DMXDEV_STATE_GO,
DMXDEV_STATE_DONE,
DMXDEV_STATE_TIMEDOUT
} dmxdev_state_t;
typedef struct dmxdev_buffer_s {
uint8_t *data;
uint32_t size;
int32_t pread;
int32_t pwrite;
WAIT_QUEUE queue;
int error;
} dmxdev_buffer_t;
typedef struct dmxdev_filter_s {
union {
dmx_pes_filter_t *pes;
dmx_section_filter_t *sec;
} filter;
union {
dmx_ts_feed_t *ts;
dmx_section_feed_t *sec;
} feed;
union {
struct dmxSctFilterParams sec;
struct dmxPesFilterParams pes;
} params;
int type;
dmxdev_state_t state;
struct dmxdev_s *dev;
dmxdev_buffer_t buffer;
// only for sections
struct timer_list timer;
int todo;
uint8_t secheader[3];
u16 pid;
} dmxdev_filter_t;
typedef struct dmxdev_dvr_s {
int state;
struct dmxdev_s *dev;
dmxdev_buffer_t buffer;
} dmxdev_dvr_t;
typedef struct dmxdev_s {
dmxdev_filter_t *filter;
dmxdev_dvr_t *dvr;
dmx_demux_t *demux;
int filternum;
int capabilities;
#define DMXDEV_CAP_DUPLEX 1
dmx_frontend_t *dvr_orig_fe;
dmxdev_buffer_t dvr_buffer;
#define DVR_BUFFER_SIZE (512*1024)
struct semaphore mutex;
spinlock_t lock;
} dmxdev_t;
int DmxDevInit(dmxdev_t *dmxdev);
void DmxDevRelease(dmxdev_t *dmxdev);
int DmxDevFilterAlloc(dmxdev_t *dmxdev, struct file *file);
int DmxDevFilterFree(dmxdev_t *dmxdev, struct file *file);
int DmxDevIoctl(dmxdev_t *dmxdev, struct file *file,
unsigned int cmd, unsigned long arg);
unsigned int DmxDevPoll(dmxdev_t *dmxdev, struct file *file, poll_table * wait);
ssize_t DmxDevRead(dmxdev_t *dmxdev, struct file *file,
char *buf, size_t count, loff_t *ppos);
int DmxDevDVROpen(dmxdev_t *dmxdev, struct file *file);
int DmxDevDVRClose(dmxdev_t *dmxdev, struct file *file);
ssize_t DmxDevDVRWrite(dmxdev_t *dmxdev, struct file *file,
const char *buf, size_t count, loff_t *ppos);
ssize_t DmxDevDVRRead(dmxdev_t *dmxdev, struct file *file,
char *buf, size_t count, loff_t *ppos);
int DmxDevDVRIoctl(dmxdev_t *dmxdev, struct file *file,
unsigned int cmd, unsigned long arg);
unsigned int DmxDevDVRPoll(dmxdev_t *dmxdev, struct file *file, poll_table * wait);
#endif /* _DMXDEV_H_ */
|
