commit a01473887c803a382bef1ef80a80ad3ab1329640
author Zhenkai Zhu <zhenkai@cs.ucla.edu> Tue Jan 29 15:57:27 2013 -0800
committer Zhenkai Zhu <zhenkai@cs.ucla.edu> Tue Jan 29 15:57:27 2013 -0800
tree 3b24bd1aed9feb3777780fffaf901da311190985
parent d4a8b120aef3d67c87d42d003f07f63eb62d126c

enable default callbacks for fetch-manager

src/fetch-manager.h

diff --git a/src/fetch-manager.h b/src/fetch-manager.h
index 793c5c6..8c0ad83 100644
--- a/src/fetch-manager.h
+++ b/src/fetch-manager.h
@@ -46,7 +46,12 @@
   typedef boost::function<Ccnx::Name(const Ccnx::Name &)> Mapping;
   typedef boost::function<void(Ccnx::Name &deviceName, Ccnx::Name &baseName, uint64_t seq, Ccnx::PcoPtr pco)> SegmentCallback;
   typedef boost::function<void(Ccnx::Name &deviceName, Ccnx::Name &baseName)> FinishCallback;
-  FetchManager (Ccnx::CcnxWrapperPtr ccnx, const Mapping &mapping, uint32_t parallelFetches = 3);
+  FetchManager (Ccnx::CcnxWrapperPtr ccnx
+                , const Mapping &mapping
+                , uint32_t parallelFetches = 3
+                , const SegmentCallback &defaultSegmentCallback = SegmentCallback()
+                , const FinishCallback &defaultFinishCallback = FinishCallback()
+                );
   virtual ~FetchManager ();
 
   void
@@ -54,6 +59,11 @@
            const SegmentCallback &segmentCallback, const FinishCallback &finishCallback,
            uint64_t minSeqNo, uint64_t maxSeqNo, int priority=PRIORITY_NORMAL);
 
+  // Enqueue using default callbacks
+  void
+  Enqueue (const Ccnx::Name &deviceName, const Ccnx::Name &baseName,
+           uint64_t minSeqNo, uint64_t maxSeqNo, int priority=PRIORITY_NORMAL);
+
   // only for Fetcher
   inline Ccnx::CcnxWrapperPtr
   GetCcnx ();
@@ -90,6 +100,8 @@
   SchedulerPtr m_scheduler;
   ExecutorPtr m_executor;
   TaskPtr m_scheduleFetchesTask;
+  SegmentCallback m_defaultSegmentCallback;
+  FinishCallback m_defaultFinishCallback;
 };
 
 Ccnx::CcnxWrapperPtr