1 /* GSequencer - Advanced GTK Sequencer
2  * Copyright (C) 2005-2019 Joël Krähemann
3  *
4  * This file is part of GSequencer.
5  *
6  * GSequencer is free software: you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation, either version 3 of the License, or
9  * (at your option) any later version.
10  *
11  * GSequencer is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with GSequencer.  If not, see <http://www.gnu.org/licenses/>.
18  */
19 
20 #ifndef __AGS_LV2_WORKER_H__
21 #define __AGS_LV2_WORKER_H__
22 
23 #include <glib.h>
24 #include <glib-object.h>
25 
26 #include <ags/libags.h>
27 
28 #include <lv2.h>
29 #include <lv2/lv2plug.in/ns/ext/worker/worker.h>
30 
31 G_BEGIN_DECLS
32 
33 #define AGS_TYPE_LV2_WORKER                (ags_lv2_worker_get_type())
34 #define AGS_LV2_WORKER(obj)                (G_TYPE_CHECK_INSTANCE_CAST((obj), AGS_TYPE_LV2_WORKER, AgsLv2Worker))
35 #define AGS_LV2_WORKER_CLASS(class)        (G_TYPE_CHECK_CLASS_CAST((class), AGS_TYPE_LV2_WORKER, AgsLv2WorkerClass))
36 #define AGS_IS_LV2_WORKER(obj)             (G_TYPE_CHECK_INSTANCE_TYPE ((obj), AGS_TYPE_LV2_WORKER))
37 #define AGS_IS_LV2_WORKER_CLASS(class)     (G_TYPE_CHECK_CLASS_TYPE ((class), AGS_TYPE_LV2_WORKER))
38 #define AGS_LV2_WORKER_GET_CLASS(obj)      (G_TYPE_INSTANCE_GET_CLASS ((obj), AGS_TYPE_LV2_WORKER, AgsLv2WorkerClass))
39 
40 #define AGS_LV2_WORKER_GET_OBJ_MUTEX(obj) (&(((AgsLv2Worker *) obj)->obj_mutex))
41 
42 #define AGS_LV2_WORKER_RESPONSE_DATA(ptr) ((AgsLv2WorkerResponseData *)(ptr))
43 
44 typedef struct _AgsLv2Worker AgsLv2Worker;
45 typedef struct _AgsLv2WorkerClass AgsLv2WorkerClass;
46 typedef struct _AgsLv2WorkerResponseData AgsLv2WorkerResponseData;
47 
48 /**
49  * AgsLv2WorkerFlags:
50  * @AGS_LV2_WORKER_RUN: the worker is running
51  *
52  * Enum values to control the behavior or indicate internal state of #AgsLv2Worker by
53  * enable/disable as flags.
54  */
55 typedef enum{
56   AGS_LV2_WORKER_RUN    = 1,
57 }AgsLv2WorkerFlags;
58 
59 struct _AgsLv2Worker
60 {
61   GObject gobject;
62 
63   guint flags;
64 
65   GRecMutex obj_mutex;
66 
67   LV2_Handle handle;
68   LV2_Worker_Interface *worker_interface;
69 
70   guint work_size;
71   void *work_data;
72 
73   GList *response_data;
74 
75   AgsThread *worker_thread;
76 };
77 
78 struct _AgsLv2WorkerClass
79 {
80   GObjectClass gobject;
81 };
82 
83 struct _AgsLv2WorkerResponseData
84 {
85   uint32_t data_size;
86   void *data;
87 };
88 
89 GType ags_lv2_worker_get_type(void);
90 GType ags_lv2_worker_flags_get_type();
91 
92 gboolean ags_lv2_worker_test_flags(AgsLv2Worker *lv2_worker, guint flags);
93 void ags_lv2_worker_set_flags(AgsLv2Worker *lv2_worker, guint flags);
94 void ags_lv2_worker_unset_flags(AgsLv2Worker *lv2_worker, guint flags);
95 
96 AgsLv2WorkerResponseData* ags_lv2_worker_alloc_response_data();
97 void ags_lv2_worker_free_response_data(AgsLv2WorkerResponseData *response_data);
98 
99 LV2_Worker_Status ags_lv2_worker_respond(LV2_Worker_Respond_Handle handle,
100 					 uint32_t data_size,
101 					 const void* data);
102 
103 LV2_Worker_Status ags_lv2_worker_schedule_work(LV2_Worker_Schedule_Handle handle,
104 					       uint32_t data_size,
105 					       const void* data);
106 
107 void ags_lv2_worker_do_poll(AgsWorkerThread *worker_thread, gpointer data);
108 
109 AgsLv2Worker* ags_lv2_worker_new();
110 
111 G_END_DECLS
112 
113 #endif /*__AGS_LV2_WORKER_H__*/
114