blob: df9309d845eadb6fe17ea251ebbd6360f077266a [file] [log] [blame]
Junxiao Shiea48d8b2014-03-16 13:53:47 -07001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
3 * Copyright (C) 2014 Named Data Networking Project
4 * See COPYING for copyright and distribution information.
5 */
6
7#include "status-server.hpp"
8#include "fw/forwarder.hpp"
9#include "core/version.hpp"
10
11namespace nfd {
12
13const Name StatusServer::DATASET_PREFIX = "ndn:/localhost/nfd/status";
Alexander Afanasyeveb3197f2014-03-17 19:28:18 -070014const time::milliseconds StatusServer::RESPONSE_FRESHNESS = time::milliseconds(5000);
Junxiao Shiea48d8b2014-03-16 13:53:47 -070015
16StatusServer::StatusServer(shared_ptr<AppFace> face, Forwarder& forwarder)
17 : m_face(face)
18 , m_forwarder(forwarder)
Alexander Afanasyeveb3197f2014-03-17 19:28:18 -070019 , m_startTimestamp(time::system_clock::now())
Junxiao Shiea48d8b2014-03-16 13:53:47 -070020{
21 m_face->setInterestFilter(DATASET_PREFIX, bind(&StatusServer::onInterest, this, _2));
22}
23
24void
25StatusServer::onInterest(const Interest& interest) const
26{
27 Name name(DATASET_PREFIX);
Alexander Afanasyev06ae9072014-03-22 23:42:08 -070028 name.appendVersion();
29 name.appendSegment(0);
Junxiao Shiea48d8b2014-03-16 13:53:47 -070030
31 shared_ptr<Data> data = make_shared<Data>(name);
32 data->setFreshnessPeriod(RESPONSE_FRESHNESS);
33
34 shared_ptr<ndn::nfd::Status> payload = this->collectStatus();
35 ndn::EncodingBuffer payloadBuffer;
36 payload->wireEncode(payloadBuffer);
37 data->setContent(payloadBuffer.buf(), payloadBuffer.size());
38
39 m_face->sign(*data);
40 m_face->put(*data);
41}
42
43shared_ptr<ndn::nfd::Status>
44StatusServer::collectStatus() const
45{
46 shared_ptr<ndn::nfd::Status> status = make_shared<ndn::nfd::Status>();
47
48 status->setNfdVersion(NFD_VERSION);
49 status->setStartTimestamp(m_startTimestamp);
Alexander Afanasyeveb3197f2014-03-17 19:28:18 -070050 status->setCurrentTimestamp(time::system_clock::now());
Junxiao Shiea48d8b2014-03-16 13:53:47 -070051
52 status->setNNameTreeEntries(m_forwarder.getNameTree().size());
53 status->setNFibEntries(m_forwarder.getFib().size());
54 status->setNPitEntries(m_forwarder.getPit().size());
55 status->setNMeasurementsEntries(m_forwarder.getMeasurements().size());
56 status->setNCsEntries(m_forwarder.getCs().size());
57
58 const ForwarderCounters& counters = m_forwarder.getCounters();
59 status->setNInInterests(counters.getInInterest());
60 status->setNOutInterests(counters.getOutInterest());
61 status->setNInDatas(counters.getInData());
62 status->setNOutDatas(counters.getOutData());
63
64 return status;
65}
66
67} // namespace nfd