Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

JETTY-1484 Add option for HashSessionManager to delete session files if it can't restore them

This commit is contained in:
Jan Bartel 2012-02-09 19:21:10 +11:00
parent 5f0fdb7d32
commit b949fb7622
1 changed files with 29 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
jetty-server/src/main/java/org/eclipse/jetty/server/session/HashSessionManager.java
View File

@ -60,6 +60,10 @@ public class HashSessionManager extends AbstractSessionManager
File _storeDir; File _storeDir;
private boolean _lazyLoad=false; private boolean _lazyLoad=false;
private volatile boolean _sessionsLoaded=false; private volatile boolean _sessionsLoaded=false;
private boolean _deleteUnrestorableSessions=false;
/* ------------------------------------------------------------ */ /* ------------------------------------------------------------ */
public HashSessionManager() public HashSessionManager()
@ -433,6 +437,18 @@ public class HashSessionManager extends AbstractSessionManager
{ {
return _lazyLoad; return _lazyLoad;
} }
/* ------------------------------------------------------------ */
public boolean isDeleteUnrestorableSessions()
{
return _deleteUnrestorableSessions;
}
/* ------------------------------------------------------------ */
public void setDeleteUnrestorableSessions(boolean deleteUnrestorableSessions)
{
_deleteUnrestorableSessions = deleteUnrestorableSessions;
}
/* ------------------------------------------------------------ */ /* ------------------------------------------------------------ */
public void restoreSessions () throws Exception public void restoreSessions () throws Exception
@ -460,9 +476,9 @@ public class HashSessionManager extends AbstractSessionManager
/* ------------------------------------------------------------ */ /* ------------------------------------------------------------ */
protected synchronized HashedSession restoreSession(String idInCuster) protected synchronized HashedSession restoreSession(String idInCuster)
{ {
File file = new File(_storeDir,idInCuster);
try try
{ {
File file = new File(_storeDir,idInCuster);
if (file.exists()) if (file.exists())
{ {
FileInputStream in = new FileInputStream(file); FileInputStream in = new FileInputStream(file);
@ -476,7 +492,18 @@ public class HashSessionManager extends AbstractSessionManager
} }
catch (Exception e) catch (Exception e)
{ {
__log.warn("Problem restoring session "+idInCuster, e);
if (isDeleteUnrestorableSessions())
{
if (file.exists())
{
file.delete();
__log.warn("Deleting file for unrestorable session "+idInCuster, e);
}
}
else
__log.warn("Problem restoring session "+idInCuster, e);
} }
return null; return null;
} }