#include "head.h"
// 1 版本 发送一个小文件
//int transFile(int netfd){
//    send(netfd,"file1",5,0);
//    int fd = open("file1",O_RDWR);
//    char buf[4096] = {0};
//    ssize_t sret = read(fd,buf,sizeof(buf));
//    send(netfd,buf,sret,0);
//    return 0;
//}
// 2 版本 小火车协议发送一个小文件
typedef struct train_s {
    int length;
    char data[1000]; //1000是上限值
}train_t;
//int transFile(int netfd){
//    train_t train;
//    train.length = 5;
//    memcpy(train.data,"file1",5);
//    send(netfd,&train,sizeof(train.length)+train.length,0);
//    int fd = open("file1",O_RDWR);
//    ssize_t sret = read(fd,train.data,sizeof(train.data));
//    train.length = sret;
//    send(netfd,&train,sizeof(train.length)+train.length,0);
//    return 0;
//}
// 3 版本 小火车协议 发送一个大文件
//int transFile(int netfd){
//    train_t train;
//    train.length = 5;
//    memcpy(train.data,"file1",5);
//    send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
//    int fd = open("file1",O_RDWR);
//    struct stat statbuf;
//    fstat(fd,&statbuf);
//    train.length = sizeof(statbuf.st_size);
//    memcpy(train.data,&statbuf.st_size,train.length);
//    send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
//    while(1){
//        bzero(train.data,sizeof(train.data));
//        ssize_t sret = read(fd,train.data,sizeof(train.data));
//        if(sret == 0){
//            break;
//        }
//        train.length = sret;
//        send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
//    }
//    train.length = 0;
//    send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
//    close(fd);
//    return 0;
//}
// 3 版本 服务端使用mmap
//int transFile(int netfd){
//    train_t train;
//    train.length = 5;
//    memcpy(train.data,"file1",5);
//    send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
//    int fd = open("file1",O_RDWR);
//    struct stat statbuf;
//    fstat(fd,&statbuf);
//    train.length = sizeof(statbuf.st_size);
//    memcpy(train.data,&statbuf.st_size,train.length);
//    send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
//    ftruncate(fd,statbuf.st_size);
//    char *p = (char *)mmap(NULL,statbuf.st_size,PROT_READ|PROT_WRITE,MAP_SHARED,fd,0);
//    off_t totalsize = 0;
//    while(totalsize < statbuf.st_size){
//        if(statbuf.st_size - totalsize > (long )sizeof(train.data)){
//            train.length = sizeof(train.data);
//        }
//        else{
//            train.length = statbuf.st_size - totalsize;
//        }
//        send(netfd,&train.length,sizeof(train.length),MSG_NOSIGNAL);
//        send(netfd,p+totalsize,train.length,MSG_NOSIGNAL);
//        totalsize += train.length;
//    }
//    train.length = 0;
//    send(netfd,&train.length,sizeof(train.length),MSG_NOSIGNAL);
//    munmap(p,statbuf.st_size);
//    close(fd);
//    return 0;
//}
// 版本4 使用大火车
int transFile(int netfd){
    train_t train;
    train.length = 5;
    memcpy(train.data,"file1",5);
    send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
    int fd = open("file1",O_RDWR);
    struct stat statbuf;
    fstat(fd,&statbuf);
    train.length = sizeof(statbuf.st_size);
    memcpy(train.data,&statbuf.st_size,train.length);
    send(netfd,&train,sizeof(train.length)+train.length,MSG_NOSIGNAL);
   // ftruncate(fd,statbuf.st_size);
   // char *p = (char *)mmap(NULL,statbuf.st_size,PROT_READ|PROT_WRITE,MAP_SHARED,fd,0);
   // send(netfd,p,statbuf.st_size,MSG_NOSIGNAL);
   // munmap(p,statbuf.st_size);
    sleep(20);
    sendfile(netfd,fd,NULL,statbuf.st_size);
    close(fd);
    return 0;
}