Changeset 365

Timestamp:

07/23/09 11:02:27 (15 years ago)

Author:

sriram

Message:

This does not work..keeping a backup

Files:

• vtcross/branches/sriram/benchmark_txrxnode1.py (modified) (8 diffs)

vtcross/branches/sriram/benchmark_txrxnode1.py

@@ -54 +54 @@
 
         
-        #print "inside rx callback"
+        print "inside rx callback"
         global n_rcvd, n_right, sync_status,mode,hop_freq
         #tb.rxpath.min_freq = hop_freq - 80e3 
         #tb.rxpath.max_freq = hop_freq + 80e3 
         #tb.rxpath.get_spec_stats(1e13,20,2)
-        (pktno,) = struct.unpack('!H', payload[0:2])
         #temp = struct.unpack('!s', payload[3:10])
         #print "printing the elements of packet",temp,"!!!!!!!!!!!\n"
         #####################################################
         if mode == "sync":
-                (sync_signal,) = struct.unpack('!s', payload[2]) 
-                (sync_signal_red,) = struct.unpack('!s', payload[3])  #redundant sync bit
-                (data_channel,) = struct.unpack('!s', payload[4])
-                (data_channel_red,) = struct.unpack('!s', payload[5])  #redundant channel bit
-                #print "printing the elements of packet  ",sync_signal,"  !!!!!!!!!!!  ",sync_signal_red," !!!!!\n"    
-                #print "printing the channel  ",data_channel_red,"  !!!!!!!!!!!  ",data_channel_red," !!!!!\n"
-                if ok: #== True :# and str(sync_signal) == 'o' and str(sync_signal_red) == 'o':
-                        #print "inside if"
-                        if ok: #== True: #str(data_channel) == str(data_channel_red):
-                                #print "inside if1$$$$$"
-                                if str(data_channel) == str(ch):
-                                        #print "inside if2"
-                                        sync_status = True
-                                        #tb.stop()
-                                        #print "after tb stop ans sync status is ",sync_status," sync status\n"
-                                        #print "received a sync packet on channel %s\n" %(data_channel)
-                                        #data = 'o'+'o'+str(data_channel)+str(data_channel)
-                                        #print "sending this data",data,"@@@@@\n"
-                                        #sync_pktno=0
-                                        #ack_payload = struct.pack('!H', sync_pktno & 0xffff) + data
-                                        #print "printing the ack packet",ack_payload,"$$$$$\n"
-                                        #k=0
-                                        #while k < 10000:
-                                        #print "inside while"
-                                        #send_pkt(tb,ack_payload) #sending back the acknowledgement
-                                        #k=k+1
+                if ok:
+                        (pktno,) = struct.unpack('!H', payload[0:2])
+                        (sync_signal,) = struct.unpack('!s', payload[2]) 
+                        (sync_signal_red,) = struct.unpack('!s', payload[3])  #redundant sync bit
+                        (data_channel,) = struct.unpack('!s', payload[4])
+                        (data_channel_red,) = struct.unpack('!s', payload[5])  #redundant channel bit
+                        #print "printing the elements of packet  ",sync_signal,"  !!!!!!!!!!!  ",sync_signal_red," !!!!!\n"    
+                        #print "printing the channel  ",data_channel_red,"  !!!!!!!!!!!  ",data_channel_red," !!!!!\n"
+                        #== True :# and str(sync_signal) == 'o' and str(sync_signal_red) == 'o':
+                        if str(data_channel) == str(ch):
+                                #print "inside if2"
+                                sync_status = True
+                                #tb.stop()
+                                #print "after tb stop ans sync status is ",sync_status," sync status\n"
+                                #print "received a sync packet on channel %s\n" %(data_channel)
+                                #data = 'o'+'o'+str(data_channel)+str(data_channel)
+                                #print "sending this data",data,"@@@@@\n"
+                                #sync_pktno=0
+                                #ack_payload = struct.pack('!H', sync_pktno & 0xffff) + data
+                                #print "printing the ack packet",ack_payload,"$$$$$\n"
+                                #k=0
+                                #while k < 10000:
+                                #print "inside while"
+                                #send_pkt(tb,ack_payload) #sending back the acknowledgement
+                                #k=k+1
         #####################################################
         
         ######################### traffic ############################
         if mode == "traffic":
