#include"../source/channel.hpp"
#include"../source/socket.hpp"
#include"../source/Eventloop.hpp"

void ReadCallBack()
{
    std::cout<<"ReadCallBack"<<std::endl;
}

void WriteCallBack()
{
    std::cout<<"WriteCallBack"<<std::endl;
}

void AnyCallBack()
{
    std::cout<<"AnyCallBack"<<std::endl;
}

void CloseCallBack()
{
    std::cout<<"CloseCallBack"<<std::endl;
}

void ErrorCallBack()
{
    std::cout<<"ErrorCallBack"<<std::endl;
}

void test()
{
    //创建一个文件描述符，让channel管理起来
    Socket sock;
    sock.CreateClient("127.0.0.1",8888);
    Eventloop loop;
    Channel ch(sock.RetSock(),&loop);
    //设置读事件监控
    std::cout<<"设置读事件监控"<<std::endl;
    ch.SetListenRead();
    if(ch.IsListenRead())
    {
        std::cout<<"设置读事件监控成功"<<std::endl;
    }
    else
    {
        std::cout<<"设置读事件监控失败"<<std::endl;
    }
    //取消读事件监控
    ch.CancelRead();
    if(ch.IsListenRead())
    {
        std::cout<<"取消读事件监控失败"<<std::endl;
    }
    else
    {
        std::cout<<"取消读事件监控成功"<<std::endl;
    }

    //设置写事件监控
    ch.SetListenWrite();
    if(ch.IsListenWrite())
    {
        std::cout<<"设置写事件监控成功"<<std::endl;
    }
    else
    {
        std::cout<<"设置写事件监控失败"<<std::endl;
    }
    //取消写事件监控
    ch.CancelWrite();
    if(ch.IsListenWrite())
    {
        std::cout<<"取消写事件监控失败"<<std::endl;
    }
    else
    {
        std::cout<<"取消写事件监控成功"<<std::endl;
    }

    //取消所有事件监控
    ch.SetListenRead();
    ch.SetListenWrite();
    ch.DeleteAllListen();
    if(ch.IsListenWrite()||ch.IsListenRead())
    {
        std::cout<<"取消所有事件监控失败"<<std::endl;
        return;
    }
    else
    {
        std::cout<<"取消所有事件监控成功"<<std::endl;
    }

    //设置回调函数
    ch.SetAnyCallBack(AnyCallBack);
    ch.SetCloseCallBack(CloseCallBack);
    ch.SetErrorCallBack(ErrorCallBack);
    ch.SetReadCallBack(ReadCallBack);
    ch.SetWriteCallBack(WriteCallBack);

    //执行回调
    uint32_t i=0;
    i|=EPOLLIN;
    i|=EPOLLOUT;
    ch.SetRevent(i);
    ch.Handler();
}

int main()
{
    test();
    return 0;
}