chiark - git - mdw - mLib-python/blob - conn.pyx

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