path: root/src/log.h

#ifndef _LOG_H
#define _LOG_H

#if(__GNUC__ * 100 + __GNUC_MINOR__ * 10 + __GNUC_PATCHLEVEL__ >= 410)
#define atomic_inc(x) __sync_add_and_fetch((x),1)
#define atomic_dec(x) __sync_sub_and_fetch((x),1)
#define atomic_add(x,y) __sync_add_and_fetch((x),(y))
#define atomic_sub(x,y) __sync_sub_and_fetch((x),(y))
typedef long atomic_t;
#define ATOMIC_INIT(i)  { (i) }
#define atomic_read(x) __sync_add_and_fetch((x),0)
#define atomic_set(x,y) __sync_lock_test_and_set((x),y)
#else 
typedef long atomic_t;
#define atomic_inc(x)	((*(x))++)
#define atomic_dec(x)	((*(x))--)
#define atomic_add(x,y) ((*(x))+=(y))
#define atomic_sub(x,y) ((*(x))-=(y))
#define ATOMIC_INIT(i)  { (i) }
#define atomic_read(x) 	(*(x))
#define atomic_set(x,y)	((*(x))=(y))
#endif 

/*********************************************debug log type***********************************/
typedef enum
{
	ADD_META=0,
	ADD_FRAG,
	ADD_FRAG_NOUSE,
	GET_META,
	GET_FRAG,
	ADD_FRAG_TO_CNVG_LQ,	
	GET_FRAG_FROM_CNVG_LQ,
	ADD_FRAG_TO_INDEX_LQ,
	GET_FRAG_FROM_INDEX_LQ,
	ADD_FRAG_TO_WAIT_LQ,

	ADD_FRAG_TO_TAILQ,
	ADD_FRAG_FROM_TAILQ,
	
	ADD_FRAG_TO_APP_LQ,

	MEDIA_NO_META,
	HLS_OSMF_REPEAT,
	SET_OFFSET,
	
	APP_CHANGE_PID,

	/*cnvg��ѯ*/
	SEND_CNVG_QUERY_1,
	RECV_CNVG_ACK_1,	
	CNVG_QUERY_FAIL_1,

	SEND_CNVG_QUERY_2,
	RECV_CNVG_ACK_2,	
	CNVG_QUERY_FAIL_2,
	
	CNVG_FAIL_PROC,    /*��ѯ�ɹ���������Ϊģ���ȡʧ��*/
	
	/*AV��ѯ*/
	SEND_AV_QUERY_1,
	RECV_AV_ACK_1,
	AV_QUERY_FAIL_1,

	SEND_AV_QUERY_2,
	RECV_AV_ACK_2,
	AV_QUERY_FAIL_2,
		
	/*��Ƭ������ѯ*/
	SEND_INDEX_QUERY_1,
	RECV_INDEX_ACK_1,	
	INDEX_QUERY_FAIL_1,

	SEND_INDEX_QUERY_2,
	RECV_INDEX_ACK_2,	
	INDEX_QUERY_FAIL_2,
		
	INDEX_FAIL_PROC,    /*��ѯ�ɹ���������Ϊģ���ȡʧ��*/

	/*VOIP��ѯ*/	
	SEND_VOIP_QUERY_1,
	RECV_VOIP_ACK_1,
	VOIP_QUERY_FAIL_1,

	SEND_VOIP_QUERY_2,
	RECV_VOIP_ACK_2,
	VOIP_QUERY_FAIL_2,

	/*����*/
	SEND_AV_DEDUP_QUERY,
	RECV_AV_DEDUP_ACK,
	RECV_AV_DEDUP_ACK_KNOWN,
	RECV_AV_DEDUP_ACK_MULTI,
	AV_DEDUP_QUERY_TIMEOUT,
	AV_DEDUP_REPORT,		

	/*��ƬԤ�棬����URL��URL��������Ƭ����*/
	FRAG_FORECAST_ERROR,
}FRAG_LOG_TYPE;

