svcsock.h 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. /*
  2. * linux/include/linux/sunrpc/svcsock.h
  3. *
  4. * RPC server socket I/O.
  5. *
  6. * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de>
  7. */
  8. #ifndef SUNRPC_SVCSOCK_H
  9. #define SUNRPC_SVCSOCK_H
  10. #include <linux/sunrpc/svc.h>
  11. /*
  12. * RPC server socket.
  13. */
  14. struct svc_sock {
  15. struct list_head sk_ready; /* list of ready sockets */
  16. struct list_head sk_list; /* list of all sockets */
  17. struct socket * sk_sock; /* berkeley socket layer */
  18. struct sock * sk_sk; /* INET layer */
  19. struct svc_pool * sk_pool; /* current pool iff queued */
  20. struct svc_serv * sk_server; /* service for this socket */
  21. atomic_t sk_inuse; /* use count */
  22. unsigned long sk_flags;
  23. #define SK_BUSY 0 /* enqueued/receiving */
  24. #define SK_CONN 1 /* conn pending */
  25. #define SK_CLOSE 2 /* dead or dying */
  26. #define SK_DATA 3 /* data pending */
  27. #define SK_TEMP 4 /* temp (TCP) socket */
  28. #define SK_DEAD 6 /* socket closed */
  29. #define SK_CHNGBUF 7 /* need to change snd/rcv buffer sizes */
  30. #define SK_DEFERRED 8 /* request on sk_deferred */
  31. #define SK_OLD 9 /* used for temp socket aging mark+sweep */
  32. #define SK_DETACHED 10 /* detached from tempsocks list */
  33. atomic_t sk_reserved; /* space on outq that is reserved */
  34. spinlock_t sk_defer_lock; /* protects sk_deferred */
  35. struct list_head sk_deferred; /* deferred requests that need to
  36. * be revisted */
  37. struct mutex sk_mutex; /* to serialize sending data */
  38. int (*sk_recvfrom)(struct svc_rqst *rqstp);
  39. int (*sk_sendto)(struct svc_rqst *rqstp);
  40. /* We keep the old state_change and data_ready CB's here */
  41. void (*sk_ostate)(struct sock *);
  42. void (*sk_odata)(struct sock *, int bytes);
  43. void (*sk_owspace)(struct sock *);
  44. /* private TCP part */
  45. int sk_reclen; /* length of record */
  46. int sk_tcplen; /* current read length */
  47. time_t sk_lastrecv; /* time of last received request */
  48. /* cache of various info for TCP sockets */
  49. void *sk_info_authunix;
  50. struct sockaddr_storage sk_remote; /* remote peer's address */
  51. int sk_remotelen; /* length of address */
  52. };
  53. /*
  54. * Function prototypes.
  55. */
  56. int svc_makesock(struct svc_serv *, int, unsigned short, int flags);
  57. void svc_force_close_socket(struct svc_sock *);
  58. int svc_recv(struct svc_rqst *, long);
  59. int svc_send(struct svc_rqst *);
  60. void svc_drop(struct svc_rqst *);
  61. void svc_sock_update_bufs(struct svc_serv *serv);
  62. int svc_sock_names(char *buf, struct svc_serv *serv, char *toclose);
  63. int svc_addsock(struct svc_serv *serv,
  64. int fd,
  65. char *name_return,
  66. int *proto);
  67. /*
  68. * svc_makesock socket characteristics
  69. */
  70. #define SVC_SOCK_DEFAULTS (0U)
  71. #define SVC_SOCK_ANONYMOUS (1U << 0) /* don't register with pmap */
  72. #define SVC_SOCK_TEMPORARY (1U << 1) /* flag socket as temporary */
  73. #endif /* SUNRPC_SVCSOCK_H */