#ifndef IPC_MSG_H  
#define IPC_MSG_H  
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <unistd.h>

#ifdef __cplusplus 
extern "C" { 
#endif


#define UNIX_DOMAIN "/tmp/UNIX.domain"
#define errExit(msg)    do { perror(msg); exit(EXIT_FAILURE); \
} while (0)

#define MAX_LEN  4096
#define GET_MEMFD_MSG "basic_get_memfd"
#define GET_DATA_MSG "basic_get_data"
#define GET_CUSTOM_MSG "basic_get_custom"

#define offsetof(TYPE, MEMBER) ((size_t) &((TYPE *)0)->MEMBER)

#define container_of(ptr, type, member) ({\
const typeof(((type *)0)->member) * __mptr = (ptr);\
(type *)((char *)__mptr - offsetof(type, member)); }

typedef struct memfd_data {
  pid_t pid;
  int memfd;
  void * data;
  int len;
} memfd_data_st;

struct user_data
{
  int fd;
  unsigned int n_size;
  char line[MAX_LEN];
};

typedef int (*wfunc)(struct user_data*, void *arg, int len);
typedef struct arg_struct {
    wfunc wfunc;
    void * args;
    int len;
}args_data_st;

typedef struct custom_data{
    int memfd;
    void * data;
    int len;
}st_custom_data;


#define READ_THREAD_NUM  2
#define WRITE_THREAD_NUM 2

int file_exists(char *filename);
int proc_msg(struct user_data* rdata, void * arg, int len);
int basic_create_ipc_server(char * unix_domain_path, args_data_st * pargs_data_st);
int basic_create_ipc_client(char * unix_domain_path, char * send_buf, int send_len, void ** pptr_recv_buf, int *ptr_recv_len);

int  send_fd_sendmsg(int  fd, memfd_data_st** ppmemfd_data);

/**
 * @brief 发送目标文件描述符
 * @param fd		传递信息的 UNIX 域 文件描述符
 * @param fd_to_send	待发送的文件描述符
 */
int  send_fd_args_sendmsg(int  fd, int fd_to_send, pid_t pid, void **ppdata, int len);

/**
 * @brief 接受文件描述符
 * @param fd 传递信息的 UNIX 域 文件描述符
 */
int recv_fd_recvmsg(int  fd, memfd_data_st** ppmemfd_data);

#ifdef __cplusplus 
} 
#endif
#endif