arangodb
diff --git a/‎CHANGELOG
Lines changed: 4 additions & 0 deletions b/‎CHANGELOG
Lines changed: 4 additions & 0 deletions
diff --git a/‎arangod/Pregel/Algos/PageRank.cpp
Lines changed: 2 additions & 2 deletions b/‎arangod/Pregel/Algos/PageRank.cpp
Lines changed: 2 additions & 2 deletions
diff --git a/‎arangod/Pregel/GraphStore.cpp
Lines changed: 6 additions & 3 deletions b/‎arangod/Pregel/GraphStore.cpp
Lines changed: 6 additions & 3 deletions
@@ -1,6 +1,10 @@
 devel
 -----
 
+* When creating Pregel memory-mapped files, create them with O_TMPFILE
+  attribute on Linux so that files are guaranteed to vanish even if a 
+  process dies.
+
 * Fixed: getResponsibleShard call on disjoint Smart Graphs
   if you asked for the responsible shard on a disjoint edge collection
   where the _from and _to differ (invalid), the server would respond with
 
@@ -116,8 +116,8 @@ struct PRMasterContext : public MasterContext {
   }
 
   void preApplication() override {
-    LOG_TOPIC("e0598", DEBUG, Logger::PREGEL) << "Using threshold " << _threshold;
-  };
+    LOG_TOPIC("e0598", DEBUG, Logger::PREGEL) << "Using threshold " << _threshold << " for pagerank";
+  }
 
   bool postGlobalSuperstep() override {
     float const* diff = getAggregatedValue<float>(kConvergence);
 
@@ -293,12 +293,15 @@ void moveAppend(std::vector<X>& src, std::vector<X>& dst) {
 template <typename M>
 std::unique_ptr<TypedBuffer<M>> createBuffer(WorkerConfig const& config, size_t cap) {
   if (config.useMemoryMaps()) {
-    auto ptr = std::make_unique<MappedFileBuffer<M>>(cap);
+    // prefix used for logging in TypedBuffer.h
+    std::string logPrefix = "[job " + std::to_string(config.executionNumber()) + "] ";
+
+    auto ptr = std::make_unique<MappedFileBuffer<M>>(cap, logPrefix);
     ptr->sequentialAccess();
     return ptr;
-  } else {
-    return std::make_unique<VectorTypedBuffer<M>>(cap);
   }
+
+  return std::make_unique<VectorTypedBuffer<M>>(cap);
 }
 }  // namespace
Original file line number	Diff line number	Diff line change
`@@ -116,8 +116,8 @@ struct PRMasterContext : public MasterContext {`
`116`	`116`	`}`
`117`	`117`
`118`	`118`	`void preApplication() override {`
`119`		`- LOG_TOPIC("e0598", DEBUG, Logger::PREGEL) << "Using threshold " << _threshold;`
`120`		`- };`
	`119`	`+ LOG_TOPIC("e0598", DEBUG, Logger::PREGEL) << "Using threshold " << _threshold << " for pagerank";`
	`120`	`+ }`
`121`	`121`
`122`	`122`	`bool postGlobalSuperstep() override {`
`123`	`123`	`float const* diff = getAggregatedValue<float>(kConvergence);`