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
|
// $Id: gssm_sink.h,v 1.2 2007-07-07 16:31:42 jl Exp $
#pragma once
#include <linux/if_ether.h>
#include <gr_sync_block.h>
#include <gri_mmse_fir_interpolator.h>
#include "gssm_state.h"
class gssm_sink;
typedef boost::shared_ptr<gssm_sink> gssm_sink_sptr;
gssm_sink_sptr gssm_make_sink(double);
class gssm_sink : public gr_sync_block {
public:
~gssm_sink(void);
int work(int nitems, gr_vector_const_void_star &input_items,
gr_vector_void_star &output_items);
private:
// sample speeds
double d_sps; // samples per second
double d_samples_per_symbol;
// M&M clock recovery
gri_mmse_fir_interpolator *d_interp;
double d_mu;
double d_gain_mu;
double d_omega;
double d_gain_omega;
double d_omega_relative_limit;
double d_max_omega;
double d_min_omega;
float d_last_sample;
double d_mu_bak;
double d_omega_bak;
double d_last_sample_bak;
int d_bitno;
// buffers
gr_buffer_sptr d_buf_qd;
gr_buffer_reader_sptr d_qd_reader;
gr_buffer_sptr d_buf_mm;
gr_buffer_reader_sptr d_mm_reader;
// quad demod
gr_complex d_qd_last;
double d_qd_gain;
// GSM BTS timing
int d_tn; // time slot
int d_fn; // frame number
int d_fnm51; // frame number mod 51
int d_fnm102; // frame number mod 102
int d_bsic; // current bsic
// program state
gssm_state_t d_state;
// buffer to hold physical data
unsigned char * d_phy_buf;
int * d_phy_ind;
// Wireshark interface
int d_tunfd; // TUN fd
unsigned char d_ether_addr[ETH_ALEN];
/*******************************************************************/
friend gssm_sink_sptr gssm_make_sink(double);
gssm_sink(double);
int search_state_fc(const float *, int);
int search_state_s(const float *, int);
int search_state_data(const float *, int);
void search_sch(const unsigned char *);
int handle_sch(const unsigned char *, int *, int *);
void next_timeslot(void);
int check_logical_channel(int, int, int, int);
void check_logical_channels(void);
int mm_demod(const float *, int, float *, int &);
int quad_demod(const gr_complex *, int, float *, int &);
int process_input(const gr_complex *, int);
int process_qd(const gr_complex *, int);
void save_clock();
void restore_clock();
void reset_clock();
void flush_buffers();
void reset_state();
/*******************************************************************/
// Debug
int check_num_invalid_s();
public:
int d_search_fc_count,
d_found_fc_count,
d_valid_s,
d_invalid_s,
d_invalid_s_1,
d_valid_bcch,
d_invalid_bcch,
d_valid_ia,
d_invalid_ia,
d_valid_sdcch4,
d_invalid_sdcch4,
d_valid_sacchc4,
d_invalid_sacchc4,
d_valid_sdcch8,
d_invalid_sdcch8,
d_valid_sacchc8,
d_invalid_sacchc8;
void stats();
};
|
