mdw@git.distorted.org.uk Git - mLib-python/blob - conn.pyx

   1 ### -*-pyrex-*-
   2 ###
   3 ### Non-blocking connections
   4 ###
   5 ### (c) 2005 Straylight/Edgeware
   6 ###
   7
   8 ###----- Licensing notice -----------------------------------------------------
   9 ###
  10 ### This file is part of the Python interface to mLib.
  11 ###
  12 ### mLib/Python is free software; you can redistribute it and/or modify
  13 ### it under the terms of the GNU General Public License as published by
  14 ### the Free Software Foundation; either version 2 of the License, or
  15 ### (at your option) any later version.
  16 ###
  17 ### mLib/Python is distributed in the hope that it will be useful,
  18 ### but WITHOUT ANY WARRANTY; without even the implied warranty of
  19 ### MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  20 ### GNU General Public License for more details.
  21 ###
  22 ### You should have received a copy of the GNU General Public License
  23 ### along with mLib/Python; if not, write to the Free Software Foundation,
  24 ### Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  25
  26 cdef class SelConnect:
  27   """
  28   SelConnect(SK, [connectedproc = FUNC], [errorproc = FUNC])
  29
  30   When socket SK connects, call CONNECTEDPROC(); if connection fails, call
  31   ERRORPROC(ERRNO, MESSAGE).
  32
  33   Attributes: C.socket, C.activep, C.connectedproc, C.errorproc.
  34   """
  35   cdef conn c
  36   cdef int _activep
  37   cdef readonly object socket
  38   cdef _connected
  39   cdef _error
  40   def __cinit__(me, sk, connectedproc = None, errorproc = None,
  41               *hunoz, **hukairz):
  42     conn_fd(&me.c, &_sel, sk.fileno(), _connfunc, <void *>me)
  43     me._activep = 1
  44     me.socket = sk
  45     me._connected = _checkcallable(connectedproc, 'connected proc')
  46     me._error = _checkcallable(errorproc, 'error proc')
  47   def __dealloc__(me):
  48     if me._activep:
  49       conn_kill(&me.c)
  50   property activep:
  51     """C.activep -> BOOL: is connection still in progress?"""
  52     def __get__(me):
  53       return _tobool(me._activep)
  54   property connectedproc:
  55     """C.connectedproc -> FUNC: call FUNC() when connection completes"""
  56     def __get__(me):
  57       return me._connected
  58     def __set__(me, proc):
  59       me._connected = _checkcallable(proc, 'connected proc')
  60     def __del__(me):
  61       me._connected = None
  62   property errorproc:
  63     """
  64     C.errorproc -> FUNC: call FUNC(ERRNO, MSG) if connection fails
  65     """
  66     def __get__(me):
  67       return me._error
  68     def __set__(me, proc):
  69       me._error = _checkcallable(proc, 'error proc')
  70     def __del__(me):
  71       me._error = None
  72   def kill(me):
  73     """C.kill(): give up on connection"""
  74     if not me._activep:
  75       raise ValueError, 'already dead'
  76     conn_kill(&me.c);
  77     me._dead()
  78     return me
  79   cdef _dead(me):
  80     me._activep = 0
  81     me.dead()
  82   def dead(me):
  83     """C.dead(): called when connection completes or fails"""
  84     pass
  85   def connected(me):
  86     """C.connected(): called when connection completes successfully"""
  87     return _maybecall(me._connected, ())
  88   def error(me, errno, strerror):
  89     """C.error(ERRNO, MSG): called when connection fails"""
  90     return _maybecall(me._error, ())
  91
  92 cdef void _connfunc(int fd, void *arg):
  93   cdef SelConnect c
  94   c = <SelConnect>arg
  95   c._dead()
  96   if fd == -1:
  97     c.socket = None
  98     c.error(errno, strerror(errno))
  99   else:
 100     c.connected()
 101
 102 ###----- That's all, folks --------------------------------------------------