package/tapi_sip/src/tapi_agent.c

   1
   2 #include <stdbool.h>
   3 #include <stdio.h>
   4 #include <tapi-port.h>
   5
   6 #include "session.h"
   7 #include "agent.h"
   8 #include "tapi_agent.h"
   9
  10 static int tapi_agent_invite(struct agent *agent, struct session *session)
  11 {
  12         struct tapi_agent *tagent = agent_to_tapi_agent(agent);
  13
  14         if (tagent->session)
  15                 return -1;
  16
  17         tagent->state = TAPI_AGENT_STATE_RINGING;
  18         tapi_port_set_ring(&tagent->port, true);
  19
  20         tagent->session = session;
  21
  22         return 0;
  23 }
  24
  25 static int tapi_agent_accept(struct agent *agent, struct session *session)
  26 {
  27         return 0;
  28 }
  29
  30 static int tapi_agent_hangup(struct agent *agent, struct session *session)
  31 {
  32         struct tapi_agent *tagent = agent_to_tapi_agent(agent);
  33
  34         switch (tagent->state) {
  35         case TAPI_AGENT_STATE_RINGING:
  36                 tapi_port_set_ring(&tagent->port, false);
  37                 break;
  38         default:
  39                 break;
  40         }
  41
  42         tagent->state = TAPI_AGENT_STATE_IDLE;
  43         tagent->session = NULL;
  44
  45         return 0;
  46 }
  47
  48 static int tapi_agent_get_endpoint(struct agent *agent, struct session *session)
  49 {
  50         struct tapi_agent *tagent = agent_to_tapi_agent(agent);
  51         return tapi_port_get_endpoint(&tagent->port);
  52 }
  53
  54 static const struct agent_ops tapi_agent_ops = {
  55         .invite = tapi_agent_invite,
  56         .accept = tapi_agent_accept,
  57         .hangup = tapi_agent_hangup,
  58         .get_endpoint = tapi_agent_get_endpoint,
  59 };
  60
  61 static void tapi_agent_event(struct tapi_port *port, struct tapi_event *event,
  62         void *data)
  63 {
  64         struct tapi_agent *tagent = data;
  65
  66         if (event->type != TAPI_EVENT_TYPE_HOOK)
  67                 return;
  68
  69         if (!tagent->session)
  70                 return;
  71
  72         if (event->hook.on) {
  73                 session_hangup(tagent->session, &tagent->agent);
  74                 tagent->state = TAPI_AGENT_STATE_IDLE;
  75                 tagent->session = NULL;
  76         } else {
  77                 session_accept(tagent->session, &tagent->agent);
  78                 tagent->state = TAPI_AGENT_STATE_ACTIVE;
  79         }
  80 }
  81
  82 void tapi_agent_init(struct tapi_device *tdev, int port, struct tapi_agent *tagent)
  83 {
  84         int ret;
  85
  86         tagent->agent.ops = &tapi_agent_ops;
  87         tagent->state = TAPI_AGENT_STATE_IDLE;
  88         tagent->session = NULL;
  89
  90         ret = tapi_port_open(tdev, port, &tagent->port);
  91         if (ret) {
  92                 printf("Failed to open tapi port %d: %d\n", port, ret);
  93                 return;
  94         }
  95
  96         tagent->event_listener.callback = tapi_agent_event;
  97         tagent->event_listener.data = tagent;
  98
  99         tapi_port_register_event(&tagent->port, &tagent->event_listener);
 100 }
 101
 102 void tapi_agent_free(struct tapi_agent *tagent)
 103 {
 104         tapi_port_unregister_event(&tagent->port, &tagent->event_listener);
 105 }