wangyu-UDPspeeder/delay_manager.h

/*
 * delay_manager.h
 *
 *  Created on: Sep 15, 2017
 *      Author: root
 */

#ifndef DELAY_MANAGER_H_
#define DELAY_MANAGER_H_

#include "common.h"
#include "packet.h"
#include "log.h"

//enum delay_type_t {none=0,enum_sendto_u64,enum_send_fd,client_to_local,client_to_remote,server_to_local,server_to_remote};

/*
struct fd_ip_port_t
{
	int fd;
	u32_t ip;
	u32_t port;
};
union dest_t
{
	fd_ip_port_t fd_ip_port;
	int fd;
	u64_t u64;
};
*/
/*
struct my_timer_t
{
	int timer_fd;
	fd64_t timer_fd64;
	my_timer_t()
	{
		if ((timer_fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK)) < 0)
		{
			mylog(log_fatal,"timer_fd create error");
			myexit(1);
		}
		timer_fd64=fd_manager.create(timer_fd);
	}
	my_timer_t(const my_timer_t &b)
	{
		assert(0==1);
	}
	~my_timer_t()
	{
		fd_manager.fd64_close(timer_fd64);
	}
	int add_fd_to_epoll(int epoll_fd)
	{
		epoll_event ev;;
		ev.events = EPOLLIN;
		ev.data.u64 = timer_fd;
		int ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, timer_fd, &ev);
		if (ret!= 0) {
			mylog(log_fatal,"add delay_manager.get_timer_fd() error\n");
			myexit(-1);
		}
		return 0;
	}
	int add_fd64_to_epoll(int epoll_fd)
	{
		epoll_event ev;;
		ev.events = EPOLLIN;
		ev.data.u64 = timer_fd64;
		int ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, timer_fd, &ev);
		if (ret!= 0) {
			mylog(log_fatal,"add delay_manager.get_timer_fd() error\n");
			myexit(-1);
		}
		return 0;
	}
	int get_timer_fd()
	{
		return timer_fd;
	}
	fd64_t get_timer_fd64()
	{
		return timer_fd64;
	}
	int set_timer_repeat_us(my_time_t my_time)
	{
		itimerspec its;
		memset(&its,0,sizeof(its));
		its.it_interval.tv_sec=my_time/1000000llu;
		its.it_interval.tv_nsec=my_time%1000000llu*1000llu;
		its.it_value.tv_nsec=1; //imidiately
		timerfd_settime(timer_fd,0,&its,0);
		return 0;
	}
	int set_timer_abs_us(my_time_t my_time)
	{
		itimerspec its;
		memset(&its,0,sizeof(its));
		its.it_value.tv_sec=my_time/1000000llu;
		its.it_value.tv_nsec=my_time%1000000llu*1000llu;
		timerfd_settime(timer_fd,TFD_TIMER_ABSTIME,&its,0);
		return 0;
	}
};*/


struct delay_data_t
{
	dest_t dest;
	//int left_time;//
	char * data;
	int len;
	int handle();
};

struct delay_manager_t
{
	ev_timer timer;
	struct ev_loop *loop=0;
	void (*cb) (struct ev_loop *loop, struct ev_timer *watcher, int revents)=0;

	//int timer_fd;
	int capacity;
	multimap<my_time_t,delay_data_t> delay_mp;  //unit us,1 us=0.001ms
	delay_manager_t();
	delay_manager_t(delay_manager_t &b)
	{
		assert(0==1);
	}
	void set_loop_and_cb(struct ev_loop *loop,void (*cb) (struct ev_loop *loop, struct ev_timer *watcher, int revents))
	{
		this->loop=loop;
		this->cb=cb;
		ev_init(&timer,cb);
	}
	int set_capacity(int a){capacity=a;return 0;}
	~delay_manager_t();
	ev_timer& get_timer();
	int check();
	int add(my_time_t delay,const dest_t &dest,char *data,int len);
};

#endif /* DELAY_MANAGER_H_ */