aboutsummaryrefslogtreecommitdiffstats
path: root/src/fl2k_tcp.c
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2022-01-09 20:02:59 +0100
committerMatthias P. Braendli <matthias.braendli@mpb.li>2022-01-09 20:02:59 +0100
commit36276e45cc3dbca2e954515bd7b6b3b4498ddbb2 (patch)
tree4ec57160a6b6ec14974e44b5beabf8103907aa1e /src/fl2k_tcp.c
parent2cf0eaffddab2457fc81d672599c0f58eb6950f9 (diff)
parenta0e7a58447006cdb1e10f781323c88bd08e66eea (diff)
downloadosmo-fl2k-36276e45cc3dbca2e954515bd7b6b3b4498ddbb2.tar.gz
osmo-fl2k-36276e45cc3dbca2e954515bd7b6b3b4498ddbb2.tar.bz2
osmo-fl2k-36276e45cc3dbca2e954515bd7b6b3b4498ddbb2.zip
Merge branch 'iq' into interleaved_rg
Diffstat (limited to 'src/fl2k_tcp.c')
-rw-r--r--src/fl2k_tcp.c14
1 files changed, 13 insertions, 1 deletions
diff --git a/src/fl2k_tcp.c b/src/fl2k_tcp.c
index bd01758..871ac26 100644
--- a/src/fl2k_tcp.c
+++ b/src/fl2k_tcp.c
@@ -107,6 +107,12 @@ void fl2k_callback(fl2k_data_info_t *data_info)
int r;
struct timeval tv = { 1, 0 };
+ if (data_info->device_error) {
+ fprintf(stderr, "Device error, exiting.\n");
+ do_exit = 1;
+ return;
+ }
+
if (!connected)
return;
@@ -122,6 +128,12 @@ void fl2k_callback(fl2k_data_info_t *data_info)
if (r) {
received = recv(sock, txbuf + (FL2K_BUF_LEN - left), left, 0);
+ if (!received) {
+ fprintf(stderr, "Connection was closed!\n");
+ fl2k_stop_tx(dev);
+ do_exit = 1;
+ }
+
left -= received;
}
}
@@ -233,8 +245,8 @@ int main(int argc, char **argv)
sleep_ms(500);
out:
- free(txbuf);
fl2k_close(dev);
+ free(txbuf);
closesocket(s);
#ifdef _WIN32
WSACleanup();