blob: fba4f292c854ba88e3c2ca449c8a7138f4632741 [file] [log] [blame]
/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil -*- */
/*
* Copyright (c) 2012-2013 University of California, Los Angeles
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 2 as
* published by the Free Software Foundation;
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
* Author: Alexander Afanasyev <alexander.afanasyev@ucla.edu>
* Zhenkai Zhu <zhenkai@cs.ucla.edu>
*/
#ifndef FETCHER_H
#define FETCHER_H
#include "ccnx-wrapper.h"
#include "scheduler.h"
class Fetcher
{
public:
Fetcher (Ccnx::CcnxWrapperPtr ccnx, SchedulerPtr scheduler,
const Ccnx::Name &name, int32_t minSeqNo, int32_t maxSeqNo,
const Ccnx::Name &forwardingHint = Ccnx::Name ());
virtual ~Fetcher ();
private:
Ccnx::CcnxWrapperPtr m_ccnx;
SchedulerPtr m_scheduler;
Ccnx::Name m_name;
Ccnx::Name m_forwardingHint;
int32_t m_minSendSeqNo;
int32_t m_maxSendSeqNo;
int32_t m_minSeqNo;
int32_t m_maxSeqNo;
uint32_t m_pipeline;
};
typedef boost::error_info<struct tag_errmsg, std::string> errmsg_info_str;
namespace Error {
struct Fetcher : virtual boost::exception, virtual std::exception { };
}
typedef boost::shared_ptr<Fetcher> FetcherPtr;
#endif // FETCHER_H