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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
/*
* openser osp module.
*
* This module enables openser to communicate with an Open Settlement
* Protocol (OSP) server. The Open Settlement Protocol is an ETSI
* defined standard for Inter-Domain VoIP pricing, authorization
* and usage exchange. The technical specifications for OSP
* (ETSI TS 101 321 V4.1.1) are available at www.etsi.org.
*
* Uli Abend was the original contributor to this module.
*
* Copyright (C) 2001-2005 Fhg Fokus
*
* This file is part of openser, a free SIP server.
*
* openser is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version
*
* openser is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* History:
* ---------
* 2006-03-13 TM functions are loaded via API function (bogdan)
*/
#include "tm.h"
#include "destination.h"
#include "usage.h"
#include "../tm/tm_load.h"
static struct tm_binds osp_tmb;
static void onreq( struct cell* t, int type, struct tmcb_params *ps );
static void tmcb_func( struct cell* t, int type, struct tmcb_params *ps );
int mod_init_tm()
{
LOG(L_INFO, "osp/tm - initializing\n");
if (load_tm_api(&osp_tmb)!=0) {
LOG(L_ERR, "ERROR:osp:mod_init_tm: can't load TM API\n");
LOG(L_ERR,"ERROR:osp:mod_init_tm: tm is required for reporting "
"call set up usage info\n");
return -1;
}
/* register callbacks*/
/* listen for all incoming requests */
if ( osp_tmb.register_tmcb( 0, 0, TMCB_REQUEST_IN, onreq, 0 ) <=0 ) {
LOG(L_ERR,"ERROR:osp:mod_init_tm: cannot register TMCB_REQUEST_IN "
"callback\n");
LOG(L_ERR,"ERROR:osp:mod_init_tm: tm callbacks are required for "
"reporting call set up usage info\n");
return -1;
}
return 0;
}
static void onreq( struct cell* t, int type, struct tmcb_params *ps )
{
int tmcb_types;
DBG("osp: onreq: Registering transaction call backs\n\n");
/* install addaitional handlers */
tmcb_types =
//TMCB_REQUEST_FWDED |
//TMCB_RESPONSE_FWDED |
TMCB_ON_FAILURE |
//TMCB_LOCAL_COMPLETED |
/* report on completed transactions */
TMCB_RESPONSE_OUT |
/* account e2e acks if configured to do so */
TMCB_E2EACK_IN |
/* report on missed calls */
TMCB_ON_FAILURE_RO //|
/* get incoming replies ready for processing */
//TMCB_RESPONSE_IN
;
if (osp_tmb.register_tmcb( 0, t, tmcb_types, tmcb_func, 0 )<=0) {
LOG(L_ERR,"ERROR:osp:onreq: cannot register for tm callbacks\n");
LOG(L_ERR,"ERROR:osp:onreq: tm callbacks are required for reporting "
"call set up usage info\n");
return;
}
/* also, if that is INVITE, disallow silent t-drop */
if (ps->req->REQ_METHOD==METHOD_INVITE) {
DBG("DEBUG: noisy_timer set for accounting\n");
t->flags |= T_NOISY_CTIMER_FLAG;
}
}
static void tmcb_func( struct cell* t, int type, struct tmcb_params *ps )
{
if (type&TMCB_RESPONSE_OUT) {
DBG("osp:tmcb: on-RESPONSE_OUT-out\n");
} else if (type&TMCB_E2EACK_IN) {
DBG("osp:tmcb: on-E2EACK_IN\n");
} else if (type&TMCB_ON_FAILURE_RO) {
DBG("osp:tmcb: on-FAILURE_RO\n");
} else if (type&TMCB_RESPONSE_IN) {
DBG("osp:tmcb: on-RESPONSE_IN\n");
} else if (type&TMCB_REQUEST_FWDED) {
DBG("osp:tmcb: on-REQUEST_FWDED\n");
} else if (type&TMCB_RESPONSE_FWDED) {
DBG("osp:tmcb: on-RESPONSE_FWDED\n");
} else if (type&TMCB_ON_FAILURE) {
DBG("osp:tmcb: on-FAILURE\n");
} else if (type&TMCB_LOCAL_COMPLETED) {
DBG("osp:tmcb: on-COMPLETED\n");
} else {
DBG("osp:tmcb: on-something-else: %d\n",type);
}
if (t) {
recordEvent(t->uac[t->first_branch].last_received,t->uas.status);
} else {
DBG("osp:tmcb: cell is empty\n");
}
}
|
