IBR-DTNSuite  0.12
BundleStream.h
Go to the documentation of this file.
1 /*
2  * BundleStream.h
3  *
4  * Copyright (C) 2011 IBR, TU Braunschweig
5  *
6  * Written-by: Johannes Morgenroth <morgenroth@ibr.cs.tu-bs.de>
7  *
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  * http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  *
20  */
21 
22 #ifndef BUNDLESTREAM_H_
23 #define BUNDLESTREAM_H_
24 
25 #include "streaming/StreamBundle.h"
26 #include "streaming/BundleStreamBuf.h"
27 #include <ibrdtn/api/Client.h>
28 #include <ibrdtn/data/EID.h>
29 #include <ibrdtn/data/SDNV.h>
30 #include <ibrdtn/data/StreamBlock.h>
31 #include <ibrdtn/data/BundleID.h>
32 #include <ibrcommon/net/socketstream.h>
33 #include <vector>
34 
35 class BundleStream : public dtn::api::Client
36 {
37 public:
38  BundleStream(ibrcommon::socketstream &stream, size_t min_chunk_size, size_t max_chunk_size, const std::string &app = "stream", const dtn::data::EID &group = dtn::data::EID(), bool wait_seq_zero = false);
39  virtual ~BundleStream();
40 
41  BundleStreamBuf& rdbuf();
42  dtn::data::Bundle& base();
43 
47  void setAutoFlush(bool val);
48 
52  void setReceiveTimeout(unsigned int timeout);
53 
54 protected:
58  virtual void received(const dtn::data::Bundle &b);
59 
60 private:
61  ibrcommon::socketstream &_stream;
62  StreamBundle _chunk;
63  BundleStreamBuf _buf;
64  bool _auto_flush;
65  dtn::data::BundleID _last_delivery_ack;
66 };
67 
68 #endif /* BUNDLESTREAM_H_ */