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 _OSMOCOM_LAPDM_H
#define _OSMOCOM_LAPDM_H
#include <stdint.h>
#include <osmocom/core/timer.h>
#include <osmocom/core/msgb.h>
#include <l1ctl_proto.h>
enum lapdm_state {
LAPDm_STATE_NULL = 0,
LAPDm_STATE_IDLE,
LAPDm_STATE_SABM_SENT,
LAPDm_STATE_MF_EST,
LAPDm_STATE_TIMER_RECOV,
LAPDm_STATE_DISC_SENT,
};
struct lapdm_entity;
struct osmocom_ms;
struct lapdm_msg_ctx {
struct lapdm_datalink *dl;
int lapdm_fmt;
uint8_t n201;
uint8_t chan_nr;
uint8_t link_id;
uint8_t addr;
uint8_t ctrl;
uint8_t ta_ind;
uint8_t tx_power_ind;
};
/* TS 04.06 / Section 3.5.2 */
struct lapdm_datalink {
uint8_t V_send; /* seq nr of next I frame to be transmitted */
uint8_t V_ack; /* last frame ACKed by peer */
uint8_t N_send; /* ? set to V_send at Tx time*/
uint8_t V_recv; /* seq nr of next I frame expected to be received */
uint8_t N_recv; /* expected send seq nr of the next received I frame */
uint32_t state;
int seq_err_cond; /* condition of sequence error */
uint8_t own_busy, peer_busy;
struct timer_list t200;
uint8_t retrans_ctr;
struct llist_head send_queue; /* frames from L3 */
struct msgb *send_buffer; /* current frame transmitting */
int send_out; /* how much was sent from send_buffer */
uint8_t tx_hist[8][200]; /* tx history buffer */
int tx_length[8]; /* length in history buffer */
struct llist_head tx_queue; /* frames to L1 */
struct lapdm_msg_ctx mctx; /* context of established connection */
struct msgb *rcv_buffer; /* buffer to assemble the received message */
struct lapdm_entity *entity;
};
enum lapdm_dl_sapi {
DL_SAPI0 = 0,
DL_SAPI3 = 1,
_NR_DL_SAPI
};
struct lapdm_entity {
struct lapdm_datalink datalink[_NR_DL_SAPI];
int last_tx_dequeue; /* last entity that was dequeued */
int tx_pending; /* currently a pending frame not confirmed by L1 */
struct osmocom_ms *ms;
};
const char *get_rsl_name(int value);
extern const char *lapdm_state_names[];
/* initialize a LAPDm entity */
void lapdm_init(struct lapdm_entity *le, struct osmocom_ms *ms);
/* deinitialize a LAPDm entity */
void lapdm_exit(struct lapdm_entity *le);
/* input into layer2 (from layer 1) */
int l2_ph_data_ind(struct msgb *msg, struct lapdm_entity *le, struct l1ctl_info_dl *l1i);
int l2_ph_data_conf(struct msgb *msg, struct lapdm_entity *le);
/* L1 confirms channel request */
int l2_ph_chan_conf(struct msgb *msg, struct osmocom_ms *ms,
struct l1ctl_info_dl *dl);
/* input into layer2 (from layer 3) */
int rslms_recvmsg(struct msgb *msg, struct osmocom_ms *ms);
/* sending messages up from L2 to L3 */
int rslms_sendmsg(struct msgb *msg, struct osmocom_ms *ms);
typedef int (*osmol2_cb_t)(struct msgb *msg, struct osmocom_ms *ms);
/* register message handler for messages that are sent from L2->L3 */
int osmol2_register_handler(struct osmocom_ms *ms, osmol2_cb_t cb);
#endif /* _OSMOCOM_LAPDM_H */
|