/*********************************************stat log type***********************************/
typedef enum
{
	LOG_MEDIA_CREATE=0,	
	LOG_MEDIA_RENEW,		
	
	LOG_MEDIA_EXPIRE,	
	LOG_MEDIA_OUTPUT,	
	
	LOG_MEDIA_HTTP,	
	LOG_MEDIA_OFFSET_ZERO,	
	LOG_MEDIA_DEDUP_QUERY,
	LOG_MEDIA_TD_QUERY,
	LOG_MEDIA_DEDUP_ACK,	
	LOG_MEDIA_DEDUP,		
	LOG_MEDIA_MULTI,			
	LOG_MEDIA_DEDUP_ACK_TIMEOUT,
	LOG_MEDIA_DEDUP_TIMEOUT,
	LOG_MEDIA_DEDUP_REPORT,
	LOG_MEDIA_DEDUP_REPORT_COMPLETE,
		
	LOG_AV_RECORD,	
	LOG_AV_DIGEST_RECORD,	
	
	MEDIALOG_TYPE_MAXNUM,	
}MEDIALOG_TYPE;

typedef enum
{
	/*recv data*/
	RECV=0,	
	RECV_DROP,
	INVALID_RECV,
	META_RECV, 	
	DATA_RECV,
	OTHER_RECV,		
	MEDIA_NOMETA,

	/*recv response message*/
	RESP_UNRECOGNIZED,
	RESP_CHARACTER,
	
	INVALID_RESP_CHECKRESULT,
	RESP_CHECKRESULT,	
	RESP_CHECKRESULT_WHITELIST_IN,  						//resp msg whitelist : level = 0;
	RESP_CHECKRESULT_BLACKLIST_IN,							//resp msg blacklist : level > 0;
	RESP_CHECKRESULT_BLACKLIST_IN_NOFOUND,					//resp msg blacklist : level > 0; not found 
	RESP_CHECKRESULT_VOIP_FULLLOG,							//VOIP full log 
	RESP_CHECKRESULT_VOIP_SURVEYLOG,						//VOIP survey log
	RESP_CHECKRESULT_BLACKLIST_IN_REPEAT,					//resp msg blacklist : level > 0; repeat
	RESP_CHECKRESULT_BLACKLIST_IN_MONITOR_LEVEL1,			//resp msg blacklist : level > 0;  monitor service, first
	RESP_CHECKRESULT_BLACKLIST_IN_MONITOR_LEVEL2,			//resp msg blacklist : level > 0;  monitor service, again
	RESP_CHECKRESULT_BLACKLIST_IN_BLOCK,					//resp msg blacklist : level > 0;  block service
	
	RESP_CHECKRESULT_FRAG_SURVEY,							//frag survey log
	RESP_CHECKRESULT_INDEX_SURVEY,							//frag survey log include index
	
	INVALID_RESP_PROG_SYNC,	
	RESP_PROG_SYNC,	
	RESP_PROG_SYNC_IN_NOFOUND,
	RESP_PROG_SYNC_AUDIO,
	RESP_PROG_SYNC_VIDEO,	

	/*send survey*/
	RESP_CHECKRESULT_BLACKLIST_OUT_BLOCK,
	AUDIO_LANG_MONITOR_OUT,									//hit audio lang monitor service, send monitor
	CONFIG_MONITOR_OUT,											//hit config monitor service,send monitor

	/*dumpfile*/
	MONITOR_DUMP_FILE,

	/*qd_ack*/
	RESP_CHARACTER_ACK,
	
	/*to_send ~~ DEDUP_DROP+SRC_SEND*/
	TO_SEND,
	
	FRAG_DEDUP,

	/*dedup drop*/
	DEDUP_DROP,
	
	/*wait drop*/
	WAIT_QUEUE_FULL_DROP,

	/*send data*/	
	SRC_SEND_LOCAL,
	SRC_SEND_CPZ,
	SRC_WINS_SEND,	

	/*json kafka*/
	MEDIA_JSON,
	SURVEY_JSON,
	
	LOG_TYPE_MAXNUM,
}LOG_TYPE;

