File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -370,7 +370,7 @@ func fetchLssdsForRaiding(lssdCount int) ([]string, error) {
370
370
return availableLssds [:lssdCount ], nil
371
371
}
372
372
373
- func setupDataCache (ctx context.Context , nodeName string ) error {
373
+ func setupDataCache (ctx context.Context , nodeName string , nodeId string ) error {
374
374
isAlreadyRaided , err := driver .IsRaided ()
375
375
if err != nil {
376
376
klog .V (4 ).Infof ("Errored while scanning for available LocalSSDs err:%v; continuing Raiding" , err )
@@ -400,6 +400,11 @@ func setupDataCache(ctx context.Context, nodeName string) error {
400
400
return fmt .Errorf ("Failed to Raid local SSDs, unable to setup Data Cache, got error %v" , err )
401
401
}
402
402
403
+ // Initializing data cache node (VG checks w/ raided lssd)
404
+ if err := driver .InitializeDataCacheNode (nodeId ); err != nil {
405
+ return err
406
+ }
407
+
403
408
klog .V (4 ).Infof ("LSSD caching is setup for the Data Cache enabled node %s" , nodeName )
404
409
return nil
405
410
}
You can’t perform that action at this time.
0 commit comments