Skip to content

Instantly share code, notes, and snippets.

@dariocazzani

dariocazzani/receiver.py

Last active April 15, 2022 09:09
Show Gist options
  • Save dariocazzani/1f358d7c6b336a18bb06f8f543298876 to your computer and use it in GitHub Desktop.
Save dariocazzani/1f358d7c6b336a18bb06f8f543298876 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. dariocazzani revised this gist Jul 11, 2017. 1 changed file with 1 addition and 0 deletions.
    1 change: 1 addition & 0 deletions receiver.py
    View file
    Original file line number Diff line number Diff line change
    @@ -5,6 +5,7 @@
    import socket
    import sys
    import pyaudio
    import numpy as np

    class Receiver(object):
    def __init__(self):
  2. dariocazzani revised this gist Jul 11, 2017. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion receiver.py
    View file
    Original file line number Diff line number Diff line change
    @@ -7,7 +7,7 @@
    import pyaudio

    class Receiver(object):
    def __init__(self):
    def __init__(self):
    self.HOST = '' # Symbolic name meaning all available interfaces
    self.PORT = 9999 # Arbitrary non-privileged port
    self._create_socket()
  3. dariocazzani revised this gist Jul 11, 2017. 1 changed file with 4 additions and 3 deletions.
    7 changes: 4 additions & 3 deletions receiver.py
    View file
    Original file line number Diff line number Diff line change
    @@ -7,7 +7,7 @@
    import pyaudio

    class Receiver(object):
    def __init__(self):
    def __init__(self):
    self.HOST = '' # Symbolic name meaning all available interfaces
    self.PORT = 9999 # Arbitrary non-privileged port
    self._create_socket()
    @@ -51,10 +51,11 @@ def receive(self):
    #now keep talking with the client
    while 1:
    # receive data from client (data, addr)
    d = self.s.recvfrom(160)
    d = self.s.recvfrom(1024)
    data = d[0]
    addr = d[1]
    self.play(data)
    samples = np.fromstring(data, np.float32)
    self.play(samples)
    if not data:
    break
    print('received packet of size {} from {}'.format(len(data), addr))
  4. dariocazzani created this gist Jul 11, 2017.
    73 changes: 73 additions & 0 deletions receiver.py
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,73 @@
    '''
    Simple udp socket server
    '''

    import socket
    import sys
    import pyaudio

    class Receiver(object):
    def __init__(self):
    self.HOST = '' # Symbolic name meaning all available interfaces
    self.PORT = 9999 # Arbitrary non-privileged port
    self._create_socket()
    self._bind_socket()
    print('Socket bind complete')
    self._init_pyaudio()
    print('PyAudio initialized')

    def _init_pyaudio(self):
    try:
    p = pyaudio.PyAudio()
    self.stream = p.open(format=p.get_format_from_width(2),
    channels=1,
    rate=16000,
    output=True)
    except Exception as e:
    print('Error in creating PyAudio: {}'.format(e))
    sys.exit()

    def _create_socket(self):
    # Datagram (udp) socket
    try :
    self.s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    print('Socket created')
    except socket.error, msg :
    print('Failed to create socket. Error Code : {}, Message: '.format(msg[0], msg[1]))
    sys.exit()

    def _bind_socket(self):
    # Bind socket to local host and port
    try:
    self.s.bind((self.HOST, self.PORT))
    except socket.error , msg:
    print('Bind failed. Error Code : {}, Message: '.format(msg[0], msg[1]))
    sys.exit()

    def play(self, data):
    self.stream.write(data)

    def receive(self):
    #now keep talking with the client
    while 1:
    # receive data from client (data, addr)
    d = self.s.recvfrom(160)
    data = d[0]
    addr = d[1]
    self.play(data)
    if not data:
    break
    print('received packet of size {} from {}'.format(len(data), addr))

    print('Closing socket')
    self.s.close()

    self.stream.stop_stream()
    self.stream.close()

    def main():
    r = Receiver()
    r.receive()

    if __name__ == '__main__':
    main()