diff options
Diffstat (limited to 'src/libcoopgamma.py')
| -rw-r--r-- | src/libcoopgamma.py | 29 |
1 files changed, 24 insertions, 5 deletions
diff --git a/src/libcoopgamma.py b/src/libcoopgamma.py index 31f5aaa..9aae31b 100644 --- a/src/libcoopgamma.py +++ b/src/libcoopgamma.py @@ -596,7 +596,14 @@ class Context: @param method:int|str? The adjustment method, `None` for automatic @param site:str? The site, `None` for automatic ''' - pass + if method is not None and isinstance(method, int): + method = str(method) + error = libcoopgamma_native_connect(method, site, self.address) + if error is not None: + if errno == 0: + pass # TODO server failed to initialise + else: + pass # TODO def detach(self): ''' @@ -625,7 +632,9 @@ class Context: @param nonblocking:bool Nonblocking mode? ''' - pass + error = libcoopgamma_native.libcoopgamma_native_set_nonblocking(self.address, nonbreaking) + if error != 0: + pass # TODO def flush(self): ''' @@ -635,7 +644,9 @@ class Context: 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. ''' - pass + error = libcoopgamma_native.libcoopgamma_native_flush(self.address) + if error != 0: + pass # TODO def synchronise(self, pending : list) -> int: ''' @@ -651,13 +662,21 @@ class Context: `None` if the message is ignored, which happens if corresponding AsyncContext is not listed. ''' - pass + pending = [p.address for p in pending] + (successful, value) = libcoopgamma_native.libcoopgamma_native_flush(self.address, pending) + if not successful: + if error == 0: + return None + else: + pass # TODO + else: + return value def skip_message(self): ''' Tell the library that you will not be parsing a receive message ''' - pass + libcoopgamma_native.libcoopgamma_native_skip_message(self.address) def get_crtcs_send(self) -> AsyncContext: ''' |