Add support for "abstract unix socket"

Author: baixuefeng

uvloop/handles/pipe.pxd

@@ -16,7 +16,7 @@ cdef class UnixTransport(UVStream):
     cdef UnixTransport new(Loop loop, object protocol, Server server,
                            object waiter, object context)
 
-    cdef connect(self, char* addr)
+    cdef connect(self, const char* name, size_t namelen)
 
 
 cdef class ReadUnixTransport(UVStream):

uvloop/handles/pipe.pyx

@@ -121,10 +121,10 @@ cdef class UnixTransport(UVStream):
     cdef _open(self, int sockfd):
         __pipe_open(<UVStream>self, sockfd)
 
-    cdef connect(self, char* addr):
+    cdef connect(self, const char* name, size_t namelen):
         cdef _PipeConnectRequest req
         req = _PipeConnectRequest(self._loop, self)
-        req.connect(addr)
+        req.connect(name, namelen)
 
 
 @cython.no_gc_clear
@@ -216,11 +216,12 @@ cdef class _PipeConnectRequest(UVRequest):
         self.request.data = <void*>self
         self.transport = transport
 
-    cdef connect(self, char* addr):
-        # uv_pipe_connect returns void
-        uv.uv_pipe_connect(<uv.uv_connect_t*>self.request,
+    cdef connect(self, const char* name, size_t namelen):
+        uv.uv_pipe_connect2(<uv.uv_connect_t*>self.request,
                            <uv.uv_pipe_t*>self.transport._handle,
-                           addr,
+                           name,
+                           namelen,
+                           0,
                            __pipe_connect_callback)
 
 cdef void __pipe_connect_callback(

uvloop/includes/uv.pxd

@@ -381,8 +381,9 @@ cdef extern from "uv.h" nogil:
     int uv_pipe_open(uv_pipe_t* handle, uv_os_fd_t file)
     int uv_pipe_bind(uv_pipe_t* handle, const char* name)
 
-    void uv_pipe_connect(uv_connect_t* req, uv_pipe_t* handle,
-                         const char* name, uv_connect_cb cb)
+    void uv_pipe_connect2(uv_connect_t* req, uv_pipe_t* handle,
+                         const char* name, size_t namelen,
+                         unsigned int flags, uv_connect_cb cb)
 
     # UDP
 

uvloop/loop.pyx

@@ -2283,7 +2283,7 @@ cdef class Loop:
 
             waiter = self._new_future()
             tr = UnixTransport.new(self, protocol, None, waiter, context)
-            tr.connect(path)
+            tr.connect(path, len(path))
             try:
                 await waiter
             except (KeyboardInterrupt, SystemExit):