1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
#include <stdlib.h>
#include <stdio.h>
#include "agent.h"
#include "session.h"
#include <tapi-device.h>
struct session
{
struct agent *agents[2];
struct tapi_device *tdev;
void (*release)(struct session *);
int link;
};
struct session *session_alloc(struct tapi_device *dev, struct agent *caller,
struct agent *callee, void (*release)(struct session *))
{
struct session *session;
int ret;
session = malloc(sizeof(*session));
session->tdev = dev;
session->agents[0] = caller;
session->agents[1] = callee;
ret = agent_invite(callee, session);
if (ret < 0) {
session_hangup(session, callee);
free(session);
return NULL;
}
session->release = release;
return session;
}
void session_accept(struct session *session, struct agent *agent)
{
int ep[2];
printf("session_accept: %p %p\n", session, agent);
printf("session agents: %p %p\n", session->agents[0], session->agents[1]);
printf("session tdev: %p\n", session->tdev);
agent_accept(session->agents[0], session);
ep[0] = agent_get_endpoint(session->agents[0], session);
ep[1] = agent_get_endpoint(session->agents[1], session);
session->link = tapi_link_alloc(session->tdev, ep[0], ep[1]);
printf("eps: %d %d\n", ep[0], ep[1]);
tapi_link_enable(session->tdev, session->link);
tapi_sync(session->tdev);
}
void session_hangup(struct session *session, struct agent *agent)
{
struct agent *other_agent;
if (session->agents[0] == agent)
other_agent = session->agents[1];
else
other_agent = session->agents[0];
agent_hangup(other_agent, session);
tapi_link_disable(session->tdev, session->link);
tapi_link_free(session->tdev, session->link);
tapi_sync(session->tdev);
if (session->release)
session->release(session);
}
|
