Sojus07/hackrf
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add commentary to TX callback.

Browse Source
This commit is contained in:
Martin Ling
2022-09-14 15:25:48 +01:00
parent e38534b99d
commit f2d00adab8
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
host/hackrf-tools/src/hackrf_transfer.c
View File

@ -481,6 +481,7 @@ int tx_callback(hackrf_transfer* transfer)
size_t bytes_read; size_t bytes_read;
unsigned int i; unsigned int i;
/* Check we have a valid source of samples. */
if (file == NULL && transceiver_mode != TRANSCEIVER_MODE_SS) { if (file == NULL && transceiver_mode != TRANSCEIVER_MODE_SS) {
stop_main_loop(); stop_main_loop();
return -1; return -1;
@ -497,11 +498,13 @@ int tx_callback(hackrf_transfer* transfer)
byte_count += transfer->valid_length; byte_count += transfer->valid_length;
stream_power += sum; stream_power += sum;
/* If the last data was already buffered, stop. */
if (tx_complete) { if (tx_complete) {
stop_main_loop(); stop_main_loop();
return -1; return -1;
} }
/* Determine how many bytes we need to put in the buffer. */
bytes_to_read = transfer->buffer_length; bytes_to_read = transfer->buffer_length;
if (limit_num_samples) { if (limit_num_samples) {
if (bytes_to_read >= bytes_to_xfer) { if (bytes_to_read >= bytes_to_xfer) {
@ -509,31 +512,37 @@ int tx_callback(hackrf_transfer* transfer)
} }
bytes_to_xfer -= bytes_to_read; bytes_to_xfer -= bytes_to_read;
} }
if (file == NULL) { // transceiver_mode == TRANSCEIVER_MODE_SS
/* Fill the buffer. */
if (file == NULL) {
/* Transmit continuous wave with specific amplitude */ /* Transmit continuous wave with specific amplitude */
for (i = 0; i < bytes_to_read; i++) for (i = 0; i < bytes_to_read; i++)
transfer->buffer[i] = -(uint8_t) amplitude; transfer->buffer[i] = -(uint8_t) amplitude;
bytes_read = bytes_to_read; bytes_read = bytes_to_read;
} else { } else {
/* Read samples from file. */
bytes_read = fread(transfer->buffer, 1, bytes_to_read, file); bytes_read = fread(transfer->buffer, 1, bytes_to_read, file);
} }
transfer->valid_length = bytes_read; transfer->valid_length = bytes_read;
/* If the sample limit has been reached, this is the last data. */
if (limit_num_samples && (bytes_to_xfer == 0)) { if (limit_num_samples && (bytes_to_xfer == 0)) {
tx_complete = true; tx_complete = true;
return 0; return 0;
} }
/* If we filled the number of bytes needed, return normally. */
if (bytes_read == bytes_to_read) { if (bytes_read == bytes_to_read) {
return 0; return 0;
} }
/* Otherwise, the file ran short. If not repeating, this is the last data. */
if (!repeat) { if (!repeat) {
tx_complete = true; tx_complete = true;
return 0; return 0;
} }
/* If we get to here, we need to repeat the file until we fill the buffer. */
while (bytes_read < bytes_to_read) { while (bytes_read < bytes_to_read) {
rewind(file); rewind(file);
bytes_read += bytes_read +=
@ -544,6 +553,7 @@ int tx_callback(hackrf_transfer* transfer)
transfer->valid_length = bytes_read; transfer->valid_length = bytes_read;
} }
/* Then return normally. */
return 0; return 0;
} }