Skip to content
This repository has been archived by the owner on Sep 24, 2024. It is now read-only.

Commit

Permalink
Merge branch 'main' of github.com:microsoft/dpdpu
Browse files Browse the repository at this point in the history
  • Loading branch information
qizzz committed Dec 14, 2023
2 parents 85cbadb + 3da61bc commit 8d53994
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 28 deletions.
1 change: 1 addition & 0 deletions DPDPU/Common/Source/DPU/FileService.c
Original file line number Diff line number Diff line change
Expand Up @@ -248,6 +248,7 @@ StartFileServiceWrapper(

printf("starting FS, StartSPDKFileService()...\n");
spdk_app_start(&opts, StartSPDKFileService, StartCtx);
printf("spdk_app_start returns\n");
return NULL;
}

Expand Down
29 changes: 1 addition & 28 deletions DPDPU/NetworkEngine/Source/PEPOTLDKTCP.c
Original file line number Diff line number Diff line change
Expand Up @@ -3659,26 +3659,6 @@ PEPOLcoreMain(
return result;
}

//
// Storage engine execution
//
//
typedef struct {
void (*StorageEngine)(void*);
void* StorageEngineArg;
} StorageEngineT;

static int
StorageEngineThread(
void *Arg
) {
StorageEngineT* sEng = (StorageEngineT*)Arg;

sEng->StorageEngine(sEng->StorageEngineArg);

return 0;
}

//
// Run the PEPO
//
Expand Down Expand Up @@ -3721,14 +3701,7 @@ PEPOTLDKTCPRun(
printf("Master lcore = %d\n", i);
#endif

StorageEngineT sEng;
sEng.StorageEngine = StorageEngine;
sEng.StorageEngineArg = StorageEngineArg;

result = rte_eal_remote_launch(StorageEngineThread, &sEng, CORE_ALLOCATION_STORAGE_ENGINE_SPDK_CORE);
if (result != 0) {
RTE_LOG(ERR, USER1, "rte_eal_remote_launch failed for storage engine: err = %d, lcore = %u\n", result, CORE_ALLOCATION_STORAGE_ENGINE_SPDK_CORE);
}
StorageEngine(StorageEngineArg);

//
// Wait for exit signal and sleep to avoid burning CPUs
Expand Down

0 comments on commit 8d53994

Please sign in to comment.