blob: a1b899bfa8d4b6312d98f4cdefd8e87799d40834 [file] [log] [blame]
/*
* 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 */