Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

ClangFormat

This commit is contained in:
Michael Hackstein 2017-04-13 14:35:42 +02:00
parent 904ec5d7a1
commit d61203907b
1 changed files with 28 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
arangod/Cluster/ClusterEdgeCursor.cpp
View File

@ -35,28 +35,32 @@
using ClusterEdgeCursor = arangodb::traverser::ClusterEdgeCursor; using ClusterEdgeCursor = arangodb::traverser::ClusterEdgeCursor;
using StringRef = arangodb::StringRef; using StringRef = arangodb::StringRef;
ClusterEdgeCursor::ClusterEdgeCursor(StringRef vertexId, uint64_t depth, ClusterEdgeCursor::ClusterEdgeCursor(
StringRef vertexId, uint64_t depth,
arangodb::traverser::ClusterTraverser* traverser) arangodb::traverser::ClusterTraverser* traverser)
: _position(0), _resolver(traverser->_trx->resolver()), _traverser(traverser) { : _position(0),
_resolver(traverser->_trx->resolver()),
_traverser(traverser) {
transaction::BuilderLeaser leased(traverser->_trx); transaction::BuilderLeaser leased(traverser->_trx);
transaction::BuilderLeaser b(traverser->_trx); transaction::BuilderLeaser b(traverser->_trx);
b->add(VPackValuePair(vertexId.data(), vertexId.length(), VPackValueType::String)); b->add(VPackValuePair(vertexId.data(), vertexId.length(),
VPackValueType::String));
fetchEdgesFromEngines(traverser->_dbname, traverser->_engines, b->slice(),
depth, traverser->_edges, _edgeList,
traverser->_datalake, *(leased.get()),
traverser->_filteredPaths, traverser->_readDocuments);
}
fetchEdgesFromEngines(traverser->_dbname, traverser->_engines, b->slice(), depth, bool ClusterEdgeCursor::next(
traverser->_edges, _edgeList, traverser->_datalake, std::function<void(StringRef const&, VPackSlice, size_t)> callback) {
*(leased.get()), traverser->_filteredPaths,
traverser->_readDocuments);
}
bool ClusterEdgeCursor::next(std::function<void(StringRef const&,
VPackSlice, size_t)> callback) {
if (_position < _edgeList.size()) { if (_position < _edgeList.size()) {
VPackSlice edge = _edgeList[_position]; VPackSlice edge = _edgeList[_position];
std::string eid = transaction::helpers::extractIdString(_resolver, edge, VPackSlice()); std::string eid =
StringRef persId = _traverser->traverserCache()->persistString(StringRef(eid)); transaction::helpers::extractIdString(_resolver, edge, VPackSlice());
StringRef persId =
_traverser->traverserCache()->persistString(StringRef(eid));
callback(persId, edge, _position); callback(persId, edge, _position);
++_position; ++_position;
return true; return true;
@ -64,11 +68,13 @@ bool ClusterEdgeCursor::next(std::function<void(StringRef const&,
return false; return false;
} }
void ClusterEdgeCursor::readAll(std::function<void(StringRef const&, void ClusterEdgeCursor::readAll(
VPackSlice, size_t&)> callback) { std::function<void(StringRef const&, VPackSlice, size_t&)> callback) {
for (auto const& edge : _edgeList) { for (auto const& edge : _edgeList) {
std::string eid = transaction::helpers::extractIdString(_resolver, edge, VPackSlice()); std::string eid =
StringRef persId = _traverser->traverserCache()->persistString(StringRef(eid)); transaction::helpers::extractIdString(_resolver, edge, VPackSlice());
StringRef persId =
_traverser->traverserCache()->persistString(StringRef(eid));
callback(persId, edge, _position); callback(persId, edge, _position);
} }
} }