| | |
|---|
| | | port = GetConfig().GetServerPort()
|
|---|
| | | logging.debug( "Connect to %s:%d", ip, port )
|
|---|
| | | self.__peer = self.__mgr.CreatePeer()
|
|---|
| | | logging.debug( "create __peer:0x%08X", self.GetPeerValue() )
|
|---|
| | | logging.info( "create %s __peer:0x%08X", self.__params[1], self.GetPeerValue() )
|
|---|
| | |
|
|---|
| | | #注册回调
|
|---|
| | | logging.debug( "register callback function for 0x%08X" % self.GetPeerValue() )
|
|---|
| | |
|---|
| | | self.allsend += sendPack.GetLength()
|
|---|
| | | logging.debug( "%s send %d bytes data. recvAll:%d sendAll:%d ALL:%d" % \
|
|---|
| | | ( str(self), sendPack.GetLength(), self.allrecv, self.allsend, self.allrecv+self.allsend ) )
|
|---|
| | | if not self.__peer:
|
|---|
| | | return
|
|---|
| | | self.__mgr.SendData( self.__peer, sendPack.GetBuffer(), sendPack.GetLength() )
|
|---|
| | |
|
|---|
| | |
|
|---|
