#include <cstring>
#include <stdio.h>
#include <unistd.h>

#include <sys/types.h>
#include <sys/stat.h>

#include "src2/shmh.h"

#include <chrono>

int main(int argc, char const *argv[])
{
    int sock = unix_domain_client_fd("/tmp/memfd_shm.sock", 0);
    if (sock <= 0){
        printf("unix_domain_client_fd failed\n");
        return -1;
    }

    int count = 0;

    using namespace std::chrono;
    auto s = steady_clock::now();
    auto e = s;

    while (true) {

        int recvfds[16];
        memset(recvfds, 0, sizeof(int)*16);
        int fd = recvfd(sock, recvfds, 16);
        if (fd < 0){
            printf("memfd %d no exist\n", fd);
            continue;
        }
        // struct stat st;
        // if (fstat (fd, &st))
        // {
        //     return -1;
        // }
        // printf("st size %ld\n", st.st_size);

        count++;

        unsigned char* addr;
        int len = basic_shm_mmap(recvfds[0], &addr);
        if (len <= 0) break;
        printf("======>> mmap len %d msg %s\n", len, addr);
        basic_shm_unmmap(fd, &addr);
        for (int i = 0; i < 16; i++) {
            close(recvfds[i]);
        }
        usleep(20000);

        // e = steady_clock::now();
        // if (duration_cast<milliseconds>(e-s).count() > 1000){
        //     s = e;
        //     printf("======>> around 1 s recv count %d\n", count);
        //     _exit(0);
        //     count = 0;
        // }
    }

    close(sock);

    return 0;
}