myvtm/Module/mod_sipphone/endpoint.cpp

#ifdef RVC_OS_WIN
#include "stdafx.h"
#else

#endif

#include "endpoint.h"

#include <sofia-sip/su.h>
#include <sofia-sip/su_tag_class.h>
#include <sofia-sip/nua.h>
#include <sofia-sip/sip_status.h>
#include <sofia-sip/sdp.h>
#include <sofia-sip/sip_header.h>
#include <sofia-sip/su_log.h>
#include <sofia-sip/su_tagarg.h>
#include <sofia-sip/su_tag_io.h>
#include <sofia-sip/soa_tag.h>
#include <sofia-sip/su_wait.h>
#include <sofia-sip/nua_tag.h>

#include "refcnt.h"
#include "list.h"
#include "sockutil.h"
#include "hash.h"

#include "SpBase.h"

#include "video_session.h"
#include "audio_session.h"

#include "rec_common.h"
#include "Event.h"


BOOL g_IsExternalTerminalted = FALSE;
// default: ptime = 20ms

#define CONDITION_PARAMS			\
	int status, \
	char const *phrase,		\
	nua_t *nua, \
	struct endpoint_t *ep,				\
	nua_handle_t *nh, \
	struct endpoint_call_t *call,		\
	sip_t const *sip,				\
	tagi_t tags[]


// the same with rtp payload type, the same as huawei open-eye
enum e_audio_rtp_pt 
{
	PCMU = 0, // 64kbps, 4.17
	PCMA = 8, // 64kbps, 4.11
	G729 = 18, // 8kbps, 3.9
};

enum e_video_rtp_pt
{
	H263 = 34, // h263
};

enum e_media_dir
{
	DIR_NONE = 0,
	DIR_TX = 1, 
	DIR_RX = 2,
	DIR_BOTH = 3,
};

typedef struct sdpvideo_desc_t
{
	unsigned long local_rtp_ip;
	int local_rtp_port;
	unsigned long remote_rtp_ip;
	int remote_rtp_port;
	int local_pt;
	int remote_pt;
};

typedef struct media_desc_t 
{
	unsigned long remote_ip;
	int remote_port;
	unsigned long local_ip;
	int local_port;

	int media_dir;

	int local_pt;
	int local_ptime;
	int remote_pt;
	int remote_ptime;

	int local_telephone_event_pt;
	int remote_telephone_event_pt;

	int param[16];
}media_desc_t;

// 1. how to exit

struct endpoint_call_t {
	struct list_head entry;
	endpoint_call_callback_t cb;
	endpoint_t *ep;
	audio_session_t *audio;
	video_session_t *video;
	int id;
	su_home_t *home;
	nua_handle_t *nh;
	char *remote_uri;
	sdp_session_t *last_sdp;
	int connected;
	int local_media_port;
	int local_video_port;
	unsigned int last_media_desc_hash;
	char local_ip[256];
	DeviceTypeEnum eDeviceType;
	CallingTypeEnum nCallType;
	sdpvideo_desc_t sdpvieo_desc;
	DECLARE_REF_COUNT_MEMBER(ref_cnt);
};

DECLARE_REF_COUNT_STATIC(endpoint_call, endpoint_call_t)

struct endpoint_t {
	su_home_t home[1];
	su_root_t *root;
	nua_t *nua;
	endpoint_call_t *active_call;
#ifdef RVC_OS_WIN
	HANDLE event_thread;;
#else
	pthread_t ievent_threadid;
#endif
	
	int call_seq;
	int media_port_seq;
	CEntityBase *entity;
	struct list_head call_list;
	endpoint_conf_t conf;
	int curr_audio_dev_type; // handfree or pickup
};

static const char *state_desc[] = {
	"STATE::INIT",
	"STATE::CALLING",
	"STATE::PROCEEDING",
	"STATE::COMPLETING",
	"STATE::READY",
	"STATE::TERMINATING",
	"STATE::TERMINATED",
};

static const char* call_type_table[] = {
	"NORMAL_CALLTYPE",
	"PADRINGUP_CALLTYPE",
	"PADTOPAD_CALLTYPE",
	"MOBILETOPAD_CALLTYPE",
	"DOUBLERECORD_CALLTYPE"
};

#ifndef VIDEOPLAYER_FLAG_DOUBLESIZE
#define VIDEOPLAYER_FLAG_DOUBLESIZE	0x01
#endif

#ifndef VIDEOPLAYER_FLAG_NOTIMER
#define VIDEOPLAYER_FLAG_NOTIMER	0x02
#endif

#ifndef VIDEOPLAYER_FLAG_PUSH
#define VIDEOPLAYER_FLAG_PUSH		0x04
#endif

#ifndef VIDEOPLAYER_FLAG_PULL
#define VIDEOPLAYER_FLAG_PULL		0x08
#endif

#ifndef VIDEOPLAYER_FLAG_CHECKTOP
#define VIDEOPLAYER_FLAG_CHECKTOP	0x10
#endif

#ifndef VIDEOPLAYER_FLAG_ZOOMOUTSIZE
#define VIDEOPLAYER_FLAG_ZOOMOUTSIZE	0x100
#endif

static void endpoint_media_change_audio_dev(endpoint_call_t *call, e_dev_type current_dev_type)
{
	LOG_FUNCTION();
	if (call->audio) {
		Dbg("begin audio_session_change_dev %d", current_dev_type);
		char strmsg[MAX_PATH] = { 0 };
		snprintf(strmsg, MAX_PATH, "change audio device to %s mode.", DEV_PICKUP == current_dev_type ? "pickup" : "hand free");
		LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_AUDIO_DEVICE_SWITCH, strmsg);
		audio_session_change_dev(call->audio, current_dev_type);
		Dbg("end audio_session_change_dev");
	}
}

static __inline struct in_addr __lton(unsigned long ip)
{
	struct in_addr addr;
	addr.s_addr = ip;
	return addr;
}

