#include??
#include??
#include?
#include?
#include??
#include??
#include??
#include??

#include?
#include?
#include?
#include?

#include?
#include?


ntrip_caster::ntrip_caster（）
{
	m_listen_sock?=?0;
	m_epoll_fd?=?0;
	m_max_count?=?0;
	m_epoll_events?=?NULL;
}
?
ntrip_caster::~ntrip_caster（）
{
	if（m_listen_sock?>?0）{
		close（m_listen_sock）;
	}

	if（m_epoll_fd?>?0）{
		close（m_epoll_fd）;
	}
}
?
bool?ntrip_caster::init（int?port??int?sock_count）
{
	m_max_count?=?sock_count;
	struct?sockaddr_in?caster_addr;
	memset（&caster_addr?0?sizeof（struct?sockaddr_in））;
	caster_addr.sin_family?=?AF_INET;
	caster_addr.sin_port?=?htons（port）;
	caster_addr.sin_addr.s_addr?=?htonl（INADDR_ANY）;

	m_listen_sock?=?socket（AF_INET?SOCK_STREAM?0）;
	if（m_listen_sock?==?-1）?{
		exit（1）;
	}

	if（bind（m_listen_sock?（struct?sockaddr*）&caster_addr?sizeof（struct?sockaddr））?==?-1）{
		exit（1）;
	}

	if（listen（m_listen_sock?5）?==?-1）{
		exit（1）;
	}
											?
	m_epoll_events?=?new?struct?epoll_event[sock_count];
	if?（m_epoll_events?==?NULL）{
		exit（1）;
	}

	m_epoll_fd?=?epoll_create（sock_count）;
	epoll_ops（m_listen_sock?EPOLL_CTL_ADD?EPOLLIN）;

	return?true;
}
?
bool?ntrip_caster::init（const?char?*ip?int?port??int?sock_count）
{	
	m_max_count?=?sock_count;
	struct?sockaddr_in?server_addr;
	memset（&server_addr?0?sizeof（struct?sockaddr））;
	server_addr.sin_family?=?AF_INET;
	server_addr.sin_port?=?htons（port）;
	server_addr.sin_addr.s_addr?=?inet_addr（ip）;		

	m_listen_sock?=?socket（AF_INET?SOCK_STREAM?0）;
	if（m_listen_sock?==?-1）{
		exit（1）;
	}

	if（bind（m_listen_sock?（struct?sockaddr*）&server_addr?sizeof（struct?sockaddr））?==?-1）{
		exit（1）;
	}
											
	if（listen（m_listen_sock?5）?==?-1）{
		exit（1）;
	}

	m_epoll_events?=?new?struct?epoll_event[sock_count];
	if?（m_epoll_events?==?NULL）{
		exit（1）;
	}

	m_epoll_fd?=?epoll_create（sock_count）;
	epoll_ops（m_listen_sock?EPOLL_CTL_ADD?EPOLLIN）;

	return?true;
}
?
int?ntrip_caster::accept_new_client（）
{
	struct?sockaddr_in?client_addr;
	memset（&client_addr?0?sizeof（struct?sockaddr_in））;
	socklen_t?clilen?=?sizeof（struct?sockaddr）;?

	int?new_sock?=?accept（m_listen_sock?（struct?sockaddr*）&client_addr?&clilen）;	
	epoll_ops（new_sock?EPOLL_CTL_ADD?EPOLLIN）;
	
	return?new_sock;
}
?
int?ntrip_caster::recv_data（int?sock?char?*recv_buf）
{
	char?buf[1024]?=?{0};
	int?len?=?0;
	int?ret?=?0;

	while（ret?>=?0）
	{
		ret?=?recv（sock?buf?sizeof（buf）?0）;
		if（ret?<=?0）
		{
			epoll_ops（sock?EPOLL_CTL_DEL?EPOLLERR）;
			close（sock）;
			break;
		}else?if（ret?			memcpy（recv_buf?buf?ret）;
			len?+=?ret;	
			break;
		}else{
			memcpy（recv_buf?buf?sizeof（buf））;
			len?+=?ret;
		}
	}

	return?ret?<=?0???ret?:?len;
}
?
int?ntrip_caster::send_data（int?sock?const?char?*send_buf?int?buf_len）
{
	int?len?=?0;
	int?ret?=?0;

	while（len?		if（buf_len?