http_conn.h

#ifndef HTTPCONNECTION_H
#define HTTPCONNECTION_H

#include <unistd.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/epoll.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <assert.h>
#include <sys/stat.h>
#include <string.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <stdarg.h>
#include <errno.h>
#include "locker.h"
#include <sys/uio.h>


class http_conn {

public:
    // HTTP请求方法，这里只支持GET
    enum METHOD {GET = 0, POST, HEAD, PUT, DELETE, TRACE, OPTIONS, CONNECT};
    
    /*
        主状态机的状态
        CHECK_STATE_REQUESTLINE:当前正在分析请求行
        CHECK_STATE_HEADER:当前正在分析头部字段
        CHECK_STATE_CONTENT:当前正在解析请求体
    */
    enum CHECK_STATE { CHECK_STATE_REQUESTLINE = 0, CHECK_STATE_HEADER, CHECK_STATE_CONTENT };
    
    /*
        服务器处理HTTP请求的可能结果，报文解析的结果
        NO_REQUEST          :   请求不完整，需要继续读取客户数据
        GET_REQUEST         :   表示获得了一个完成的客户请求
        BAD_REQUEST         :   表示客户请求语法错误
        NO_RESOURCE         :   表示服务器没有资源
        FORBIDDEN_REQUEST   :   表示客户对资源没有足够的访问权限
        FILE_REQUEST        :   文件请求,获取文件成功
        INTERNAL_ERROR      :   表示服务器内部错误
        CLOSED_CONNECTION   :   表示客户端已经关闭连接了
    */
    enum HTTP_CODE { NO_REQUEST, GET_REQUEST, BAD_REQUEST, NO_RESOURCE, FORBIDDEN_REQUEST, FILE_REQUEST, INTERNAL_ERROR, CLOSED_CONNECTION };
    
    // 从状态机的三种可能状态，即当前行的读取状态，分别表示
    // 1.读取到一个完整的行 2.行出错 3.行数据尚未读取完
    enum LINE_STATUS { LINE_OK = 0, LINE_BAD, LINE_OPEN };

public:
    http_conn() {}
    ~http_conn() {}

    static int m_epollfd; // 所有socket上的事件也就是http_conn对象都注册到同一个epollfd上
    static int m_user_count; // 统计当前用户数量
    static const int FILENAME_LEN = 200; // 文件名的最大长度
    static const int READ_BUFFER_SIZE = 2048; // 读缓冲区的大小
    static const int WRITE_BUFFER_SIZE = 1024; // 写缓冲的大小

    void init(int sockfd, const sockaddr_in& addr); // 初始化新连接
    void close_conn(); // 关闭连接

    void process(); //工作线程执行的代码：解析客户端的请求，把请求的资源封装好

    

    bool read(); // 非阻塞的读
    bool write(); // 非阻塞写

private:
    int m_sockfd; // 客户端的socket
    sockaddr_in m_address;

    char m_read_buf[READ_BUFFER_SIZE]; // 读缓冲区
    char m_write_buf[WRITE_BUFFER_SIZE];

    int m_read_idx; // 下一个需要读的起始点, 0 ~ idx是已读完的
    int m_checked_idx; // 当前正在分析的字符在读缓冲区中的位置
    int m_start_line; // 当前正在解析的行的起始位置

    int m_write_idx;                        // 写缓冲区中待发送的字节数
    char* m_file_address;                   // 客户请求的目标文件被mmap到内存中的起始位置
    struct stat m_file_stat;                // 目标文件的状态。通过它我们可以判断文件是否存在、是否为目录、是否可读，并获取文件大小等信息
    struct iovec m_iv[2];                   // 我们将采用writev来执行写操作，所以定义下面两个成员，其中m_iv_count表示被写内存块的数量。
    int m_iv_count;

    char m_real_file[ FILENAME_LEN ]; // 客户请求的目标文件的完整路径，其内容等于 doc_root（资源路径） + m_url
    
    char* m_url; // 请求目标文件的文件名
    char* m_version; // 版本号 只支持 http1.1
    METHOD m_method; // 请求方法

    char* m_host; // 主机名
    int m_content_length; // HTTP请求的消息总长度
    bool m_linger; // http请求是否保持连接

    CHECK_STATE m_check_state; // 主状态机当前所处的状态

    int bytes_to_send;              // 将要发送的数据的字节数
    int bytes_have_send;            // 已经发送的字节数

private:
    void init(); // 初始化连接的其他信息
    
    // 主状态机 都用于process_read
    HTTP_CODE process_read(); // 解析http请求
    HTTP_CODE parse_request_line(char* text); // 解析请求首行
    HTTP_CODE parse_headers(char* text); // 解析请求头
    HTTP_CODE parse_content(char* text); // 解析请求体
    HTTP_CODE do_request();
    // 从状态机
    LINE_STATUS parse_line(); // 解析具体某一行
    char* getline() {return &m_read_buf[m_start_line];}

    // 用于process_write
    bool process_write( HTTP_CODE ret );    // 填充HTTP应答
    void unmap();
    bool add_response( const char* format, ... );
    bool add_content( const char* content );
    bool add_content_type();
    bool add_status_line( int status, const char* title );
    void add_headers( int content_length );
    bool add_content_length( int content_length );
    bool add_linger();
    bool add_blank_line();

};


#endif