GObject断开连接处理程序

import gobject
import socket

class ConnectionHandler(gobject.GObject):
    def __init__(self):
        super(ConnectionHandler, self).__init__()
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.socket.setblocking(False)
        self.socket.connect_ex(('example.com', 80))
        self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        
        # 注册断开连接处理程序
        self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_LINGER, struct.pack('ii', 1, 0))
        self.socket.close()
        gobject.io_add_watch(self.socket, gobject.IO_IN | gobject.IO_ERR | gobject.IO_HUP, self.on_disconnect)

    def on_disconnect(self, source, condition):
        if condition & gobject.IO_ERR or condition & gobject.IO_HUP:
            print("Connection lost. Cleaning up...")
            self.socket.close()
            # 执行其他清理操作
        return False  # 停止监视此文件描述符

if __name__ == "__main__":
    loop = gobject.MainLoop()
    handler = ConnectionHandler()
    loop.run()