lili/amodem
1
0
Fork 0
mirror of https://github.com/romanz/amodem.git synced 2026-04-21 05:36:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

send should work with stdin and stdout

Browse Source
This commit is contained in:
Roman Zeyde
2014-07-22 09:49:56 +03:00
parent f2d1d1535e
commit bc52203560
1 changed files with 26 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
send.py
View File

@@ -36,7 +36,6 @@ write = Writer().write
def start(fd, c): def start(fd, c):
write(fd, c*0, n=50)
write(fd, c*1, n=400) write(fd, c*1, n=400)
write(fd, c*0, n=50) write(fd, c*0, n=50)
@@ -54,7 +53,7 @@ def modulate(fd, bits):
symbols = itertools.islice(symbols_iter, len(sym.carrier)) symbols = itertools.islice(symbols_iter, len(sym.carrier))
symbols = np.array(list(symbols)) symbols = np.array(list(symbols))
write(fd, np.dot(symbols, carriers)) write(fd, np.dot(symbols, carriers))
if all(symbols == 0): if all(symbols == 0): # EOF marker
break break
@@ -76,28 +75,33 @@ class Reader(object):
return self return self
def main(fname): def main(args):
import ecc import ecc
log.info('Running MODEM @ {:.1f} kbps'.format(sigproc.modem_bps / 1e3)) log.info('Running MODEM @ {:.1f} kbps'.format(sigproc.modem_bps / 1e3))
with open(fname, 'wb') as fd: fd = sys.stdout
start(fd, sym.carrier[carrier_index])
for c in sym.carrier:
training(fd, c)
training_size = fd.tell()
log.info('%.3f seconds of training audio',
training_size / wave.bytes_per_second)
reader = Reader(sys.stdin, 64 << 10) # padding audio with silence
data = itertools.chain.from_iterable(reader) write(fd, np.zeros(int(Fs * args.silence_start)))
encoded = itertools.chain.from_iterable(ecc.encode(data))
modulate(fd, bits=to_bits(encoded))
data_size = fd.tell() - training_size start(fd, sym.carrier[carrier_index])
log.info('%.3f seconds of data audio, for %.3f kB of data', for c in sym.carrier:
data_size / wave.bytes_per_second, reader.total / 1e3) training(fd, c)
# padding audio with silence training_size = fd.tell()
fd.write('\x00' * int(wave.bytes_per_second)) log.info('%.3f seconds of training audio',
training_size / wave.bytes_per_second)
reader = Reader(sys.stdin, 64 << 10)
data = itertools.chain.from_iterable(reader)
encoded = itertools.chain.from_iterable(ecc.encode(data))
modulate(fd, bits=to_bits(encoded))
data_size = fd.tell() - training_size
log.info('%.3f seconds of data audio, for %.3f kB of data',
data_size / wave.bytes_per_second, reader.total / 1e3)
# padding audio with silence
write(fd, np.zeros(int(Fs * args.silence_stop)))
if __name__ == '__main__': if __name__ == '__main__':
logging.basicConfig(level=logging.DEBUG, logging.basicConfig(level=logging.DEBUG,
@@ -105,6 +109,7 @@ if __name__ == '__main__':
import argparse import argparse
p = argparse.ArgumentParser() p = argparse.ArgumentParser()
p.add_argument('fname') p.add_argument('--silence-start', type=float, default=1.0)
p.add_argument('--silence-stop', type=float, default=1.0)
args = p.parse_args() args = p.parse_args()
main(fname=args.fname) main(args)