#include "ClpeStream.h"

Include dependency graph for ClpeStream.cpp:

Classes
struct	frame_info

struct	function_arg

Macros
#define	MAX_SEQ_OFFSET 110000

#define	SIMPLE_LOCK while(g_lock) { usleep(10); } g_lock = 1;

#define	SIMPLE_UNLOCK g_lock = 0;

Typedefs
typedef struct frame_info	t_frame_info

typedef struct function_arg	t_function_arg

Functions
int	clpe_getFrameAnyCam (int p_camera_id, unsigned char p_buffer, unsigned int p_size, struct timeval *pt_camera_timeStamp)

int	clpe_getFrameWithCamId (int camera_id, unsigned char *p_buffer, unsigned int p_size, struct timeval *pt_camera_timeStamp)

void *	clpe_runStream (void *pArg)

int	clpe_startStream (T_CB_APP cb_app, char use_cam_0, char use_cam_1, char use_cam_2, char use_cam_3, int display_on)

int	clpe_stopStream (void)

void	increase_seq (PortData *data, xu32 now_seq)

void	intecept_frame (int camera_id, unsigned int cur_frame_seq, unsigned char p_buffer, unsigned int size, struct timeval pt_camera_timeStamp)

int	launch_port (PortData *data)

static GstFlowReturn	on_new_sample_from_sink (GstElement elt, PortData data)

gboolean	on_sink_message_appsink (GstBus bus, GstMessage message, PortData *data)

gboolean	on_source_message (GstBus bus, GstMessage message, PortData *data)

int	process_block_done (PortData *data)

Variables
GstBus *	appSinkBus

struct timeval	frame_pre [AVAILALE_PORT] = {{0,},}

unsigned int	g_cur_cam_id = 0

unsigned int	g_cur_frame_seq = 0

unsigned int	g_last_cam_id = 0

unsigned int	g_last_frame_seq = 0

int	g_lock = 0

ProgramMain	g_MainData

unsigned int	g_max_seq_offset = MAX_SEQ_OFFSET

pthread_t	g_pthread

T_UDP_BLOCK_CONTENT	g_recv [AVAILALE_PORT]

unsigned int	g_stop_signal = 0

GstElement *	gAppSink

t_frame_info	gt_frame_info [AVAILALE_PORT] = {0,}

struct timeval	prePcTime [AVAILALE_PORT] = {{0,},}

unsigned int	seq_base [AVAILALE_PORT] = {0, }

Macro Definition Documentation

◆ MAX_SEQ_OFFSET

#define MAX_SEQ_OFFSET 110000

Definition at line 11 of file ClpeStream.cpp.

◆ SIMPLE_LOCK

#define SIMPLE_LOCK while(g_lock) { usleep(10); } g_lock = 1;

Definition at line 17 of file ClpeStream.cpp.

◆ SIMPLE_UNLOCK

#define SIMPLE_UNLOCK g_lock = 0;

Definition at line 18 of file ClpeStream.cpp.

Typedef Documentation

◆ t_frame_info

typedef struct frame_info t_frame_info

◆ t_function_arg

typedef struct function_arg t_function_arg

Function Documentation

◆ clpe_getFrameAnyCam()

int clpe_getFrameAnyCam	(	int *	p_camera_id,
		unsigned char **	p_buffer,
		unsigned int *	p_size,
		struct timeval *	pt_camera_timeStamp
	)

Definition at line 619 of file ClpeStream.cpp.

◆ clpe_getFrameWithCamId()

int clpe_getFrameWithCamId	(	int	camera_id,
		unsigned char **	p_buffer,
		unsigned int *	p_size,
		struct timeval *	pt_camera_timeStamp
	)

Definition at line 645 of file ClpeStream.cpp.

◆ clpe_runStream()

void* clpe_runStream ( void * pArg )

Definition at line 445 of file ClpeStream.cpp.

◆ clpe_startStream()

