1 #include "schedule_module_base.h"
6 class schedule_module_test1 : public schedule_module_base{
8 // boost::asio::ip::tcp::endpoint tcp_endpoint ;
9 // boost::asio::ip::udp::endpoint udp_endpoint ;
11 schedule_module_test1();
12 ~schedule_module_test1();
20 boost::thread::id thread_id,
21 rslist_iterator_begin_func_type inlist_begin,
22 rslist_iterator_end_func_type inlist_end,
23 rslist_iterator_next_func_type inlist_next,
24 boost::asio::ip::tcp::endpoint& outendpoint );
27 boost::thread::id thread_id,
28 rslist_iterator_begin_func_type inlist_begin,
29 rslist_iterator_end_func_type inlist_end,
30 rslist_iterator_next_func_type inlist_next,
31 boost::asio::ip::udp::endpoint& outendpoint );
33 void replication_interrupt(){}
36 schedule_module_test1::schedule_module_test1() : schedule_module_base( "schedule_module_test1" )
40 schedule_module_test1::~schedule_module_test1(){}
42 void schedule_module_test1::initialize(){
45 bool schedule_module_test1::is_tcp(){ return true; }
46 bool schedule_module_test1::is_udp(){ return true; }
48 void schedule_module_test1::handle_schedule(
49 boost::thread::id thread_id,
50 rslist_iterator_begin_func_type inlist_begin,
51 rslist_iterator_end_func_type inlist_end,
52 rslist_iterator_next_func_type inlist_next,
53 boost::asio::ip::tcp::endpoint& outendpoint ){
56 void schedule_module_test1::handle_schedule(
57 boost::thread::id thread_id,
58 rslist_iterator_begin_func_type inlist_begin,
59 rslist_iterator_end_func_type inlist_end,
60 rslist_iterator_next_func_type inlist_next,
61 boost::asio::ip::udp::endpoint& outendpoint ){
66 extern "C" l7vs::schedule_module_base*
68 return dynamic_cast<l7vs::schedule_module_base*>(new l7vs::schedule_module_test1());
72 destroy_module( l7vs::schedule_module_base* in ){