blob: 21a9759c818575ab9f211234de7d44bdcadffb50 [file] [log] [blame]
Alexander Afanasyev359bfb72012-01-09 18:42:50 -08001/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil; -*- */
2/*
3 * Copyright (c) 2011 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: Ilya Moiseenko <iliamo@cs.ucla.edu>
19 * Alexander Afanasyev <alexander.afanasyev@ucla.edu>
20 */
21
22#ifndef CCNX_CONSUMER_WINDOW_H
23#define CCNX_CONSUMER_WINDOW_H
24
25#include "ccnx-consumer.h"
Alexander Afanasyeve4c2ece2012-01-11 10:44:40 -080026#include "ns3/traced-value.h"
Alexander Afanasyev359bfb72012-01-09 18:42:50 -080027
28namespace ns3
29{
30
31/**
32 * @ingroup ccnx
33 * \brief CCNx application for sending out Interest packets (window-based)
34 */
35class CcnxConsumerWindow: public CcnxConsumer
36{
37public:
38 static TypeId GetTypeId ();
39
40 /**
41 * \brief Default constructor
42 */
43 CcnxConsumerWindow ();
44
45 // From CcnxApp
46 // virtual void
47 // OnInterest (const Ptr<const CcnxInterestHeader> &interest);
48
49 virtual void
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -080050 OnNack (const Ptr<const CcnxInterestHeader> &interest, Ptr<Packet> payload);
Alexander Afanasyev359bfb72012-01-09 18:42:50 -080051
52 virtual void
53 OnContentObject (const Ptr<const CcnxContentObjectHeader> &contentObject,
Alexander Afanasyeve9c9d722012-01-19 16:59:30 -080054 Ptr<Packet> payload);
Alexander Afanasyev359bfb72012-01-09 18:42:50 -080055
56 virtual void
57 OnTimeout (uint32_t sequenceNumber);
58
59protected:
60 /**
61 * \brief Constructs the Interest packet and sends it using a callback to the underlying CCNx protocol
62 */
63 virtual void
64 ScheduleNextPacket ();
65
66private:
67 virtual void
68 SetWindow (uint32_t window);
69
70 uint32_t
71 GetWindow () const;
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080072
73 virtual void
74 SetPayloadSize (uint32_t payload);
75
76 uint32_t
77 GetPayloadSize () const;
78
79 double
80 GetMaxSize () const;
81
82 void
83 SetMaxSize (double size);
Alexander Afanasyev359bfb72012-01-09 18:42:50 -080084
85protected:
Alexander Afanasyevb7ad2322012-01-17 22:54:49 -080086 uint32_t m_payloadSize; // expected payload size
87 double m_maxSize; // max size to request
88
Alexander Afanasyeve4c2ece2012-01-11 10:44:40 -080089 TracedValue<uint32_t> m_window;
Alexander Afanasyev06b42ec2012-01-11 19:05:36 -080090 TracedValue<uint32_t> m_inFlight;
Alexander Afanasyev359bfb72012-01-09 18:42:50 -080091};
92
93} // namespace ns3
94
95#endif