int clpe_startStream	(	T_CB_APP	cb_app,
		char	use_cam_0,
		char	use_cam_1,
		char	use_cam_2,
		char	use_cam_3,
		int	display_on
	)

Definition at line 574 of file ClpeStream.cpp.

◆ clpe_stopStream()

int clpe_stopStream ( void )

Definition at line 599 of file ClpeStream.cpp.

◆ increase_seq()

void increase_seq	(	PortData *	data,
		xu32	now_seq
	)

Definition at line 48 of file ClpeStream.cpp.

◆ intecept_frame()

void intecept_frame	(	int	camera_id,
		unsigned int	cur_frame_seq,
		unsigned char *	p_buffer,
		unsigned int	size,
		struct timeval *	pt_camera_timeStamp
	)

Definition at line 562 of file ClpeStream.cpp.

◆ launch_port()

int launch_port ( PortData * data )

Definition at line 333 of file ClpeStream.cpp.

◆ on_new_sample_from_sink()

static GstFlowReturn on_new_sample_from_sink	(	GstElement *	elt,
		PortData *	data
	)

static

Definition at line 156 of file ClpeStream.cpp.

◆ on_sink_message_appsink()

gboolean on_sink_message_appsink	(	GstBus *	bus,
		GstMessage *	message,
		PortData *	data
	)

Definition at line 288 of file ClpeStream.cpp.

◆ on_source_message()

gboolean on_source_message	(	GstBus *	bus,
		GstMessage *	message,
		PortData *	data
	)

Definition at line 309 of file ClpeStream.cpp.

◆ process_block_done()

int process_block_done ( PortData * data )

Definition at line 65 of file ClpeStream.cpp.

Variable Documentation

◆ appSinkBus

GstBus* appSinkBus

Definition at line 45 of file ClpeStream.cpp.

◆ frame_pre

struct timeval frame_pre[AVAILALE_PORT] = {{0,},}

Definition at line 13 of file ClpeStream.cpp.

◆ g_cur_cam_id

unsigned int g_cur_cam_id = 0

Definition at line 36 of file ClpeStream.cpp.

◆ g_cur_frame_seq

unsigned int g_cur_frame_seq = 0

Definition at line 38 of file ClpeStream.cpp.

◆ g_last_cam_id

unsigned int g_last_cam_id = 0

Definition at line 35 of file ClpeStream.cpp.

◆ g_last_frame_seq

unsigned int g_last_frame_seq = 0

Definition at line 37 of file ClpeStream.cpp.

◆ g_lock

int g_lock = 0

Definition at line 16 of file ClpeStream.cpp.

◆ g_MainData

ProgramMain g_MainData

Definition at line 6 of file ClpeStream.cpp.

◆ g_max_seq_offset

unsigned int g_max_seq_offset = MAX_SEQ_OFFSET

Definition at line 12 of file ClpeStream.cpp.

◆ g_pthread

pthread_t g_pthread

Definition at line 43 of file ClpeStream.cpp.

◆ g_recv

T_UDP_BLOCK_CONTENT g_recv[AVAILALE_PORT]

Definition at line 7 of file ClpeStream.cpp.

◆ g_stop_signal

unsigned int g_stop_signal = 0

Definition at line 8 of file ClpeStream.cpp.

◆ gAppSink

GstElement* gAppSink

Definition at line 46 of file ClpeStream.cpp.

◆ gt_frame_info

t_frame_info gt_frame_info[AVAILALE_PORT] = {0,}

Definition at line 40 of file ClpeStream.cpp.

◆ prePcTime

struct timeval prePcTime[AVAILALE_PORT] = {{0,},}

Definition at line 14 of file ClpeStream.cpp.

◆ seq_base

unsigned int seq_base[AVAILALE_PORT] = {0, }

Definition at line 15 of file ClpeStream.cpp.

Classes

Macros

Typedefs

Functions

Variables