...

Signed-off-by: Mattias Andrée <maandree@kth.se>

1 files changed, 92 insertions, 0 deletions

diff --git a/src/libcoopgamma_native.pyx.gpp b/src/libcoopgamma_native.pyx.gpp
index 73d8353..b28c57b 100644
--- a/src/libcoopgamma_native.pyx.gpp
+++ b/src/libcoopgamma_native.pyx.gpp
@@ -1043,3 +1043,95 @@ def libcoopgamma_native_async_context_unmarshal(buf : bytes):
     ret0 = <int>libcoopgamma_async_context_unmarshal(this, <bytes>buf, &ret1)
     return (ret0, <int>ret1)
 
+
+def libcoopgamma_native_connect(method : str, site : str, address : int):
+    '''
+    Connect to a coopgamma server, and start it if necessary
+    
+    Use `libcoopgamma_context_destroy` to disconnect
+    
+    SIGCHLD must not be ignored or blocked
+    
+    @param   method:str?  The adjustment method, `NULL` for automatic
+    @param   site:str?    The site, `NULL` for automatic
+    @param   address:int  The address of the state of the library, must be initialised
+    @return  :int?        `None`, 0 if the server on could not be initialised,
+                          the value `errno` on other errors
+    '''
+    cdef libcoopgamma_context_t* ctx = <libcoopgamma_context_t*><void*><intptr_t>address
+    if libcoopgamma_connect(method, site, ctx) < 0:
+        return int(errno)
+    return None
+
+
+def libcoopgamma_native_set_nonblocking(address : int, nonblocking : bool):
+    '''
+    By default communication is blocking, this function
+    can be used to switch between blocking and nonblocking
+    
+    After setting the communication to nonblocking,
+    `libcoopgamma_flush`, `libcoopgamma_synchronise` and
+    and request-sending functions can fail with EAGAIN and
+    EWOULDBLOCK. It is safe to continue with `libcoopgamma_flush`
+    (for `libcoopgamma_flush` it selfand equest-sending functions)
+    or `libcoopgamma_synchronise` just like EINTR failure.
+    
+    @param   address:int       The address of the state of the library, must be connected
+    @param   nonblocking:bool  Nonblocking mode?
+    @return  :int              Zero on success, the value of `errno` on error
+    '''
+    cdef libcoopgamma_context_t* ctx = <libcoopgamma_context_t*><void*><intptr_t>address
+    if libcoopgamma_set_nonblocking(ctx, <int>(1 if nonblocking else 0)) < 0:
+        return int(errno)
+    return 0
+
+
+def libcoopgamma_native_flush(address : int):
+    '''
+    Send all pending outbound data
+    
+    If this function or another function that sends a request
+    to the server fails with EINTR, call this function to
+    complete the transfer. The `async` parameter will always
+    be in a properly configured state if a function fails
+    with EINTR.
+    
+    @param   address:int  The address of the state of the library, must be connected
+    @return  :int         Zero on success, the value of `errno` on error
+    '''
+    cdef libcoopgamma_context_t* ctx = <libcoopgamma_context_t*><void*><intptr_t>address
+    if libcoopgamma_flush(ctx) < 0:
+        return int(errno)
+    return 0
+
+
+def libcoopgamma_native_synchronise(address : int, pending : list):
+    '''
+    Wait for the next message to be received
+    
+    @param   address:int        The address of the state of the library, must be connected
+    @param   pending:list<int>  Addresses of the information for each pending request
+    @return  :(:bool, :int)     If [0] = 0: [1] is the value of `errno`
+                                   [0] = 1: [1] is the selected request
+    '''
+    cdef libcoopgamma_context_t* ctx = <libcoopgamma_context_t*><void*><intptr_t>address
+    cdef libcoopgamma_async_context_t* pends
+    cdef size_t selected = 0
+    pends = <libcoopgamma_async_context_t*>malloc(n * sizeof(*pends))
+    if pends is None:
+        pass
+    for i in range(len(pending)):
+        pends[i] = *<libcoopgamma_async_context_t*><void*><intptr_t>pendings[i]
+    if libcoopgamma_synchronise(ctx, pends, <size_t>len(pending), &selected) < 0:
+        return (False, int(errno))
+    return (True, <int>selected)
+
+
+def libcoopgamma_native_skip_message(address : int):
+    '''
+    Tell the library that you will not be parsing a receive message
+    
+    @param  address:int  The address of the state of the library, must be connected
+    '''
+    libcoopgamma_skip_message(<libcoopgamma_context_t*><void*><intptr_t>address)
+