ServerSessionManager.java

Go to the documentation of this file.

package org.openslx.imagemaster.serversession;

import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

import org.openslx.bwlp.thrift.iface.ServerSessionData;
import org.openslx.imagemaster.util.Hash;
import org.openslx.util.QuickTimer;
import org.openslx.util.QuickTimer.Task;

public class ServerSessionManager
{
   // Map of currently known sessions
   private static final Map<String, ServerSession> serverSessions = new LinkedHashMap<String, ServerSession>();

   public static ServerSessionData addSession( ServerSession serverSession )
   {
      final String sessionId = Hash.sha256( UUID.randomUUID().toString() );

      synchronized ( serverSessions ) {
         serverSessions.put( sessionId, serverSession );
      }
      return new ServerSessionData( sessionId );
   }

   public static ServerSession getSession( String sessionId )
   {
      final ServerSession serverSession;
      synchronized ( serverSessions ) {
         serverSession = serverSessions.get( sessionId );
      }
      if ( serverSession == null || serverSession.timedOut() ) {
         return null;
      }
      serverSession.refresh();
      return serverSession;
   }

   static {
      QuickTimer.scheduleAtFixedDelay( new Task() {
         @Override
         public void fire()
         {
            synchronized ( serverSessions ) {
               Iterator<ServerSession> it = serverSessions.values().iterator();
               while ( it.hasNext() ) {
                  final ServerSession s = it.next();
                  if ( s.timedOut() ) {
                     it.remove();
                  }
               }
            }
         }
      }, 911, TimeUnit.MINUTES.toMillis( 14 ) );
   }

}