ktp_session.c 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. #include <stdlib.h>
  2. #include <stdio.h>
  3. #include <string.h>
  4. #include <assert.h>
  5. #include <unistd.h>
  6. #include <errno.h>
  7. #include <sys/types.h>
  8. #include <sys/stat.h>
  9. #include <fcntl.h>
  10. #include <sys/socket.h>
  11. #include <sys/un.h>
  12. #include <faux/str.h>
  13. #include <klish/ktp_session.h>
  14. typedef enum {
  15. KTP_SESSION_STATE_DISCONNECTED = 'd',
  16. KTP_SESSION_STATE_NOT_AUTHORIZED = 'a',
  17. KTP_SESSION_STATE_IDLE = 'i',
  18. KTP_SESSION_STATE_WAIT_FOR_COMPLETION = 'v',
  19. KTP_SESSION_STATE_WAIT_FOR_HELP = 'h',
  20. KTP_SESSION_STATE_WAIT_FOR_CMD = 'c',
  21. } ktp_session_state_e;
  22. struct ktp_session_s {
  23. ktp_session_state_e state;
  24. faux_net_t *net;
  25. };
  26. ktp_session_t *ktp_session_new(int sock)
  27. {
  28. ktp_session_t *session = NULL;
  29. if (sock < 0)
  30. return NULL;
  31. session = faux_zmalloc(sizeof(*session));
  32. assert(session);
  33. if (!session)
  34. return NULL;
  35. // Init
  36. session->state = KTP_SESSION_STATE_NOT_AUTHORIZED;
  37. session->net = faux_net_new();
  38. assert(session->net);
  39. faux_net_set_fd(session->net, sock);
  40. return session;
  41. }
  42. void ktp_session_free(ktp_session_t *session)
  43. {
  44. if (!session)
  45. return;
  46. faux_net_free(session->net);
  47. faux_free(session);
  48. }
  49. bool_t ktp_session_connected(ktp_session_t *session)
  50. {
  51. assert(session);
  52. if (!session)
  53. return BOOL_FALSE;
  54. if (KTP_SESSION_STATE_DISCONNECTED == session->state)
  55. return BOOL_FALSE;
  56. return BOOL_TRUE;
  57. }
  58. int ktp_session_fd(const ktp_session_t *session)
  59. {
  60. assert(session);
  61. if (!session)
  62. return BOOL_FALSE;
  63. return faux_net_get_fd(session->net);
  64. }
  65. #if 0
  66. static void ktp_session_bad_socket(ktp_session_t *session)
  67. {
  68. assert(session);
  69. if (!session)
  70. return;
  71. session->state = KTP_SESSION_STATE_DISCONNECTED;
  72. }
  73. #endif