| author | Tero Marttila <terom@fixme.fi> |
| Mon, 31 Aug 2009 22:17:00 +0300 | |
| changeset 43 | 9fdef438e3a2 |
| parent 27 | 12468e38227e |
| child 46 | 64b4ffb44754 |
| permissions | -rw-r--r-- |
|
11
7ae92c2b433f
move libc+py back to qmsk.net.x
Tero Marttila <terom@fixme.fi>
parents:
10
diff
changeset
|
1 |
cimport qmsk.net.libc as libc |
|
22
f6e8d5e37998
some __cmp__ and doctest love for socket.address
Tero Marttila <terom@fixme.fi>
parents:
20
diff
changeset
|
2 |
cimport qmsk.net.py as py |
| 6 | 3 |
|
|
20
0e4933d5862e
rename qmsk.net.socket.addr -> qmsk.net.socket.address
Tero Marttila <terom@fixme.fi>
parents:
17
diff
changeset
|
4 |
from qmsk.net.socket.address cimport * |
| 10 | 5 |
|
6 |
cimport qmsk.net.socket.platform as platform |
|
| 6 | 7 |
|
8 |
cdef class sockaddr : |
|
| 10 | 9 |
cdef void _init_family (self, platform.sa_family_t family=platform.AF_UNSPEC) : |
| 6 | 10 |
self.family = family |
11 |
||
12 |
# XXX:use size_t |
|
| 10 | 13 |
cdef int _get_sockaddr (self, platform.sockaddr **sa_ptr, platform.socklen_t *sa_len) except -1 : |
| 6 | 14 |
""" |
15 |
Get the sockaddr pointer and sockaddr length for this address |
|
16 |
""" |
|
17 |
||
18 |
raise NotImplementedError() |
|
19 |
||
| 10 | 20 |
cdef platform.sockaddr* _get_sockaddr_ptr (self) except NULL : |
| 6 | 21 |
""" |
22 |
Get the sockaddr pointer |
|
23 |
""" |
|
24 |
||
| 10 | 25 |
cdef platform.sockaddr *sa |
26 |
cdef platform.socklen_t sa_len |
|
| 6 | 27 |
|
28 |
self._get_sockaddr(&sa, &sa_len) |
|
29 |
||
30 |
return sa |
|
31 |
||
| 10 | 32 |
cdef platform.socklen_t _get_sockaddr_len (self) except -1 : |
| 6 | 33 |
""" |
34 |
Get the sockaddr len |
|
35 |
""" |
|
36 |
||
| 10 | 37 |
cdef platform.sockaddr *sa |
38 |
cdef platform.socklen_t sa_len |
|
| 6 | 39 |
|
40 |
self._get_sockaddr(&sa, &sa_len) |
|
41 |
||
42 |
return sa_len |
|
43 |
||
| 10 | 44 |
cdef int _set_sockaddr (self, platform.sockaddr *sa, size_t sa_len) except -1 : |
| 6 | 45 |
""" |
46 |
Set the sockaddr value for this address; sa_len must match! |
|
47 |
""" |
|
48 |
||
49 |
raise NotImplementedError() |
|
50 |
||
51 |
def getnameinfo (self) : |
|
52 |
""" |
|
53 |
Returns a (host, serv) tuple for this address à la getnameinfo |
|
|
23
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
54 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
55 |
>>> addr = sockaddr_in() |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
56 |
>>> assert addr.getnameinfo() == (addr.addr, str(addr.port)) |
| 6 | 57 |
""" |
58 |
||
| 10 | 59 |
cdef platform.sockaddr *sa |
60 |
cdef platform.socklen_t sa_len |
|
| 6 | 61 |
|
62 |
# XXX: take as args? |
|
| 10 | 63 |
cdef int flags = platform.NI_NUMERICHOST | platform.NI_NUMERICSERV |
| 6 | 64 |
|
65 |
# get our abstract sockaddr |
|
66 |
self._get_sockaddr(&sa, &sa_len) |
|
67 |
||
68 |
# get nice text format |
|
| 10 | 69 |
return platform.getnameinfo(sa, sa_len, flags) |
| 6 | 70 |
|
71 |
property addr : |
|
72 |
""" |
|
73 |
The ASCII literal network address |
|
74 |
""" |
|
75 |
||
76 |
def __get__ (self) : |
|
77 |
""" |
|
78 |
Default implmentation using getnameinfo() |
|
79 |
""" |
|
80 |
||
81 |
addr, port = self.getnameinfo() |
|
82 |
||
83 |
return addr |
|
84 |
||
85 |
property port : |
|
86 |
""" |
|
87 |
The integer port number |
|
88 |
""" |
|
89 |
||
90 |
def __get__ (self) : |
|
91 |
""" |
|
92 |
Default implementation using getnameinfo() and int() |
|
93 |
""" |
|
94 |
||
95 |
addr, port = self.getnameinfo() |
|
96 |
||
97 |
return int(port) |
|
|
17
5f4077a530b0
add repr for sockaddr, and implment read for sockets, plus a recvmsg wrapper called readv...
Tero Marttila <terom@fixme.fi>
parents:
11
diff
changeset
|
98 |
|
|
5f4077a530b0
add repr for sockaddr, and implment read for sockets, plus a recvmsg wrapper called readv...
Tero Marttila <terom@fixme.fi>
parents:
11
diff
changeset
|
99 |
def __repr__ (self) : |
|
5f4077a530b0
add repr for sockaddr, and implment read for sockets, plus a recvmsg wrapper called readv...
Tero Marttila <terom@fixme.fi>
parents:
11
diff
changeset
|
100 |
return "sockaddr(%d, %s, %d)" % (self.family, self.addr, self.port) |
| 6 | 101 |
|
|
24
f18b5787c46c
reorganize socket, adding af_inet/af_inet6 modules, and moving sctp in
Tero Marttila <terom@fixme.fi>
parents:
23
diff
changeset
|
102 |
# mapping of AF -> sockaddr, user-modifyable |
|
f18b5787c46c
reorganize socket, adding af_inet/af_inet6 modules, and moving sctp in
Tero Marttila <terom@fixme.fi>
parents:
23
diff
changeset
|
103 |
cimport qmsk.net.socket.af_inet, qmsk.net.socket.af_inet6 |
| 6 | 104 |
|
105 |
SOCKADDR_BY_FAMILY = {
|
|
|
24
f18b5787c46c
reorganize socket, adding af_inet/af_inet6 modules, and moving sctp in
Tero Marttila <terom@fixme.fi>
parents:
23
diff
changeset
|
106 |
platform.AF_INET: qmsk.net.socket.af_inet.sockaddr_in, |
|
f18b5787c46c
reorganize socket, adding af_inet/af_inet6 modules, and moving sctp in
Tero Marttila <terom@fixme.fi>
parents:
23
diff
changeset
|
107 |
platform.AF_INET6: qmsk.net.socket.af_inet6.sockaddr_in6, |
| 6 | 108 |
} |
109 |
||
110 |
# build a sockaddr from the given sockaddr struct, based on sa_family |
|
| 10 | 111 |
cdef sockaddr build_sockaddr (platform.sockaddr *sa, size_t sa_len) : |
| 6 | 112 |
# lookup correct class to use |
113 |
addr_type = SOCKADDR_BY_FAMILY[sa.sa_family] |
|
114 |
||
115 |
# construct with defaults |
|
116 |
cdef sockaddr addr = addr_type() |
|
117 |
||
118 |
# store |
|
119 |
addr._set_sockaddr(sa, sa_len) |
|
120 |
||
121 |
return addr |
|
122 |
||
123 |
cdef class addrinfo : |
|
|
23
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
124 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
125 |
cdef _init_ai_members (self) : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
126 |
""" |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
127 |
Update self.ai.ai_* to reflect self.ai_* |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
128 |
""" |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
129 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
130 |
cdef platform.socklen_t addr_len |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
131 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
132 |
if self.ai_addr is not None : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
133 |
self.ai_addr._get_sockaddr(&self.ai.ai_addr, &addr_len) |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
134 |
self.ai.ai_addrlen = addr_len |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
135 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
136 |
else : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
137 |
self.ai.ai_addr = NULL |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
138 |
self.ai.ai_addrlen = 0 |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
139 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
140 |
if self.ai_canonname is not None : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
141 |
self.ai.ai_canonname = self.ai_canonname |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
142 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
143 |
else : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
144 |
self.ai.ai_canonname = NULL |
| 6 | 145 |
|
|
23
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
146 |
def __init__ (self, int flags = 0, int family = 0, int socktype = 0, int protocol = 0, sockaddr addr = None, object canonname = None) : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
147 |
""" |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
148 |
Construct a new addrinfo with the given parameters |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
149 |
""" |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
150 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
151 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
152 |
self.ai.ai_flags = flags |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
153 |
self.ai.ai_family = family |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
154 |
self.ai.ai_socktype = socktype |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
155 |
self.ai.ai_protocol = protocol |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
156 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
157 |
self.ai_addr = addr |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
158 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
159 |
if canonname is not None : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
160 |
self.ai_canonname = str(canonname) |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
161 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
162 |
else : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
163 |
self.ai_canonname = None |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
164 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
165 |
# update self.ai |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
166 |
self._init_ai_members() |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
167 |
|
| 10 | 168 |
cdef _init_addrinfo (self, platform.addrinfo *ai) : |
|
23
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
169 |
""" |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
170 |
Re-initialize this addrinfo's parameters from the given addrinfo |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
171 |
""" |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
172 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
173 |
# copy raw |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
174 |
self.ai = ai[0] |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
175 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
176 |
# store copies of external objects |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
177 |
if ai.ai_addr : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
178 |
# copy addr as object |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
179 |
self.ai_addr = build_sockaddr(ai.ai_addr, ai.ai_addrlen) |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
180 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
181 |
else : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
182 |
self.ai_addr = None |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
183 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
184 |
if ai.ai_canonname : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
185 |
# copy as object |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
186 |
self.ai_canonname = ai.ai_canonname |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
187 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
188 |
else : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
189 |
self.ai_canonname = None |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
190 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
191 |
# update self.ai |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
192 |
self._init_ai_members() |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
193 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
194 |
property flags : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
195 |
def __get__ (self) : return self.ai.ai_flags |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
196 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
197 |
property family : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
198 |
def __get__ (self) : return self.ai.ai_family |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
199 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
200 |
property socktype : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
201 |
def __get__ (self) : return self.ai.ai_socktype |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
202 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
203 |
property protocol : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
204 |
def __get__ (self) : return self.ai.ai_protocol |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
205 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
206 |
property addr : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
207 |
# XXX: None? |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
208 |
def __get__ (self) : return self.ai_addr |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
209 |
|
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
210 |
property canonname : |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
211 |
# XXX: None? |
|
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
212 |
def __get__ (self) : return self.ai_canonname |
| 6 | 213 |
|
214 |
def __str__ (self) : |
|
215 |
return "family=%d, socktype=%d, protocol=%d, addr=%s, canonname=%s" % (self.family, self.socktype, self.protocol, self.addr, self.canonname) |
|
216 |
||
| 10 | 217 |
cdef addrinfo build_addrinfo (platform.addrinfo *c_ai) : |
| 6 | 218 |
cdef addrinfo ai = addrinfo() |
219 |
||
220 |
ai._init_addrinfo(c_ai) |
|
221 |
||
222 |
return ai |
|
223 |
||
224 |
cdef class endpoint : |
|
225 |
||
226 |
def __init__ (self, hostname=None, service=None) : |
|
227 |
""" |
|
228 |
Construct with the given hostname/service, either of which may be None. |
|
229 |
||
230 |
A hostname of None implies all valid local addresses (with AI_PASSIVE), and a service of None implies an |
|
231 |
ephemeral port. |
|
232 |
||
233 |
hostname - the literal address or DNS hostname or anything else that GAI supports |
|
234 |
service - the numeric port or service name |
|
235 |
""" |
|
236 |
||
237 |
self.hostname = str(hostname) |
|
238 |
self.service = str(service) |
|
239 |
||
| 10 | 240 |
cpdef getaddrinfo (self, int family, int socktype, int protocol = 0, int flags = platform.AI_PASSIVE) : |
| 6 | 241 |
""" |
242 |
Look up our hostname/service using the given socket parameters, and return a sequence of addrinfo objects. |
|
|
27
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
243 |
|
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
244 |
family - the address family to use, one of AF_*. May be AF_UNSPEC. |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
245 |
socktype - the socket type to use, one of SOCK_*. |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
246 |
protocol - the protocol to use, one of IPPROTO_* or zero to pick a suitable protocol |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
247 |
for the given socktype. |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
248 |
flags - bitmask of AI_* flags for getaddrinfo() |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
249 |
|
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
250 |
AI_NUMERICHOST - self.hostname is a literal address, do not perform any network host address lookups |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
251 |
AI_NUMERICSERV - self.service is a literal port number, do not lookup service names |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
252 |
AI_CANONNAME - return addrinfo objects with .canonname set to the official name of the host |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
253 |
AI_PASSIVE - intended for use by server applications, return addrinfos with an unspecified |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
254 |
.addr if no self.hostname is not given. |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
255 |
AI_ADDRCONFIG - only return addrinfos with a .addrs of a given address family if the system has at |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
256 |
least one local address of that address family configured. |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
257 |
AI_V4MAPPED - if family=AF_INET6, and no matching IPv6 addresses could be found, return IPv4-mapped |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
258 |
IPv6 addresses. |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
259 |
AI_ALL - if used together with AI_V4MAPPED, then return both IPv6 and IPv4-mapped IPv6 |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
260 |
addresses. |
|
12468e38227e
[socket] add sockaddr_un (still dysfunctional\!) + doc fixes
Tero Marttila <terom@fixme.fi>
parents:
24
diff
changeset
|
261 |
|
| 6 | 262 |
""" |
263 |
||
264 |
# XXX: Cython doesn't support proper compound value literals... |
|
| 10 | 265 |
cdef platform.addrinfo hints |
| 6 | 266 |
|
267 |
libc.memset(&hints, 0, sizeof(hints)) |
|
268 |
hints.ai_flags = flags |
|
269 |
hints.ai_family = family |
|
270 |
hints.ai_socktype = socktype |
|
271 |
hints.ai_protocol = protocol |
|
272 |
||
| 10 | 273 |
cdef platform.addrinfo *res, *r |
| 6 | 274 |
cdef int err |
275 |
cdef object ret = [] |
|
276 |
||
277 |
cdef char *hostname = NULL |
|
278 |
cdef char *service = NULL |
|
279 |
||
280 |
if self.hostname is not None : |
|
281 |
hostname = self.hostname |
|
282 |
||
283 |
if self.service is not None : |
|
284 |
service = self.service |
|
285 |
||
286 |
# operate! |
|
| 10 | 287 |
err = platform.c_getaddrinfo(hostname, service, &hints, &res) |
| 6 | 288 |
|
|
43
9fdef438e3a2
fix getaddrinfo crash in case of errors
Tero Marttila <terom@fixme.fi>
parents:
27
diff
changeset
|
289 |
if err : |
|
9fdef438e3a2
fix getaddrinfo crash in case of errors
Tero Marttila <terom@fixme.fi>
parents:
27
diff
changeset
|
290 |
# XXX: raise a GAIError |
|
9fdef438e3a2
fix getaddrinfo crash in case of errors
Tero Marttila <terom@fixme.fi>
parents:
27
diff
changeset
|
291 |
raise Exception(platform.gai_strerror(err)) |
|
9fdef438e3a2
fix getaddrinfo crash in case of errors
Tero Marttila <terom@fixme.fi>
parents:
27
diff
changeset
|
292 |
|
| 6 | 293 |
try : |
|
23
15d8bb96b8d4
fix up addrinfo to hold a real platform.addrinfo, storing ai_addr/ai_canonname as objects
Tero Marttila <terom@fixme.fi>
parents:
22
diff
changeset
|
294 |
# gather results from linked list to PyList |
| 6 | 295 |
r = res |
296 |
||
297 |
while r : |
|
298 |
ret.append(build_addrinfo(r)) |
|
299 |
||
300 |
r = r.ai_next |
|
301 |
||
302 |
# ok |
|
303 |
return ret |
|
304 |
||
305 |
finally : |
|
| 10 | 306 |
platform.c_freeaddrinfo(res) |
| 6 | 307 |
|
308 |
def __str__ (self) : |
|
309 |
return "hostname=%s, service=%s" % (self.hostname, self.service) |
|
310 |