chiark / gitweb /
*.pyx: Replace __new__ with __cinit__ like the program says.
[mLib-python] / conn.pyx
CommitLineData
579d0169 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.
d8d81d1b 18#
579d0169 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.
d8d81d1b 23#
579d0169 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
28cdef class SelConnect:
29 cdef conn c
30 cdef int _activep
31 cdef readonly object socket
32 cdef _connected
33 cdef _error
376ad06d 34 def __cinit__(me, sk, connectedproc = None, errorproc = None,
579d0169 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
b51b6cf0 77cdef void _connfunc(int fd, void *arg):
579d0169 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 ----------------------------------------------------