(self, proxy)
| 130 | self.get_proxies() |
| 131 | |
| 132 | def delete_proxy(self, proxy): |
| 133 | # it's not thread safe |
| 134 | self.pool.pop(0) |
| 135 | pipe = self.conn.pipeline(True) |
| 136 | pipe.srem(DATA_ALL, proxy) |
| 137 | pipe.zrem(self.score_queue, proxy) |
| 138 | pipe.zrem(self.speed_queue, proxy) |
| 139 | pipe.zrem(self.ttl_queue, proxy) |
| 140 | pipe.execute() |