Improvement: Add names to background jobs for easier debugging (#412)

Improvement: Background jobs now temporarily sets thread name to background job name while executing
Improvement: Background jobs tracks worker thread id used while executing

1 files changed, 32 insertions, 28 deletions

diff --git a/src/zenserver/projectstore/projectstore.cpp b/src/zenserver/projectstore/projectstore.cpp
index 1ad4403f4..70dc678a9 100644
--- a/src/zenserver/projectstore/projectstore.cpp
+++ b/src/zenserver/projectstore/projectstore.cpp
@@ -2881,34 +2881,37 @@ ProjectStore::Export(Ref<ProjectStore::Project> Project, ProjectStore::Oplog& Op
 			 NiceBytes(MaxBlockSize),
 			 NiceBytes(MaxChunkEmbedSize));
 
-	JobId JobId = m_JobQueue.QueueJob([this,
-									   ActualRemoteStore = std::move(RemoteStore),
-									   Project,
-									   OplogPtr = &Oplog,
-									   MaxBlockSize,
-									   MaxChunkEmbedSize,
-									   EmbedLooseFile,
-									   CreateBlocks		 = StoreInfo.CreateBlocks,
-									   UseTempBlockFiles = StoreInfo.UseTempBlockFiles,
-									   Force](JobContext& Context) {
-		RemoteProjectStore::Result Result	= SaveOplog(m_CidStore,
-														*ActualRemoteStore,
-														*Project.Get(),
-														*OplogPtr,
-														MaxBlockSize,
-														MaxChunkEmbedSize,
-														EmbedLooseFile,
-														CreateBlocks,
-														UseTempBlockFiles,
-														Force,
-														&Context);
-		auto					   Response = ConvertResult(Result);
-		ZEN_INFO("SaveOplog: Status: {} '{}'", ToString(Response.first), Response.second);
-		if (!IsHttpSuccessCode(Response.first))
-		{
-			throw std::runtime_error(fmt::format("Export failed. Status '{}'. Reason: '{}'", ToString(Response.first), Response.second));
-		}
-	});
+	JobId JobId =
+		m_JobQueue.QueueJob(fmt::format("Export oplog '{}/{}' to {}", Project->Identifier, Oplog.OplogId(), StoreInfo.Description),
+							[this,
+							 ActualRemoteStore = std::move(RemoteStore),
+							 Project,
+							 OplogPtr = &Oplog,
+							 MaxBlockSize,
+							 MaxChunkEmbedSize,
+							 EmbedLooseFile,
+							 CreateBlocks	   = StoreInfo.CreateBlocks,
+							 UseTempBlockFiles = StoreInfo.UseTempBlockFiles,
+							 Force](JobContext& Context) {
+								RemoteProjectStore::Result Result	= SaveOplog(m_CidStore,
+																				*ActualRemoteStore,
+																				*Project.Get(),
+																				*OplogPtr,
+																				MaxBlockSize,
+																				MaxChunkEmbedSize,
+																				EmbedLooseFile,
+																				CreateBlocks,
+																				UseTempBlockFiles,
+																				Force,
+																				&Context);
+								auto					   Response = ConvertResult(Result);
+								ZEN_INFO("SaveOplog: Status: {} '{}'", ToString(Response.first), Response.second);
+								if (!IsHttpSuccessCode(Response.first))
+								{
+									throw std::runtime_error(
+										fmt::format("Export failed. Status '{}'. Reason: '{}'", ToString(Response.first), Response.second));
+								}
+							});
 
 	return {HttpResponseCode::Accepted, fmt::format("{}", JobId.Id)};
 }
@@ -2935,6 +2938,7 @@ ProjectStore::Import(ProjectStore::Project& Project, ProjectStore::Oplog& Oplog,
 
 	ZEN_INFO("Loading oplog '{}/{}' from {}", Project.Identifier, Oplog.OplogId(), StoreInfo.Description);
 	JobId JobId = m_JobQueue.QueueJob(
+		fmt::format("Import oplog '{}/{}' from {}", Project.Identifier, Oplog.OplogId(), StoreInfo.Description),
 		[this, ActualRemoteStore = std::move(RemoteStore), OplogPtr = &Oplog, MaxBlockSize, MaxChunkEmbedSize, Force](JobContext& Context) {
 			RemoteProjectStore::Result Result	= LoadOplog(m_CidStore, *ActualRemoteStore, *OplogPtr, Force, &Context);
 			auto					   Response = ConvertResult(Result);