/usr/include/d/gtkd-3/gstreamer/TaskPool.d is in libgstreamerd-3-dev 3.7.5-2build1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 | /*
* This file is part of gtkD.
*
* gtkD 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 3
* of the License, or (at your option) any later version, with
* some exceptions, please read the COPYING file.
*
* gtkD 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 gtkD; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110, USA
*/
// generated automatically - do not change
// find conversion definition on APILookup.txt
// implement new conversion functionalities on the wrap.utils pakage
module gstreamer.TaskPool;
private import glib.ConstructionException;
private import glib.ErrorG;
private import glib.GException;
private import gobject.ObjectG;
private import gstreamer.ObjectGst;
private import gstreamer.c.functions;
public import gstreamer.c.types;
public import gstreamerc.gstreamertypes;
/**
* This object provides an abstraction for creating threads. The default
* implementation uses a regular GThreadPool to start tasks.
*
* Subclasses can be made to create custom threads.
*/
public class TaskPool : ObjectGst
{
/** the main Gtk struct */
protected GstTaskPool* gstTaskPool;
/** Get the main Gtk struct */
public GstTaskPool* getTaskPoolStruct(bool transferOwnership = false)
{
if (transferOwnership)
ownedRef = false;
return gstTaskPool;
}
/** the main Gtk struct as a void* */
protected override void* getStruct()
{
return cast(void*)gstTaskPool;
}
protected override void setStruct(GObject* obj)
{
gstTaskPool = cast(GstTaskPool*)obj;
super.setStruct(obj);
}
/**
* Sets our main struct and passes it to the parent class.
*/
public this (GstTaskPool* gstTaskPool, bool ownedRef = false)
{
this.gstTaskPool = gstTaskPool;
super(cast(GstObject*)gstTaskPool, ownedRef);
}
/** */
public static GType getType()
{
return gst_task_pool_get_type();
}
/**
* Create a new default task pool. The default task pool will use a regular
* GThreadPool for threads.
*
* Returns: a new #GstTaskPool. gst_object_unref() after usage.
*
* Throws: ConstructionException GTK+ fails to create the object.
*/
public this()
{
auto p = gst_task_pool_new();
if(p is null)
{
throw new ConstructionException("null returned by new");
}
this(cast(GstTaskPool*) p, true);
}
/**
* Wait for all tasks to be stopped. This is mainly used internally
* to ensure proper cleanup of internal data structures in test suites.
*
* MT safe.
*/
public void cleanup()
{
gst_task_pool_cleanup(gstTaskPool);
}
/**
* Join a task and/or return it to the pool. @id is the id obtained from
* gst_task_pool_push().
*
* Params:
* id = the id
*/
public void join(void* id)
{
gst_task_pool_join(gstTaskPool, id);
}
/**
* Prepare the taskpool for accepting gst_task_pool_push() operations.
*
* MT safe.
*
* Throws: GException on failure.
*/
public void prepare()
{
GError* err = null;
gst_task_pool_prepare(gstTaskPool, &err);
if (err !is null)
{
throw new GException( new ErrorG(err) );
}
}
/**
* Start the execution of a new thread from @pool.
*
* Params:
* func = the function to call
* userData = data to pass to @func
*
* Returns: a pointer that should be used
* for the gst_task_pool_join function. This pointer can be %NULL, you
* must check @error to detect errors.
*
* Throws: GException on failure.
*/
public void* push(GstTaskPoolFunction func, void* userData)
{
GError* err = null;
auto p = gst_task_pool_push(gstTaskPool, func, userData, &err);
if (err !is null)
{
throw new GException( new ErrorG(err) );
}
return p;
}
}
|