diff --git a/CMakeLists.txt b/CMakeLists.txt index 7c3336a..e1f5901 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -10,6 +10,7 @@ find_package (NIIMAQ) find_package (FreeImage) find_package (OpenCV) find_package (Euresys) +find_package (IOtechDaqX) # conditional required packages include (CheckIncludeFiles) diff --git a/cmake/modules/FindIOtechDaqX.cmake b/cmake/modules/FindIOtechDaqX.cmake new file mode 100644 index 0000000..1185e0d --- /dev/null +++ b/cmake/modules/FindIOtechDaqX.cmake @@ -0,0 +1,49 @@ +# - Try to find IOtech DaqX SDK +# Once done this will define +# +# IOTECHDAQX_FOUND - system has IOtech DaqX SDK +# IOTECHDAQX_INCLUDE_DIR - the IOtech DaqX SDK include directory +# IOTECHDAQX_LIBRARIES - the libraries needed to use IOtech DaqX + +# Copyright (c) 2006, Tim Beaulen +# +# Redistribution and use is allowed according to the terms of the BSD license. +# For details see the accompanying COPYING-CMAKE-SCRIPTS file. + +IF (IOTECHDAQX_INCLUDE_DIR AND IOTECHDAQX_LIBRARIES) + # in cache already + SET(IOTECHDAQX_FIND_QUIETLY TRUE) +ELSE (IOTECHDAQX_INCLUDE_DIR AND IOTECHDAQX_LIBRARIES) + SET(IOTECHDAQX_FIND_QUIETLY FALSE) +ENDIF (IOTECHDAQX_INCLUDE_DIR AND IOTECHDAQX_LIBRARIES) + +IF (NOT IOTECHDAQX_DIR) + SET (IOTECHDAQX_DIR "C:/Program Files/DaqX" CACHE PATH "Directory containing IOtech DaqX") +ENDIF (NOT IOTECHDAQX_DIR) + +FIND_PATH (IOTECHDAQX_INCLUDE_DIR DAQX.H + PATHS + "${IOTECHDAQX_DIR}/Programming Language Support/WaveBook/C/32-bit Enhanced API" + DOC "Directory containing DAQX.H include file") + +FIND_LIBRARY (IOTECHDAQX_LIBRARIES NAMES DAQX + PATHS + "${IOTECHDAQX_DIR}/Programming Language Support/WaveBook/C/32-bit Enhanced API" + DOC "IOTECHDAQX library to link with") + +IF (IOTECHDAQX_INCLUDE_DIR) + #MESSAGE(STATUS "DEBUG: Found IOtech DaqX include dir: ${IOTECHDAQX_INCLUDE_DIR}") +ELSE (IOTECHDAQX_INCLUDE_DIR) + MESSAGE(STATUS "IOTECHDAQX: WARNING: include dir not found") +ENDIF (IOTECHDAQX_INCLUDE_DIR) + +IF (IOTECHDAQX_LIBRARIES) + #MESSAGE(STATUS "DEBUG: Found IOtech DaqX library: ${IOTECHDAQX_LIBRARIES}") +ELSE (IOTECHDAQX_LIBRARIES) + MESSAGE(STATUS "IOTECHDAQX: WARNING: library not found") +ENDIF (IOTECHDAQX_LIBRARIES) + +INCLUDE (FindPackageHandleStandardArgs) +FIND_PACKAGE_HANDLE_STANDARD_ARGS (IOTECHDAQX DEFAULT_MSG IOTECHDAQX_INCLUDE_DIR IOTECHDAQX_LIBRARIES) + +MARK_AS_ADVANCED(IOTECHDAQX_INCLUDE_DIR IOTECHDAQX_LIBRARIES) \ No newline at end of file diff --git a/sys/CMakeLists.txt b/sys/CMakeLists.txt index 84d2c72..70f3d44 100644 --- a/sys/CMakeLists.txt +++ b/sys/CMakeLists.txt @@ -1,2 +1,3 @@ add_subdirectory (euresys) add_subdirectory (niimaq) +add_subdirectory (iotechdaqx) diff --git a/sys/iotechdaqx/CMakeLists.txt b/sys/iotechdaqx/CMakeLists.txt new file mode 100644 index 0000000..0a548d7 --- /dev/null +++ b/sys/iotechdaqx/CMakeLists.txt @@ -0,0 +1,26 @@ +add_definitions(-DHAVE_CONFIG_H) + +set ( SOURCES + gstiotechdaqx.c ) + +set ( HEADERS + gstiotechdaqx.h ) + +include_directories ( AFTER + . + ${WAVEBOOK_INCLUDE_DIR} ) + +add_library ( libgstiotechdaqx MODULE + ${SOURCES} + ${HEADERS} ) + +target_link_libraries ( libgstiotechdaqx + ${GLIB2_LIBRARIES} + ${GSTREAMER_LIBRARIES} + ${GSTREAMER_BASE_LIBRARY} + ${GSTREAMER_INTERFACE_LIBRARY} + ${GSTREAMER_VIDEO_LIBRARY} + ${IOTECHDAQX_LIBRARIES}) + +install (TARGETS libgstiotechdaqx + LIBRARY DESTINATION lib/gstreamer-0.10) \ No newline at end of file diff --git a/sys/iotechdaqx/gstiotechdaqx.c b/sys/iotechdaqx/gstiotechdaqx.c new file mode 100644 index 0000000..09be737 --- /dev/null +++ b/sys/iotechdaqx/gstiotechdaqx.c @@ -0,0 +1,493 @@ +/* GStreamer + * Copyright (C) 2011 FIXME + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Library General Public + * License as published by the Free Software Foundation; either + * version 2 of the License, or (at your option) any later version. + * + * 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 + * Library General Public License for more details. + * + * You should have received a copy of the GNU Library General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 51 Franklin Street, Suite 500, + * Boston, MA 02110-1335, USA. + */ +/** + * SECTION:element-gstiotechdaqx + * + * The iotechdaqx element is a source for data acquisition devices supported by the IOtechDaqX driver. + * + * + * Example launch line + * |[ + * gst-launch -v iotechdaqx ! FIXME + * ]| + * FIXME from the default IOtechDaqX device + * + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include +#include +#include "gstiotechdaqx.h" + +#define NULL 0 + +GST_DEBUG_CATEGORY_STATIC (gst_iotechdaqx_debug); +#define GST_CAT_DEFAULT gst_iotechdaqx_debug + +/* prototypes */ + + +static void gst_iotechdaqx_set_property (GObject * object, + guint property_id, const GValue * value, GParamSpec * pspec); +static void gst_iotechdaqx_get_property (GObject * object, + guint property_id, GValue * value, GParamSpec * pspec); +static void gst_iotechdaqx_dispose (GObject * object); +static void gst_iotechdaqx_finalize (GObject * object); + +static GstCaps *gst_iotechdaqx_get_caps (GstBaseSrc * src); +static gboolean gst_iotechdaqx_set_caps (GstBaseSrc * src, GstCaps * caps); +static gboolean gst_iotechdaqx_newsegment (GstBaseSrc * src); +static gboolean gst_iotechdaqx_start (GstBaseSrc * src); +static gboolean gst_iotechdaqx_stop (GstBaseSrc * src); +static void +gst_iotechdaqx_get_times (GstBaseSrc * src, GstBuffer * buffer, + GstClockTime * start, GstClockTime * end); +static gboolean gst_iotechdaqx_get_size (GstBaseSrc * src, guint64 * size); +static gboolean gst_iotechdaqx_is_seekable (GstBaseSrc * src); +static gboolean gst_iotechdaqx_query (GstBaseSrc * src, GstQuery * query); +static gboolean gst_iotechdaqx_check_get_range (GstBaseSrc * src); +static void gst_iotechdaqx_fixate (GstBaseSrc * src, GstCaps * caps); +static GstFlowReturn gst_iotechdaqx_create (GstPushSrc * src, GstBuffer ** buf); + +enum +{ + PROP_0, + PROP_BOARD_INDEX + /* FILL ME */ +}; + +#define DEFAULT_PROP_BOARD_INDEX 0 + +/* pad templates */ + +static GstStaticPadTemplate gst_iotechdaqx_src_template = +GST_STATIC_PAD_TEMPLATE ("src", + GST_PAD_SRC, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ( + //GST_AUDIO_INT_PAD_TEMPLATE_CAPS) + "audio/x-raw-int, " \ + "rate = (int) 10000, " \ + "channels = (int) 1, " \ + "endianness = (int) BYTE_ORDER, " \ + "width = (int) 16, " \ + "depth = (int) 16, " \ + "signed = (boolean) true") + ); + +/* class initialization */ + +GST_BOILERPLATE (GstIOtechDaqX, gst_iotechdaqx, GstPushSrc, + GST_TYPE_PUSH_SRC); + + +char* GetProtocol(DaqProtocol protocol){ + /*This function is used to display the protcol name; since the + protcol itself is stored as a number, this function associates + the protocol number with a string. + */ + char* protocolName[64]; + + switch (protocol) + { + case DaqProtocolNone: *protocolName="DaqProtocolNone";break; + case DaqProtocol4: *protocolName="DaqProtocol4";break; + case DaqProtocol8: *protocolName="DaqProtocol8";break; + case DaqProtocolSMC666: *protocolName="DaqProtocolSMC666";break; + case DaqProtocolFastEPP: *protocolName="DaqProtocolFastEPP";break; + case DaqProtocolECP: *protocolName="DaqProtocolECP";break; + case DaqProtocol8BitEPP: *protocolName="DaqProtocol8BitEPP";break; + case DaqProtocolTCPIP: *protocolName="DaqProtocolTCPIP";break; + case DaqProtocolISA: *protocolName="DaqProtocolISA";break; + case DaqProtocolPcCard: *protocolName="DaqProtocolPcCard";break; + case DaqProtocolUSB: *protocolName="DaqProtocolUSB";break; + case DaqProtocolPCI: *protocolName="DaqProtocolPCI";break; + case DaqProtocolCPCI: *protocolName="DaqProtocolCPCI";break; + default: *protocolName="Unknown";break; + } + return *protocolName; +} + + +static void +gst_iotechdaqx_base_init (gpointer g_class) +{ + GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); + + gst_element_class_add_pad_template (element_class, + gst_static_pad_template_get (&gst_iotechdaqx_src_template)); + + gst_element_class_set_details_simple (element_class, + "IOtechDaqX Data Source", "Source/Audio", + "IOtechDaqX data source", + "Joshua Doe "); +} + +static void +gst_iotechdaqx_class_init (GstIOtechDaqXClass * klass) +{ + GObjectClass *gobject_class = G_OBJECT_CLASS (klass); + GstBaseSrcClass *base_src_class = GST_BASE_SRC_CLASS (klass); + GstPushSrcClass *push_src_class = GST_PUSH_SRC_CLASS (klass); + + gobject_class->set_property = gst_iotechdaqx_set_property; + gobject_class->get_property = gst_iotechdaqx_get_property; + gobject_class->dispose = gst_iotechdaqx_dispose; + gobject_class->finalize = gst_iotechdaqx_finalize; + base_src_class->get_caps = GST_DEBUG_FUNCPTR (gst_iotechdaqx_get_caps); + base_src_class->set_caps = GST_DEBUG_FUNCPTR (gst_iotechdaqx_set_caps); + base_src_class->newsegment = GST_DEBUG_FUNCPTR (gst_iotechdaqx_newsegment); + base_src_class->start = GST_DEBUG_FUNCPTR (gst_iotechdaqx_start); + base_src_class->stop = GST_DEBUG_FUNCPTR (gst_iotechdaqx_stop); + base_src_class->get_times = GST_DEBUG_FUNCPTR (gst_iotechdaqx_get_times); + base_src_class->get_size = GST_DEBUG_FUNCPTR (gst_iotechdaqx_get_size); + base_src_class->is_seekable = GST_DEBUG_FUNCPTR (gst_iotechdaqx_is_seekable); + base_src_class->query = GST_DEBUG_FUNCPTR (gst_iotechdaqx_query); + base_src_class->check_get_range = GST_DEBUG_FUNCPTR (gst_iotechdaqx_check_get_range); + base_src_class->fixate = GST_DEBUG_FUNCPTR (gst_iotechdaqx_fixate); + + push_src_class->create = GST_DEBUG_FUNCPTR (gst_iotechdaqx_create); + + + /* Install GObject properties */ + //g_object_class_install_property (gobject_class, PROP_BOARD_INDEX, + // g_param_spec_int ("board", "Board", "Index of board connected to camera", + // 0, 15, DEFAULT_PROP_BOARD_INDEX, G_PARAM_READWRITE)); + +} + +static void +gst_iotechdaqx_init (GstIOtechDaqX * iotechdaqx, GstIOtechDaqXClass * iotechdaqx_class) +{ + iotechdaqx->srcpad = gst_pad_new_from_static_template (&gst_iotechdaqx_src_template + , "src"); + + /* set source as live (no preroll) */ + gst_base_src_set_live (GST_BASE_SRC (iotechdaqx), TRUE); + + /* override default of BYTES to operate in time mode */ + gst_base_src_set_format (GST_BASE_SRC (iotechdaqx), GST_FORMAT_TIME); + + /* initialize member variables */ + iotechdaqx->caps = NULL; + iotechdaqx->handle = -1; + iotechdaqx->opened = FALSE; + + // FIXME: initialize ALL member variables +} + +void +gst_iotechdaqx_set_property (GObject * object, guint property_id, + const GValue * value, GParamSpec * pspec) +{ + GstIOtechDaqX *iotechdaqx; + + g_return_if_fail (GST_IS_IOTECHDAQX (object)); + iotechdaqx = GST_IOTECHDAQX (object); + + switch (property_id) { + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); + break; + } +} + +void +gst_iotechdaqx_get_property (GObject * object, guint property_id, + GValue * value, GParamSpec * pspec) +{ + GstIOtechDaqX *iotechdaqx; + + g_return_if_fail (GST_IS_IOTECHDAQX (object)); + iotechdaqx = GST_IOTECHDAQX (object); + + switch (property_id) { + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); + break; + } +} + +void +gst_iotechdaqx_dispose (GObject * object) +{ + GstIOtechDaqX *iotechdaqx; + + g_return_if_fail (GST_IS_IOTECHDAQX (object)); + iotechdaqx = GST_IOTECHDAQX (object); + + /* clean up as possible. may be called multiple times */ + + G_OBJECT_CLASS (parent_class)->dispose (object); +} + +void +gst_iotechdaqx_finalize (GObject * object) +{ + GstIOtechDaqX *iotechdaqx; + + g_return_if_fail (GST_IS_IOTECHDAQX (object)); + iotechdaqx = GST_IOTECHDAQX (object); + + /* clean up object here */ + + G_OBJECT_CLASS (parent_class)->finalize (object); +} + + +static GstCaps * +gst_iotechdaqx_get_caps (GstBaseSrc * src) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "get_caps"); + + /* return template caps if we don't know the actual camera caps */ + if (!iotechdaqx->caps) { + return gst_caps_copy (gst_pad_get_pad_template_caps (GST_BASE_SRC_PAD (iotechdaqx))); + } + + return gst_caps_copy (iotechdaqx->caps); + + return NULL; +} + +static gboolean +gst_iotechdaqx_set_caps (GstBaseSrc * src, GstCaps * caps) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + GstStructure *structure; + gboolean ret; + + GST_DEBUG_OBJECT (iotechdaqx, "set_caps"); + + if (iotechdaqx->caps) { + gst_caps_unref (iotechdaqx->caps); + iotechdaqx->caps = gst_caps_copy (caps); + } + + /* parse caps */ + + if (gst_caps_get_size (caps) < 1) + return FALSE; + + structure = gst_caps_get_structure (caps, 0); + + ret = gst_structure_get (structure, + "width", G_TYPE_INT, &iotechdaqx->width, + "rate", G_TYPE_INT, &iotechdaqx->rate, + "channels", G_TYPE_INT, &iotechdaqx->channels, + NULL); + + if (!ret) { + GST_DEBUG ("Failed to retrieve width and height"); + return FALSE; + } + + return TRUE; +} + +static gboolean +gst_iotechdaqx_newsegment (GstBaseSrc * src) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "newsegment"); + + return TRUE; +} + +static gboolean +gst_iotechdaqx_start (GstBaseSrc * src) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + DaqDeviceListT *devList; + DaqDevicePropsT devProps; + DWORD devCount, deviceIndex; + + GST_DEBUG_OBJECT (iotechdaqx, "start"); + + + // Find out how many devices are installed and allocate memory for device list + daqGetDeviceCount(&devCount); + devList = (DaqDeviceListT*)malloc(sizeof(DaqDeviceListT)*devCount); + + GST_DEBUG ("Found %d devices", devCount); + + // Get the names of all installed devices and the device count + daqGetDeviceList(devList, &devCount); + + deviceIndex = 0; + do { + // Get the device properties for each device + daqGetDeviceProperties(devList[deviceIndex].daqName, &devProps); + + GST_DEBUG ("Device %i: %s", deviceIndex, devList[deviceIndex].daqName); + deviceIndex++; + + // Loop until a WaveBook is found or all the devices have been searched + } while (deviceIndex < devCount); + + // We are done with the device list + free(devList); + + iotechdaqx->handle = daqOpen(devProps.daqName); + GST_DEBUG ("Connected to %s on LPT%d\n", devProps.daqName, devProps.basePortAddress+1); + GST_DEBUG ("Protocol: %s \n", GetProtocol(devProps.protocol)); + + //FIXME check for errors! + + return TRUE; +} + +static gboolean +gst_iotechdaqx_stop (GstBaseSrc * src) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "stop"); + + /* Stop the acquisition */ + daqAdcTransferStop (iotechdaqx->handle); + daqClose (iotechdaqx->handle); + + gst_caps_unref (iotechdaqx->caps); + iotechdaqx->caps = NULL; + + iotechdaqx->opened = FALSE; + + return TRUE; +} + +static void +gst_iotechdaqx_get_times (GstBaseSrc * src, GstBuffer * buffer, + GstClockTime * start, GstClockTime * end) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + //GST_DEBUG_OBJECT (iotechdaqx, "get_times"); +} + +static gboolean +gst_iotechdaqx_get_size (GstBaseSrc * src, guint64 * size) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "get_size"); + + return TRUE; +} + +static gboolean +gst_iotechdaqx_is_seekable (GstBaseSrc * src) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "is_seekable"); + + return FALSE; +} + +static gboolean +gst_iotechdaqx_query (GstBaseSrc * src, GstQuery * query) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "query"); + + return TRUE; +} + +static gboolean +gst_iotechdaqx_check_get_range (GstBaseSrc * src) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "get_range"); + + return FALSE; +} + +static void +gst_iotechdaqx_fixate (GstBaseSrc * src, GstCaps * caps) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + + GST_DEBUG_OBJECT (iotechdaqx, "fixate"); +} + +static GstFlowReturn +gst_iotechdaqx_create (GstPushSrc * src, GstBuffer ** buf) +{ + GstIOtechDaqX *iotechdaqx = GST_IOTECHDAQX (src); + DWORD retCount; + + //GST_DEBUG ("create (handle=%d)", iotechdaqx->handle); + + if (!iotechdaqx->opened) { + DWORD channels[1] = {1}; + DaqAdcGain gains[1] = {DgainX1}; + DWORD flags[1] = {DafAnalog|DafBipolar}; + + GST_DEBUG ("Setting up acquisition: rate=%d", iotechdaqx->rate); + + daqAdcSetScan (iotechdaqx->handle, channels, gains, flags, 1); + daqAdcSetAcq (iotechdaqx->handle, DaamInfinitePost, 0, 0); + daqSetTriggerEvent (iotechdaqx->handle, DatsSoftware, NULL, NULL, NULL, NULL, NULL, NULL, NULL, DaqStartEvent); + //daqSetTriggerEvent (iotechdaqx->handle, DatsSoftware, NULL, NULL, NULL, NULL, NULL, NULL, NULL, DaqStopEvent); + daqAdcSetFreq (iotechdaqx->handle, (float)iotechdaqx->rate); + daqAdcTransferSetBuffer (iotechdaqx->handle, NULL, 44100, DatmCycleOn|DatmDriverBuf); + + daqAdcTransferStart (iotechdaqx->handle); + daqAdcArm (iotechdaqx->handle); + daqAdcSoftTrig (iotechdaqx->handle); //FIXME: put in create() and use has_started flag + + iotechdaqx->opened = TRUE; + } + + gst_pad_alloc_buffer_and_set_caps (GST_BASE_SRC_PAD (GST_BASE_SRC (src)), 0, 2048*2, iotechdaqx->caps, buf); + + daqAdcTransferBufData (iotechdaqx->handle, GST_BUFFER_DATA(*buf), 2048, DabtmOldest|DabtmWait, &retCount); + + //GST_DEBUG ("Asked for %d samples, got %d", 2048, retCount); + + //memcpy(GST_BUFFER_DATA (*buf), tmp, 16*sizeof(SHORT)); + + return GST_FLOW_OK; +} + +static gboolean +plugin_init (GstPlugin * plugin) +{ + GST_DEBUG_CATEGORY_INIT (gst_iotechdaqx_debug, "iotechdaqx", 0, \ + "debug category for iotechdaqx element"); + gst_element_register (plugin, "iotechdaqx", GST_RANK_NONE, + gst_iotechdaqx_get_type ()); + + return TRUE; +} + +GST_PLUGIN_DEFINE (GST_VERSION_MAJOR, + GST_VERSION_MINOR, + "iotechdaqx", + "IOtechDaqX source", + plugin_init, VERSION, "LGPL", PACKAGE_NAME, GST_PACKAGE_ORIGIN) diff --git a/sys/iotechdaqx/gstiotechdaqx.h b/sys/iotechdaqx/gstiotechdaqx.h new file mode 100644 index 0000000..3d7ebd1 --- /dev/null +++ b/sys/iotechdaqx/gstiotechdaqx.h @@ -0,0 +1,66 @@ +/* GStreamer + * Copyright (C) 2011 FIXME + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Library General Public + * License as published by the Free Software Foundation; either + * version 2 of the License, or (at your option) any later version. + * + * 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 + * Library General Public License for more details. + * + * You should have received a copy of the GNU Library General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 59 Temple Place - Suite 330, + * Boston, MA 02111-1307, USA. + */ + +#ifndef _GST_IOTECHDAQX_H_ +#define _GST_IOTECHDAQX_H_ + +#include +#include +#include + +G_BEGIN_DECLS + +#define GST_TYPE_IOTECHDAQX (gst_iotechdaqx_get_type()) +#define GST_IOTECHDAQX(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_IOTECHDAQX,GstIOtechDaqX)) +#define GST_IOTECHDAQX_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_IOTECHDAQX,GstIOtechDaqXClass)) +#define GST_IS_IOTECHDAQX(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_IOTECHDAQX)) +#define GST_IS_IOTECHDAQX_CLASS(obj) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_IOTECHDAQX)) + +typedef struct _GstIOtechDaqX GstIOtechDaqX; +typedef struct _GstIOtechDaqXClass GstIOtechDaqXClass; + +struct _GstIOtechDaqX +{ + GstPushSrc base_iotechdaqx; + + GstPad *srcpad; + + GstCaps *caps; + gint rate; + gint channels; + gint endianness; + gint width; + gint depth; + gboolean is_signed; + + gboolean opened; + + DaqHandleT handle; +}; + +struct _GstIOtechDaqXClass +{ + GstPushSrcClass base_iotechdaqx_class; +}; + +GType gst_iotechdaqx_get_type (void); + +G_END_DECLS + +#endif