static void endpoint_media_update_video(endpoint_call_t *call, media_desc_t *video_desc, video_session_callback_t* cb)
{
	LOG_FUNCTION();
	if (video_desc->media_dir == DIR_NONE) 
	{
		if (call->video) 
		{
			video_session_stop(call->video);
			video_session_destroy(call->video);
			call->video = NULL;
		}
		else
		{
			if (DOUBLERECORD_CALLTYPE == call->nCallType)
			{
				double_record_broadcast_video_session_stop();
			}
		}
	} 
	else 
	{
		int rc;
		BOOL bCreateAudioObject = FALSE;
		endpoint_conf_t *ep_conf = &call->ep->conf;

		if (!call->audio)
		{
			audio_session_conf_t conf = {0};
			strcpy(&conf.in_dev[DEV_PICKUP][0], ep_conf->audio_pickup_in_dev);
			strcpy(&conf.in_dev[DEV_HANDFREE][0], ep_conf->audio_handfree_in_dev);
			strcpy(&conf.out_dev[DEV_PICKUP][0], ep_conf->audio_pickup_out_dev);
			strcpy(&conf.out_dev[DEV_HANDFREE][0], ep_conf->audio_handfree_out_dev);
			conf.agc_in[DEV_PICKUP] = !!ep_conf->audio_pickup_in_agc;
			conf.agc_in[DEV_HANDFREE] = !!ep_conf->audio_handfree_in_agc;
			conf.agc_out[DEV_PICKUP] = !!ep_conf->audio_pickup_out_agc;
			conf.agc_out[DEV_HANDFREE] = !!ep_conf->audio_handfree_out_agc;
			conf.ns_in[DEV_PICKUP] = !!ep_conf->audio_pickup_in_ns;
			conf.ns_in[DEV_HANDFREE] = !!ep_conf->audio_handfree_in_ns;
			conf.ns_out[DEV_PICKUP] = !!ep_conf->audio_pickup_out_ns;
			conf.ns_out[DEV_HANDFREE] = !!ep_conf->audio_handfree_out_ns;
			conf.aec[DEV_PICKUP] = !!ep_conf->audio_pickup_aec;
			conf.aec[DEV_HANDFREE] = !!ep_conf->audio_handfree_aec;
			rc = audio_session_create(&conf, &call->audio);
			if (rc != 0) 
			{
				Dbg("create audio session failed! rc = %d", rc);
				return;
			}
			bCreateAudioObject = TRUE;
		}

		//audio_session_remote_recording_conf_t remote_conf = {0};
		//remote_conf.local_rtp_ip = video_desc->local_ip;
		//remote_conf.local_rtp_port = video_desc->local_port+2;
		//remote_conf.ptime = REC_COMMON_AUDIO_FRAME_PTIME; // for remote recording
		//remote_conf.remote_rtp_ip = video_desc->remote_ip;
		//remote_conf.remote_rtp_port = video_desc->remote_port+2;
		//rc = audio_session_start_remote_recording(call->audio, &remote_conf);
		//if (rc != 0) 
		//{
		//	Dbg("audio_session_start_remote_recording failed! rc = %d", rc);
		//	if (bCreateAudioObject) 
		//	{
		//		audio_session_destroy(call->audio);
		//		call->audio = NULL;
		//	}
		//	//return;
		//}

		if (call->video) {
			video_session_destroy(call->video);
			call->video = NULL;
		}

		int i = 0;
		int local_view_x = video_desc->param[i++];
		int local_view_y = video_desc->param[i++];
		int local_view_cx = video_desc->param[i++];
		int local_view_cy = video_desc->param[i++];
		int remote_view_x = video_desc->param[i++];
		int remote_view_y = video_desc->param[i++];
		int remote_view_cx = video_desc->param[i++];
		int remote_view_cy = video_desc->param[i++];
		int remote_width = video_desc->param[i++];
		int remote_height = video_desc->param[i++];

		//add by clp 20190823
		int local_hwd_move = video_desc->param[i++];
		int remote_hwd_move = video_desc->param[i++];

		int local_fresh_time = video_desc->param[i++];
		int remote_fresh_time = video_desc->param[i++];

		video_session_conf_t video_conf = {0};
		if (eMobilePadType == call->eDeviceType)
		{
			video_conf.bit_rate = 150 * 1024;
		}
		else
		{
			video_conf.bit_rate = 256 * 1024;
		}
		video_conf.local_rtp_ip = video_desc->local_ip;
		video_conf.local_rtp_port = video_desc->local_port;
		video_conf.local_video_view_x = local_view_x;
		video_conf.local_video_view_y = local_view_y;
		video_conf.local_video_view_cx = local_view_cx;
		video_conf.local_video_view_cy = local_view_cy;
		video_conf.mtu = ep_conf->mtu;
		video_conf.video_quant = ep_conf->quant;
		video_conf.remote_rtp_ip = video_desc->remote_ip;
		video_conf.remote_rtp_port = video_desc->remote_port;
		video_conf.remote_video_view_x = remote_view_x;
		video_conf.remote_video_view_y = remote_view_y;
		video_conf.remote_video_view_cx = remote_view_cx;
		video_conf.remote_video_view_cy = remote_view_cy;
		video_conf.remote_video_width = remote_width;
		video_conf.remote_video_height = remote_height;
		video_conf.ref_active_camera = call->ep->conf.ref_active_camera;
		video_conf.ref_camera_switch = call->ep->conf.ref_camera_switch;
		video_conf.ref_camera_state = call->ep->conf.ref_camera_state;
		video_conf.ref_window_state = call->ep->conf.ref_window_state;
		video_conf.ref_Is_showPersonArea = call->ep->conf.ref_Is_showPersonArea;
		//video_conf.ref_active_img = call->ep->conf.ref_active_img;
		//video_conf.ref_Is_ActiveInspect = call->ep->conf.ref_Is_ActiveInspect;
		video_conf.ref_active_img = NULL;
		video_conf.ref_Is_ActiveInspect = NULL;
		video_conf.camera_count = call->ep->conf.camera_count;
		video_conf.screen_count = call->ep->conf.screen_count;
		video_conf.ref_Up_Fps = call->ep->conf.ref_Up_Fps;
		video_conf.eDeviceType = call->eDeviceType;
		video_conf.nCallType = call->nCallType;
		video_conf.local_move = local_hwd_move;
		video_conf.remote_move = remote_hwd_move;
		video_conf.video_echo_cb = cb;
		video_conf.ilocal_wind_flags = VIDEOPLAYER_FLAG_PULL|VIDEOPLAYER_FLAG_CHECKTOP;
		video_conf.iremote_wind_flags = VIDEOPLAYER_FLAG_PUSH|VIDEOPLAYER_FLAG_CHECKTOP;
		video_conf.ilvideo_ft = local_fresh_time;
		
		if (video_conf.nCallType == MOBILETOPAD_CALLTYPE )  //如果与手机连接使用标准H264
		{
			video_conf.local_pt = video_desc->local_pt;
			video_conf.remote_pt = video_desc->remote_pt;
		} 
		else   //如果与pad连接或者常规连接模式使用H264+         
		{
			//huchen modify, now we use standard h264
			//video_conf.local_pt = REC_COMMON_VIDEO_PT;
			//video_conf.remote_pt = REC_COMMON_VIDEO_PT;
			video_conf.local_pt = REC_COMMON_VIDEO_H264_PT;
			video_conf.remote_pt = REC_COMMON_VIDEO_H264_PT;
		}
		rc = video_session_create(&video_conf, &call->video);
		if (rc != 0) {
			Dbg("create video session failed! rc = %d", rc);
			return;
		}
		else{
			Dbg("make remote call session addr is 0x%08x.",call->video);
		}
		rc = video_session_start(call->video);
		if (rc != 0) {
			Dbg("start video session failed! rc = %d", rc);
			video_session_destroy(call->video);
			call->video = NULL;
			return;
		}
		else{
			Dbg("endpoint media update video, video session start suc, and session is 0x%08x.", call->video);
		}
	}
}

static void endpoint_media_update_audio(endpoint_call_t *call, media_desc_t *audio_desc, int dev_type)
{
	LOG_TRACE("audio dir:%d", audio_desc->media_dir);
	if (audio_desc->media_dir == DIR_NONE) {
		if (call->audio) {
			LOG_TRACE("stop audio...");
			audio_session_stop(call->audio);
			audio_session_destroy(call->audio);
			call->audio = NULL;
			LOG_TRACE("stop audio ok!");
		}
		else{
			LOG_TRACE("call->audio is null.");
		}

		if (call->video) { // close video also 
			LOG_TRACE("stop video...");
			video_session_stop(call->video);
			video_session_destroy(call->video);
			call->video = NULL;
			LOG_TRACE("stop video ok!");
		}
		else{
			LOG_TRACE("call->video is null.");
		}
	} else {
		int rc;
		if (call->audio) {
			LOG_TRACE("stop audio...");
			audio_session_stop(call->audio);
			audio_session_destroy(call->audio);
			call->audio = NULL;
			LOG_TRACE("stop audio ok!");
		}
		if (!call->audio) {
			endpoint_conf_t *ep_conf = &call->ep->conf;
			audio_session_conf_t conf = {0};
			strcpy(&conf.in_dev[DEV_PICKUP][0], ep_conf->audio_pickup_in_dev);
			strcpy(&conf.in_dev[DEV_HANDFREE][0], ep_conf->audio_handfree_in_dev);
			strcpy(&conf.out_dev[DEV_PICKUP][0], ep_conf->audio_pickup_out_dev);
			strcpy(&conf.out_dev[DEV_HANDFREE][0], ep_conf->audio_handfree_out_dev);			
			conf.agc_in[DEV_PICKUP] = !!ep_conf->audio_pickup_in_agc;
			conf.agc_in[DEV_HANDFREE] = !!ep_conf->audio_handfree_in_agc;
			conf.agc_out[DEV_PICKUP] = !!ep_conf->audio_pickup_out_agc;
			conf.agc_out[DEV_HANDFREE] = !!ep_conf->audio_handfree_out_agc;
			conf.ns_in[DEV_PICKUP] = !!ep_conf->audio_pickup_in_ns;
			conf.ns_in[DEV_HANDFREE] = !!ep_conf->audio_handfree_in_ns;
			conf.ns_out[DEV_PICKUP] = !!ep_conf->audio_pickup_out_ns;
			conf.ns_out[DEV_HANDFREE] = !!ep_conf->audio_handfree_out_ns;
			conf.aec[DEV_PICKUP] = !!ep_conf->audio_pickup_aec;
			conf.aec[DEV_HANDFREE] = !!ep_conf->audio_handfree_aec;
			rc = audio_session_create(&conf, &call->audio);
			if (rc != 0) {
				Dbg("create audio session failed! rc = %d", rc);
				return;
			}
		}
		audio_session_phonemedia_conf_t phone_conf = {0};
		phone_conf.dir = audio_desc->media_dir;
		phone_conf.dev_type = (e_dev_type)dev_type;
		phone_conf.local_dtmf_pt = audio_desc->local_telephone_event_pt;
		phone_conf.local_pt = audio_desc->local_pt;
		phone_conf.local_ptime = audio_desc->local_ptime;
		phone_conf.local_rtp_ip = audio_desc->local_ip;
		phone_conf.local_rtp_port = audio_desc->local_port;
		phone_conf.remote_dtmf_pt = audio_desc->remote_telephone_event_pt;
		phone_conf.remote_pt = audio_desc->remote_pt;
		phone_conf.remote_ptime = audio_desc->remote_ptime;
		phone_conf.remote_rtp_ip = audio_desc->remote_ip;
		phone_conf.remote_rtp_port = audio_desc->remote_port;
		
		if (NULL != call){
			phone_conf.eCalltype = call->nCallType;
			phone_conf.eDeviceType = call->eDeviceType;
		}
		
		rc = audio_session_start_phonemedia(call->audio, &phone_conf);
		if (rc != 0) {
			Dbg("start audio session failed! rc = %d", rc);
			LogError(Severity_High,Error_DevMedia,ERROR_MOD_SIP_AUDIO_INITFAIL,"audio initialize fail");
			audio_session_destroy(call->audio);
			call->audio = NULL;
			return;
		}
		else {
			Dbg("start audio session success!");
		}
	}
}

