Changeset 339

Timestamp:

07/17/09 20:39:00 (15 years ago)

Author:

sriram

Message:

Changes

Files:

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

vtcross/branches/sriram/benchmark_txrxnode1.py

@@ -18 +18 @@
 from transmit_path import transmit_path
 from receive_path import receive_path
-import spec_sense_path
+#import spec_sense_path
 
 global sync_status
@@ -38 +38 @@
         
         ########connect for the spectrum sense#########
-        default_min_freq = 462.4825e6 #80 Khz to the left of channel 1 (462.5625e6) in frs band 
-        default_max_freq = 462.6425e6 #80 Khz to the right of channel 1 (462.5625e6) in frs band 
-        self.sp_sense_path = spec_sense_path.spec_sense_top_block(default_min_freq,default_min_freq)
-        self.connect(self.sp_sense_path.u, self.sp_sense_path.s2v, self.sp_sense_path.fft, self.sp_sense_path.c2mag, self.sp_sense_path.stats)
-        #self.connect(self.txpath);
-        #self.connect(self.rxpath);
+        #default_min_freq = 462.4825e6 #80 Khz to the left of channel 1 (462.5625e6) in frs band 
+        #default_max_freq = 462.6425e6 #80 Khz to the right of channel 1 (462.5625e6) in frs band 
+        #self.sp_sense_path = spec_sense_path.spec_sense_top_block(default_min_freq,default_min_freq)
+        #self.connect(self.sp_sense_path.u, self.sp_sense_path.s2v, self.sp_sense_path.fft, self.sp_sense_path.c2mag, self.sp_sense_path.stats)
+
+        self.connect(self.txpath);
+        self.connect(self.rxpath);
 
         
 #//////main//////  
 
-global n_rcvd, n_right
+global n_rcvd, n_right,hop_freq
 
 def main():
-    global n_rcvd, n_right,sync_status,mode
+    global n_rcvd, n_right,sync_status,mode,hop_freq
     n_rcvd = 0
     n_right = 0
@@ -58 +59 @@
 
     def rx_callback(ok, payload):
+
+        
         #print "inside rx callback"
-        global n_rcvd, n_right, sync_status,mode
+        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_avg_power(10)
         (pktno,) = struct.unpack('!H', payload[0:2])
         #temp = struct.unpack('!s', payload[3:10])
@@ -78 +84 @@
                                         #print "inside if2"
                                         sync_status = True
-                                        tb.stop()
+                                        #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)
@@ -137 +143 @@
     options_tx.fusb_block_size = 4096
     options_tx.fusb_nblocks = 16
+    options_tx.bitrate = 0.0125e6
     #############
     if options_tx.tx_freq is None:
@@ -183 +190 @@
     options_rx.fusb_block_size = 4096
     options_rx.fusb_nblocks = 16
+    options_rx.bitrate = 0.0125e6
     #############
     if options_rx.rx_freq is None:
@@ -193 +201 @@
 
     ######################## adding another top block for usrp spectrum sense ########################
-    trials = 10
+    #This is not needed anymore
+    #trials = 10
     
     #tb_spec_sense = spec_sense_top_block(default_min_freq,default_min_freq)
@@ -215 +224 @@
        print "Warning: failed to enable realtime scheduling"
 
-    #tb.start()
+    tb.start()
+    #tb.rxpath.get_avg_power(10) #10 is the number of fft frames that we are looking at to determine the average power
     # generate and send packets
     #print "printing megamytes",options_tx.megabytes,"  $$$$\n"
@@ -237 +247 @@
     #resend_count= 0 #initializing resend count
     #while running
-    
+    if mode  == "sync":
+        #nbytes = int(1e6 * .0003)
+        #nbytes = int(1e6 * .0003)
+        nbytes = 6
+        pkt_size = 6
+        print "printing packet size",pkt_size,"pkt size\n"
+        while sync_status != True:
+                #ch = random.randint(1, 7)
+                #ch = int(random.choice('17'))
+                #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
+                
+                #hop_freq = float(1e6 * (462.5625+(5-1)*0.05))#setting the centre freq frequency for sending packets
+                tb.txpath.set_freq(hop_freq)
+                tb.rxpath.set_freq(hop_freq)
+                #print "inside while pppp printing sync channel",sync_status,"  done"
+                #if sync_status == "True":
+                #print "synchronization done..data channel is found"
+                #break
+                #else:
+                #print "inside else1"
+                n = 0
+                pktno = 0
+                print >> myfile, "out"
+                while n < nbytes:
+                        print >> myfile, "inside while"
+                        if options_tx.from_file is None:
+                                #data = (pkt_size - 2) * chr(pktno & 0xff) #0xff is 255
+                                data = 's'+'s'+str(ch)+str(ch) #adding redundant bits for sync and channel
+                                #print >> myfile, data
+                                #print "printing data",data,"****\n"
+                        else:
+                                data = source_file.read(pkt_size - 2)
+                                if data == '':
+                                        break;
+
+                        payload = struct.pack('!H', pktno & 0xffff) + data
+                        #print "printing payload",payload,"**\n"
+                        
+                        send_pkt(tb,payload)
+                        #print "printing payload",payload,"**\n"
+                        n += len(payload)
+                        sys.stderr.write('.')
+                        if options_tx.discontinuous and pktno % 5 == 4:
+                                time.sleep(1)
+                        pktno += 1
+                        #print "before sleeping for 10 seconds and value of resend count is",resend_count
+
+                tb.rxpath.min_freq = hop_freq - 80e3 
+                tb.rxpath.max_freq = hop_freq + 80e3 
+                tb.rxpath.get_avg_power(10) #10 is the number of fft frames that we are looking at to determine the average power
+
+                time.sleep(0.05)
+                #time.sleep(2)
+                #resend_count += 1 
+    print "sync channel found! and it is channel ",ch,"\n"
+    send_pkt(tb,eof=True)
+    #myfile.close()
+    tb.wait()