minor

microsoft · Sep 14, 2023 · 19c7219 · 19c7219
1 parent 6107503
commit 19c7219
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/DPDPU/Common/Source/Host/DMABuffer.cpp b/DPDPU/Common/Source/Host/DMABuffer.cpp
@@ -122,7 +122,7 @@ DMABuffer::Allocate(
 
 	if (((MsgHeader*)MsgBuf)->MsgId == BUFF_MSG_B2F_RESPOND_ID) {
 		BufferId = ((BuffMsgB2FRespondId*)(MsgBuf + sizeof(MsgHeader)))->BufferId;
-		printf("DMABuffer: connected to the back end with assigned buffer Id (%d)\n", BufferId);
+		printf("DMABuffer: connected to the back end with assigned buffer id (%d)\n", BufferId);
 	}
 	else {
 		printf("DMABuffer: wrong message from the back end\n");

diff --git a/DPDPU/StorageEngine/DDSApplication/DDSApplication.cpp b/DPDPU/StorageEngine/DDSApplication/DDSApplication.cpp
@@ -386,7 +386,7 @@ int main()
         DummyCallback,
         &ioCount
     );
-    if (result != DDS_ERROR_CODE_SUCCESS) {
+    if (result != DDS_ERROR_CODE_SUCCESS && result != DDS_ERROR_CODE_IO_PENDING) {
         cout << "Failed to write file" << endl;
     }
     else {
@@ -432,19 +432,22 @@ int main()
 
     cout << "Data has been read: " << readBuffer << endl;
 
+    /*
     cout << "Benchmarking callback-based I/O" << endl;
     BenchmarkIO(
         store,
         fileId,
         maxFileSize
     );
 
+    
     cout << "Benchmarking polling-based I/O" << endl;
     BenchmarkIOWithPolling(
         store,
         fileId,
         maxFileSize
     );
+    */
 
     return 0;
 }
diff --git a/DPDPU/StorageEngine/DDSFrontEnd/DDSFrontEnd.cpp b/DPDPU/StorageEngine/DDSFrontEnd/DDSFrontEnd.cpp
@@ -876,7 +876,7 @@ DDSFrontEnd::ReadFileScatter(
 ErrorCodeT
 DDSFrontEnd::WriteFile(
     FileIdT FileId,
-    BufferT DestBuffer,
+    BufferT SourceBuffer,
     FileIOSizeT BytesToWrite,
     FileIOSizeT* BytesWritten,
     ReadWriteCallback Callback,