static unsigned int __hash_media_desc(media_desc_t *media_desc, unsigned int hash_code)
{
	if (media_desc) {
		hash_code += (unsigned int)media_desc->local_ip * 33;
		hash_code += (unsigned int)media_desc->remote_ip * 33;
		hash_code += (unsigned int)media_desc->local_port * 33;
		hash_code += (unsigned int)media_desc->remote_port * 33;
		hash_code += (unsigned int)media_desc->media_dir * 33;
		hash_code += (unsigned int)media_desc->local_pt * 33;
		hash_code += (unsigned int)media_desc->local_ptime * 33;
		hash_code += (unsigned int)media_desc->remote_pt * 33;
		hash_code += (unsigned int)media_desc->remote_ptime * 33;
		hash_code += (unsigned int)media_desc->local_telephone_event_pt * 33;
		hash_code += (unsigned int)media_desc->remote_telephone_event_pt * 33;
	}
	return hash_code;
}

static unsigned int hash_media_desc(media_desc_t *audio)
{
	unsigned int hash_code = 0;
	hash_code = __hash_media_desc(audio, hash_code);
	return hash_code;
}

#define USE_ALAW	1

static const char *call_make_offer(endpoint_call_t *call, char *buf, int size)
{
	int local_audio_rtp_port = call->local_media_port;
	int local_video_rtp_port = call->local_video_port;
	int local_video_pt = REC_COMMON_VIDEO_PT;
	int need;
	const char *fmt;

	Dbg("make call offer,device type is %s, Call Type is %s", Device_Type_Table[call->eDeviceType], call_type_table[call->nCallType]);
	if ((eMobilePadType == call->eDeviceType) || (ePadtype == call->eDeviceType)||(eDesk2SType == call->eDeviceType)||(eDesk1SType==call->eDeviceType)||(eDesk2SIntegratedType==call->eDeviceType)) //pad
	{
		if (call->nCallType == MOBILETOPAD_CALLTYPE)  //如果跟手机对接
		{
			local_video_pt = REC_COMMON_VIDEO_H264_PT;
			fmt = "c=IN IP4 %s\r\n"
				"m=audio %d RTP/AVP 8\r\n"
				"a=rtpmap:8 PCMA/8000\r\n"
				"a=ptime:30\r\n"
				"m=video %d RTP/AVP %d\r\n"
				"a=rtpmap:%d H264/90000\r\n";

			need = _scprintf(fmt, call->local_ip, local_audio_rtp_port,local_video_rtp_port, local_video_pt,local_video_pt);

			if (size < 0 || size > need) {
				sprintf(buf, fmt, call->local_ip, local_audio_rtp_port, local_video_rtp_port, local_video_pt,local_video_pt);
				return buf;
			} 
			else {
				return NULL;
			}
		}
		else if((call->nCallType == PADRINGUP_CALLTYPE)||(call->nCallType == PADTOPAD_CALLTYPE))
		{
			fmt = "c=IN IP4 %s\r\n"
				"m=audio %d RTP/AVP 8\r\n"
				"a=rtpmap:8 PCMA/8000\r\n"
				"a=ptime:30\r\n"
				;
			need = _scprintf(fmt, call->local_ip, local_audio_rtp_port);

			if (size < 0 || size > need) {
				sprintf(buf, fmt, call->local_ip, local_audio_rtp_port);
				return buf;
			} 
			else {
				return NULL;
			}
		}
		else  if(call->nCallType == NORMAL_CALLTYPE || call->nCallType == DOUBLERECORD_CALLTYPE)//如果是可视柜台模式以及外拓版
		{
			if(eMobilePadType == call->eDeviceType)
			{
				fmt = "c=IN IP4 %s\r\n"
					"m=audio %d RTP/AVP 18\r\n"
					"a=rtpmap:18 G729/8000\r\n"
					"a=fmtp:18 annexb=no\r\n"
					"a=ptime:30\r\n"
					;
				Dbg("pad site = CMB.FLB");
			}
			else
			{
				fmt = "c=IN IP4 %s\r\n"
					"m=audio %d RTP/AVP 8\r\n"
					"a=rtpmap:8 PCMA/8000\r\n"
					"a=ptime:30\r\n"
					;
				Dbg("pad site = CMB.LIB");
			}

			need = _scprintf(fmt, call->local_ip, local_audio_rtp_port);
			
			if (size < 0 || size > need) {
				sprintf(buf, fmt, call->local_ip, local_audio_rtp_port);
				return buf;
			} 
			else {
				return NULL;
			}
		}
	}
	else  //大机
	{
		fmt = 
			"c=IN IP4 %s\r\n"
#ifdef USE_ALAW
			"m=audio %d RTP/AVP 8\r\n"
			"a=rtpmap:8 PCMA/8000\r\n"
			"a=ptime:30\r\n"
#elif defined(USE_G729)
			"m=audio %d RTP/AVP 18\r\n"
			"a=rtpmap:18 G729/8000\r\n"
			"a=fmtp:18 annexb=no\r\n"
			"a=ptime:30\r\n"
#endif
			//"a=rtpmap:97 telephone-event/8000\r\n"
			//"a=fmtp:97 0-15\r\n"
#ifdef USE_H263_VIDEO
			"m=video %d RTP/AVP	34\r\n"
			"a=rtpmap:34 H263/90000\r\n"
			"a=fmtp:34 QCIF=2 MaxBR=5040\r\n"
#endif
			//"a=inactive\r\n" //for debug only
			;
		Dbg("pad site != CMB.FLB");
	}
	
	need = _scprintf(fmt, call->local_ip, local_audio_rtp_port);
	if (size < 0 || size > need) {
		sprintf(buf, fmt, call->local_ip, local_audio_rtp_port);
		return buf;
	} else {
		return NULL;
	}
}

static int new_call_id(endpoint_t *ep)
{
	return ++ep->call_seq;
}

static int new_media_port(endpoint_t *ep)
{
	ep->media_port_seq += 2;
	if (ep->media_port_seq >= ep->conf.media_stop_port) {
		ep->media_port_seq = ep->conf.media_start_port;
	}
	return ep->media_port_seq;
}

static void handle_invite(CONDITION_PARAMS)
{
	// we are client only, not accept in-comming call
	nua_respond(nh, SIP_403_FORBIDDEN, TAG_END());
}

static void handle_reinvite(CONDITION_PARAMS)
{
	char sdp[512];
	sip_content_type_t const *ct = NULL;

	tl_gets(tags,
		SIPTAG_CONTENT_TYPE_REF(ct),
		TAG_END());

	if (ct) {
		call_make_offer(call, sdp, sizeof(sdp));		
	}

	nua_respond(nh, 
		SIP_200_OK, 
		TAG_IF(ct, SOATAG_USER_SDP_STR(sdp)), 
		TAG_IF(ct, SOATAG_AUDIO_AUX("telephone-event")), 
		TAG_END());
}

