gravelrpc: fd needs to be instanceof FD

gravelrpc.py

@@ -52,6 +52,7 @@ def _call(self, name, *args, **kwargs):
         doc = dict(name=name, args=args, kwargs=kwargs)
         if '_fds' in kwargs:
             doc['fds'] = kwargs['_fds']
+            kwargs['_fds'] = None
         write_bson(sock, doc)
         result = read_bson(sock)
         if 'error' in result:
@@ -77,7 +78,9 @@ def write_bson(sock, doc):
 
     sock.send(struct.pack('!I', len(fds)))
     for fd in fds:
-        passfd.sendfd(sock, fd, 'whatever')
+        if not isinstance(fd, FD):
+            raise TypeError('fds need to be instances of FD (not %r)' % fd)
+        passfd.sendfd(sock, fd.fileno(), 'whatever')
 
     sock.sendall(bson.BSON.encode(doc))
     sock.shutdown(socket.SHUT_WR)

rpctool.py

@@ -1,6 +1,7 @@
 #!/usr/bin/env python
 import argparse
 import gravelrpc
+from gravelrpc import FD
 
 parser = argparse.ArgumentParser()
 parser.add_argument('name')

testrpc_client.py

@@ -5,4 +5,4 @@
 c = gravelrpc.Client('foo')
 print c.hello(u'Michał!')
 
-c.say_hello(_fds=[sys.stdout.fileno()])
+c.say_hello(_fds=[gravelrpc.FD(1)])