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
|
/* -*- c++ -*- */
/*
* Copyright 2010 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 GNU Radio; see the file COPYING. If not, write to
* the Free Software Foundation, Inc., 51 Franklin Street,
* Boston, MA 02110-1301, USA.
*/
#include <uhd_simple_source.h>
#include <gr_io_signature.h>
#include <stdexcept>
#include "utils.h"
/***********************************************************************
* Make UHD Source
**********************************************************************/
boost::shared_ptr<uhd_simple_source> uhd_make_simple_source(
const std::string &args,
const uhd::io_type_t::tid_t &type
){
return boost::shared_ptr<uhd_simple_source>(
new uhd_simple_source(args, type)
);
}
/***********************************************************************
* UHD Source
**********************************************************************/
uhd_simple_source::uhd_simple_source(
const std::string &args,
const uhd::io_type_t &type
) : gr_sync_block(
"uhd source",
gr_make_io_signature(0, 0, 0),
gr_make_io_signature(1, 1, type.size)
), _type(type){
_dev = uhd::usrp::simple_usrp::make(args);
set_streaming(false);
}
uhd_simple_source::~uhd_simple_source(void){
set_streaming(false);
}
void uhd_simple_source::set_streaming(bool enb){
if (enb)
_dev->issue_stream_cmd(uhd::stream_cmd_t::STREAM_MODE_START_CONTINUOUS);
else
_dev->issue_stream_cmd(uhd::stream_cmd_t::STREAM_MODE_STOP_CONTINUOUS);
_is_streaming = enb;
}
void uhd_simple_source::set_samp_rate(double rate){
_dev->set_rx_rate(rate);
do_samp_rate_error_message(rate, get_samp_rate());
}
double uhd_simple_source::get_samp_rate(void){
return _dev->get_rx_rate();
}
uhd::tune_result_t uhd_simple_source::set_center_freq(double freq){
return _dev->set_rx_freq(freq);
}
uhd::freq_range_t uhd_simple_source::get_freq_range(void){
return _dev->get_rx_freq_range();
}
void uhd_simple_source::set_gain(float gain){
return _dev->set_rx_gain(gain);
}
float uhd_simple_source::get_gain(void){
return _dev->get_rx_gain();
}
uhd::gain_range_t uhd_simple_source::get_gain_range(void){
return _dev->get_rx_gain_range();
}
void uhd_simple_source::set_antenna(const std::string &ant){
return _dev->set_rx_antenna(ant);
}
std::string uhd_simple_source::get_antenna(void){
return _dev->get_rx_antenna();
}
std::vector<std::string> uhd_simple_source::get_antennas(void){
return _dev->get_rx_antennas();
}
/***********************************************************************
* Work
**********************************************************************/
int uhd_simple_source::work(
int noutput_items,
gr_vector_const_void_star &input_items,
gr_vector_void_star &output_items
){
//conditionally start streaming in the work call
//this prevents streaming before the runtime is ready
if (not _is_streaming) set_streaming(true);
size_t total_items_read = 0;
uhd::rx_metadata_t metadata;
//call until the output items are all filled
//or an exit condition below is encountered
while(total_items_read < size_t(noutput_items)){
size_t items_read = _dev->get_device()->recv(
boost::asio::buffer(
(uint8_t *)output_items[0]+(total_items_read*_type.size),
(noutput_items-total_items_read)*_type.size
), metadata, _type
);
total_items_read += items_read;
//we timed out, get out of here
if (items_read == 0) break;
}
return total_items_read;
}
|
