dasima / ftpserver Goto Github PK

Contributors

Stargazers

Forkers

jianzi123 whf839 xjx79 zhangli88 peterdocter yuanzh1024 shook2012 ngdmcc ghice yuhongjiu8888 zzu-andrew weiminzhang gczhcm fengxingwei369 kjwonderful mingdonghu 9176324 2217936322 morningblu anchor037 hmrg-grmh josoen bingo787 leevisin bypasscc lw-lx enoch0614 justdoit0910 attendantpansy jeff-cn zhengxinyu13 wogeri-zxs gtdongle loogg

//获取监听fd
void privop_pasv_listen(Session_t *sess)
{
    //创建listen fd
    char ip[16] = {0};
    get_local_ip(ip);
    /* 打开的端口号是固定的 20 号 */
    int listenfd = tcp_server(ip, 20);
    sess->listen_fd = listenfd;

//获取数据套接字
void privop_pasv_get_data_sock(Session_t *sess)
{
    char ip[16] = {0};
    priv_sock_recv_str(sess->nobody_fd, ip, sizeof ip);
    uint16_t port = priv_sock_recv_int(sess->nobody_fd);
    //创建fd
    /* 这里直接指定 20 号端口是用于什么的呢？ */
    int data_fd = tcp_client(20);

    struct sockaddr_in addr;
    memset(&addr, 0, sizeof addr);
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = inet_addr(ip);
    addr.sin_port = htons(port);
    int ret = connect_timeout(data_fd, &addr, tunable_connect_timeout);
    if(ret == -1)
        ERR_EXIT("connect_timeout");
    priv_sock_send_result(sess->nobody_fd, PRIV_SOCK_RESULT_OK);
    priv_sock_send_fd(sess->nobody_fd, data_fd);
    close(data_fd);
}