Rx3/MassiveCore
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

(Probably) Fix bug where unclosed WatchServices cause inotify limit to fill upp. Also cache the values for a minor speedup.

Browse Source
This commit is contained in:
Olof Larsson 2016-01-21 12:53:48 +01:00
parent b3e117277e
commit 0c2e624f10
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/com/massivecraft/massivecore/store/DriverFlatfile.java
View File

@ -3,6 +3,7 @@ package com.massivecraft.massivecore.store;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.nio.file.FileSystems; import java.nio.file.FileSystems;
import java.nio.file.WatchService;
import java.util.AbstractMap.SimpleEntry; import java.util.AbstractMap.SimpleEntry;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
@ -218,12 +219,15 @@ public class DriverFlatfile extends DriverAbstract
file.delete(); file.delete();
} }
@Override private boolean supportsPusher = this.supportsPusherCalc();
public boolean supportsPusher() private boolean supportsPusherCalc()
{ {
try try
{ {
return ! ( FileSystems.getDefault().newWatchService().getClass().getName().equals("sun.nio.fs.PollingWatchService")); WatchService watchService = FileSystems.getDefault().newWatchService();
boolean ret = ! watchService.getClass().getName().equals("sun.nio.fs.PollingWatchService");
watchService.close();
return ret;
} }
catch (IOException e) catch (IOException e)
{ {
@ -231,6 +235,12 @@ public class DriverFlatfile extends DriverAbstract
} }
} }
@Override
public boolean supportsPusher()
{
return this.supportsPusher;
}
@Override @Override
public PusherColl getPusher(Coll<?> coll) public PusherColl getPusher(Coll<?> coll)
{ {