Skip to content

Commit

Permalink
# ignite-164 : rename resolveGridGainPath, resolveGridGainUrl util me…
Browse files Browse the repository at this point in the history
…thods
  • Loading branch information
ashutakGG committed Feb 5, 2015
1 parent 0b7b251 commit c323001
Show file tree
Hide file tree
Showing 65 changed files with 86 additions and 86 deletions.
Expand Up @@ -93,7 +93,7 @@ public abstract class ClientAbstractMultiThreadedSelfTest extends GridCommonAbst
public static final int REST_TCP_PORT_BASE = 12345; public static final int REST_TCP_PORT_BASE = 12345;


static { static {
System.setProperty("CLIENTS_MODULE_PATH", U.resolveGridGainPath("modules/clients").getAbsolutePath()); System.setProperty("CLIENTS_MODULE_PATH", U.resolveIgnitePath("modules/clients").getAbsolutePath());
} }


/** Client instance for each test. */ /** Client instance for each test. */
Expand Down
Expand Up @@ -50,7 +50,7 @@ public class ClientSslNodeStartup {
* @throws IgniteCheckedException In case of any exception. * @throws IgniteCheckedException In case of any exception.
*/ */
public static void main(String[] args) throws IgniteCheckedException { public static void main(String[] args) throws IgniteCheckedException {
System.setProperty("CLIENTS_MODULE_PATH", U.resolveGridGainPath("modules/clients").getAbsolutePath()); System.setProperty("CLIENTS_MODULE_PATH", U.resolveIgnitePath("modules/clients").getAbsolutePath());


try (Ignite g = G.start("modules/clients/src/test/resources/spring-server-ssl-node.xml")) { try (Ignite g = G.start("modules/clients/src/test/resources/spring-server-ssl-node.xml")) {
U.sleep(Long.MAX_VALUE); U.sleep(Long.MAX_VALUE);
Expand Down
Expand Up @@ -102,7 +102,7 @@ static IgniteConfiguration getConfig(String type) {
if (path == null) if (path == null)
throw new IllegalArgumentException("Unsupported node type: " + type); throw new IllegalArgumentException("Unsupported node type: " + type);


URL url = U.resolveGridGainUrl(path); URL url = U.resolveIgniteUrl(path);


BeanFactory ctx = new FileSystemXmlApplicationContext(url.toString()); BeanFactory ctx = new FileSystemXmlApplicationContext(url.toString());


Expand Down
Expand Up @@ -50,9 +50,9 @@ public class ClientPropertiesConfigurationSelfTest extends GridCommonAbstractTes
*/ */
static { static {
GRID_CLIENT_SPRING_CONFIG = GRID_CLIENT_SPRING_CONFIG =
U.resolveGridGainUrl("/modules/clients/config/grid-client-spring-config.xml"); U.resolveIgniteUrl("/modules/clients/config/grid-client-spring-config.xml");


GRID_CLIENT_CONFIG = U.resolveGridGainUrl("/modules/clients/config/grid-client-config.properties"); GRID_CLIENT_CONFIG = U.resolveIgniteUrl("/modules/clients/config/grid-client-config.properties");
} }


/** /**
Expand Down
Expand Up @@ -199,7 +199,7 @@ protected Object getTaskArgument() {


clientCfg.setRestAccessibleFolders( clientCfg.setRestAccessibleFolders(
U.getIgniteHome() + "/work/log", U.getIgniteHome() + "/work/log",
U.resolveGridGainPath("modules/core/src/test/resources/log").getAbsolutePath()); U.resolveIgnitePath("modules/core/src/test/resources/log").getAbsolutePath());


if (useSsl()) { if (useSsl()) {
clientCfg.setRestTcpSslEnabled(true); clientCfg.setRestTcpSslEnabled(true);
Expand Down
Expand Up @@ -32,7 +32,7 @@
* <pre name="code" class="java"> * <pre name="code" class="java">
* GridConfiguration cfg = new GridConfiguration(); * GridConfiguration cfg = new GridConfiguration();
* ... * ...
* URL xml = U.resolveGridGainUrl("config/custom-log4j.xml"); * URL xml = U.resolveIgniteUrl("config/custom-log4j.xml");
* GridLogger log = new GridLog4jLogger(xml); * GridLogger log = new GridLog4jLogger(xml);
* ... * ...
* cfg.setGridLogger(log); * cfg.setGridLogger(log);
Expand Down
Expand Up @@ -40,7 +40,7 @@ public class CachingProvider implements javax.cache.spi.CachingProvider {
URI uri = null; URI uri = null;


try { try {
URL dfltCfgURL = U.resolveGridGainUrl(IgnitionEx.DFLT_CFG); URL dfltCfgURL = U.resolveIgniteUrl(IgnitionEx.DFLT_CFG);


if (dfltCfgURL != null) if (dfltCfgURL != null)
uri = dfltCfgURL.toURI(); uri = dfltCfgURL.toURI();
Expand Down
Expand Up @@ -118,7 +118,7 @@ public static void main(String[] args) throws IgniteCheckedException {


String cfgPath = args[0]; String cfgPath = args[0];


URL cfgUrl = U.resolveGridGainUrl(cfgPath); URL cfgUrl = U.resolveIgniteUrl(cfgPath);


if (cfgUrl == null) { if (cfgUrl == null) {
X.error("Spring XML file not found (is IGNITE_HOME set?): " + cfgPath); X.error("Spring XML file not found (is IGNITE_HOME set?): " + cfgPath);
Expand Down
Expand Up @@ -426,7 +426,7 @@ public static Ignite start() throws IgniteCheckedException {
* also if default grid has already been started. * also if default grid has already been started.
*/ */
public static Ignite start(@Nullable GridSpringResourceContext springCtx) throws IgniteCheckedException { public static Ignite start(@Nullable GridSpringResourceContext springCtx) throws IgniteCheckedException {
URL url = U.resolveGridGainUrl(DFLT_CFG); URL url = U.resolveIgniteUrl(DFLT_CFG);


if (url != null) if (url != null)
return start(DFLT_CFG, null, springCtx); return start(DFLT_CFG, null, springCtx);
Expand Down Expand Up @@ -577,7 +577,7 @@ public static Ignite startInterop(@Nullable String springCfgPath, @Nullable Stri
url = new URL(springCfgPath); url = new URL(springCfgPath);
} }
catch (MalformedURLException e) { catch (MalformedURLException e) {
url = U.resolveGridGainUrl(springCfgPath); url = U.resolveIgniteUrl(springCfgPath);


if (url == null) if (url == null)
throw new IgniteCheckedException("Spring XML configuration path is invalid: " + springCfgPath + throw new IgniteCheckedException("Spring XML configuration path is invalid: " + springCfgPath +
Expand Down Expand Up @@ -810,7 +810,7 @@ private static URL resolveSpringUrl(String springCfgPath) throws IgniteCheckedEx
url = new URL(springCfgPath); url = new URL(springCfgPath);
} }
catch (MalformedURLException e) { catch (MalformedURLException e) {
url = U.resolveGridGainUrl(springCfgPath); url = U.resolveIgniteUrl(springCfgPath);


if (url == null) if (url == null)
throw new IgniteCheckedException("Spring XML configuration path is invalid: " + springCfgPath + throw new IgniteCheckedException("Spring XML configuration path is invalid: " + springCfgPath +
Expand Down Expand Up @@ -2018,7 +2018,7 @@ private IgniteLogger initLogger(@Nullable IgniteLogger cfgLog, UUID nodeId) thro


if (log4jCls != null) { if (log4jCls != null) {
try { try {
URL url = U.resolveGridGainUrl("config/ignite-log4j.xml"); URL url = U.resolveIgniteUrl("config/ignite-log4j.xml");


if (url == null) { if (url == null) {
File cfgFile = new File("config/ignite-log4j.xml"); File cfgFile = new File("config/ignite-log4j.xml");
Expand Down
Expand Up @@ -118,7 +118,7 @@ else if (log.isDebugEnabled())
* @throws IOException If file couldn't be accessed or read failed. * @throws IOException If file couldn't be accessed or read failed.
*/ */
private List<String> readLog(String path, int from, int to) throws IgniteCheckedException, IOException { private List<String> readLog(String path, int from, int to) throws IgniteCheckedException, IOException {
URL url = U.resolveGridGainUrl(path); URL url = U.resolveIgniteUrl(path);


if (url == null) if (url == null)
throw new IgniteCheckedException("Log file not found: " + path); throw new IgniteCheckedException("Log file not found: " + path);
Expand Down
Expand Up @@ -2548,7 +2548,7 @@ public static void setIgniteHome(@Nullable String path) {
* @param path Path to resolve. * @param path Path to resolve.
* @return Resolved path as file, or {@code null} if path cannot be resolved. * @return Resolved path as file, or {@code null} if path cannot be resolved.
*/ */
@Nullable public static File resolveGridGainPath(String path) { @Nullable public static File resolveIgnitePath(String path) {
assert path != null; assert path != null;


/* /*
Expand Down Expand Up @@ -2596,8 +2596,8 @@ public static void setIgniteHome(@Nullable String path) {
* @return Resolved path as URL, or {@code null} if path cannot be resolved. * @return Resolved path as URL, or {@code null} if path cannot be resolved.
* @see #getIgniteHome() * @see #getIgniteHome()
*/ */
@Nullable public static URL resolveGridGainUrl(String path) { @Nullable public static URL resolveIgniteUrl(String path) {
return resolveGridGainUrl(path, true); return resolveIgniteUrl(path, true);
} }


/** /**
Expand All @@ -2615,11 +2615,11 @@ public static void setIgniteHome(@Nullable String path) {
* @see #getIgniteHome() * @see #getIgniteHome()
*/ */
@SuppressWarnings({"UnusedCatchParameter"}) @SuppressWarnings({"UnusedCatchParameter"})
@Nullable public static URL resolveGridGainUrl(String path, boolean metaInf) { @Nullable public static URL resolveIgniteUrl(String path, boolean metaInf) {
File f = resolveGridGainPath(path); File f = resolveIgnitePath(path);


if (f == null) if (f == null)
f = resolveGridGainPath("os/" + path); f = resolveIgnitePath("os/" + path);


if (f != null) { if (f != null) {
try { try {
Expand Down
Expand Up @@ -100,7 +100,7 @@ private VisorFileBlockJob(VisorFileBlockArg arg, boolean debug) {
/** {@inheritDoc} */ /** {@inheritDoc} */
@Override protected IgniteBiTuple<? extends IOException, VisorFileBlock> run(VisorFileBlockArg arg) { @Override protected IgniteBiTuple<? extends IOException, VisorFileBlock> run(VisorFileBlockArg arg) {
try { try {
URL url = U.resolveGridGainUrl(arg.path); URL url = U.resolveIgniteUrl(arg.path);


if (url == null) if (url == null)
return new IgniteBiTuple<>(new NoSuchFileException("File path not found: " + arg.path), null); return new IgniteBiTuple<>(new NoSuchFileException("File path not found: " + arg.path), null);
Expand Down
Expand Up @@ -66,7 +66,7 @@ private VisorLatestTextFilesJob(IgniteBiTuple<String, String> arg, boolean debug
assert path != null; assert path != null;
assert regexp != null; assert regexp != null;


URL url = U.resolveGridGainUrl(path); URL url = U.resolveIgniteUrl(path);


if (url == null) if (url == null)
return null; return null;
Expand Down
Expand Up @@ -210,7 +210,7 @@ private List<GridTuple3<String[], Integer, Integer>> searchInFile(File f, Charse


/** {@inheritDoc} */ /** {@inheritDoc} */
@Override protected Collection<VisorLogSearchResult> run(VisorLogSearchArg arg) { @Override protected Collection<VisorLogSearchResult> run(VisorLogSearchArg arg) {
URL url = U.resolveGridGainUrl(arg.folder); URL url = U.resolveIgniteUrl(arg.folder);


if (url == null) if (url == null)
throw U.convertException(new GridInternalException(new FileNotFoundException("Log folder not found: " + arg.folder))); throw U.convertException(new GridInternalException(new FileNotFoundException("Log folder not found: " + arg.folder)));
Expand Down
Expand Up @@ -622,7 +622,7 @@ else if (ggfs == null)
else else
throw new IgniteCheckedException("Failed to get profiler log folder (unexpected GGFS instance type)"); throw new IgniteCheckedException("Failed to get profiler log folder (unexpected GGFS instance type)");


URL logsDirUrl = U.resolveGridGainUrl(logsDir != null ? logsDir : DFLT_GGFS_LOG_DIR); URL logsDirUrl = U.resolveIgniteUrl(logsDir != null ? logsDir : DFLT_GGFS_LOG_DIR);


return logsDirUrl != null ? new File(logsDirUrl.getPath()).toPath() : null; return logsDirUrl != null ? new File(logsDirUrl.getPath()).toPath() : null;
} }
Expand Down
Expand Up @@ -127,7 +127,7 @@ public static boolean isConfigured() {
* Reads default JUL configuration. * Reads default JUL configuration.
*/ */
private void defaultConfiguration() { private void defaultConfiguration() {
final URL cfgUrl = U.resolveGridGainUrl(DFLT_CONFIG_PATH); final URL cfgUrl = U.resolveIgniteUrl(DFLT_CONFIG_PATH);


if (cfgUrl == null) { if (cfgUrl == null) {
error("Failed to resolve default logging config file: " + DFLT_CONFIG_PATH); error("Failed to resolve default logging config file: " + DFLT_CONFIG_PATH);
Expand Down
Expand Up @@ -183,7 +183,7 @@ public void setClassNamesPath(@Nullable String path) throws IgniteCheckedExcepti
if (path == null) if (path == null)
return; return;


URL url = IgniteUtils.resolveGridGainUrl(path, false); URL url = IgniteUtils.resolveIgniteUrl(path, false);


if (url == null) if (url == null)
throw new IgniteCheckedException("Failed to find resource for name: " + path); throw new IgniteCheckedException("Failed to find resource for name: " + path);
Expand Down
Expand Up @@ -39,7 +39,7 @@ public class GridGcTimeoutTest {
*/ */
@SuppressWarnings("InfiniteLoopStatement") @SuppressWarnings("InfiniteLoopStatement")
public static void main(String[] args) throws IgniteCheckedException { public static void main(String[] args) throws IgniteCheckedException {
Ignite g = G.start(U.resolveGridGainUrl(CFG_PATH)); Ignite g = G.start(U.resolveIgniteUrl(CFG_PATH));


IgniteDataLoader<Long, String> ldr = g.dataLoader(null); IgniteDataLoader<Long, String> ldr = g.dataLoader(null);


Expand Down
Expand Up @@ -41,7 +41,7 @@ public class GridJobLoadTest implements Runnable {
*/ */
static { static {
try { try {
TEST_CONF_DIR = new File(U.resolveGridGainUrl("/modules/core/src/test/config/job-loadtest").toURI()); TEST_CONF_DIR = new File(U.resolveIgniteUrl("/modules/core/src/test/config/job-loadtest").toURI());
} }
catch (URISyntaxException e) { catch (URISyntaxException e) {
throw new RuntimeException("Failed to initialize directory.", e); throw new RuntimeException("Failed to initialize directory.", e);
Expand Down
Expand Up @@ -78,7 +78,7 @@ public void run() throws UnknownHostException, IgniteCheckedException {
} }
}; };


IgniteLogger log = new GridTestLog4jLogger(U.resolveGridGainUrl("config/ignite-log4j.xml")); IgniteLogger log = new GridTestLog4jLogger(U.resolveIgniteUrl("config/ignite-log4j.xml"));


GridNioServer.<ByteBuffer>builder() GridNioServer.<ByteBuffer>builder()
.address(InetAddress.getByName("localhost")) .address(InetAddress.getByName("localhost"))
Expand Down
Expand Up @@ -121,7 +121,7 @@ private static Collection<GridStreamerLoad> loads(String cfgPath) throws Excepti
cfgUrl = new URL(cfgPath); cfgUrl = new URL(cfgPath);
} }
catch (MalformedURLException ignore) { catch (MalformedURLException ignore) {
cfgUrl = U.resolveGridGainUrl(cfgPath); cfgUrl = U.resolveIgniteUrl(cfgPath);
} }


if (cfgUrl == null) if (cfgUrl == null)
Expand Down
Expand Up @@ -341,7 +341,7 @@ private static IgniteConfiguration getConfiguration(String springCfgPath, @Nulla
assert cfg != null; assert cfg != null;


if (logCfgPath != null) if (logCfgPath != null)
cfg.setGridLogger(new GridTestLog4jLogger(U.resolveGridGainUrl(logCfgPath))); cfg.setGridLogger(new GridTestLog4jLogger(U.resolveIgniteUrl(logCfgPath)));


return cfg; return cfg;
} }
Expand Down
Expand Up @@ -1323,7 +1323,7 @@ public static SSLContext sslContext() throws GeneralSecurityException, IOExcepti


KeyStore keyStore = KeyStore.getInstance("JKS"); KeyStore keyStore = KeyStore.getInstance("JKS");


keyStore.load(new FileInputStream(U.resolveGridGainPath(GridTestProperties.getProperty("ssl.keystore.path"))), keyStore.load(new FileInputStream(U.resolveIgnitePath(GridTestProperties.getProperty("ssl.keystore.path"))),
storePass); storePass);


keyMgrFactory.init(keyStore, storePass); keyMgrFactory.init(keyStore, storePass);
Expand All @@ -1343,7 +1343,7 @@ public static GridSslContextFactory sslContextFactory() {
GridSslBasicContextFactory factory = new GridSslBasicContextFactory(); GridSslBasicContextFactory factory = new GridSslBasicContextFactory();


factory.setKeyStoreFilePath( factory.setKeyStoreFilePath(
U.resolveGridGainPath(GridTestProperties.getProperty("ssl.keystore.path")).getAbsolutePath()); U.resolveIgnitePath(GridTestProperties.getProperty("ssl.keystore.path")).getAbsolutePath());
factory.setKeyStorePassword(GridTestProperties.getProperty("ssl.keystore.password").toCharArray()); factory.setKeyStorePassword(GridTestProperties.getProperty("ssl.keystore.password").toCharArray());


factory.setTrustManagers(GridSslBasicContextFactory.getDisabledTrustManager()); factory.setTrustManagers(GridSslBasicContextFactory.getDisabledTrustManager());
Expand Down
Expand Up @@ -864,7 +864,7 @@ protected Ignite startGrid(String gridName, IgniteConfiguration cfg) throws Exce
*/ */
@SuppressWarnings("deprecation") @SuppressWarnings("deprecation")
protected IgniteConfiguration loadConfiguration(String springCfgPath) throws IgniteCheckedException { protected IgniteConfiguration loadConfiguration(String springCfgPath) throws IgniteCheckedException {
URL cfgLocation = U.resolveGridGainUrl(springCfgPath); URL cfgLocation = U.resolveIgniteUrl(springCfgPath);


assert cfgLocation != null; assert cfgLocation != null;


Expand Down
Expand Up @@ -57,7 +57,7 @@ protected final void startRemoteNodes() throws Exception {
if (rmtCfgs.isEmpty()) { if (rmtCfgs.isEmpty()) {
info("Loading remote configs properties from file: " + RMT_NODE_CFGS); info("Loading remote configs properties from file: " + RMT_NODE_CFGS);


try (FileReader reader = new FileReader(U.resolveGridGainPath(RMT_NODE_CFGS))) { try (FileReader reader = new FileReader(U.resolveIgnitePath(RMT_NODE_CFGS))) {
rmtCfgs.load(reader); rmtCfgs.load(reader);
} }
} }
Expand Down
Expand Up @@ -164,7 +164,7 @@ public GridTestLog4jLogger(String path) throws IgniteCheckedException {


this.path = path; this.path = path;


final URL cfgUrl = U.resolveGridGainUrl(path); final URL cfgUrl = U.resolveIgniteUrl(path);


if (cfgUrl == null) if (cfgUrl == null)
throw new IgniteCheckedException("Log4j configuration path was not found: " + path); throw new IgniteCheckedException("Log4j configuration path was not found: " + path);
Expand Down
Expand Up @@ -238,7 +238,7 @@ public void colocateFileWrites(boolean colocateFileWrites) {
// Get log directory. // Get log directory.
String logDirCfg = parameter(cfg, PARAM_GGFS_LOG_DIR, uriAuthority, DFLT_GGFS_LOG_DIR); String logDirCfg = parameter(cfg, PARAM_GGFS_LOG_DIR, uriAuthority, DFLT_GGFS_LOG_DIR);


File logDirFile = U.resolveGridGainPath(logDirCfg); File logDirFile = U.resolveIgnitePath(logDirCfg);


String logDir = logDirFile != null ? logDirFile.getAbsolutePath() : null; String logDir = logDirFile != null ? logDirFile.getAbsolutePath() : null;


Expand Down Expand Up @@ -295,7 +295,7 @@ public void colocateFileWrites(boolean colocateFileWrites) {
try { try {
secondaryUri = new URI(secUri); secondaryUri = new URI(secUri);


URL secondaryCfgUrl = U.resolveGridGainUrl(secConfPath); URL secondaryCfgUrl = U.resolveIgniteUrl(secConfPath);


Configuration conf = new Configuration(); Configuration conf = new Configuration();


Expand Down
Expand Up @@ -234,7 +234,7 @@ private void initialize(URI name, Configuration cfg) throws IOException {
// Get log directory. // Get log directory.
String logDirCfg = parameter(cfg, PARAM_GGFS_LOG_DIR, uriAuthority, DFLT_GGFS_LOG_DIR); String logDirCfg = parameter(cfg, PARAM_GGFS_LOG_DIR, uriAuthority, DFLT_GGFS_LOG_DIR);


File logDirFile = U.resolveGridGainPath(logDirCfg); File logDirFile = U.resolveIgnitePath(logDirCfg);


String logDir = logDirFile != null ? logDirFile.getAbsolutePath() : null; String logDir = logDirFile != null ? logDirFile.getAbsolutePath() : null;


Expand Down Expand Up @@ -298,7 +298,7 @@ private void initialize(URI name, Configuration cfg) throws IOException {
try { try {
secondaryUri = new URI(secUri); secondaryUri = new URI(secUri);


URL secondaryCfgUrl = U.resolveGridGainUrl(secConfPath); URL secondaryCfgUrl = U.resolveIgniteUrl(secConfPath);


if (secondaryCfgUrl == null) if (secondaryCfgUrl == null)
throw new IOException("Failed to resolve secondary file system config URL: " + secConfPath); throw new IOException("Failed to resolve secondary file system config URL: " + secConfPath);
Expand Down
Expand Up @@ -60,7 +60,7 @@ public GridGgfsHadoopFileSystemWrapper(@Nullable String uri, @Nullable String cf
Configuration cfg = new Configuration(); Configuration cfg = new Configuration();


if (cfgPath != null) if (cfgPath != null)
cfg.addResource(U.resolveGridGainUrl(cfgPath)); cfg.addResource(U.resolveIgniteUrl(cfgPath));


try { try {
fileSys = uri == null ? FileSystem.get(cfg) : FileSystem.get(new URI(uri), cfg); fileSys = uri == null ? FileSystem.get(cfg) : FileSystem.get(new URI(uri), cfg);
Expand Down
Expand Up @@ -147,7 +147,7 @@ private File outputDirectory() throws IOException {
* @return Logger. * @return Logger.
*/ */
private IgniteLogger logger(final File outputDir) { private IgniteLogger logger(final File outputDir) {
final URL url = U.resolveGridGainUrl(DFLT_LOG4J_CONFIG); final URL url = U.resolveIgniteUrl(DFLT_LOG4J_CONFIG);


IgniteLog4jLogger logger; IgniteLog4jLogger logger;


Expand Down
Expand Up @@ -232,7 +232,7 @@ public static void main(String[] args) throws Exception {
if (startNode) { if (startNode) {
X.println("Starting node using configuration: " + nodeCfg); X.println("Starting node using configuration: " + nodeCfg);


ignite = G.start(U.resolveGridGainUrl(nodeCfg)); ignite = G.start(U.resolveIgniteUrl(nodeCfg));
} }


try { try {
Expand Down Expand Up @@ -269,7 +269,7 @@ public void runLoad(String url, String hadoopCfg, final boolean primaryOnly, int


Configuration cfg = new Configuration(true); Configuration cfg = new Configuration(true);


cfg.addResource(U.resolveGridGainUrl(hadoopCfg)); cfg.addResource(U.resolveIgniteUrl(hadoopCfg));


final FileSystem fs = FileSystem.get(fsPath.toUri(), cfg); final FileSystem fs = FileSystem.get(fsPath.toUri(), cfg);


Expand Down
Expand Up @@ -293,7 +293,7 @@ private CommunicationSpi communicationSpi() {


primaryFsCfg = new Configuration(); primaryFsCfg = new Configuration();


primaryFsCfg.addResource(U.resolveGridGainUrl(primaryFileSystemConfigPath())); primaryFsCfg.addResource(U.resolveIgniteUrl(primaryFileSystemConfigPath()));


fs = AbstractFileSystem.get(primaryFsUri, primaryFsCfg); fs = AbstractFileSystem.get(primaryFsUri, primaryFsCfg);


Expand Down
Expand Up @@ -240,7 +240,7 @@ public void testOpenPrefetchOverride() throws Exception {
// Instantiate file system with overridden "seq reads before prefetch" property. // Instantiate file system with overridden "seq reads before prefetch" property.
Configuration cfg = new Configuration(); Configuration cfg = new Configuration();


cfg.addResource(U.resolveGridGainUrl(PRIMARY_CFG)); cfg.addResource(U.resolveIgniteUrl(PRIMARY_CFG));


int seqReads = SEQ_READS_BEFORE_PREFETCH + 1; int seqReads = SEQ_READS_BEFORE_PREFETCH + 1;


Expand Down
Expand Up @@ -2102,7 +2102,7 @@ private void checkConsistency(int createBufSize, int writeCntsInCreate, int open
private FileSystem local(Path home) throws IOException { private FileSystem local(Path home) throws IOException {
Configuration cfg = new Configuration(); Configuration cfg = new Configuration();


cfg.addResource(U.resolveGridGainUrl(HADOOP_FS_CFG)); cfg.addResource(U.resolveIgniteUrl(HADOOP_FS_CFG));


return FileSystem.get(home.toUri(), cfg); return FileSystem.get(home.toUri(), cfg);
} }
Expand Down

0 comments on commit c323001

Please sign in to comment.