Changeset 0fa70d99fc44dd20b66347158c7d926daeff7397

Timestamp:

09/24/07 05:06:10 (6 years ago)

Author:

Guillaume Pellerin <yomguy@…>

Children:

f301a42ec88d17568c5e38c8fe8c40e8d96caaea

Parents:

17fad2a8ef3f22149fa58696d469a7a8b497fd0f

git-committer:

Guillaume Pellerin <yomguy@parisson.com> / 2007-09-24T03:06:10Z+0000

Message:

* Create Station class (producer)
* Modify Channel class (worker)
* Get the multi-channels work (Thread + Queue) !!
* Fix random playlist bug
* Cleanup

Files:

• d-fuzz.py (modified) (14 diffs)

d-fuzz.py

@@ -53 +53 @@
     
     def __init__(self, conf_file):
-        #Thread.__init__(self)
-        self.status = -1
-        self.version = '0.1'
         self.conf_file = conf_file
 
@@ -69 +66 @@
 
     def run(self):
-        print "D-fuzz v"+self.version
         self.conf = self.get_conf_dict()
-        print self.conf
+        #print self.conf
 
         # Fix wrong type data from xmltodict when one station (*)
@@ -80 +76 @@
         print 'Number of stations : ' + str(nb_stations)
         
-        # Create a Queue:
-        #stream_pool = Queue.Queue ( 0 )
-
         for i in range(0,nb_stations):
+            # Create a Queue
+            q = Queue.Queue(1)
+
             # (*) idem
             if isinstance(self.conf['d-fuzz']['station'], dict):
@@ -89 +85 @@
             else:
                 station = self.conf['d-fuzz']['station'][i]
-            print station
+            #print station
             name = station['infos']['name']
-            channels = int(station['infos']['channels'])
-            print 'Station %s has %s channels' % (name, str(channels))
-            for channel_id in range(0,channels):
+            nb_channels = int(station['infos']['channels'])
+            print 'Station %s: %s has %s channels' % (str(i+1), name, str(nb_channels))
+            s = Station(station, nb_channels, q)
+            s.start()
+            time.sleep(0.1)
+            for channel_id in range(0, nb_channels):
                 #print channel_id
-                Channel(station, channel_id + 1).start()
-                #channel.start()
-                time.sleep(0.5)
+                c = Channel(station, channel_id + 1, q)
+                c.start()
+                #time.sleep(0.5)
+
+
+class Station(Thread):
+    """A D-Fuzz Station thread"""
+
+    def __init__(self, station, nb_channels, station_q):
+        Thread.__init__(self)
+        self.station_q = station_q
+        self.station = station
+        self.nb_channels = nb_channels
+
+    def run(self):
+        #station_q = self.station_q
+        i=0
+        while 1 : 
+            #print currentThread(),"Produced One Item:",i
+            self.station_q.put(i,1)
+            i+=1
+            #time.sleep(1)
 
 
@@ -103 +121 @@
     """A channel shouting thread"""
 
-    def __init__(self, station, channel_id):
+    def __init__(self, station, channel_id, channel_q):
         Thread.__init__(self)
+        self.channel_q = channel_q
         self.station = station
         self.main_command = 'cat'
-        self.buffer_size = 0xFFFF
+        self.buffer_size = 16384
         self.channel_id = channel_id
-
-        # Pool Queue
-        #self.stream_pool = stream_pool
-        
         self.channel = Shout()
-        #self.station = station
         self.id = 999999
+        self.counter = 0
         self.rand_list = []
-         
         # Media
         self.media_dir = self.station['media']['dir']
-
         self.channel.format = self.station['media']['format']
         self.mode_shuffle = int(self.station['media']['shuffle'])
-
         # Infos
         self.short_name = self.station['infos']['short_name'] + '_' + str(self.channel_id)
@@ -130 +142 @@
         self.channel.description = self.station['infos']['description']
         self.channel.url = self.station['infos']['url']
-        
         # Server
         self.channel.protocol = 'http'     # | 'xaudiocast' | 'icy'
@@ -140 +151 @@
         #print self.channel.mount
         self.channel.public = int(self.station['server']['public'])
-
         # s.audio_info = { 'key': 'val', ... }
         #  (keys are shout.SHOUT_AI_BITRATE, shout.SHOUT_AI_SAMPLERATE,
@@ -164 +174 @@
         lp = len(playlist)
         if self.id >= (lp - 1):
+            #print 'Get random list...'
             playlist = self.get_playlist()
             lp_new = len(playlist)
-            if lp_new != lp:
+            if lp_new != lp or self.counter == 0:
                 self.rand_list = range(0,lp_new)
                 random.shuffle(self.rand_list)
-            #print self.rand_list
+                #print self.rand_list
             self.id = 0
         else:
@@ -180 +191 @@
         """Apply command and stream data through a generator. 
         Taken from Telemeta..."""
-        
         __chunk = 0
         try:
@@ -191 +201 @@
         except:
             raise DFuzzError('Command failure:', command, proc)
-
         # Core processing
         while True:
@@ -204 +213 @@
     def run(self):
         #print "Using libshout version %s" % shout.version()
-
         #__chunk = 0
         self.channel.open()
@@ -214 +222 @@
         lp = len(playlist)
         self.rand_list = range(0,lp)
-
         
         while True:
             if lp == 0:
                 break
-
-            # Get a client out of the queue
-            #client = self.stream_pool.get()
-
-            #if client != None:
-
-            time.sleep(0.1)
             if self.mode_shuffle == 1:
+                #print 'Shuffle mode'
                 playlist, media = self.get_next_media_rand(playlist)
             else:
                 playlist, media = self.get_next_media_lin(playlist)
-
+            self.counter += 1
             file_name = string.replace(media, self.media_dir + os.sep, '')
             #print 'Playlist (%s ch%s) : %s' % (self.short_name, self.channel_id, file_name)
@@ -242 +243 @@
 
             for __chunk in stream:
+                # Get the queue
+                self.channel_q.get(1)
                 self.channel.send(__chunk)
                 self.channel.sync()
 
         self.channel.close()
-
 
 
@@ -265 +267 @@
                                                 error)
 
-                                                
 def main():    
     if len(sys.argv) == 2:
+        print "D-fuzz v"+version
         dfuzz_main = DFuzz(sys.argv[1])
         dfuzz_main.run()