LocalSessionMgr.java 文件源码

/**
 * 
 * @param sid
 * @param serverType
 * @param sequence
 * @param localSession
 * @return
 */
public LocalSession addSession(String serverId,String serverType,int sessionId,LocalSession localSession) {
    if (localSession == null) {
        return null;
    }
    localSession.setServerId(serverId);
    localSession.setServerType(serverType);
    localSession.setId(sessionId);
    localSession.setlistener(this.closeListener);
    localSession.setStatus(ISession.STATUS_WORKING);
    sessionBySid.put(serverId, localSession);

    synchronized(sessionByStype) {
        LinkedListMultimap<String, LocalSession> multimap = sessionByStype.get(serverType);
        if (multimap == null) {
            multimap = LinkedListMultimap.create();
            sessionByStype.put(serverType, multimap);
        }
        multimap.put(serverId, localSession);
    }
    return localSession;
}