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
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
|
/*
* Copyright (C) 2006-2007 Texas Instruments, Incorporated
* Copyright (C) 2007-2009 Nokia Corporation.
*
* Author: Felipe Contreras <felipe.contreras@nokia.com>
*
* This library 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
* version 2.1 of the License.
*
* This library 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*
*/
#ifndef GSTOMX_UTIL_H
#define GSTOMX_UTIL_H
#include <glib.h>
#include <OMX_Core.h>
#include <OMX_Component.h>
#include <async_queue.h>
#include <sem.h>
/* Typedefs. */
typedef struct GOmxCore GOmxCore;
typedef struct GOmxPort GOmxPort;
typedef struct GOmxImp GOmxImp;
typedef struct GOmxSymbolTable GOmxSymbolTable;
typedef enum GOmxPortType GOmxPortType;
typedef void (*GOmxCb) (GOmxCore *core);
typedef void (*GOmxPortCb) (GOmxPort *port);
/* Enums. */
enum GOmxPortType
{
GOMX_PORT_INPUT,
GOMX_PORT_OUTPUT
};
/* Structures. */
struct GOmxSymbolTable
{
OMX_ERRORTYPE (*init) (void);
OMX_ERRORTYPE (*deinit) (void);
OMX_ERRORTYPE (*get_handle) (OMX_HANDLETYPE *handle,
OMX_STRING name,
OMX_PTR data,
OMX_CALLBACKTYPE *callbacks);
OMX_ERRORTYPE (*free_handle) (OMX_HANDLETYPE handle);
};
struct GOmxImp
{
guint client_count;
void *dl_handle;
GOmxSymbolTable sym_table;
GMutex *mutex;
};
struct GOmxCore
{
gpointer object; /**< GStreamer element. */
OMX_HANDLETYPE omx_handle;
OMX_ERRORTYPE omx_error;
OMX_STATETYPE omx_state;
GCond *omx_state_condition;
GMutex *omx_state_mutex;
GPtrArray *ports;
GSem *done_sem;
GSem *flush_sem;
GSem *port_sem;
GOmxCb settings_changed_cb;
GOmxImp *imp;
gboolean done;
gchar *library_name;
gchar *component_name;
gchar *component_role;
};
struct GOmxPort
{
GOmxCore *core;
GOmxPortType type;
guint num_buffers;
gulong buffer_size;
guint port_index;
OMX_BUFFERHEADERTYPE **buffers;
GMutex *mutex;
gboolean enabled;
gboolean omx_allocate; /**< Setup with OMX_AllocateBuffer rather than OMX_UseBuffer */
AsyncQueue *queue;
};
/* Functions. */
void g_omx_init (void);
void g_omx_deinit (void);
GOmxCore *g_omx_core_new (void *object);
void g_omx_core_free (GOmxCore *core);
void g_omx_core_init (GOmxCore *core);
void g_omx_core_prepare (GOmxCore *core);
void g_omx_core_start (GOmxCore *core);
void g_omx_core_pause (GOmxCore *core);
void g_omx_core_stop (GOmxCore *core);
void g_omx_core_unload (GOmxCore *core);
void g_omx_core_set_done (GOmxCore *core);
void g_omx_core_wait_for_done (GOmxCore *core);
void g_omx_core_flush_start (GOmxCore *core);
void g_omx_core_flush_stop (GOmxCore *core);
GOmxPort *g_omx_core_new_port (GOmxCore *core, guint index);
GOmxPort *g_omx_port_new (GOmxCore *core, guint index);
void g_omx_port_free (GOmxPort *port);
void g_omx_port_setup (GOmxPort *port);
void g_omx_port_push_buffer (GOmxPort *port, OMX_BUFFERHEADERTYPE *omx_buffer);
OMX_BUFFERHEADERTYPE *g_omx_port_request_buffer (GOmxPort *port);
void g_omx_port_release_buffer (GOmxPort *port, OMX_BUFFERHEADERTYPE *omx_buffer);
void g_omx_port_resume (GOmxPort *port);
void g_omx_port_pause (GOmxPort *port);
void g_omx_port_flush (GOmxPort *port);
void g_omx_port_enable (GOmxPort *port);
void g_omx_port_disable (GOmxPort *port);
void g_omx_port_finish (GOmxPort *port);
/* Utility Macros */
/**
* Basically like GST_BOILERPLATE / GST_BOILERPLATE_FULL, but follows the
* init fxn naming conventions used by gst-openmax. It expects the following
* functions to be defined in the same src file following this macro
* <ul>
* <li> type_base_init(gpointer g_class)
* <li> type_class_init(gpointer g_class, gpointer class_data)
* <li> type_instance_init(GTypeInstance *instance, gpointer g_class)
* </ul>
*/
#define GSTOMX_BOILERPLATE_FULL(type, type_as_function, parent_type, parent_type_macro, additional_initializations) \
static void type_base_init (gpointer g_class); \
static void type_class_init (gpointer g_class, gpointer class_data); \
static void type_instance_init (GTypeInstance *instance, gpointer g_class); \
static parent_type ## Class *parent_class; \
static void type_class_init_trampoline (gpointer g_class, gpointer class_data)\
{ \
parent_class = g_type_class_ref (parent_type_macro); \
type_class_init (g_class, class_data); \
} \
GType type_as_function ## _get_type (void) \
{ \
/* The typedef for GType may be gulong or gsize, depending on the \
* system and whether the compiler is c++ or not. The g_once_init_* \
* functions always take a gsize * though ... */ \
static volatile gsize gonce_data = 0; \
if (g_once_init_enter (&gonce_data)) { \
GType _type; \
GTypeInfo *type_info; \
type_info = g_new0 (GTypeInfo, 1); \
type_info->class_size = sizeof (type ## Class); \
type_info->base_init = type_base_init; \
type_info->class_init = type_class_init_trampoline; \
type_info->instance_size = sizeof (type); \
type_info->instance_init = type_instance_init; \
_type = g_type_register_static (parent_type_macro, #type, type_info, 0);\
g_free (type_info); \
additional_initializations (_type); \
g_once_init_leave (&gonce_data, (gsize) _type); \
} \
return (GType) gonce_data; \
}
#define GSTOMX_BOILERPLATE(type,type_as_function,parent_type,parent_type_macro) \
GSTOMX_BOILERPLATE_FULL (type, type_as_function, parent_type, parent_type_macro, \
__GST_DO_NOTHING)
#include <string.h> /* for memset */
#define G_OMX_INIT_PARAM(param) G_STMT_START { \
memset (&(param), 0, sizeof ((param))); \
(param).nSize = sizeof (param); \
(param).nVersion.s.nVersionMajor = 1; \
(param).nVersion.s.nVersionMinor = 1; \
} G_STMT_END
#endif /* GSTOMX_UTIL_H */
|
