Update of /cvsroot/freevo/freevo/src/record
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv25065/record

Modified Files:
        server.py 
Log Message:
make it possible to schedule recordings for testing

Index: server.py
===================================================================
RCS file: /cvsroot/freevo/freevo/src/record/server.py,v
retrieving revision 1.10
retrieving revision 1.11
diff -C2 -d -r1.10 -r1.11
*** server.py   4 Nov 2004 19:14:08 -0000       1.10
--- server.py   4 Nov 2004 19:55:49 -0000       1.11
***************
*** 8,11 ****
--- 8,14 ----
  # -----------------------------------------------------------------------
  # $Log$
+ # Revision 1.11  2004/11/04 19:55:49  dischi
+ # make it possible to schedule recordings for testing
+ #
  # Revision 1.10  2004/11/04 19:14:08  dischi
  # add mbus parameter parsing
***************
*** 41,51 ****
  
  import notifier
  import mcomm
  
  class RecordServer(mcomm.RPCServer):
  
      def __rpc_recording_list__(self, addr, val):
          self.parse_parameter(val, () )
!         return mcomm.RPCReturn()
  
      def __rpc_recording_add__(self, addr, val):
--- 44,87 ----
  
  import notifier
+ 
+ import sysconfig
+ import util.cache
  import mcomm
  
+ VERSION = 1
+ 
  class RecordServer(mcomm.RPCServer):
+     def __init__(self):
+         mcomm.RPCServer.__init__(self)
+         self.cachefile = sysconfig.cachefile('recordserver.dump')
+         self.load()
+         
  
+     def load(self):
+         c = util.cache.load(self.cachefile, VERSION)
+         print c
+         if c:
+             self.next_id, self.recordings = c
+         else:
+             self.recordings = {}
+             self.next_id = 0
+ 
+         print self.next_id
+         print self.recordings
+ 
+ 
+     def save(self):
+         print (self.next_id, self.recordings)
+         util.cache.save(self.cachefile, (self.next_id, self.recordings), VERSION)
+ 
+         
      def __rpc_recording_list__(self, addr, val):
          self.parse_parameter(val, () )
!         ret = []
!         for id in self.recordings:
!             name, channel, prio, start, stop, info = self.recordings[id]
!             ret.append((id, channel, prio, start, stop))
!         return mcomm.RPCReturn(ret)
! 
  
      def __rpc_recording_add__(self, addr, val):
***************
*** 53,56 ****
--- 89,95 ----
                self.parse_parameter(val, ( unicode, unicode, int, int, int, dict ) )
          print 'RecordRequest: %s' % String(name)
+         self.recordings[self.next_id] = (name, channel, prio, start, stop, info)
+         self.next_id += 1
+         self.save()
          return mcomm.RPCReturn()
  



-------------------------------------------------------
This SF.Net email is sponsored by:
Sybase ASE Linux Express Edition - download now for FREE
LinuxWorld Reader's Choice Award Winner for best database on Linux.
http://ads.osdn.com/?ad_id=5588&alloc_id=12065&op=click
_______________________________________________
Freevo-cvslog mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/freevo-cvslog

Reply via email to