Changeset 1005
- Timestamp:
- 08/08/08 12:57:05 (3 months ago)
- Files:
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
projects/2008/pyogp/pyogp.interop/trunk/pyogp/interop/tests/test_ogp_teleport.py
r1004 r1005 135 135 MsgType.MVT_U32) 136 136 self.messenger.send_reliable(self.host, 0) 137 137 138 138 while True: 139 139 recv_message = '' … … 153 153 avatar = place(tp_region) 154 154 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 155 166 print "Entering loop" 167 last_ping = 0 156 168 while True: 157 169 recv_message = '' 158 170 if self.messenger.receive_check() == True: 159 171 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 161 183 else: 162 184 print 'No message' … … 173 195 self.messenger.next_block("AgentData") 174 196 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), \ 179 201 MsgType.MVT_LLUUID) 180 202 self.messenger.send_message(self.host) … … 221 243 self.messenger.send_message(self.host) 222 244 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) 223 259 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 224 268 def test_suite(): 225 269 from unittest import TestSuite, makeSuite projects/2008/pyogp/pyogp.lib.base/trunk/pyogp/lib/base/message/message_system.py
r1004 r1005 164 164 """ This is a retry because we didn't get acked """ 165 165 #sets up the message so send_message will add the RETRY flag to it 166 print 'Sending retry'167 166 self.send_flags |= PackFlags.LL_RESENT_FLAG 168 167 self.send_message(host, message_buf) … … 218 217 append_ack_count = self.packer.pack_data(ack_count, MsgType.MVT_U8) 219 218 message_buf += append_ack_count 220 print 'Adding ack count: ' + append_ack_count221 222 print "Message buf: " + repr(message_buf)219 #print 'Adding ack count: ' + append_ack_count 220 221 #print "Message buf: " + repr(message_buf) 223 222 224 223 #now that the pre-message data is added, add the real data to the end … … 302 301 def new_message(self, message_name): 303 302 if self.message_dict[message_name] == None: 304 return305 306 flavor = self.message_dict.get_message_flavor(message_name)307 if flavor == 'template':308 303 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 311 310 312 311 self.reliable_msg = False