static void handle_r_invite(CONDITION_PARAMS)
{
	// nothing to do
}

static int dir_from_attr(const sdp_media_t *m)
{
	int dir = DIR_NONE;

	if (m) {
		if (m->m_attributes) {
			static const char *ds[] = {
				"inactive", "sendonly", "recvonly", "sendrecv"
			};
			int i;
			int n = array_size(ds);
			for (i = 0; i < n; ++i) {
				sdp_attribute_t *attr = sdp_attribute_find(m->m_attributes, ds[i]);
				if (attr) {
					dir = i;
					break;
				}
			}
			if (i >= n)
				dir = DIR_BOTH;
		} else {
			dir = DIR_BOTH;
		}
	}

	return dir;
}

static int ptime_from_attr(const sdp_media_t *m)
{
	int ptime = 0; // zero for default

	if (m) {
		if (m->m_attributes) {
			sdp_attribute_t *attr = sdp_attribute_find(m->m_attributes, "ptime");
			if (attr && attr->a_value) {
				ptime = atoi(attr->a_value);
				if (ptime < 0)
					ptime = 0;
			}
		}
	}

	return ptime;
}

static const sdp_rtpmap_t *find_codec(const sdp_rtpmap_t *list, const char *codec)
{
	if (!codec)
		return NULL;
	for (;list; list=list->rm_next) {
		if (!_stricmp(list->rm_encoding, codec)) {
			break;
		}
	}
	return list;
}

static int get_telephone_event_pt(const sdp_rtpmap_t *list)
{
	int pt = -1;
	const sdp_rtpmap_t *rm = find_codec(list, "telephone-event");
	if (rm) {
		pt = rm->rm_pt;
	}
	return pt;
}

static int get_media_direction(const sdp_media_t *lm, const sdp_media_t *rm)
{
	int media_dir = DIR_NONE;
	if (rm->m_port == 0 || lm->m_port == 0) {
		media_dir = DIR_NONE;
	} else {
		int ldir = dir_from_attr(lm);
		int rdir = dir_from_attr(rm);
		if (ldir == DIR_NONE || rdir == DIR_NONE) {
			media_dir = DIR_NONE;
		} else if (ldir == DIR_TX || rdir == DIR_RX) {
			media_dir = DIR_TX;
		}  else if (ldir == DIR_RX || rdir == DIR_TX) {
			media_dir = DIR_RX;
		} else {
			media_dir = DIR_BOTH;
		}
	}
	return media_dir;
}

static int negotiate_audio(endpoint_call_t *call, media_desc_t *audio_desc, const sdp_media_t *lm, const sdp_media_t *rm)
{
	memset(audio_desc, 0, sizeof(media_desc_t));
	const char *local_ip;
	const char *remote_ip;

	local_ip = lm->m_connections ? lm->m_connections->c_address : lm->m_session->sdp_connection->c_address;
	remote_ip = rm->m_connections ? rm->m_connections->c_address : rm->m_session->sdp_connection->c_address;

	audio_desc->local_ip = local_ip ? inet_addr(local_ip) : 0;
	audio_desc->local_port = lm->m_port;
	audio_desc->remote_ip = remote_ip ? inet_addr(remote_ip) : 0;
	audio_desc->remote_port = rm->m_port;
	audio_desc->local_telephone_event_pt = 97;
	audio_desc->remote_telephone_event_pt = get_telephone_event_pt(rm->m_rtpmaps);
	audio_desc->local_ptime = ptime_from_attr(lm);
	audio_desc->remote_ptime = ptime_from_attr(rm);

	int pt = -1;
	for (sdp_rtpmap_t *t = lm->m_rtpmaps; t; t = t->rm_next) {
		sdp_rtpmap_t *tt = sdp_rtpmap_find_matching(rm->m_rtpmaps, t);
		if (tt && tt->rm_pt < 96) {
			pt = tt->rm_pt;
			break;
		}
	}
	audio_desc->local_pt = audio_desc->remote_pt = pt;

	audio_desc->media_dir = get_media_direction(lm, rm);
	return 0;
}

static int negotiate_video(endpoint_call_t *call, media_desc_t *video_desc, const sdp_media_t *lm, const sdp_media_t *rm)
{
	memset(video_desc, 0, sizeof(media_desc_t));

	const char *local_ip;
	const char *remote_ip;

	local_ip = lm->m_connections ? lm->m_connections->c_address : lm->m_session->sdp_connection->c_address;
	remote_ip = rm->m_connections ? rm->m_connections->c_address : rm->m_session->sdp_connection->c_address;

	video_desc->local_ip = local_ip ? inet_addr(local_ip) : 0;
	video_desc->local_port = lm->m_port;
	video_desc->remote_ip = remote_ip ? inet_addr(remote_ip) : 0;
	video_desc->remote_port = rm->m_port;
	video_desc->local_telephone_event_pt = 97;
	video_desc->remote_telephone_event_pt = get_telephone_event_pt(rm->m_rtpmaps);
	video_desc->local_ptime = ptime_from_attr(lm);
	video_desc->remote_ptime = ptime_from_attr(rm);

	int pt = -1;
	for (sdp_rtpmap_t *t = lm->m_rtpmaps; t; t = t->rm_next) {
		sdp_rtpmap_t *tt = sdp_rtpmap_find_matching(rm->m_rtpmaps, t);
		if (tt) {
			pt = tt->rm_pt;
			break;
		}
	}
	video_desc->local_pt = video_desc->remote_pt = pt;
	video_desc->media_dir = get_media_direction(lm, rm);
	return 0;
}


static void negotiate_sdp(endpoint_call_t *call, const sdp_session_t *local_sdp, const sdp_session_t* remote_sdp)
{
	LOG_FUNCTION();
	const sdp_media_t *lm = local_sdp->sdp_media;
	const sdp_media_t *rm = remote_sdp->sdp_media;
	media_desc_t audio_desc = {0}, video_desc = {0};
	int rc = -1, rv = -1;
	for(; lm; lm = lm->m_next)
	{
		if (0 == lm->m_port)
		{
			continue;
		}
		const sdp_media_t *rm = remote_sdp->sdp_media;
		for (; rm; rm = rm->m_next)
		{
			if (rm->m_type == lm->m_type)
			{
				if (sdp_media_audio == rm->m_type)
				{
					rc = negotiate_audio(call, &audio_desc, lm, rm);
				}
				if (call->nCallType != NORMAL_CALLTYPE && call->nCallType != DOUBLERECORD_CALLTYPE)
				{
					if (sdp_media_video == rm->m_type)
					{
						rv = negotiate_video(call, &video_desc, lm, rm);
					}
				}
			}
		}
	}

	if (rc == 0) 
	{
		unsigned int hash_code = hash_media_desc(&audio_desc);
		if (hash_code != call->last_media_desc_hash) 
		{
			char str_local[128] = {0};
			char str_remote[128] = {0};
			translate_ipaddr_from_int(str_local, 128, audio_desc.local_ip);
			translate_ipaddr_from_int(str_remote, 128, audio_desc.remote_ip);
			Dbg("negotiate audio success!local audio ip=%s port=%d pt=%d,remote audio ip=%s port=%d,pt=%d",str_local,audio_desc.local_port,audio_desc.local_pt,str_remote,audio_desc.remote_port,audio_desc.remote_pt);
			endpoint_media_update_audio(call, &audio_desc, call->ep->curr_audio_dev_type);
			call->last_media_desc_hash = hash_code;
		}
	}

	if (rv == 0) 
	{
		unsigned int hash_code = hash_media_desc(&video_desc);
		if (hash_code != call->last_media_desc_hash) 
		{
			char str_local[128] = {0};
			char str_remote[128] = {0};
			translate_ipaddr_from_int(str_local, 128, video_desc.local_ip);
			translate_ipaddr_from_int(str_remote, 128, video_desc.remote_ip);

			Dbg("negotiate video success!local video ip=%s port=%d pt=%d,remote video ip=%s port=%d pt=%d",str_local,video_desc.local_port,video_desc.local_pt,str_remote,video_desc.remote_port,video_desc.remote_pt);
			call->sdpvieo_desc.local_pt = video_desc.local_pt;
			call->sdpvieo_desc.local_rtp_ip = video_desc.local_ip;
			call->sdpvieo_desc.local_rtp_port = video_desc.local_port;
			call->sdpvieo_desc.remote_pt = video_desc.remote_pt;
			call->sdpvieo_desc.remote_rtp_ip = video_desc.remote_ip;
			call->sdpvieo_desc.remote_rtp_port = video_desc.remote_port;
			call->last_media_desc_hash = hash_code;
		}
	}
	else
	{
		if (call->nCallType != NORMAL_CALLTYPE && call->nCallType != DOUBLERECORD_CALLTYPE)
		{
			Dbg("negotiate video Fail!!!");
		}
	}
}

