blob: c41c23c5c2a5666c9dac8fd1d480aa1f731d9195 [file] [log] [blame]
Alexander Afanasyevdfe58192013-01-17 17:34:04 -08001/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil -*- */
2/*
3 * Copyright (c) 2012-2013 University of California, Los Angeles
4 *
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License version 2 as
7 * published by the Free Software Foundation;
8 *
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
13 *
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 *
18 * Author: Alexander Afanasyev <alexander.afanasyev@ucla.edu>
19 * Zhenkai Zhu <zhenkai@cs.ucla.edu>
20 */
21
22#ifndef FETCHER_H
23#define FETCHER_H
24
Alexander Afanasyev49a18522013-01-18 17:49:04 -080025#include "ccnx-wrapper.h"
Alexander Afanasyevd6c2a902013-01-19 21:24:30 -080026#include "ccnx-name.h"
27
Alexander Afanasyev49a18522013-01-18 17:49:04 -080028#include "scheduler.h"
Alexander Afanasyev83531a42013-01-19 16:21:54 -080029#include <boost/intrusive/list.hpp>
Alexander Afanasyevdfe58192013-01-17 17:34:04 -080030
Alexander Afanasyev76d4fa42013-01-19 14:51:21 -080031class FetchManager;
32
Alexander Afanasyev83531a42013-01-19 16:21:54 -080033class Fetcher
Alexander Afanasyevdfe58192013-01-17 17:34:04 -080034{
35public:
Alexander Afanasyev76d4fa42013-01-19 14:51:21 -080036 Fetcher (FetchManager &fetchManger,
Alexander Afanasyev49a18522013-01-18 17:49:04 -080037 const Ccnx::Name &name, int32_t minSeqNo, int32_t maxSeqNo,
38 const Ccnx::Name &forwardingHint = Ccnx::Name ());
Alexander Afanasyevdfe58192013-01-17 17:34:04 -080039 virtual ~Fetcher ();
Alexander Afanasyev76d4fa42013-01-19 14:51:21 -080040
41private:
42 void
Alexander Afanasyev83531a42013-01-19 16:21:54 -080043 RestartPipeline ();
Alexander Afanasyev76d4fa42013-01-19 14:51:21 -080044
45 void
Alexander Afanasyev50547892013-01-19 22:03:45 -080046 FillPipeline ();
Alexander Afanasyevd6c2a902013-01-19 21:24:30 -080047
48 void
Alexander Afanasyev50547892013-01-19 22:03:45 -080049 OnData (uint32_t seqno, const Ccnx::Name &name, const Ccnx::Bytes &);
50
51 Ccnx::Closure::TimeoutCallbackReturnValue
Alexander Afanasyevd6c2a902013-01-19 21:24:30 -080052 OnTimeout (uint32_t seqno, const Ccnx::Name &name);
53
Alexander Afanasyevdfe58192013-01-17 17:34:04 -080054private:
Alexander Afanasyev76d4fa42013-01-19 14:51:21 -080055 FetchManager &m_fetchManager;
Alexander Afanasyev83531a42013-01-19 16:21:54 -080056 bool m_active;
Alexander Afanasyevd6c2a902013-01-19 21:24:30 -080057
Alexander Afanasyev49a18522013-01-18 17:49:04 -080058 Ccnx::Name m_name;
59 Ccnx::Name m_forwardingHint;
Alexander Afanasyevd6c2a902013-01-19 21:24:30 -080060
Alexander Afanasyev49a18522013-01-18 17:49:04 -080061 int32_t m_minSendSeqNo;
Alexander Afanasyev50547892013-01-19 22:03:45 -080062 int32_t m_maxInOrderRecvSeqNo;
63 std::set<int32_t> m_outOfOrderRecvSeqNo;
64
Alexander Afanasyev49a18522013-01-18 17:49:04 -080065 int32_t m_minSeqNo;
66 int32_t m_maxSeqNo;
Alexander Afanasyevdfe58192013-01-17 17:34:04 -080067
Alexander Afanasyev49a18522013-01-18 17:49:04 -080068 uint32_t m_pipeline;
Alexander Afanasyev50547892013-01-19 22:03:45 -080069 uint32_t m_activePipeline;
Alexander Afanasyevd6c2a902013-01-19 21:24:30 -080070
71 boost::intrusive::list_member_hook<> m_managerListHook;
Alexander Afanasyev83531a42013-01-19 16:21:54 -080072 friend class FetchManager;
Alexander Afanasyevdfe58192013-01-17 17:34:04 -080073};
74
Alexander Afanasyevd6c2a902013-01-19 21:24:30 -080075typedef boost::error_info<struct tag_errmsg, std::string> errmsg_info_str;
Alexander Afanasyev49a18522013-01-18 17:49:04 -080076
Alexander Afanasyevdfe58192013-01-17 17:34:04 -080077namespace Error {
78struct Fetcher : virtual boost::exception, virtual std::exception { };
79}
80
81typedef boost::shared_ptr<Fetcher> FetcherPtr;
82
83
84#endif // FETCHER_H