/* * camtransport.h - GStreamer CAM (EN50221) transport layer * Copyright (C) 2007 Alessandro Decina * * Authors: * Alessandro Decina <alessandro@nnva.org> * * 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 St, Fifth Floor, * Boston, MA 02110-1301, USA. */ #ifndef CAM_TRANSPORT_H #define CAM_TRANSPORT_H #include <gst/gst.h> #include "cam.h" #include "camutils.h" #define HOST_BUFFER_SIZE 1024 #define CAM_TL(obj) ((CamTL *) obj) #define CAM_TL_CONNECTION(obj) ((CamTLConnection *) obj) typedef struct _CamTL CamTL; typedef struct _CamTLPrivate CamTLPrivate; typedef struct _CamTLConnection CamTLConnection; typedef struct _CamTLConnectionPrivate CamTLConnectionPrivate; typedef enum { CAM_TL_CONNECTION_STATE_CLOSED, CAM_TL_CONNECTION_STATE_IN_CREATION, CAM_TL_CONNECTION_STATE_OPEN, CAM_TL_CONNECTION_STATE_IN_DELETION } CamTLConnectionState; struct _CamTL { int fd; guint connection_ids; GHashTable *connections; guint expected_tpdus; /* buffer containing module data */ guint8 buffer [HOST_BUFFER_SIZE]; /* number of bytes written in the buffer */ guint buffer_size; /* index pointing to the first byte of a TPDU's body */ guint8 *body; /* length of the body part */ guint body_length; /* callbacks */ void (*request_connection) (CamTL *tl, CamTLConnection *connection); void (*connection_created) (CamTL *tl, CamTLConnection *connection); void (*connection_deleted) (CamTL *tl, CamTLConnection *connection); CamReturn (*connection_data) (CamTL *tl, CamTLConnection *connection, guint8 *data, guint length); /* used by the upper layer to extend this layer */ gpointer user_data; }; struct _CamTLConnection { CamTL *tl; guint8 slot; guint id; CamTLConnectionState state; /* TRUE if the last status byte was 0x80, FALSE otherwise */ gboolean has_data; /* NCAS 1.0 sometimes reports that it has data even if it doesn't. After * MAX_EMPTY_DATA times that we don't get any data we assume that there's * actually no data. */ guint empty_data; /* timer restarted every time the connection is polled */ GTimer *last_poll; gpointer user_data; }; CamTL *cam_tl_new (int cam_device_fd); void cam_tl_destroy (CamTL *tl); CamReturn cam_tl_create_connection (CamTL *tl, guint8 slot, CamTLConnection **connnection); CamReturn cam_tl_connection_delete (CamTLConnection *connection); void cam_tl_calc_buffer_size (CamTL *tl, guint body_length, guint *buffer_size, guint *offset); CamReturn cam_tl_connection_write (CamTLConnection *connection, guint8 *data, guint buffer_size, guint body_length); CamReturn cam_tl_connection_poll (CamTLConnection *connection, gboolean force); CamReturn cam_tl_read_all (CamTL *tl, gboolean poll); #endif /* CAM_TRANSPORT_H */