diff options
Diffstat (limited to 'netcon/RPC.h')
| -rw-r--r-- | netcon/RPC.h | 124 |
1 files changed, 124 insertions, 0 deletions
diff --git a/netcon/RPC.h b/netcon/RPC.h new file mode 100644 index 00000000..35387a8f --- /dev/null +++ b/netcon/RPC.h @@ -0,0 +1,124 @@ +#ifndef __RPCLIB_H_ +#define __RPCLIB_H_ + +#include <stdint.h> + +#define CANARY_SIZE sizeof(uint64_t) +#define CANARY_PADDING_SIZE 12 +#define TOKEN_SIZE CANARY_SIZE+CANARY_PADDING_SIZE + +#define RPC_PHRASE "zerotier\0" +#define RPC_PHRASE_SIZE 9 +// 1st RPC section (metdata) +#define IDX_SIGNAL_PHRASE 0 +#define IDX_PID IDX_SIGNAL_PHRASE + RPC_PHRASE_SIZE +#define IDX_TID sizeof(pid_t) + IDX_PID +#define IDX_COUNT IDX_TID + sizeof(pid_t) +#define IDX_TIME IDX_COUNT + sizeof(int) +#define IDX_PAYLOAD IDX_TIME + 20 /* 20 being the length of the timestamp string */ +// 2nd RPC section (payload and canary) +#define CMD_ID_IDX 0 +#define CANARY_IDX 1 +#define STRUCT_IDX CANARY_IDX+CANARY_SIZE + +#define BUF_SZ 256 +#define PAYLOAD_SZ 223 /* BUF_SZ-IDX_PAYLOAD */ + +#define ERR_OK 0 + +/* RPC codes */ +#define RPC_UNDEFINED 0 +#define RPC_CONNECT 1 +#define RPC_CONNECT_SOCKARG 2 +#define RPC_CLOSE 3 +#define RPC_READ 4 +#define RPC_WRITE 5 +#define RPC_BIND 6 +#define RPC_ACCEPT 7 +#define RPC_LISTEN 8 +#define RPC_SOCKET 9 +#define RPC_SHUTDOWN 10 +#define RPC_GETSOCKNAME 11 + +/* Administration RPC codes */ +#define RPC_MAP 20 /* Give the service the value we "see" for the new buffer fd */ +#define RPC_MAP_REQ 21 /* A call to determine whether an fd is mapped to the service */ +#define RPC_RETVAL 22 /* not RPC per se, but something we should codify */ +#define RPC_KILL_INTERCEPT 23 /* Tells the service we need to shut down all connections */ + + +#ifdef __cplusplus +extern "C" { +#endif + +int get_retval(int); + +//#ifdef NETCON_INTERCEPT +int rpc_join(const char * sockname); +int rpc_send_command(char *path, int cmd, int forfd, void *data, int len); +//#endif + +int get_new_fd(int sock); +ssize_t sock_fd_write(int sock, int fd); +ssize_t sock_fd_read(int sock, void *buf, ssize_t bufsize, int *fd); + +void rpc_mutex_destroy(); +void rpc_mutex_init(); + + +/* Structures used for sending commands via RPC mechanism */ + +struct bind_st { + int sockfd; + struct sockaddr_storage addr; + socklen_t addrlen; + int __tid; +}; + +struct connect_st { + int __fd; + struct sockaddr_storage __addr; + socklen_t __len; + int __tid; +}; + +struct close_st { + int fd; +}; + +struct listen_st { + int sockfd; + int backlog; + int __tid; +}; + +struct socket_st { + int socket_family; + int socket_type; + int protocol; + int __tid; +}; + +struct accept_st { + int sockfd; + struct sockaddr_storage addr; + socklen_t addrlen; + int __tid; +}; + +struct shutdown_st { + int socket; + int how; +}; + +struct getsockname_st { + int sockfd; + struct sockaddr_storage addr; + socklen_t addrlen; +}; + +#ifdef __cplusplus +} +#endif + +#endif
\ No newline at end of file |