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
|
#ifndef _OSMUX_H_
#define _OSMUX_H_
/* OSmux header:
*
* ft (4 bits): 0=signalling, 1=voice (AMR-CMR)
* amr_cmr (4 bits): see cmr field in AMR header (RFC3267)
* circuit_id (8 bits): simplified version of RTP SSRC
* seq (8-bits): combination of RTP timestamp and seq. number
* amr_f (1-bits): AMR f bit (RFC3267)
* amr_ft (4-bits): AMR ft bit (RFC3267)
* amr_q (1-bits): AMR q bit (RFC3267)
* rtp_marker (1 bits): RTP marker
*/
#define OSMUX_FT_SIGNAL 0
#define OSMUX_FT_VOICE_AMR 1
struct osmux_hdr {
#if __BYTE_ORDER == __BIG_ENDIAN
uint8_t ft:3,
ctr:3,
amr_f:1,
amr_q:1;
#elif __BYTE_ORDER == __LITTLE_ENDIAN
uint8_t amr_q:1,
amr_f:1,
ctr:3,
ft:3;
#endif
uint8_t seq;
uint8_t circuit_id;
#if __BYTE_ORDER == __BIG_ENDIAN
uint8_t amr_ft:4,
amr_cmr:4;
#elif __BYTE_ORDER == __LITTLE_ENDIAN
uint8_t amr_cmr:4,
amr_ft:4;
#endif
} __attribute__((packed));
/* one to handle all existing RTP flows */
struct osmux_in_handle {
uint8_t osmux_seq;
uint8_t batch_factor;
void (*deliver)(struct msgb *msg);
char *data; /* internal data */
};
/* one per OSmux circuit_id, ie. one per RTP flow. */
struct osmux_out_handle {
uint16_t rtp_seq[8];
uint32_t rtp_timestamp[8];
};
static inline uint8_t *osmux_get_payload(struct osmux_hdr *osmuxh)
{
return (uint8_t *)osmuxh + sizeof(struct osmux_hdr);
}
void osmux_xfrm_input_init(struct osmux_in_handle *h);
int osmux_xfrm_input_get_ccid(struct osmux_in_handle *h, uint32_t ssrc);
void osmux_xfrm_input_register_ccid(struct osmux_in_handle *h, uint32_t ssrc);
int osmux_xfrm_input(struct osmux_in_handle *h, struct msgb *msg);
void osmux_xfrm_input_deliver(struct osmux_in_handle *h);
void osmux_xfrm_output_init(struct osmux_out_handle *h);
int osmux_xfrm_output(struct osmux_hdr *osmuxh, struct osmux_out_handle *h, struct llist_head *list);
struct osmux_hdr *osmux_xfrm_output_pull(struct msgb *msg);
void osmux_tx_sched(struct llist_head *list, void (*tx_cb)(struct msgb *msg, void *data), void *data);
#endif
|
