Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 2012-08-27 17:26:50,261 UNHANDLED EXCEPTION (2012-08-27 17:26:50.259687)
- Working directory: /opt/noc
- <type 'exceptions.OSError'>
- [Errno 9] Bad file descriptor
- START OF TRACEBACK
- ------------------------------------------------------------------------
- File: /opt/noc/lib/nbsocket/pollers/keventpoller.py (Line: 35)
- Function: add_reader
- 28 :return:
- 29 """
- 30 if sock in self.readers:
- 31 return
- 32 f = sock.fileno()
- 33 self.kqueue.control([
- 34 select.kevent(f, select.KQ_FILTER_READ,
- 35 ==> select.KQ_EV_ADD)], 0)
- 36 self.readers.add(sock)
- 37 self.sockets[f] = sock
- 38
- 39 def add_writer(self, sock):
- 40 """
- 41 Add writer to poller
- Variables:
- self = <noc.lib.nbsocket.pollers.keventpoller.KEventPoller object at 0x803c200d0>
- sock = <ListenTCPSocket(0x803c20110)>
- f = 8
- ------------------------------------------------------------------------
- File: /opt/noc/lib/nbsocket/socketfactory.py (Line: 185)
- Function: set_status
- 178 self.init_socket(socket, name)
- 179
- 180 def set_status(self, sock, r=None, w=None):
- 181 logging.debug("set_status(%s, r=%s, w=%s)" % (sock, r, w))
- 182 with self.register_lock:
- 183 if r is not None:
- 184 if r:
- 185 ==> self.poller.add_reader(sock)
- 186 else:
- 187 self.poller.remove_reader(sock)
- 188 if w is not None:
- 189 if w:
- 190 self.poller.add_writer(sock)
- 191 if not self.write_delay:
- Variables:
- self = <noc.lib.nbsocket.socketfactory.SocketFactory object at 0x803c0f610>
- r = True
- sock = <ListenTCPSocket(0x803c20110)>
- w = None
- ------------------------------------------------------------------------
- File: /opt/noc/lib/nbsocket/basesocket.py (Line: 182)
- Function: set_status
- 175 def update_status(self):
- 176 """
- 177 Update socket status to indicate socket still active
- 178 """
- 179 self.last_read = time.time()
- 180
- 181 def set_status(self, r=None, w=None):
- 182 ==> self.factory.set_status(self, r=r, w=w)
- 183
- 184 def is_stale(self):
- 185 """
- 186 Check socket is stale.
- 187 Called by SocketFactory.close_stale to determine
- 188 should socket be closed forcefully
- Variables:
- self = <ListenTCPSocket(0x803c20110)>
- r = True
- w = None
- ------------------------------------------------------------------------
- File: /opt/noc/lib/nbsocket/basesocket.py (Line: 50)
- Function: create_socket
- 43 """
- 44 Performs actial socket creation and initialization
- 45 and pust socket into nonblocking mode.
- 46 """
- 47 if not self.socket_is_ready(): # Socket was not created
- 48 raise SocketNotImplemented()
- 49 self.socket.setblocking(0)
- 50 ==> self.set_status(r=True)
- 51 self.update_status()
- 52
- 53 def set_timeout(self, ttl):
- 54 """
- 55 Change socket timeout
- 56
- Variables:
- self = <ListenTCPSocket(0x803c20110)>
- ------------------------------------------------------------------------
- File: /opt/noc/lib/nbsocket/listentcpsocket.py (Line: 56)
- Function: create_socket
- 49 self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- 50 self.socket.setsockopt(
- 51 socket.SOL_SOCKET,
- 52 socket.SO_REUSEADDR,
- 53 self.socket.getsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR) | 1)
- 54 self.socket.bind((self.address, self.port))
- 55 self.socket.listen(self.backlog)
- 56 ==> super(ListenTCPSocket, self).create_socket()
- 57
- 58 def handle_read(self):
- 59 """Handle new connections."""
- 60 s, addr = self.socket.accept()
- 61 if self.socket_class.check_access(addr[0]):
- 62 self.socket_class(self.factory, s, **self.kwargs)
- Variables:
- self = <ListenTCPSocket(0x803c20110)>
- ------------------------------------------------------------------------
- File: /opt/noc/lib/nbsocket/socketfactory.py (Line: 93)
- Function: guarded_socket_call
- 86 Wrapper for safe call of socket method. Handles and reports
- 87 socket errors.
- 88
- 89 :return: Call status
- 90 :rtype: Bool
- 91 """
- 92 try:
- 93 ==> method()
- 94 except Exception:
- 95 exc = get_socket_error()
- 96 try:
- 97 if exc:
- 98 socket.on_error(exc)
- 99 else:
- Variables:
- self = <noc.lib.nbsocket.socketfactory.SocketFactory object at 0x803c0f610>
- socket = <ListenTCPSocket(0x803c20110)>
- exc = None
- method = <bound method ListenTCPSocket.create_socket of <ListenTCPSocket(0x803c20110)>>
- ------------------------------------------------------------------------
- END OF TRACEBACK
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement