GetWorker() → GetAssignedWorker()

extratype · extratype · commit 681b6fadff34 · 2021-11-08T15:46:47.000+09:00
diff --git a/main.cpp b/main.cpp
@@ -153,7 +153,7 @@ ChunkDisk* StorageUnitChunkDisk(SPD_STORAGE_UNIT* StorageUnit)
     return recast<ChunkDisk*>(StorageUnit->UserContext);
 }
 
-ChunkDiskWorker* GetWorker(SPD_STORAGE_UNIT* StorageUnit)
+ChunkDiskWorker* GetAssignedWorker(SPD_STORAGE_UNIT* StorageUnit)
 {
     static thread_local auto* worker = (ChunkDiskWorker*)(nullptr);
     if (worker == nullptr)
@@ -180,7 +180,7 @@ BOOLEAN PostWork(SPD_STORAGE_UNIT* StorageUnit, ChunkOpKind op_kind, u64 block_a
         if (count) block_addr = descs[0].BlockAddress;
     }
 
-    auto* worker = GetWorker(StorageUnit);
+    auto* worker = GetAssignedWorker(StorageUnit);
     worker->Wait();
     auto err = worker->PostWork(context, op_kind, block_addr, count);
     if (err != ERROR_IO_PENDING && err != ERROR_SUCCESS)

Original file line number	Diff line number	Diff line change
`@@ -153,7 +153,7 @@ ChunkDisk* StorageUnitChunkDisk(SPD_STORAGE_UNIT* StorageUnit)`
`153`	`153`	`return recast<ChunkDisk*>(StorageUnit->UserContext);`
`154`	`154`	`}`
`155`	`155`
`156`		`-ChunkDiskWorker* GetWorker(SPD_STORAGE_UNIT* StorageUnit)`
	`156`	`+ChunkDiskWorker* GetAssignedWorker(SPD_STORAGE_UNIT* StorageUnit)`
`157`	`157`	`{`
`158`	`158`	`static thread_local auto* worker = (ChunkDiskWorker*)(nullptr);`
`159`	`159`	`if (worker == nullptr)`
`@@ -180,7 +180,7 @@ BOOLEAN PostWork(SPD_STORAGE_UNIT* StorageUnit, ChunkOpKind op_kind, u64 block_a`
`180`	`180`	`if (count) block_addr = descs[0].BlockAddress;`
`181`	`181`	`}`
`182`	`182`
`183`		`- auto* worker = GetWorker(StorageUnit);`
	`183`	`+ auto* worker = GetAssignedWorker(StorageUnit);`
`184`	`184`	`worker->Wait();`
`185`	`185`	`auto err = worker->PostWork(context, op_kind, block_addr, count);`
`186`	`186`	`if (err != ERROR_IO_PENDING && err != ERROR_SUCCESS)`