leechanx / easy-reactor Goto Github PK

               //multi-thread reactor model: round-robin a event loop and give message to it
                if (_thd_pool)
                {
                    thread_queue<queue_msg>* cq = _thd_pool->get_next_thread();
                    queue_msg msg;
                    msg.cmd_type = queue_msg::NEW_CONN;
                    msg.connfd = connfd;
                    cq->send_msg(msg);
                }

    }
}`

$ make
g++ -g -O2 -Wall -fPIC -Wno-deprecated -c -o src/tcp_client.o src/tcp_client.cc -Iinclude
g++ -g -O2 -Wall -fPIC -Wno-deprecated -c -o src/udp_server.o src/udp_server.cc -Iinclude
g++ -g -O2 -Wall -fPIC -Wno-deprecated -c -o src/io_buffer.o src/io_buffer.cc -Iinclude
g++ -g -O2 -Wall -fPIC -Wno-deprecated -c -o src/event_loop.o src/event_loop.cc -Iinclude
g++ -g -O2 -Wall -fPIC -Wno-deprecated -c -o src/udp_client.o src/udp_client.cc -Iinclude
g++ -g -O2 -Wall -fPIC -Wno-deprecated -c -o src/config_reader.o src/config_reader.cc -Iinclude
g++ -g -O2 -Wall -fPIC -Wno-deprecated -c -o src/tcp_conn.o src/tcp_conn.cc -Iinclude
In file included from include/thread_pool.h:5:0,
                 from include/tcp_server.h:5,
                 from src/tcp_conn.cc:3:
include/thread_queue.h: In destructor ‘thread_queue<T>::~thread_queue()’:
include/thread_queue.h:30:9: error: ‘::close’ has not been declared
         ::close(_evfd);
         ^
include/thread_queue.h: In member function ‘void thread_queue<T>::send_msg(const T&)’:
include/thread_queue.h:38:19: error: ‘::write’ has not been declared
         int ret = ::write(_evfd, &number, sizeof(unsigned long long));
                   ^
include/thread_queue.h: In member function ‘void thread_queue<T>::recv_msg(std::queue<T>&)’:
include/thread_queue.h:47:19: error: ‘::read’ has not been declared
         int ret = ::read(_evfd, &number, sizeof(unsigned long long));
                   ^
makefile:17: recipe for target 'src/tcp_conn.o' failed
make: *** [src/tcp_conn.o] Error 1

Thread model: posix
gcc version 5.4.0 20160609 (Ubuntu 5.4.0-6ubuntu1~16.04.10)

int curr_pos = _count;
_count++;

int prt_pos = (curr_pos - 1) / 2;
while (prt_pos >= 0 && _event_lst[curr_pos].ts < _event_lst[prt_pos].ts)
{
    timer_event tmp = _event_lst[curr_pos];
    _event_lst[curr_pos] = _event_lst[prt_pos];
    _event_lst[prt_pos] = tmp;
    //update position
    _position[_event_lst[curr_pos].timer_id] = curr_pos;
    _position[tmp.timer_id] = prt_pos;

    curr_pos = prt_pos;
    prt_pos = (curr_pos - 1) / 2;
}