| 49 | self.status_notify = None |
| 50 | |
| 51 | def createSocket(self): |
| 52 | # proxytype = None |
| 53 | # proxy = None |
| 54 | # if self.proxies.has_key("socks5"): |
| 55 | # proxytype = socks.PROXY_TYPE_SOCKS5 |
| 56 | # proxy = self.proxies["socks5"] |
| 57 | # elif self.proxies.has_key("socks4"): |
| 58 | # proxytype = socks.PROXY_TYPE_SOCKS4 |
| 59 | # proxy = self.proxies["socks4"] |
| 60 | # if proxytype: |
| 61 | # sock = socks.socksocket() |
| 62 | # t = _parse_proxy(proxy) |
| 63 | # sock.setproxy(proxytype, addr=t[3].split(":")[0], port=int(t[3].split(":")[1]), username=t[1], password=t[2]) |
| 64 | # else: |
| 65 | # sock = socket.socket() |
| 66 | # return sock |
| 67 | |
| 68 | sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
| 69 | # sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 16384) |
| 70 | |
| 71 | return sock |
| 72 | |
| 73 | def _write_func(self, buf): |
| 74 | size = len(buf) |