UDS_client.py

#!/usr/bin/env python
# see UDS_server.py for the other
# half of this

import socket
import sys

SERVER_PATH = "/tmp/UDS_server"

def run_unix_domain_socket_client():
    sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)

    # connect the socket to the path where server is listening
    server_address = SERVER_PATH
    print "connecting to %s" % server_address
    try:
        sock.connect(server_address)
    except socket.error, msg:
        print >> sys.stderr, msg
        sys.exit(1)

    try:
        message = "Viva la revolution!  This will be echoed back!"
        print "Sending [%s]" %message
        sock.sendall(message)
        amount_received = 0
        amount_expected = len(message)

        while amount_received < amount_expected:
            data = sock.recv(16)
            amount_received += len(data)
            print >> sys.stderr, "Received [%s]" % data

    finally:
        print "Closing client"
        sock.close()

if __name__ == '__main__':
    run_unix_domain_socket_client()