1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
/*
* Copyright (c) 2017 Cisco and/or its affiliates.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef QTPLAYER_INPUT_ICNCONNECTIONCONSUMERAPI_H_
#define QTPLAYER_INPUT_ICNCONNECTIONCONSUMERAPI_H_
#include <QMessageLogger>
#include "../Portable/Networking.h"
#include "IICNConnection.h"
#include "../debug.h"
#include <sys/types.h>
#include <string>
#include <stdint.h>
#include <iostream>
#include <sstream>
#include <chrono>
#include <inttypes.h>
#include <stdlib.h>
#include <stdarg.h>
#include <algorithm>
#include <icnet/icnet_socket_consumer.h>
#include <icnet/icnet_download_observer.h>
#include <future>
#include <inttypes.h>
#include <time.h>
#include <limits.h>
#include <errno.h>
#include "../Portable/MultiThreading.h"
#include <boost/exception/diagnostic_information.hpp>
//logging purpose
#include <chrono>
#include <stdarg.h>
namespace libdash {
namespace framework {
namespace input {
class ICNConnectionConsumerApi : public IICNConnection, public icnet::IcnObserver {
public:
ICNConnectionConsumerApi(double alpha, float beta, float drop);
virtual ~ICNConnectionConsumerApi();
virtual void Init(dash::network::IChunk *chunk);
void InitForMPD(const std::string& url);
virtual int Read(uint8_t *data, size_t len, dash::network::IChunk *chunk);
int Read(uint8_t *data, size_t len);
virtual int Peek(uint8_t *data, size_t len, dash::network::IChunk *chunk);
virtual double GetAverageDownloadingSpeed();
virtual double GetDownloadingTime();
void processPayload(icnet::ConsumerSocket& , const uint8_t*, size_t);
bool onPacket(icnet::ConsumerSocket& , const icnet::ContentObject&);
const std::vector<dash::metrics::ITCPConnection *> &GetTCPConnectionList() const;
const std::vector<dash::metrics::IHTTPTransaction *> &GetHTTPTransactionList() const;
virtual void SetBeta(float beta);
virtual void SetDrop(float drop);
virtual void notifyStats(double throughput);
private:
float beta;
float drop;
uint64_t i_chunksize;
int i_lifetime;
int i_missed_co;
/**< number of content objects we missed in ICNBlock */
std::string m_name;
icnet::ccnx::Name m_recv_name;
icnet::ccnx::Portal m_portal;
int m_first;
bool m_isFinished;
uint64_t m_nextSeg;
double icnAlpha;
bool icnRateBased;
bool allow_stale;
int sysTimeout;
unsigned InitialMaxwindow;
unsigned int timer;
double drop_factor;
double p_min;
unsigned int gamma;
unsigned int samples;
unsigned int nchunks; // XXX chunks=-1 means: download the whole file!
bool output;
bool report_path;
icnet::ConsumerSocket* myConsumer;
bool res;
std::vector<char> mdata;
char* deezData;
int deezDataSize;
int datSize;
int dataPos;
int firstChunk;
double speed; // in bps
double dnltime; //in seconds
uint64_t sizeDownloaded;
std::chrono::time_point<std::chrono::system_clock> m_start_time;
std::vector<dash::metrics::ITCPConnection *> tcpConnections;
std::vector<dash::metrics::IHTTPTransaction *> httpTransactions;
uint64_t cumulativeBytesReceived;
mutable CRITICAL_SECTION monitorMutex;
mutable CONDITION_VARIABLE contentRetrieved;
};
} /* namespace input */
} /* namespace framework */
} /* namespace libdash */
#endif /* QTPLAYER_INPUT_ICNCONNECTIONCONSUMERAPI_H_ */
|
