subnero/test_tx_rx.py at master · marinetech/subnero · GitHub

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
# Settings
# Node 1
ip_address = "192.168.0.11"
#
# Node 2
# ip_address = "192.168.0.11"
# ip_address = "localhost"
number_of_loops = 2
sleep_between_loops = 0
signal_file = 'PortoVeryShort'

##--------------------------------------##

import sys
import time
import numpy as np
import arlpy.signal as asig
import arlpy.plot as plt
from unetpy import *
import matplotlib.pyplot as plt1
rec_length = 0.5

# Open connection to the modem
print("-I- connecting to modem: " + ip_address)
try:
    sock = UnetSocket(ip_address, 1100)
    modem = sock.getGateway()
except:
	print("-I- cannot connect to modem")
	exit(1)

count=0

while True:
	################### Transmit and record a signal ##########################
	# Look for agents poviding baseband service
	bb = modem.agentForService(Services.BASEBAND)
	# Load the baseband signal to be transmitted.
	# Format: array with alternate real and imag values
	# tx_signal = np.genfromtxt(signal_file, delimiter=',')
	fs = 96000
	fc = 24000
	fd = 24000

	pb_signal = asig.sweep(20000,32000, 0.1, fs)
	tx_signal= asig.pb2bb(pb_signal,fs,fc,fd=fd,flen=127,cutoff=None)

	# Transmit the baseband signal
	bb << TxBasebandSignalReq(preamble=0, signal=tx_signal,fc=fc)

	# plt.plot(tx_signal, fs=fs)
	# plt.specgram(tx_signal, fs=fs

	txntf = modem.receive(TxFrameNtf, 5000)
	if txntf is not None:
	    # Request a recording from txTime onwards for a duration of 2x the original transmitted signal. (len(tx_signal)*2))
	    print("rec lenght", len(tx_signal)*2)
	    print("recTime", txntf.txTime)
	    bb << RecordBasebandSignalReq(recTime=(txntf.txTime+9600), recLength=fd*rec_length)
	else:
	    print('Transmission not successfull, try again!')

	# Read the receive notification
	rxntf = modem.receive(RxBasebandSignalNtf, 5000)
	rxntf.fc
	rxntf.fs

	if rxntf is not None:
	    # Extract the recorded signal
	    rec_signal = rxntf.signal
	    print('Successfully recorded signal after transmission!')
	    # The recorded signal is saved in `rec_signal` variable
	    # It can be processed as required by the user.
	    print("Rec signal:", rec_signal)
	    y = asig.bb2pb(rec_signal, rxntf.fs, rxntf.fc, fs)
	    # plt.plot(y, fs=fs)
	    plt.specgram(y, fs=fs)
	    # np.savetxt('rx_signal'+str(count)+'.txt',y)
	    time.sleep(1)
	    count += 1

	else:
	    print('Recording not successfull, try again!')

################### Close connection to modem ################################

modem.close()