|
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
|
#include "Alignment/Geners/interface/IOException.hh"
#include <cassert>
#include <sstream>
#include "Alignment/Geners/interface/StringArchive.hh"
#include "Alignment/Geners/interface/streamposIO.hh"
namespace gs {
void StringArchive::search(AbsReference &reference) {
std::vector<unsigned long long> idlist;
catalog_.search(reference.namePattern(), reference.categoryPattern(), &idlist);
const unsigned long nfound = idlist.size();
for (unsigned long i = 0; i < nfound; ++i) {
std::shared_ptr<const CatalogEntry> pentry = catalog_.retrieveEntry(idlist[i]);
if (reference.isIOCompatible(*pentry))
addItemToReference(reference, idlist[i]);
}
}
std::istream &StringArchive::inputStream(const unsigned long long id, long long *sz) {
if (!id)
throw gs::IOInvalidArgument("In gs::StringArchive::inputStream: invalid item id");
unsigned cCode;
std::streampos pos;
unsigned long long itemLen;
if (!catalog_.retrieveStreampos(id, &cCode, &itemLen, &pos)) {
std::ostringstream os;
os << "In gs::StringArchive::inputStream: "
<< "failed to locate item with id " << id;
throw gs::IOInvalidArgument(os.str());
}
if (sz)
*sz = -1LL;
stream_.seekg(pos);
return stream_;
}
bool StringArchive::isEqual(const AbsArchive &cata) const {
const StringArchive &r = static_cast<const StringArchive &>(cata);
return lastpos_ == r.lastpos_ && name() == r.name() && stream_ == r.stream_ && catalog_ == r.catalog_;
}
bool StringArchive::write(std::ostream &of) const {
write_pod(of, lastpos_);
write_pod(of, name());
return !of.fail() && stream_.classId().write(of) && stream_.write(of) && catalog_.classId().write(of) &&
catalog_.write(of);
}
StringArchive *StringArchive::read(const ClassId &id, std::istream &in) {
static const ClassId current(ClassId::makeId<StringArchive>());
current.ensureSameId(id);
std::streampos lastpos;
read_pod(in, &lastpos);
std::string nam;
read_pod(in, &nam);
if (in.fail())
throw IOReadFailure("In gs::StringArchive::read: input stream failure");
std::unique_ptr<StringArchive> archive(new StringArchive(nam.c_str()));
archive->lastpos_ = lastpos;
ClassId streamId(in, 1);
CharBuffer::restore(streamId, in, &archive->stream_);
ClassId catId(in, 1);
std::unique_ptr<ContiguousCatalog> p(ContiguousCatalog::read(catId, in));
assert(p.get());
archive->catalog_ = *p;
return archive.release();
}
} // namespace gs
|