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
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
|
/* -*- c++ -*- */
/*
* Copyright 2008,2009 Free Software Foundation, Inc.
*
* This file is part of GNU Radio
*
* GNU Radio 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 3, or (at your option)
* any later version.
*
* GNU Radio 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.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <msdd6000.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#ifdef HAVE_ARPA_INET_H
#include <arpa/inet.h>
#endif
#ifdef HAVE_NETINET_IN_H
#include <netinet/in.h>
#endif
#ifdef HAVE_SYS_SOCKET_H
#include <sys/socket.h>
#endif
#define DEBUG(A) printf("=debug=> %s\n", A)
static void
optimize_socket(int socket);
/*
* Holds types that need autoconf help. They're here and not in the .h file because
* here we've got access to config.h
*/
class MSDD6000::detail {
public:
struct sockaddr_in d_sockaddr;
};
MSDD6000::MSDD6000(char* addr)
: d_detail(new MSDD6000::detail())
{
d_sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_IP);
optimize_socket(d_sock);
// set up remote sockaddr
// int s = inet_aton(addr, &d_adx);
d_detail->d_sockaddr.sin_family = AF_INET;
d_detail->d_sockaddr.sin_port = htons(10000);
int s = inet_aton(addr, &d_detail->d_sockaddr.sin_addr);
// set up local sockaddr
struct in_addr d_myadx;
struct sockaddr_in d_mysockaddr;
short int port = 10010;
d_myadx.s_addr = INADDR_ANY;
d_mysockaddr.sin_family = AF_INET;
d_mysockaddr.sin_port = htons(port);
memcpy(&d_mysockaddr.sin_addr.s_addr, &d_myadx.s_addr, sizeof(in_addr));
//d_sockaddr.sin_addr = INADDR_ANY;
s = bind(d_sock, (const sockaddr*) &d_mysockaddr, sizeof(d_mysockaddr));
// set default values
d_decim = 2;
d_ddc_gain = 2;
d_rf_attn = 0;
d_state = STATE_STOPPED;
}
MSDD6000::~MSDD6000()
{
// printf("MSDD6000::Destructing\n");
close(d_sock);
}
static void
optimize_socket(int socket){
#define BANDWIDTH 1000000000/8
#define DELAY 0.5
int ret;
int sock_buf_size = static_cast<int>(2*BANDWIDTH*DELAY);
char textbuf[512];
snprintf(textbuf, sizeof(textbuf), "%d", sock_buf_size);
printf("sock_buf_size = %d\n", sock_buf_size);
ret = setsockopt(socket, SOL_SOCKET, SO_SNDBUF,
&sock_buf_size, sizeof(sock_buf_size));
ret = setsockopt(socket, SOL_SOCKET, SO_RCVBUF,
&sock_buf_size, sizeof(sock_buf_size));
int uid = getuid();
if(uid!=0){
printf(" ****** COULD NOT OPTIMIZE SYSTEM NETWORK PARAMETERS BECAUSE YOU ARE NOT RUNNING AS ROOT *******\n ****** YOUR MSDD6000 RECIEVER PERFORMANCE IS GOING TO BE TERRIBLE *******\n");
return;
}
// SET UP SOME SYSTEM WIDE TCP SOCKET PARAMETERS
// FIXME seems like kind of a big hammer. Are you sure you need this?
FILE* fd = fopen("/proc/sys/net/core/netdev_max_backlog", "w");
if (fd){
fwrite("10000", 1, strlen("10000"), fd);
fclose(fd);
}
fd = fopen("/proc/sys/net/core/rmem_max", "w");
if (fd){
fwrite(textbuf, 1, strlen(textbuf), fd);
fclose(fd);
}
fd = fopen("/proc/sys/net/core/wmem_max", "w");
if (fd){
fwrite(textbuf, 1, strlen(textbuf), fd);
fclose(fd);
}
// just incase these were rejected before because of max sizes...
ret = setsockopt( socket, SOL_SOCKET, SO_SNDBUF,
(char *)&sock_buf_size, sizeof(sock_buf_size) );
ret = setsockopt( socket, SOL_SOCKET, SO_RCVBUF,
(char *)&sock_buf_size, sizeof(sock_buf_size) );
}
void MSDD6000::set_decim(int decim_pow2){
DEBUG("SETTING NEW DECIM");
d_decim = decim_pow2;
if(d_state==STATE_STARTED)
send_request(d_fc_mhz, d_rf_attn, d_ddc_gain, d_decim, d_offset_hz);
}
void MSDD6000::set_rf_attn(int attn){
DEBUG("SETTING NEW RF ATTN");
d_rf_attn = attn;
if(d_state==STATE_STARTED)
send_request(d_fc_mhz, d_rf_attn, d_ddc_gain, d_decim, d_offset_hz);
}
void MSDD6000::set_ddc_gain(int gain){
DEBUG("SETTING NEW DDC GAIN");
d_ddc_gain = gain;
if(d_state==STATE_STARTED)
send_request(d_fc_mhz, d_rf_attn, d_ddc_gain, d_decim, d_offset_hz);
}
void MSDD6000::set_fc(int center_mhz, int offset_hz){
DEBUG("SETTING NEW FC");
d_fc_mhz = center_mhz;
d_offset_hz = offset_hz;
if(d_state==STATE_STARTED)
send_request(d_fc_mhz, d_rf_attn, d_ddc_gain, d_decim, d_offset_hz);
}
void MSDD6000::start(){
send_request(d_fc_mhz, d_rf_attn, d_ddc_gain, d_decim, d_offset_hz);
d_state = STATE_STARTED;
}
void MSDD6000::stop(){
// new request with 0 decim tells it to halt
send_request(d_fc_mhz, d_rf_attn, d_ddc_gain, 0, d_offset_hz);
d_state = STATE_STOPPED;
}
void MSDD6000::send_request(float freq_mhz, float rf_attn, float ddc_gain, float ddc_dec, float ddc_offset_hz){
static char buff[512];
sprintf(buff, "%f %f %f %f %f\n",freq_mhz, rf_attn, ddc_gain, ddc_dec, ddc_offset_hz);
printf("sending: %s\n", buff);
int flags = 0;
sendto( d_sock, buff, strlen(buff)+1, flags,
(const sockaddr*)&(d_detail->d_sockaddr), sizeof(d_detail->d_sockaddr));
}
int MSDD6000::read(char* buf, int size){
int flags = 0;
return recv(d_sock, buf, size, flags);
}
|
