Changeset 1005

Show
Ignore:
Timestamp:
08/08/08 12:57:05 (3 months ago)
Author:
locklainn.linden
Message:

presence started, now to find the av cloud

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • projects/2008/pyogp/pyogp.interop/trunk/pyogp/interop/tests/test_ogp_teleport.py

    r1004 r1005  
    135135                                MsgType.MVT_U32) 
    136136        self.messenger.send_reliable(self.host, 0) 
    137  
     137         
    138138        while True: 
    139139            recv_message = '' 
     
    153153        avatar = place(tp_region)         
    154154 
     155        self.host = Host(avatar.region.details['sim_ip'], 
     156                    avatar.region.details['sim_port']) 
     157 
     158        #SENDS UUIDNameRequest 
     159        self.messenger.new_message("UUIDNameRequest") 
     160        self.messenger.next_block("UUIDNameBlock") 
     161        self.messenger.add_data("ID", \ 
     162                                uuid.UUID(self.agent_id), \ 
     163                                MsgType.MVT_LLUUID) 
     164        self.messenger.send_message(self.host) 
     165         
    155166        print "Entering loop" 
     167        last_ping = 0 
    156168        while True: 
    157169            recv_message = '' 
    158170            if self.messenger.receive_check() == True: 
    159171                recv_message = self.messenger.reader.current_msg 
    160                 print 'Message received: ' + recv_message.name 
     172                print 'Received: ' + recv_message.name + ' from  ' + self.messenger.udp_client.sender.ip + ":" + \ 
     173                                                  str(self.messenger.udp_client.sender.port) 
     174 
     175                #MESSAGE HANDLERS 
     176                if recv_message.name == 'RegionHandshake': 
     177                    self.send_region_handshake_reply(self.agent_id, self.session_id) 
     178                elif recv_message.name == 'StartPingCheck': 
     179                    self.send_complete_ping_check(last_ping) 
     180                    last_ping += 1 
     181                     
     182                 
    161183            else: 
    162184                print 'No message' 
     
    173195        self.messenger.next_block("AgentData") 
    174196        self.messenger.add_data('AgentID', \ 
    175                                 uuid.UUID(agent_id), \ 
    176                                 MsgType.MVT_LLUUID) 
    177         self.messenger.add_data('SessionID', \ 
    178                                 uuid.UUID(avatar.region.details['session_id']), \ 
     197                                uuid.UUID(self.agent_id), \ 
     198                                MsgType.MVT_LLUUID) 
     199        self.messenger.add_data('SessionID', \ 
     200                                uuid.UUID(self.session_id), \ 
    179201                                MsgType.MVT_LLUUID) 
    180202        self.messenger.send_message(self.host) 
     
    221243        self.messenger.send_message(self.host) 
    222244 
     245    def send_region_handshake_reply(self, agent_id, session_id): 
     246        self.messenger.new_message("RegionHandshakeReply") 
     247        self.messenger.next_block("AgentData") 
     248        self.messenger.add_data('AgentID', \ 
     249                                uuid.UUID(agent_id), \ 
     250                                MsgType.MVT_LLUUID) 
     251        self.messenger.add_data('SessionID', \ 
     252                                uuid.UUID(session_id), \ 
     253                                MsgType.MVT_LLUUID) 
     254        self.messenger.next_block("RegionInfo") 
     255        self.messenger.add_data('Flags', \ 
     256                                0x00, \ 
     257                                MsgType.MVT_U32) 
     258        self.messenger.send_message(self.host) 
    223259     
     260    def send_complete_ping_check(self, ping): 
     261        self.messenger.new_message("CompletePingCheck") 
     262        self.messenger.next_block("PingID") 
     263        self.messenger.add_data('PingID', \ 
     264                                ping, \ 
     265                                MsgType.MVT_U8) 
     266        self.messenger.send_message(self.host) 
     267 
    224268def test_suite(): 
    225269    from unittest import TestSuite, makeSuite 
  • projects/2008/pyogp/pyogp.lib.base/trunk/pyogp/lib/base/message/message_system.py

    r1004 r1005  
    164164        """ This is a retry because we didn't get acked """ 
    165165        #sets up the message so send_message will add the RETRY flag to it 
    166         print 'Sending retry' 
    167166        self.send_flags |= PackFlags.LL_RESENT_FLAG 
    168167        self.send_message(host, message_buf)                 
     
    218217            append_ack_count = self.packer.pack_data(ack_count, MsgType.MVT_U8) 
    219218            message_buf += append_ack_count 
    220             print 'Adding ack count: ' + append_ack_count 
    221  
    222         print "Message buf: " + repr(message_buf) 
     219            #print 'Adding ack count: ' + append_ack_count 
     220 
     221        #print "Message buf: " + repr(message_buf) 
    223222 
    224223        #now that the pre-message data is added, add the real data to the end 
     
    302301    def new_message(self, message_name): 
    303302        if self.message_dict[message_name] == None: 
    304             return 
    305  
    306         flavor = self.message_dict.get_message_flavor(message_name) 
    307         if flavor == 'template': 
    308303            self.builder = self.template_builder 
    309         elif flavor == 'llsd': 
    310             self.builder = self.llsd_builder 
     304        else: 
     305            flavor = self.message_dict.get_message_flavor(message_name) 
     306            if flavor == 'template': 
     307                self.builder = self.template_builder 
     308            elif flavor == 'llsd': 
     309                self.builder = self.llsd_builder 
    311310 
    312311        self.reliable_msg = False