#!/usr/bin/env python
"""
open/DurusWorks/qp/hub/test/test_passfd.py

"""

import os, sys, socket
from qp.hub import passfd

#
# Create a pipe for sending the fd.
#

if __name__ == "__main__":
    rfd, wfd = passfd.socketpair(socket.AF_UNIX, socket.SOCK_STREAM)
    print("rfd %s wfd %s" % (rfd, wfd))

    pid = os.fork()

    if pid != 0:
        # We're in the parent.

        # Open a file for passing along to child.

        fileObj = open('/dev/zero', 'r')

        # ioctl() will only pass raw filedescriptors. Find fd of fileObj.
        fd = fileObj.fileno()

        # Send to the child
        os.write(wfd, 'x'.encode('utf8'))
        passfd.sendfd(wfd, fd)

        # Wait for child to terminate, then exit.
        os.waitpid(pid, 0)
        sys.exit(0)

    else:
        # We're in the child.

        print(os.read(rfd, 1))
        fd = passfd.recvfd(rfd)

        # Reopen the filedescriptor as a Python File-object.
        fileObj = os.fdopen(fd, 'r')

        # Example usage: Read file, print the first line.
        print("first byte %r" % fileObj.read(1))
        sys.exit(0)