mywind

// fdのラッピング
// buf:このfdがデータを受信するためのバッファ
// iptr, optrはデータの読み書き位置を記録するポインタ
// fd_fin, closed, connected: fdの状態を記録する変数
class fd_buf{
    public:
        int fd;
        char buf[MAXLINE];
        int iptr, optr;
        bool fd_fin, closed, connected;
        // uint32_t mod;
        fd_buf() {
            iptr = optr = 0;
            fd_fin = false;
            connected = false;
            closed = false;
            // mod = EPOLLIN;
        }
        fd_buf(int fd){
            iptr = optr = 0;
            fd_fin = false;
            connected = false;
            closed = false;
            // mod = EPOLLIN;
            this->fd = fd;
        }

        bool is_buf_empty() {
            return iptr == optr;
        }

        bool is_buf_full() {
            return iptr == MAXLINE;
        }
        

};

// データ転送を完了するためのオブジェクト
// ユーザーの視点から見ると、一部はアップリンク、一部はダウンロード
class tunnel{
    public:
        fd_buf *fd_up, *fd_down;
        double sum_up, sum_down;
        tunnel() {
            sum_up = 0;
            sum_down = 0;
        }
        tunnel(int fd_user, int fd_app) {
            sum_up = 0;
            sum_down = 0;
            fd_up = new fd_buf(fd_user);
            fd_down = new fd_buf(fd_app);
        }
        int do_read(fd_buf* fd_buf_in, fd_buf* pair_fd_buf);

        int do_write(fd_buf* fd_buf_out, fd_buf* pair_fd_buf);

        void fd_user_read(){
            int n = do_read(fd_up, fd_down);
            sum_up += n;
        }

        void fd_app_read(){
            do_read(fd_down, fd_up);
        }

        void fd_user_write(){
            int n = do_write(fd_up, fd_down);
            sum_down += n;
        }

        void fd_app_write(){
            do_write(fd_down, fd_up);
        }
        
        bool is_user_fd(int fd){
            return fd == fd_up->fd;
        }
        ~tunnel() {
            delete fd_down;
            delete fd_up;
        }


};

// マルチシステム互換のsetnonblocking
int setnonblocking(int fd) {
    if (fd < 0) return -1;
    int flags;
    /* O_NONBLOCKがある場合、Posix方式で行う */
    #if defined(O_NONBLOCK)
        /* Fixme: O_NONBLOCKは定義されているが、SunOS 4.1.xとAIX 3.2.5では壊れている。 */
        if (-1 == (flags = fcntl(fd, F_GETFL, 0)))
        flags = 0;
        return fcntl(fd, F_SETFL, flags | O_NONBLOCK);
    #else
        /* そうでなければ、古い方法を使用する */
        flags = 1;
        return ioctl(fd, FIOBIO, &flags);
    #endif
}

 int error;
socklen_t len = sizeof(error);

if(getsockopt(fd,SOL_SOCKET, SO_ERROR, &error, &len) == 0 && error == 0){
        printf("接続成功\n");
}
else {
    printf("接続失敗\n");
}

 // 前提 fd&EPOLLIN, 対端fd_peerの状態は不明
 n = read
 if ( n < 0) {
     // 非ブロッキングによるエラーは処理する必要はありません
     if(errno != EAGAIN && errno != EWOULDBLOCK) {
         // 現在の条件下で即座に処理できるものを先に処理し、
         // 対端の状態およびアプリケーションのバッファ状態に基づいて分類処理します。

         // fdを閉じると、epollは自動的にそのfdのリッスンを削除します。
         close(fd)

         // 現在のバッファが空でなく、対端が閉じていない場合、対端の書き込み可能をリッスンする必要があります。
         if(!fd_pair.closed && fd.buf not empty ){
             enable fd_peer EPOLLOUT
             // fdがすでに閉じているため、対端の読み取りを閉じる必要があります。
             disable fd EPOLLIN
         }
     }
 }
 else if (n == 0) {
     if(fd_pair.buf not empty ) {
         enable fd EPOLLOUT
     }

     if(!fd_pair.closed && fd.buf is empty) {
         enable fd_pair EPOLLIN
     }

 }
 else {
     if(fd.buf is empty) {
         if(fd_pair not full && !fd_pair.fd_fin) {
             fd_pair EPOLLOUT|EPOLLIN
         }
         else {
             enable fd_pair EPOLLOUT
         }
     }

     if(fd.buf is full) {
         if(fd_pair.buf not empty) {
             enable fd EPOLLOUT
         }
         else{
             disenable fd EPOLLOUT
         }
     }
 }