typedef enum
{
	BIZMAN_RECV_QUEUE=0,
	MULTISRC_QUEUE,
	APP_QUEUE,
	DUMPFILE_QUEUE,
	AV_RECORD_QUEUE,
	AV_DIGEST_RECORD_QUEUE,
	MONITOR_HASH,
	DUMPFILE_HASH,
	MEDIA_HASH,

	SYSLOG_TYPE_MAXNUM,	
}SYSLOG_TYPE;

/*----------frag_reassembly---------------*/
typedef enum
{
	RSSB_CREATE_FRAG_UNIT=0, 		//�������䵥Ԫ	
	RSSB_FREE_FRAG_UNIT,
	RSSB_FRAG_UNIT_EXIST,
	RSSB_FRAG_UNIT_ERROR,
	RSSB_FRAG_FORECAST,
	RSSB_FRAG_FORECAST_OK,

	RSSB_CNVG_ONCE_QUERY_SEND,					
	RSSB_CNVG_TWICE_QUERY_SEND,					
 	RSSB_CNVG_ONCE_QUERY_RECV,	
 	RSSB_CNVG_TWICE_QUERY_RECV,					
	RSSB_INDEX_ONCE_QUERY_SEND,					
	RSSB_INDEX_TWICE_QUERY_SEND,					
	RSSB_INDEX_ONCE_QUERY_RECV,		
	RSSB_INDEX_TWICE_QUERY_RECV,	

	RSSB_AV_ONCE_QUERY_SEND,					
	RSSB_AV_TWICE_QUERY_SEND, 				
 	RSSB_AV_ONCE_QUERY_RECV,	
 	RSSB_AV_TWICE_QUERY_RECV,	

	RSSB_SIP_ACK_KEY1,					
	RSSB_SIP_ACK_KEY2, 				
 	RSSB_SIP_ACK_KEY3,	

	RSSB_LOG_TYPE_MAXNUM,
}RSSB_LOG_TYPE;

typedef enum
{		
	RSSB_RECV_OTHER_MEDIA, 		//not HLS and osmf
	RSSB_RECV_HLS_MEDIA,	
	RSSB_HLS_TO_OTHER,			//��HLS��Ƭ������Ƶ�������޷���ɹ�������ͨ����Ƶ����
	RSSB_RECV_OSMF_MEDIA,		
	RSSB_OSMF_TO_OTHER,			//��OSMF��Ƭ������Ƶ�������޷���ɹ�������ͨ����Ƶ����
	RSSB_RECV_FRAG_MEDIA,		
	RSSB_FRAG_TO_OTHER,			//����HLS OSMF����Ƭ
	
	RSSB_DATALOG_TYPE_MAXNUM,
}RSSB_DATALOG_TYPE;

typedef enum
{
	RSSB_CNVG_QUEUE,
	RSSB_INDEX_QUEUE,
	RSSB_WAIT_QUEUE,

	RSSB_CNVG_HASH,
	
	RSSB_SYSLOG_TYPE_MAXNUM,
}RSSB_SYSLOG_TYPE;

typedef enum
{
	TOTAL_PKTS=0,
	TOTAL_BYTES,
	PPS,
	BPS,
	

	FAIL_PKTS,
	FAIL_BYTES,
	FAIL_PPS,
	FAIL_BPS,	

	LOG_STAT_MAXNUM,
}LOG_STAT;

typedef enum
{
	NUM_CUR=0,
	NUM_IN,
	NUM_OUT,

	SYSLOG_STAT_MAXNUM,
}SYSLOG_STAT;

typedef enum
{
    QUEUE_CURRENT=0,
    QUEUE_IN,
    QUEUE_OUT,

    QUEUELOG_STAT_MAXNUM,
}QUEUELOG_STAT;

typedef enum
{
    HASH_CURRENT=0,
    HASH_NUM_EXPIRE,
    HASH_TIME_EXPIRE,

    HASHLOG_STAT_MAXNUM,
}HASHLOG_STAT;

void* thread_frag_rssb_sysinfo_output(void *param);
void* thread_frag_rssb_stat_output(void *param);

void* thread_sysinfo_output(void *param);
void* thread_stat_output(void *param);


#endif