RPC.h 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. #ifndef __RPCLIB_H_
  2. #define __RPCLIB_H_
  3. #define IDX_PID 0
  4. #define IDX_TID sizeof(pid_t)
  5. #define IDX_COUNT IDX_TID + sizeof(pid_t)
  6. #define IDX_TIME IDX_COUNT + sizeof(int)
  7. #define IDX_PAYLOAD IDX_TIME + 20 /* 20 being the length of the timestamp string */
  8. #define BUF_SZ 256
  9. #define PAYLOAD_SZ 223 /* BUF_SZ-IDX_PAYLOAD */
  10. #define ERR_OK 0
  11. /* RPC codes */
  12. #define RPC_UNDEFINED 0
  13. #define RPC_CONNECT 1
  14. #define RPC_CONNECT_SOCKARG 2
  15. #define RPC_CLOSE 3
  16. #define RPC_READ 4
  17. #define RPC_WRITE 5
  18. #define RPC_BIND 6
  19. #define RPC_ACCEPT 7
  20. #define RPC_LISTEN 8
  21. #define RPC_SOCKET 9
  22. #define RPC_SHUTDOWN 10
  23. #define RPC_GETSOCKNAME 11
  24. /* Administration RPC codes */
  25. #define RPC_MAP 20 /* Give the service the value we "see" for the new buffer fd */
  26. #define RPC_MAP_REQ 21 /* A call to determine whether an fd is mapped to the service */
  27. #define RPC_RETVAL 22 /* not RPC per se, but something we should codify */
  28. #define RPC_KILL_INTERCEPT 23 /* Tells the service we need to shut down all connections */
  29. #ifdef __cplusplus
  30. extern "C" {
  31. #endif
  32. void rpc_mutex_destroy();
  33. void rpc_mutex_init();
  34. int get_retval(int);
  35. int get_new_fd(int);
  36. int rpc_join(const char * sockname);
  37. int rpc_send_command(int cmd, int rpc_sock, void *data, int len);
  38. ssize_t sock_fd_write(int sock, int fd);
  39. ssize_t sock_fd_read(int sock, void *buf, ssize_t bufsize, int *fd);
  40. /* Structures used for sending commands via RPC mechanism */
  41. struct bind_st {
  42. int sockfd;
  43. struct sockaddr_storage addr;
  44. socklen_t addrlen;
  45. int __tid;
  46. };
  47. struct connect_st {
  48. int __fd;
  49. struct sockaddr_storage __addr;
  50. socklen_t __len;
  51. int __tid;
  52. };
  53. struct close_st {
  54. int fd;
  55. };
  56. struct listen_st {
  57. int sockfd;
  58. int backlog;
  59. int __tid;
  60. };
  61. struct socket_st {
  62. int socket_family;
  63. int socket_type;
  64. int protocol;
  65. int __tid;
  66. };
  67. struct accept_st {
  68. int sockfd;
  69. struct sockaddr_storage addr;
  70. socklen_t addrlen;
  71. int __tid;
  72. };
  73. struct shutdown_st {
  74. int socket;
  75. int how;
  76. };
  77. struct getsockname_st {
  78. int sockfd;
  79. struct sockaddr_storage addr;
  80. socklen_t addrlen;
  81. };
  82. #ifdef __cplusplus
  83. }
  84. #endif
  85. #endif