- 写入出错处理
- Send Response时，如果对方不读了，继续写入就没有意义了
- 此时写入出现问题，系统会给进程发送SIGPIPE信号
- HttpServer初始化时，要将SIGPIPE进行忽略
- 如果不忽略，在向对端写入的时候，如果对端关闭链接，而Server正在写，可能直接崩溃Server
class HttpServer
{
public:
HttpServer(int port = PORT)
: _port(port)
, _stop(false)
{}
void Init()
{
signal(SIGPIPE, SIG_IGN);
}
void Loop(int threadNum = THREAD_POOL_NUM)
{
TcpServer *tsvr = TcpServer::GetInstance(_port);
LOG(INFO, "Loop Begin");
while(!_stop)
{
struct sockaddr_in peer;
socklen_t len = sizeof(peer);
int sock = accept(tsvr->Sock(), (struct sockaddr *)&peer, &len);
if(sock < 0)
{
continue;
}
LOG(INFO, "Get a new link");
Task task(sock);
ThreadPool::GetInstance(threadNum)->Push(task);
}
}
private:
uint16_t _port;
bool _stop;
};