static void on_state(CONDITION_PARAMS)
{
	int offer_recv = 0, answer_recv = 0, offer_sent = 0, answer_sent = 0;
	int state = nua_callstate_init;
	const char *replaces_str = NULL;
	const sdp_session_t *remote_sdp = NULL;
	const char *remote_sdp_str = NULL;
	const sdp_session_t *local_sdp = NULL;
	const char *local_sdp_str = NULL;
	int st;

	if (!call) {
		nua_handle_destroy(nh);
		return;
	}

	if (g_IsExternalTerminalted)
	{
		return;
	}

	tl_gets(tags,
		NUTAG_CALLSTATE_REF(state),
		NUTAG_OFFER_RECV_REF(offer_recv),
		NUTAG_ANSWER_RECV_REF(answer_recv),
		NUTAG_OFFER_SENT_REF(offer_sent),
		NUTAG_ANSWER_SENT_REF(answer_sent),
		SIPTAG_REPLACES_STR_REF(replaces_str), 
		SOATAG_REMOTE_SDP_STR_REF(remote_sdp_str), 
		SOATAG_LOCAL_SDP_STR_REF(local_sdp_str), 
		TAG_END());

	char strmsg[MAX_PATH] = { 0 };
	_snprintf(strmsg, MAX_PATH, "state = %d, offer_recv=%d, answer_recv=%d, offer_sent=%d, answer_sent=%d", state, offer_recv, answer_recv, offer_sent, answer_sent);
	LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_PROCESS_MSG, strmsg);

	switch (state)
	{
		case nua_callstate_calling:
			{
				char strcalling[MAX_PATH] = { 0 };
				_snprintf(strcalling, MAX_PATH, "nua_callstate_calling, has_local_sdp : %d, has_remote_sdp : %d", !!local_sdp_str, !!remote_sdp_str);
				LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_PROCESS_MSG, strcalling);
				if (local_sdp_str) {
					sdp_parser_t* parser = sdp_parse(call->home, local_sdp_str, strlen(local_sdp_str), -1);
					assert(call->last_sdp == NULL);
					call->last_sdp = sdp_session_dup(call->home, sdp_session(parser));
					sdp_parser_free(parser);
				}
				st = CALLING;
				call->cb.on_call_state(st, state_desc[st], phrase, call->cb.user_data);
			}
			break;

		case nua_callstate_proceeding:
			{
				char strproceeding[MAX_PATH] = { 0 };
				_snprintf(strproceeding, MAX_PATH, "nua_callstate_proceeding, status = %d, has_local_sdp: %d, has_remote_sdp : %d", status, !!local_sdp_str, !!remote_sdp_str);
				LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_PROCESS_MSG, strproceeding);
				st = PROCEEDING;
				call->cb.on_call_state(st, state_desc[st], phrase, call->cb.user_data);
				if (remote_sdp_str) {
					sdp_parser_t* parser = sdp_parse(call->home, remote_sdp_str, strlen(remote_sdp_str), -1);
					remote_sdp = sdp_session(parser);
					if (call->last_sdp) {
						negotiate_sdp(call, call->last_sdp, remote_sdp);
						su_free(call->home, call->last_sdp);
						call->last_sdp = NULL;
					}
					sdp_parser_free(parser);
				}
			}
			break;

		case nua_callstate_completing:
			{
				st = COMPLETING;
				char strcompleting[MAX_PATH] = { 0 };
				_snprintf(strcompleting, MAX_PATH, "nua_callstate_completing, has_local_sdp : %d, has_remote_sdp : %d", !!local_sdp_str, !!remote_sdp_str);
				LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_PROCESS_MSG, strcompleting);
				call->cb.on_call_state(st, state_desc[st], phrase, call->cb.user_data);
				if (remote_sdp_str) {
					sdp_parser_t* parser = sdp_parse(call->home, remote_sdp_str, strlen(remote_sdp_str), -1);
					remote_sdp = sdp_session(parser);
					if (call->last_sdp) {
						negotiate_sdp(call, call->last_sdp, remote_sdp);
						su_free(call->home, call->last_sdp);
						call->last_sdp = NULL;
					}
					sdp_parser_free(parser);
				}
			}
			break;

		case nua_callstate_completed:
			{
				char strcompleted[MAX_PATH] = { 0 };
				_snprintf(strcompleted, MAX_PATH, "nua_callstate_completed, has_local_sdp : %d, has_remote_sdp : %d", !!local_sdp_str, !!remote_sdp_str);
				LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_PROCESS_MSG, strcompleted);
				if (remote_sdp_str) {
					if (!call->last_sdp) {
						sdp_parser_t* parser = sdp_parse(call->home, remote_sdp_str, strlen(remote_sdp_str), -1);
						call->last_sdp = sdp_session_dup(call->home, sdp_session(parser));
						sdp_parser_free(parser);
					}
				}
				if (local_sdp_str) {
					if (call->last_sdp) {
						sdp_parser_t* parser = sdp_parse(call->home, local_sdp_str, strlen(local_sdp_str), -1);
						local_sdp = sdp_session(parser);
						negotiate_sdp(call, local_sdp, call->last_sdp);
						su_free(call->home, call->last_sdp);
						call->last_sdp = NULL;
						sdp_parser_free(parser);
					}
				}
			}
			break;

		case nua_callstate_ready:
			{
				call->connected = true;
				char strready[MAX_PATH] = { 0 };
				_snprintf(strready, MAX_PATH, "nua_callstate_ready, has_local_sdp : %d, has_remote_sdp : %d.", !!local_sdp_str, !!remote_sdp_str);
				LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_PROCESS_MSG, strready);
				st = READY;
				call->cb.on_call_state(st, state_desc[st], phrase, call->cb.user_data);
				if (remote_sdp_str) {
					sdp_parser_t* parser = sdp_parse(call->home, remote_sdp_str, strlen(remote_sdp_str), -1);
					remote_sdp = sdp_session(parser);
					if (call->last_sdp) {
						negotiate_sdp(call, call->last_sdp, remote_sdp);
						su_free(call->home, call->last_sdp);
						call->last_sdp = NULL;
					}
					sdp_parser_free(parser);
				}
#if 0
				if (remote_sdp_str) {
					sdp_parser_t* parser = sdp_parse(call->home, remote_sdp_str, strlen(remote_sdp_str), -1);
					remote_sdp = sdp_session(parser);
					negotiate_sdp(call, call->last_sdp, remote_sdp);
					sdp_parser_free(parser);
				}
				else if (local_sdp_str) {
					sdp_parser_t* parser = sdp_parse(call->home, local_sdp_str, strlen(local_sdp_str), -1);
					local_sdp = sdp_session(parser);
					negotiate_sdp(call, local_sdp, call->last_sdp);
					sdp_parser_free(parser);
				}
#endif
			}
			break;

		case nua_callstate_terminated:
			{
				st = TERMINATED;
				char strterminated[MAX_PATH] = { 0 };
				_snprintf(strterminated, MAX_PATH, "call terminated! in sofia thread!");
				LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_PROCESS_MSG, strterminated);
				{
					media_desc_t audio_desc = { 0 };
					audio_desc.media_dir = DIR_NONE;
					endpoint_media_update_audio(call, &audio_desc, call->ep->curr_audio_dev_type);
				}
				call->cb.on_call_state(st, state_desc[st], phrase, call->cb.user_data);
				nua_handle_bind(nh, NULL);
				nua_handle_destroy(nh);
				call->nh = NULL;
			}
			break;
		default:
			break;
	}
}

