105 lines
2.3 KiB
C
105 lines
2.3 KiB
C
|
|
#include <stdbool.h>
|
|
#include <stdio.h>
|
|
#include <tapi-port.h>
|
|
|
|
#include "session.h"
|
|
#include "agent.h"
|
|
#include "tapi_agent.h"
|
|
|
|
static int tapi_agent_invite(struct agent *agent, struct session *session)
|
|
{
|
|
struct tapi_agent *tagent = agent_to_tapi_agent(agent);
|
|
|
|
if (tagent->session)
|
|
return -1;
|
|
|
|
tagent->state = TAPI_AGENT_STATE_RINGING;
|
|
tapi_port_set_ring(&tagent->port, true);
|
|
|
|
tagent->session = session;
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int tapi_agent_accept(struct agent *agent, struct session *session)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
static int tapi_agent_hangup(struct agent *agent, struct session *session)
|
|
{
|
|
struct tapi_agent *tagent = agent_to_tapi_agent(agent);
|
|
|
|
switch (tagent->state) {
|
|
case TAPI_AGENT_STATE_RINGING:
|
|
tapi_port_set_ring(&tagent->port, false);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
tagent->state = TAPI_AGENT_STATE_IDLE;
|
|
tagent->session = NULL;
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int tapi_agent_get_endpoint(struct agent *agent, struct session *session)
|
|
{
|
|
struct tapi_agent *tagent = agent_to_tapi_agent(agent);
|
|
return tapi_port_get_endpoint(&tagent->port);
|
|
}
|
|
|
|
static const struct agent_ops tapi_agent_ops = {
|
|
.invite = tapi_agent_invite,
|
|
.accept = tapi_agent_accept,
|
|
.hangup = tapi_agent_hangup,
|
|
.get_endpoint = tapi_agent_get_endpoint,
|
|
};
|
|
|
|
static void tapi_agent_event(struct tapi_port *port, struct tapi_event *event,
|
|
void *data)
|
|
{
|
|
struct tapi_agent *tagent = data;
|
|
|
|
if (event->type != TAPI_EVENT_TYPE_HOOK)
|
|
return;
|
|
|
|
if (!tagent->session)
|
|
return;
|
|
|
|
if (event->hook.on) {
|
|
session_hangup(tagent->session, &tagent->agent);
|
|
tagent->state = TAPI_AGENT_STATE_IDLE;
|
|
tagent->session = NULL;
|
|
} else {
|
|
session_accept(tagent->session, &tagent->agent);
|
|
tagent->state = TAPI_AGENT_STATE_ACTIVE;
|
|
}
|
|
}
|
|
|
|
void tapi_agent_init(struct tapi_device *tdev, int port, struct tapi_agent *tagent)
|
|
{
|
|
int ret;
|
|
|
|
tagent->agent.ops = &tapi_agent_ops;
|
|
tagent->state = TAPI_AGENT_STATE_IDLE;
|
|
tagent->session = NULL;
|
|
|
|
ret = tapi_port_open(tdev, port, &tagent->port);
|
|
if (ret) {
|
|
printf("Failed to open tapi port %d: %d\n", port, ret);
|
|
return;
|
|
}
|
|
|
|
tagent->event_listener.callback = tapi_agent_event;
|
|
tagent->event_listener.data = tagent;
|
|
|
|
tapi_port_register_event(&tagent->port, &tagent->event_listener);
|
|
}
|
|
|
|
void tapi_agent_free(struct tapi_agent *tagent)
|
|
{
|
|
tapi_port_unregister_event(&tagent->port, &tagent->event_listener);
|
|
}
|