nodejs
diff --git a/Collapse file
‎src/tracing/agent.cc‎
Copy file name to clipboardExpand all lines: src/tracing/agent.cc
+10-2Lines changed: 10 additions & 2 deletions b/Collapse file
‎src/tracing/agent.cc‎
Copy file name to clipboardExpand all lines: src/tracing/agent.cc
+10-2Lines changed: 10 additions & 2 deletions
diff --git a/Collapse file
‎src/tracing/agent.h‎
Copy file name to clipboardExpand all lines: src/tracing/agent.h
+3-3Lines changed: 3 additions & 3 deletions b/Collapse file
‎src/tracing/agent.h‎
Copy file name to clipboardExpand all lines: src/tracing/agent.h
+3-3Lines changed: 3 additions & 3 deletions
@@ -207,9 +207,17 @@ void Agent::AppendTraceEvent(TraceObject* trace_event) {
     id_writer.second->AppendTraceEvent(trace_event);
 }
 
+void Agent::AddMetadataEvent(std::unique_ptr<TraceObject> event) {
+  Mutex::ScopedLock lock(metadata_events_mutex_);
+  metadata_events_.push_back(std::move(event));
+}
+
 void Agent::Flush(bool blocking) {
-  for (const auto& event : metadata_events_)
-    AppendTraceEvent(event.get());
+  {
+    Mutex::ScopedLock lock(metadata_events_mutex_);
+    for (const auto& event : metadata_events_)
+      AppendTraceEvent(event.get());
+  }
 
   for (const auto& id_writer : writers_)
     id_writer.second->Flush(blocking);
 
@@ -104,9 +104,7 @@ class Agent {
   // Writes to all writers registered through AddClient().
   void AppendTraceEvent(TraceObject* trace_event);
 
-  void AddMetadataEvent(std::unique_ptr<TraceObject> event) {
-    metadata_events_.push_back(std::move(event));
-  }
+  void AddMetadataEvent(std::unique_ptr<TraceObject> event);
   // Flushes all writers registered through AddClient().
   void Flush(bool blocking);
 
@@ -145,6 +143,8 @@ class Agent {
   ConditionVariable initialize_writer_condvar_;
   uv_async_t initialize_writer_async_;
   std::set<AsyncTraceWriter*> to_be_initialized_;
+
+  Mutex metadata_events_mutex_;
   std::list<std::unique_ptr<TraceObject>> metadata_events_;
 };