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
|
#ifndef _T38_H_
#define _T38_H_
struct t38_gateway;
struct t38_options {
int version;
int fec_span; // 1 means no FEC
int min_ec_entries; // currently ignored
int max_ec_entries;
int max_ifp;
int max_datagram;
unsigned int local_tcf:1;
unsigned int fill_bit_removal:1;
unsigned int transcoding_mmr:1;
unsigned int transcoding_jbig:1;
unsigned int no_ecm:1;
unsigned int no_v17:1;
unsigned int no_v27ter:1;
unsigned int no_v29:1;
unsigned int no_v34:1;
unsigned int no_iaf:1;
};
#ifdef WITH_TRANSCODING
#include <inttypes.h>
#include <sys/types.h>
#include <stdbool.h>
#include <spandsp/telephony.h>
#include <spandsp/logging.h>
#include <spandsp/t38_core.h>
#include <spandsp/t38_gateway.h>
#include "rtplib.h"
#include "helpers.h"
#include "obj.h"
#include "codeclib.h"
#include "types.h"
struct call_media;
struct media_packet;
struct media_player;
struct t38_gateway {
struct obj obj; // use refcount as this struct is shared between two medias
mutex_t lock;
struct call_media *t38_media;
struct call_media *pcm_media;
rtp_payload_type pcm_pt; // PCM input for spandsp
t38_gateway_state_t *gw;
struct t38_options options;
// udptl outgoing stuff
uint16_t seqnum;
GQueue udptl_ec_out; // seq, seq-1, seq-2, ...
// udptl incoming stuff
packet_sequencer_t sequencer;
GHashTable *udptl_fec;
// player for PCM data
struct media_player *pcm_player;
unsigned long long pts;
// to handle PCM fill-in
int64_t last_rx_ts;
};
void t38_init(void);
int t38_gateway_pair(struct call_media *t38_media, struct call_media *pcm_media, const struct t38_options *);
void t38_gateway_start(struct t38_gateway *, str_case_value_ht codec_set);
int t38_gateway_input_samples(struct t38_gateway *, int16_t amp[], int len);
int t38_gateway_input_udptl(struct t38_gateway *, const str *);
void t38_gateway_stop(struct t38_gateway *);
INLINE void t38_gateway_put(struct t38_gateway **tp) {
if (!tp || !*tp)
return;
obj_put(*tp);
*tp = NULL;
}
#else
#include "compat.h"
// stubs
INLINE void t38_init(void) { }
INLINE void t38_gateway_start(struct t38_gateway *tg, str_case_value_ht codec_set) { }
INLINE void t38_gateway_stop(struct t38_gateway *tg) { }
INLINE void t38_gateway_put(struct t38_gateway **tp) { }
#endif
#endif
|
