@@ -86,12 +86,12 @@ public static void registerNodeBaseDirs(Settings settings, Path configPath) {
86
86
Path homeDir = absolutePath (PATH_HOME_SETTING .get (settings ));
87
87
Path configDir = configPath != null ? configPath : homeDir .resolve ("config" );
88
88
Collection <Path > dataDirs = dataDirs (settings , homeDir );
89
- Path sharedDataDir = sharedDataDir (settings );
89
+ Collection < Path > sharedDataDir = sharedDataDir (settings );
90
90
Collection <Path > repoDirs = repoDirs (settings );
91
91
logger .debug ("Registering node dirs: config [{}], dataDirs [{}], repoDirs [{}]" , configDir , dataDirs , repoDirs );
92
92
baseDirPaths .compute (BaseDir .CONFIG , baseDirModifier (paths -> paths .add (configDir )));
93
93
baseDirPaths .compute (BaseDir .DATA , baseDirModifier (paths -> paths .addAll (dataDirs )));
94
- baseDirPaths .compute (BaseDir .SHARED_DATA , baseDirModifier (paths -> paths .add (sharedDataDir )));
94
+ baseDirPaths .compute (BaseDir .SHARED_DATA , baseDirModifier (paths -> paths .addAll (sharedDataDir )));
95
95
baseDirPaths .compute (BaseDir .SHARED_REPO , baseDirModifier (paths -> paths .addAll (repoDirs )));
96
96
policyManager .reset ();
97
97
}
@@ -103,12 +103,12 @@ public static void unregisterNodeBaseDirs(Settings settings, Path configPath) {
103
103
Path homeDir = absolutePath (PATH_HOME_SETTING .get (settings ));
104
104
Path configDir = configPath != null ? configPath : homeDir .resolve ("config" );
105
105
Collection <Path > dataDirs = dataDirs (settings , homeDir );
106
- Path sharedDataDir = sharedDataDir (settings );
106
+ Collection < Path > sharedDataDir = sharedDataDir (settings );
107
107
Collection <Path > repoDirs = repoDirs (settings );
108
108
logger .debug ("Unregistering node dirs: config [{}], dataDirs [{}], repoDirs [{}]" , configDir , dataDirs , repoDirs );
109
109
baseDirPaths .compute (BaseDir .CONFIG , baseDirModifier (paths -> paths .remove (configDir )));
110
110
baseDirPaths .compute (BaseDir .DATA , baseDirModifier (paths -> paths .removeAll (dataDirs )));
111
- baseDirPaths .compute (BaseDir .SHARED_DATA , baseDirModifier (paths -> paths .remove (sharedDataDir )));
111
+ baseDirPaths .compute (BaseDir .SHARED_DATA , baseDirModifier (paths -> paths .removeAll (sharedDataDir )));
112
112
baseDirPaths .compute (BaseDir .SHARED_REPO , baseDirModifier (paths -> paths .removeAll (repoDirs )));
113
113
policyManager .reset ();
114
114
}
@@ -120,9 +120,9 @@ private static Collection<Path> dataDirs(Settings settings, Path homeDir) {
120
120
: dataDirs .stream ().map (TestEntitlementBootstrap ::absolutePath ).toList ();
121
121
}
122
122
123
- private static Path sharedDataDir (Settings settings ) {
123
+ private static Collection < Path > sharedDataDir (Settings settings ) {
124
124
String sharedDataDir = PATH_SHARED_DATA_SETTING .get (settings );
125
- return Strings .hasText (sharedDataDir ) ? absolutePath (sharedDataDir ) : null ;
125
+ return Strings .hasText (sharedDataDir ) ? List . of ( absolutePath (sharedDataDir )) : List . of () ;
126
126
}
127
127
128
128
private static Collection <Path > repoDirs (Settings settings ) {
0 commit comments