void Terminatedcall(endpoint_call_t *call)
{
	int st = TERMINATED;
	g_IsExternalTerminalted = TRUE;
	Dbg("g_IsExternalTerminalted = TRUE");
	LOG_TRACE("terminated! by timeout!");
	{
		media_desc_t audio_desc = {0};
		audio_desc.media_dir = DIR_NONE;
		endpoint_media_update_audio(call, &audio_desc, call->ep->curr_audio_dev_type);
	}
}
	

static void endpoint_callback(nua_event_t   event,
						 int           status,
						 char const   *phrase,
						 nua_t        *nua,
						 nua_magic_t  *magic,
						 nua_handle_t *nh,
						 nua_hmagic_t *hmagic,
						 sip_t const  *sip,
						 tagi_t        tags[])
{
	switch (event) 
	{
		if (!g_IsExternalTerminalted)
		{
			case nua_i_invite:
				if (hmagic == NULL) {
					handle_invite(status, phrase, nua, (endpoint_t*)magic, nh, (endpoint_call_t*)hmagic, sip, tags);
				} else {
					LOG_TRACE("reinvite!");
					handle_reinvite(status, phrase, nua, (endpoint_t*)magic, nh, (endpoint_call_t*)hmagic, sip, tags);
				}
				break;

			case nua_r_invite:
				handle_r_invite(status, phrase, nua, (endpoint_t*)magic, nh, (endpoint_call_t*)hmagic, sip, tags);
				break;

			case nua_i_bye:
				//.....
				LOG_TRACE("nua_i_bye");
				break;

			case nua_i_info:
				LOG_TRACE("nua_i_info");
				break;

			case nua_i_state:
				on_state(status, phrase, nua, (endpoint_t*)magic, nh, (endpoint_call_t*)hmagic, sip, tags);
				break;

			case nua_i_active:
				LOG_TRACE("nua_i_active");
				break;

			case nua_i_options:
				//nua_respond(nh, SIP_200_OK, NUTAG_WITH_THIS(nua), SOATAG_USER_SDP_STR(NULL), TAG_END());
				nua_respond(nh, SIP_200_OK, TAG_END());
				break;

			case nua_r_cancel:
				LOG_TRACE("nua_r_cancel");
				if (status > 300) {
					nua_bye(nh, TAG_END());
				}
				break;
			case nua_i_prack:
				LOG_TRACE("nua_i_prack");
			case nua_r_prack:
				LOG_TRACE("nua_r_prack");
				break;

			case nua_r_bye:
				LOG_TRACE("nua_r_bye");
				if (status > 300) {
					nua_bye(nh, TAG_END());
				}
				break;
		/* and so on ... */

	default:
		if (status > 100) { /* unknown event -> print out error message */
		LOG_TRACE("unknown event %d: %03d %s.",
			event,
			status,
			phrase);
		} else {
			LOG_TRACE("unknown event %d.", event);
		}
		break;
	}
		
	}

	if (!hmagic) 
	{
		nua_handle_destroy(nh);
		return;
	}

}

#ifdef RVC_OS_WIN
static unsigned int __stdcall __event_thread(void* arg)
#else
void* __event_thread(void* arg)
#endif
{
	endpoint_t *ep = (endpoint_t *)arg;
	ep->entity->GetFunction()->InitLogCurrentThread();

#ifdef RVC_OS_WIN
	CoInitialize(NULL);
#else

#endif // RVC_OS_WIN

	Dbg("enter event_thread.");

	ep->root = su_root_create(ep);

	ep->nua = nua_create(ep->root,
		&endpoint_callback,
		ep,
		NUTAG_URL(ep->conf.uri),
		TAG_END());

	nua_set_params(ep->nua,
		SIPTAG_ALLOW_STR("INVITE,CANCEL,BYE,ACK,INFO,OPTIONS"),
		NUTAG_AUTOALERT(1),
		NUTAG_ALLOW("PRACK"),
		NUTAG_EARLY_MEDIA(1),
		NUTAG_SESSION_TIMER(1),
		NUTAG_AUTOANSWER(0),
		NUTAG_AUTOACK(1),
		NTATAG_SIP_T1X64(8000),
		TAG_NULL());

	su_root_run(ep->root);

	nua_shutdown(ep->nua);
	ep->nua = NULL;
	su_root_destroy(ep->root);
	ep->root = NULL;

#ifdef RVC_OS_WIN
	CoUninitialize();
#else
	Dbg("leave event_thread.");
#endif // RVC_OS_WIN
	return 0;
}

static int __endpoint_break(void *arg)
{
	endpoint_t *ep = (endpoint_t *)arg;
	//.....nua_shutdown
	su_root_break(ep->root);

	return 0;
}

#ifdef RVC_OS_WIN
#else
unsigned long GetTickCount()
{
	struct timespec ts;
	clock_gettime(CLOCK_MONOTONIC, &ts);
	return (ts.tv_sec * 1000 + ts.tv_nsec / 1000000);
}
#endif

static endpoint_t *__endpoint_create(CEntityBase *pEntity, const endpoint_conf_t *conf,int nDev)
{
	LOG_FUNCTION();
	endpoint_t *ep;

	ep = ZALLOC_T(endpoint_t);

	su_home_init(ep->home);

	memcpy(&ep->conf, conf, sizeof(endpoint_conf_t));

	ep->media_port_seq = (conf->media_start_port + (GetTickCount() % (conf->media_stop_port - conf->media_start_port))) & 0xfffc;
	
	ep->entity = pEntity;
	ep->call_seq = GetTickCount();
	ep->curr_audio_dev_type = nDev;
	INIT_LIST_HEAD(&ep->call_list);

	return ep;
}

static void __endpoint_destroy(endpoint_t *ep)
{
	su_root_destroy(ep->root);
	su_home_deinit(ep->home);
	free(ep);
}

static int __endpoint_start(endpoint_t *ep)
{
#ifdef RVC_OS_WIN
	ep->event_thread = (HANDLE)_beginthreadex(NULL, 0, &__event_thread, ep, 0, NULL);
	if (ep->event_thread)
	{
		while (!ep->root)
		{
			DWORD dwRet = WaitForSingleObject(ep->event_thread, 1);
			if (dwRet == WAIT_OBJECT_0)
			{
				CloseHandle(ep->event_thread);
				ep->event_thread = NULL;
				break;
			}
		}
	}
	return ep->event_thread ? 0 : -1;
#else
	//pthread_attr_t attr;
	//pthread_attr_init(&attr);
	//pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
	int err = pthread_create(&ep->ievent_threadid, NULL, __event_thread, ep);
	//pthread_attr_destroy(&attr);
	if (0 == err) {
		Dbg("create event thread success, event_threadid is %u.", ep->ievent_threadid);
		while (!ep->root) {
			struct timespec ts; 
			clock_gettime(CLOCK_REALTIME, &ts);
			long unsec = ts.tv_nsec + (1000 * 1000);
			ts.tv_sec += (unsec / 1000000000);
			ts.tv_nsec = (unsec % 1000000000);
			if (0 == pthread_timedjoin_np(ep->ievent_threadid, NULL, &ts)) {
				ep->ievent_threadid = 0;
				break;
			}
		}
	}
	else {
		Dbg("create event thread failed.");
	}

	return ep->ievent_threadid > 0 ? 0 : -1;
#endif
}

static void __endpoint_stop(endpoint_t *ep)
{
	LOG_FUNCTION();
#ifdef RVC_OS_WIN
	if (ep->event_thread)
	{
		int rc;
		su_task_execute(su_root_task(ep->root), &__endpoint_break, ep, &rc);
		WaitForSingleObject(ep->event_thread, INFINITE);
		CloseHandle(ep->event_thread);
		ep->event_thread = NULL;
	}
#else
	if (ep->ievent_threadid > 0)
	{
		int rc;
		su_task_execute(su_root_task(ep->root), &__endpoint_break, ep, &rc);
		Dbg("%s:%d ep address is 0x%08x, event_threadid is %u.", __FUNCTION__, __LINE__, ep, ep->ievent_threadid);
		if (0 == pthread_join(ep->ievent_threadid, NULL)) {
			Dbg("event_thread pthread join success.");
			ep->ievent_threadid = 0;
		}
		else {
			Dbg("pthread join error for %s", strerror(errno));
		}
	}
#endif

}

