honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

better method name

This commit is contained in:
kimchy 2010-06-25 01:41:06 +03:00
parent 98e93322ae
commit 811856e1f8
5 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.idea/dictionaries/kimchy.xml
View File

@ -115,6 +115,7 @@
<w>tuple</w> <w>tuple</w>
<w>unboxed</w> <w>unboxed</w>
<w>unicast</w> <w>unicast</w>
<w>unmanaged</w>
<w>unregister</w> <w>unregister</w>
<w>uptime</w> <w>uptime</w>
<w>uuid</w> <w>uuid</w>

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/store/fs/FsIndexStore.java
View File

@ -74,7 +74,7 @@ public abstract class FsIndexStore extends AbstractIndexComponent implements Ind
return location; return location;
} }
public File shardLocation(ShardId shardId) { public File shardIndexLocation(ShardId shardId) {
return new File(new File(location, Integer.toString(shardId.id())), "index"); return new File(new File(location, Integer.toString(shardId.id())), "index");
} }
} }

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/store/fs/MmapFsStore.java
View File

@ -52,7 +52,7 @@ public class MmapFsStore extends FsStore<Directory> {
// by default, we don't need to sync to disk, since we use the gateway // by default, we don't need to sync to disk, since we use the gateway
this.syncToDisk = componentSettings.getAsBoolean("sync_to_disk", false); this.syncToDisk = componentSettings.getAsBoolean("sync_to_disk", false);
LockFactory lockFactory = buildLockFactory(); LockFactory lockFactory = buildLockFactory();
File location = ((FsIndexStore) indexStore).shardLocation(shardId); File location = ((FsIndexStore) indexStore).shardIndexLocation(shardId);
location.mkdirs(); location.mkdirs();
this.fsDirectory = new CustomMMapDirectory(location, lockFactory, syncToDisk); this.fsDirectory = new CustomMMapDirectory(location, lockFactory, syncToDisk);

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/store/fs/NioFsStore.java
View File

@ -52,7 +52,7 @@ public class NioFsStore extends FsStore<Directory> {
// by default, we don't need to sync to disk, since we use the gateway // by default, we don't need to sync to disk, since we use the gateway
this.syncToDisk = componentSettings.getAsBoolean("sync_to_disk", false); this.syncToDisk = componentSettings.getAsBoolean("sync_to_disk", false);
LockFactory lockFactory = buildLockFactory(); LockFactory lockFactory = buildLockFactory();
File location = ((FsIndexStore) indexStore).shardLocation(shardId); File location = ((FsIndexStore) indexStore).shardIndexLocation(shardId);
location.mkdirs(); location.mkdirs();
this.fsDirectory = new CustomNioFSDirectory(location, lockFactory, syncToDisk); this.fsDirectory = new CustomNioFSDirectory(location, lockFactory, syncToDisk);

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/store/fs/SimpleFsStore.java
View File

@ -52,7 +52,7 @@ public class SimpleFsStore extends FsStore<Directory> {
// by default, we don't need to sync to disk, since we use the gateway // by default, we don't need to sync to disk, since we use the gateway
this.syncToDisk = componentSettings.getAsBoolean("sync_to_disk", false); this.syncToDisk = componentSettings.getAsBoolean("sync_to_disk", false);
LockFactory lockFactory = buildLockFactory(); LockFactory lockFactory = buildLockFactory();
File location = ((FsIndexStore) indexStore).shardLocation(shardId); File location = ((FsIndexStore) indexStore).shardIndexLocation(shardId);
location.mkdirs(); location.mkdirs();
this.fsDirectory = new CustomSimpleFSDirectory(location, lockFactory, syncToDisk); this.fsDirectory = new CustomSimpleFSDirectory(location, lockFactory, syncToDisk);