-                (data_header,) = struct.unpack('!s', payload[0])
-                if ok and data_header == 'd':
-                        comm = struct.unpack('!14s', data)
-                        print("received this ", comm) 
+                print "Mode is ",mode,"received traffic packet\n"
+                if ok:
+                        (data_header,) = struct.unpack('!s', payload[0])
+                        if data_header == 'd':
+                                (comm,) = struct.unpack('!14s', payload[1:15])
+                                print "received this ", comm,"\n"
+                else :
+                        print"not ok"
         
         ##############################################################
@@ -236 +238 @@
     #resend_count= 0 #initializing resend count
     sync_pktno = 0
-    ch = int(random.choice('17'))
+    #ch = int(random.choice('17'))
     while running:
         ################################################sync mode####################################
@@ -245 +247 @@
                 pkt_size = 6
                 data_pktno = 0 
-                print "printing packet size",pkt_size,"pkt size\n"
+                #print "printing packet size",pkt_size,"pkt size\n"
                 while sync_status != True:
                         #ch = random.randint(1, 7)
-                        ch = int(random.choice('17'))
+                        ch = int(random.choice('37'))
                         
                         #ch = random.randint(6,12)
                         #ch = 1
                         hop_freq = float(1e6 * (462.5625+(ch-1)*0.025))#setting the centre freq frequency for sending packets
+                        print "hop freq is ",hop_freq
                         tb.rxpath.min_freq = hop_freq - 80e3 
                         tb.rxpath.max_freq = hop_freq + 80e3 
                         is_present = tb.rxpath.get_spec_stats(1e13,1) #check if primary user is present
                         if is_present == True: #if primary user is there then dont transmit on this channel
+                                print "Cant use this channel..Primary user detected\n"
                                 continue 
                                         
@@ -262 +266 @@
                         #print "primary user present = ",is_present,"\n"
                         #tb.rxpath.get_spec_stats(10)  
-                        print "hop freq is ",hop_freq
+                        
                         
                         #hop_freq = float(1e6 * (462.5625+(5-1)*0.05))#setting the centre freq frequency for sending packets
@@ -277 +281 @@
                         print >> myfile, "out"
                         while n < nbytes:
-                                print >> myfile, "inside while"
+                                #print >> myfile, "inside while"
                                 if options_tx.from_file is None:
                                         #data = (pkt_size - 2) * chr(sync_pktno & 0xff) #0xff is 255
@@ -318 +322 @@
                 pkt_size = 15
                 sync_pktno = 0
+                n = 0
                 while n < nbytes:
                         #print >> myfile, "inside while"
@@ -335 +340 @@
                                 
                         send_pkt(tb,payload)
+                        time.sleep(0.5)
                         #print "printing payload",payload,"**\n"
                         n += len(payload)
@@ -342 +348 @@
                         data_pktno += 1
                         #print "before sleeping for 10 seconds and value of resend count is",resend_count
-                        #time.sleep(0.1)
+                        
                         tb.rxpath.min_freq = hop_freq - 80e3 
                         tb.rxpath.max_freq = hop_freq + 80e3 
-                        is_present = tb.rxpath.get_spec_stats(1e13,10) #check if primary user is present
+                        is_present = tb.rxpath.get_spec_stats(1e13,1) #check if primary user is present
                         if is_present == True: #if primary user is present then get out of this communication channel, back to sync mode.
                                 mode = "sync"
-                                
+                                sync_status = False
+                                print "Moving out of this channel..Primary user detected\n"
         ################################################ end of Communications mode####################################