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

port stream and send

Browse Source
This commit is contained in:
Roman Zeyde
2014-08-06 18:22:15 +03:00
parent 2e51b269c9
commit a748fdb5a1
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
amodem/send.py
View File

@@ -18,8 +18,9 @@ modem = sigproc.MODEM(config)
class Symbol(object): class Symbol(object):
def __init__(self):
t = np.arange(0, config.Nsym) * config.Ts t = np.arange(0, config.Nsym) * config.Ts
carrier = [np.exp(2j * np.pi * F * t) for F in modem.freqs] self.carrier = [np.exp(2j * np.pi * F * t) for F in modem.freqs]
sym = Symbol() sym = Symbol()
@@ -31,7 +32,7 @@ class Writer(object):
def write(self, fd, sym, n=1): def write(self, fd, sym, n=1):
data = common.dumps(sym, n) data = common.dumps(sym, n)
fd.write(data) fd.write(str(data))
self.offset += len(data) self.offset += len(data)
if time.time() > self.last + 1: if time.time() > self.last + 1:
log.debug('%10.3f seconds of data audio', log.debug('%10.3f seconds of data audio',
@@ -69,7 +70,7 @@ class Reader(object):
self.size = size self.size = size
self.total = 0 self.total = 0
def next(self): def __next__(self):
block = self.fd.read(self.size) block = self.fd.read(self.size)
if block: if block:
self.total += len(block) self.total += len(block)

2
amodem/stream.py
View File

@@ -19,7 +19,7 @@ class Reader(object):
def __iter__(self): def __iter__(self):
return self return self
def next(self): def __next__(self):
block = bytearray() block = bytearray()
finish_time = time.time() + self.TIMEOUT finish_time = time.time() + self.TIMEOUT
while time.time() <= finish_time: while time.time() <= finish_time: