stream.cpp
Go to the documentation of this file.
1 /*********************************************************************
2 * Software License Agreement (BSD License)
3 *
4 * Copyright (c) 2008, Willow Garage, Inc.
5 * All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 *
11 * * Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * * Redistributions in binary form must reproduce the above
14 * copyright notice, this list of conditions and the following
15 * disclaimer in the documentation and/or other materials provided
16 * with the distribution.
17 * * Neither the name of Willow Garage, Inc. nor the names of its
18 * contributors may be used to endorse or promote products derived
19 * from this software without specific prior written permission.
20 *
21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
22 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
24 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
25 * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
26 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
27 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
28 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
29 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
31 * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
32 * POSSIBILITY OF SUCH DAMAGE.
33 ********************************************************************/
34 
35 #include "rosbag/stream.h"
36 #include "rosbag/chunked_file.h"
37 
38 //#include <ros/ros.h>
39 
40 using boost::shared_ptr;
41 
42 namespace rosbag {
43 
44 // StreamFactory
45 
47  uncompressed_stream_(new UncompressedStream(file)),
48  bz2_stream_ (new BZ2Stream(file)),
49  lz4_stream_ (new LZ4Stream(file))
50 {
51 }
52 
54  switch (type) {
56  case compression::BZ2: return bz2_stream_;
57  case compression::LZ4: return lz4_stream_;
58  default: return shared_ptr<Stream>();
59  }
60 }
61 
62 // Stream
63 
64 Stream::Stream(ChunkedFile* file) : file_(file) { }
65 
67 
71 void Stream::stopRead() { }
72 
73 FILE* Stream::getFilePointer() { return file_->file_; }
75 void Stream::setCompressedIn(uint64_t nbytes) { file_->compressed_in_ = nbytes; }
76 void Stream::advanceOffset(uint64_t nbytes) { file_->offset_ += nbytes; }
77 char* Stream::getUnused() { return file_->unused_; }
79 void Stream::setUnused(char* unused) { file_->unused_ = unused; }
80 void Stream::setUnusedLength(int nUnused) { file_->nUnused_ = nUnused; }
82 
83 } // namespace rosbag
uint64_t getCompressedIn()
Definition: stream.cpp:74
int getUnusedLength()
Definition: stream.cpp:78
StreamFactory(ChunkedFile *file)
Definition: stream.cpp:46
ChunkedFile reads and writes files which contain interleaved chunks of compressed and uncompressed da...
Definition: chunked_file.h:51
virtual void startRead()
Definition: stream.cpp:70
void setUnusedLength(int nUnused)
Definition: stream.cpp:80
virtual void stopRead()
Definition: stream.cpp:71
char * getUnused()
Definition: stream.cpp:77
uint64_t offset_
current position in the file
Definition: chunked_file.h:94
boost::shared_ptr< Stream > lz4_stream_
Definition: stream.h:113
int nUnused_
number of bytes of extra data read by compressed stream
Definition: chunked_file.h:97
void advanceOffset(uint64_t nbytes)
Definition: stream.cpp:76
Stream(ChunkedFile *file)
Definition: stream.cpp:64
virtual void stopWrite()
Definition: stream.cpp:69
FILE * getFilePointer()
Definition: stream.cpp:73
uint64_t compressed_in_
number of bytes written to current compressed stream
Definition: chunked_file.h:95
ChunkedFile * file_
Definition: stream.h:100
void setCompressedIn(uint64_t nbytes)
Definition: stream.cpp:75
void clearUnused()
Definition: stream.cpp:81
virtual void startWrite()
Definition: stream.cpp:68
virtual ~Stream()
Definition: stream.cpp:66
Definition: bag.h:78
FILE * file_
file pointer
Definition: chunked_file.h:93
void setUnused(char *unused)
Definition: stream.cpp:79
boost::shared_ptr< Stream > bz2_stream_
Definition: stream.h:112
boost::shared_ptr< Stream > getStream(CompressionType type) const
Definition: stream.cpp:53
boost::shared_ptr< Stream > uncompressed_stream_
Definition: stream.h:111
char * unused_
extra data read by compressed stream
Definition: chunked_file.h:96


rosbag_storage
Author(s):
autogenerated on Sun Feb 3 2019 03:29:47