loadbalancerTCP.py 文件源码

def send(self, data):
        logging.debug('\tAdding {}b packet  to  buffer'.format(len(data)))
        self.out_buffer.append(data)
        self.initiate_send()


# NOTE: dispatcher already connects before send, when disconnected, right?
#    def send(self, data):
#        """ Wrap the builtin send with a reconnector """
#        try:
#            asyncore.dispatcher_with_send.send(self, data)
#        except socket.error as e:
#            if e.errno == 32:
#                self.loadbalancer_connect()
#            else:
#                logging.exception("{} - Could not send data because: {}".format(self, e.strerror))