首页 手机软件 手机游戏 单机游戏 资讯文章 专题下载 游戏合集 文章合集 php下载 php教程 电脑软件
+ -
当前位置：首页 → 问答吧 → 一段錯誤訊息

一段錯誤訊息

时间：2010-12-27

来源：互联网

  1. # -*- coding: utf-8 -*-

  3. import socket
  4. import asyncore


  7. servicePort = 443


  10. serviceHostAddress = 'ptt.cc'
  11. serviceHostPort = 443

  13. class AgentClient(asyncore.dispatcher_with_send):

  15.     def __init__(self, otherSocket=None):
  16.         asyncore.dispatcher_with_send.__init__(self, otherSocket)


  19.         self.client = False

  21.         self.ready = False

  23.         self.other = None

  25.         if not otherSocket:
  26.             self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
  27.         else:
  28.             self.client = True

  30.     def handle_error(self):


  33.         print "Error"
  34.         self.handle_close()

  36.     def handle_read(self):

  38.         
  39.         if self.other and self.other.ready:
  40.             data = self.recv(4096)

  42.             if data:
  43.                 self.other.send(data)

  45.     def handle_connect(self):

  47.         
  48.         self.ready = True
  49.         self.other.ready = True

  51.     def handle_close(self):


  54.         if self.client:
  55.             print "Close connection from : " + self.socket.getpeername()[0]
  56.         
  57.         self.ready = False
  58.         self.close()
  59.         if self.other and self.other.ready:
  60.             self.other.handle_close()

  62. class AgentServer(asyncore.dispatcher):

  64.    
  65.     def __init__(self, port):
  66.         asyncore.dispatcher.__init__(self)

  68.         self.port = port
  69.         self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
  70.         self.bind(('', self.port))
  71.         self.listen(5)
  72.    
  73.     def handle_accept(self):

  75.         
  76.         clientSocket, address = self.accept()
  77.         print 'New client from : ' + address[0]
  78.         
  79.         agentClient = AgentClient(clientSocket)
  80.         agentHost = AgentClient()


  83.         try:
  84.             agentHost.connect((serviceHostAddress, serviceHostPort))
  85.         except socket.error, (socketError, errorMessage):
  86.             print 'Failed to connect %s : %s' % (serviceHostAddress, errorMessage)
  87.             agentClient.handle_close()
  88.             return

  90.         agentHost.other = agentClient
  91.         agentClient.other = agentHost

  93. def cleanSocketMapUp():

  95.    

  97.     # RuntimeError: dictionary changed size during iteration
  98.     for fileno in asyncore.socket_map.keys():
  99.         asyncore.socket_map[fileno].close()

  101. agentServer = AgentServer(servicePort)
  102. print "Agent is serving at %d and target to %s:%d ..." % (servicePort, serviceHostAddress, serviceHostPort)
  103. print "Press Ctrl + C to stop service."
  104.    
  105. try:
  106.     asyncore.loop(1)
  107. except KeyboardInterrupt:
  108.     print "Stop agent service."
  109. finally:
  110.     agentServer.close()
  111.     cleanSocketMapUp()
复制代码
我是在linux 用 nohup 運行上面的代碼 , 那我發現它運行一陣子會掛掉

下面是他出現錯誤,是nohup.out的紀錄請問下面這段訊息是什麼原因造成?
  1.   1 Agent is serving at 443 and target to ptt.cc:443 ...
  2.   2 Press Ctrl + C to stop service.
  3.   3 New client from : 114.35.133.52
  4.   4 New client from : 222.79.245.84
  5.   5 Error
  6.   6 Traceback (most recent call last):
  7.   7   File "ptt.py", line 106, in <module>
  8.   8     asyncore.loop(1)
  9.   9   File "/usr/lib/python2.6/asyncore.py", line 202, in loop
  10. 10     poll_fun(timeout, map)
  11. 11   File "/usr/lib/python2.6/asyncore.py", line 143, in poll
  12. 12     read(obj)
  13. 13   File "/usr/lib/python2.6/asyncore.py", line 80, in read
  14. 14     obj.handle_error()
  15. 15   File "ptt.py", line 34, in handle_error
  16. 16     self.handle_close()
  17. 17   File "ptt.py", line 55, in handle_close
  18. 18     print "Close connection from : " + self.socket.getpeername()[0]
  19. 19   File "<string>", line 1, in getpeername
  20. 20 socket.error: [Errno 107] Transport endpoint is not connected
复制代码

作者: shihyu   发布时间: 2010-12-27

感觉像是socket已经断开了，不需要close了。

作者: nmweizi   发布时间: 2010-12-27

相关阅读 更多

热门阅读

热门下载

更多
关于本站 免责申明 联系我们

Copyright 2006-2020 php爱好者(phpfans.net) All Rights Reserved.备案号：湘ICP备2023016114号-2

本站为非盈利性网站，不接受任何广告。本站所有资源均由网友上传，如有侵权，请发邮件至 [email protected] phpfans.net