int endpoint_init_lib()
{
	return su_init();
}

void endpoint_deinit_lib()
{
	su_deinit();
}

endpoint_t *endpoint_create(CEntityBase *pEntity, const endpoint_conf_t *conf,int nDev)
{
	LOG_FUNCTION();
	endpoint_t *endpt;
	
	endpt = __endpoint_create(pEntity, conf,nDev);
	if (endpt) {
		Dbg("new create endpoint addr is 0x%08x.", endpt);
		int rc = __endpoint_start(endpt);
		if (rc != 0) {
			__endpoint_destroy(endpt);
			endpt = NULL;
		}
		else {
			Dbg("endpoint start success.");
		}
	}

	return endpt;
}

void endpoint_destroy(endpoint_t *ep)
{
	LOG_FUNCTION();
	if (ep) 
	{
		__endpoint_stop(ep);
		__endpoint_destroy(ep);
	}
}

int endpoint_invoke(endpoint_t *ep, int (*func)(void*), void *user_data, int *result)
{
	return su_task_execute(su_root_task(ep->root), func, user_data, result);
}

void endpoint_change_audio_dev(endpoint_t *ep, int dev_type)
{
	LOG_FUNCTION();
	if (ep->curr_audio_dev_type != dev_type) {
		ep->curr_audio_dev_type = dev_type;
		if (ep->active_call) {
			Dbg("begin invoke media change audio device!");
			endpoint_media_change_audio_dev(ep->active_call, (e_dev_type)dev_type);
			Dbg("end invoke media change audio device!");
		} else {
			Dbg("active call is null!");
		}
	} else {
		Dbg("current dev_type is the same as dev_type!");
	}
}

endpoint_call_t *endpoint_call_create(endpoint_t *ep, const char *remote_uri, const char*local_ip,DeviceTypeEnum nDeviceType,CallingTypeEnum nCallType,const endpoint_call_callback_t *cb)
{
	LOG_FUNCTION();
	endpoint_call_t *call = NULL;
	su_home_t *home = NULL; 

	if (!remote_uri)
		return NULL;

	home = su_home_create();
	if (!home)
		goto on_error;
	call = (endpoint_call_t*)su_home_new(sizeof(endpoint_call_t));
	if (!call)
		goto on_error;
	memset(call, 0, sizeof(endpoint_call_t));
	call->connected = 0;
	call->ep = ep;
	call->home = home;
	call->last_media_desc_hash = 0;
	call->remote_uri = su_strdup(home, remote_uri);
	memcpy(call->local_ip,local_ip,256);
	call->eDeviceType = nDeviceType;
	call->nCallType = nCallType;
	Dbg("endpoint_call_create nCallType = %d.", nCallType);
	memcpy(&call->cb, cb, sizeof(endpoint_call_callback_t));
	call->id = new_call_id(ep);
	call->local_media_port = new_media_port(ep);

	call->local_video_port = REC_COMMON_VIDEO_PORT;
	REF_COUNT_INIT(&call->ref_cnt);
	list_add_tail(&call->entry, &ep->call_list);
	ep->active_call = call;

	return call;

on_error:
	if (home)
		su_home_unref(home);

	return call;
}

void endpoint_call_destroy(endpoint_call_t *call)
{
	//LOG_FUNCTION();
	endpoint_call_dec_ref(call);
}

int endpoint_call_start(endpoint_call_t *call)
{
	//LOG_FUNCTION();

	char sdp[512] = {0};

	if (call->nh)
		return -1;

	call->nh = nua_handle(call->ep->nua, 
		call, 
		SIPTAG_FROM_STR(call->ep->conf.uri),
		SIPTAG_TO_STR(call->remote_uri),
		TAG_END());

	Dbg("uri is %s.", call->ep->conf.uri);
	Dbg("call remote_uri is %s.", call->remote_uri);
	
	call_make_offer(call, sdp, -1);

	//Dbg("sdp is %s", sdp);

	nua_invite(call->nh, 
		//NUTAG_URL(call->remote_uri), 
		SOATAG_USER_SDP_STR(sdp), 
		NUTAG_SESSION_TIMER(20000),
		//SOATAG_AUDIO_AUX("telephone-event"), 
		TAG_END());

	LogWarn(Severity_Middle, Error_Debug, EVENT_MOD_SIP_INVITE_SEND, sdp);

	return 0;
}

int endpoint_call_hangup(endpoint_call_t *call)
{
	LOG_FUNCTION();
	if (call->nh) {
		if (call->connected) {
			nua_bye(call->nh, NUTAG_SESSION_TIMER(8000),TAG_END());
		} else {
			nua_cancel(call->nh, NUTAG_SESSION_TIMER(8000),TAG_END());
		}
	}
	return 0;
}


int endpoint_call_start_video(endpoint_call_t* call, endpoint_call_param_t* pcallparam, video_session_callback_t* cb)
{
	char local_ip_str[128]={0};
	char remtote_ip_str[128]={0};
	LOG_FUNCTION();

	translate_ipaddr_from_int(local_ip_str, 128, pcallparam->local_ip);
	translate_ipaddr_from_int(remtote_ip_str, 128, pcallparam->remote_ip);
	
	Dbg("Assist channel video local: %s:%d, remote_ip:%s:%d", local_ip_str, pcallparam->local_port, remtote_ip_str, pcallparam->remote_port);
	if (call) 
	{
		int i = 0;
		media_desc_t video_desc = {0};
		video_desc.media_dir = DIR_BOTH;
		if (call->nCallType == NORMAL_CALLTYPE || call->nCallType == DOUBLERECORD_CALLTYPE)//如果是可视柜台模式，使用协助通道的协商结果
		{
			video_desc.local_ip = pcallparam->local_ip;
			video_desc.local_port = pcallparam->local_port;
			video_desc.remote_port = pcallparam->remote_port;
			video_desc.remote_ip = pcallparam->remote_ip;
		}
		else //如果是非可视柜台模式，使用SDP协商的参数
		{
			video_desc.local_ip = call->sdpvieo_desc.local_rtp_ip;
			video_desc.local_port = call->sdpvieo_desc.local_rtp_port;
			video_desc.local_pt = call->sdpvieo_desc.local_pt;
			video_desc.remote_ip = call->sdpvieo_desc.remote_rtp_ip;
			video_desc.remote_port = call->sdpvieo_desc.remote_rtp_port;
			video_desc.remote_pt = call->sdpvieo_desc.remote_pt;
		}
		video_desc.param[i++] = pcallparam->local_view_x;
		video_desc.param[i++] = pcallparam->local_view_y;
		video_desc.param[i++] = pcallparam->local_view_cx;
		video_desc.param[i++] = pcallparam->local_view_cy;
		video_desc.param[i++] = pcallparam->remote_view_x;
		video_desc.param[i++] = pcallparam->remote_view_y;
		video_desc.param[i++] = pcallparam->remote_view_cx;
		video_desc.param[i++] = pcallparam->remote_view_cy;
		video_desc.param[i++] = pcallparam->remote_width;
		video_desc.param[i++] = pcallparam->remote_height;
		//add by clp 20190823
		video_desc.param[i++] = pcallparam->local_hwd_move;
		video_desc.param[i++] = pcallparam->remote_hwd_move;
		video_desc.param[i++] = pcallparam->local_fresh_time;
		video_desc.param[i++] = pcallparam->remote_fresh_time;
		endpoint_media_update_video(call, &video_desc, cb);

		char str_local_ip[128]={0};
		char str_remtote_ip[128]={0};
		translate_ipaddr_from_int(str_local_ip, 128,video_desc.local_ip);
		translate_ipaddr_from_int(str_remtote_ip, 128, video_desc.remote_ip);

		Dbg("start video,local video ip=%s port=%d pt=%d,remote ip=%s port=%d pt=%d",str_local_ip,video_desc.local_port,video_desc.local_pt,str_remtote_ip,video_desc.remote_port,video_desc.remote_pt);
		return 0;
	} 
	else 
	{	
		return Error_Param;
	}
} 


int endpoint_call_stop_video(endpoint_call_t *call)
{
	LOG_FUNCTION();
	if (call) {
		media_desc_t video_desc = {0};
		video_desc.media_dir = DIR_NONE;
		endpoint_media_update_video(call, &video_desc,NULL);
		return 0;
	} else {
		return Error_Param;
	}
}


int endpoint_call_stop_double_record_broadcast_video()
{
	LOG_FUNCTION();

	double_record_broadcast_video_session_stop();

	return Error_Succeed;
}


int local_play_start_video(endpoint_call_t *call,int local_view_x, int local_view_y, int local_view_cx, int local_view_cy, int local_move, video_session_callback_t* cb)
{
		LOG_FUNCTION();

		int rc;
		BOOL bCreateAudioObject = FALSE;
		endpoint_conf_t *ep_conf = &call->ep->conf;
		if (call->video) 
		{
			video_session_destroy(call->video);
			call->video = NULL;
		}
		video_session_conf_t video_conf = {0};
		video_conf.bit_rate = 256 * 1024;
		video_conf.local_rtp_ip = 0;
		video_conf.local_rtp_port = 0;
		video_conf.local_video_view_x = local_view_x;
		video_conf.local_video_view_y = local_view_y;
		video_conf.local_video_view_cx = local_view_cx;
		video_conf.local_video_view_cy = local_view_cy;
		video_conf.local_move = local_move;
		video_conf.mtu = ep_conf->mtu;
		video_conf.video_quant = ep_conf->quant;
		video_conf.remote_rtp_ip = 0;
		video_conf.remote_rtp_port = 0;
		video_conf.remote_video_view_x = 0;
		video_conf.remote_video_view_y = 0;
		video_conf.remote_video_view_cx = 0;
		video_conf.remote_video_view_cy = 0;
		video_conf.remote_video_width = 0;
		video_conf.remote_video_height = 0;
		video_conf.ref_active_camera = call->ep->conf.ref_active_camera;
		video_conf.ref_camera_switch = call->ep->conf.ref_camera_switch;
		video_conf.ref_camera_state = call->ep->conf.ref_camera_state;
		video_conf.ref_window_state = call->ep->conf.ref_window_state;
		video_conf.ref_active_img = call->ep->conf.ref_active_img;
		video_conf.ref_Is_ActiveInspect = call->ep->conf.ref_Is_ActiveInspect;
		video_conf.ref_Is_showPersonArea = call->ep->conf.ref_Is_showPersonArea;
		video_conf.ref_Is_showRecordArea = call->ep->conf.ref_Is_showRecordArea;
		video_conf.camera_count = call->ep->conf.camera_count;
		video_conf.screen_count = call->ep->conf.screen_count;
		video_conf.eDeviceType = call->eDeviceType;
		video_conf.video_echo_cb = cb;
		video_conf.ilocal_wind_flags = VIDEOPLAYER_FLAG_PULL|VIDEOPLAYER_FLAG_CHECKTOP|VIDEOPLAYER_FLAG_ZOOMOUTSIZE;
		video_conf.iremote_wind_flags = VIDEOPLAYER_FLAG_PUSH|VIDEOPLAYER_FLAG_CHECKTOP;
		rc = Local_video_session_create(&video_conf, &call->video);
		if (rc != 0) 
		{
			Dbg("create video session failed! rc = %d", rc);
			return -1;
		}
		rc = video_session_start(call->video);
		if (rc != 0) 
		{
			Dbg("start video session failed! rc = %d", rc);
			video_session_destroy(call->video);
			call->video = NULL;
			return -1;
		}
		return 0;
}

int local_remote_show_video(endpoint_call_t *call,int local_view_x, int local_view_y, int local_view_cx, int local_view_cy,int remote_view_x, int remote_view_y, int remote_view_cx, int remote_view_cy, int local_move, int remote_move, video_session_callback_t* cb)
{
	LOG_FUNCTION();
	int rc;
	BOOL bCreateAudioObject = FALSE;
	endpoint_conf_t *ep_conf = &call->ep->conf;
	if (call->video) 
	{
		video_session_destroy(call->video);
		call->video = NULL;
	}
	int remote_video_width = REC_COMMON_VIDEO_SSM_AGENT_WIDTH;
	int remote_video_height = REC_COMMON_VIDEO_SSM_AGENT_HEIGHT;
	if (eStand2sType == call->eDeviceType){
		remote_video_width = REC_COMMON_VIDEO_DSM_AGENT_WIDTH;
		remote_video_height = REC_COMMON_VIDEO_DSM_AGENT_HEIGHT;
	}

	video_session_conf_t video_conf = {0};
	video_conf.bit_rate = 256 * 1024;
	video_conf.local_rtp_ip = 0;
	video_conf.local_rtp_port = 0;
	video_conf.local_video_view_x = local_view_x;
	video_conf.local_video_view_y = local_view_y;
	video_conf.local_video_view_cx = local_view_cx;
	video_conf.local_video_view_cy = local_view_cy;
	video_conf.local_move = local_move;
	video_conf.mtu = ep_conf->mtu;
	video_conf.video_quant = ep_conf->quant;
	video_conf.remote_rtp_ip = 0;
	video_conf.remote_rtp_port = 0;
	video_conf.remote_video_view_x = remote_view_x;
	video_conf.remote_video_view_y = remote_view_y;
	video_conf.remote_video_view_cx = remote_view_cx;
	video_conf.remote_video_view_cy = remote_view_cy;
	video_conf.remote_move = remote_move;
	video_conf.remote_video_width = remote_video_width;
	video_conf.remote_video_height = remote_video_height;
	video_conf.ref_active_camera = call->ep->conf.ref_active_camera;
	video_conf.ref_camera_switch = call->ep->conf.ref_camera_switch;
	video_conf.ref_camera_state = call->ep->conf.ref_camera_state;
	video_conf.ref_window_state = call->ep->conf.ref_window_state;
	video_conf.ref_active_img = call->ep->conf.ref_active_img;
	video_conf.ref_Is_ActiveInspect = call->ep->conf.ref_Is_ActiveInspect;
	video_conf.ref_Is_showPersonArea = call->ep->conf.ref_Is_showPersonArea;
	video_conf.camera_count = call->ep->conf.camera_count;
	video_conf.screen_count = call->ep->conf.screen_count;
	video_conf.eDeviceType = call->eDeviceType;
	video_conf.video_echo_cb = cb;
	video_conf.ilocal_wind_flags = VIDEOPLAYER_FLAG_PULL|VIDEOPLAYER_FLAG_CHECKTOP;
	video_conf.iremote_wind_flags = VIDEOPLAYER_FLAG_PUSH|VIDEOPLAYER_FLAG_CHECKTOP;
	
	rc = Local_video_session_create(&video_conf, &call->video, true);
	if (rc != 0){
		Dbg("create video session failed! rc = %d", rc);
		return -1;
	}
	else{
		Dbg("create video session success!");
	}

	rc = video_session_start(call->video);
	if (rc != 0){
		Dbg("start video session failed! rc = %d", rc);
		video_session_destroy(call->video);
		call->video = NULL;
		return -1;
	}
	else{
		Dbg("local remote show video success start video session 0x%08x.", call->video);
	}

	return 0;
}


int local_play_stop_video(endpoint_call_t *call)
{
	if (call) {
		media_desc_t video_desc = {0};
		video_desc.media_dir = DIR_NONE;
		endpoint_media_update_video(call, &video_desc,NULL);
		return 0;
	} else 
	{
		return Error_Param;
	}
}

static void __endpoint_call_destroy(endpoint_call_t *call)
{
	Dbg("endpoint call destroy! home ref:%d", su_home_refcount(call->home));
	list_del(&call->entry);
	if (call->ep->active_call == call) {
		call->ep->active_call = NULL;
	}
	su_home_unref(call->home);
}


int translate_ipaddr_from_int(char* strdst, unsigned ulen, unsigned long uip)
{
	int iret = -1;
	if (NULL == strdst){
		return iret;
	}

	char* pstr_ip = inet_ntoa(__lton(uip));
	size_t ulen_ip = 0;
	if (NULL != pstr_ip){
		ulen_ip = strlen(pstr_ip);
		if (ulen_ip < ulen){
			memcpy(strdst, pstr_ip, ulen_ip);
			iret = 0;
		}
	}
	return iret;
}


IMPLEMENT_REF_COUNT_MT_STATIC(endpoint_call, endpoint_call_t, ref_cnt, __endpoint_call_destroy)