Method Create

server/sessionstore.go:27–74

(conn interface{}, appid uint32)

}

func (ss *SessionStore) Create(conn interface{}, appid uint32) *Session {
	var s Session

	switch conn.(type) {
	case *websocket.Conn:
		s.proto = WEBSOCK
		s.ws, _ = conn.(*websocket.Conn)
	case http.ResponseWriter:
		s.proto = LPOLL
		s.wrt, _ = conn.(http.ResponseWriter)
	default:
		s.proto = NONE
	}

	if s.proto != NONE {
		s.subs = make(map[string]*Subscription)
		s.send = make(chan []byte, 64) // buffered
		s.stop = make(chan bool)
		s.detach = make(chan string, 64) // buffered
	}

	s.appid = appid
	s.lastTouched = time.Now()
	s.sid = getRandomString()
	s.uid = types.ZeroUid

	if s.proto != WEBSOCK {
		// Websocket connections are not managed by SessionStore
		ss.rw.Lock()

		elem := ss.lru.PushFront(&sessionStoreElement{s.sid, &s})
		ss.sessions[s.sid] = elem

		// Remove expired sessions
		expire := s.lastTouched.Add(-ss.lifeTime)
		for elem = ss.lru.Back(); elem != nil; elem = ss.lru.Back() {
			if elem.Value.(*sessionStoreElement).val.lastTouched.Before(expire) {
				ss.lru.Remove(elem)
				delete(ss.sessions, elem.Value.(*sessionStoreElement).key)
			} else {
				break // don't need to traverse further
			}
		}
		ss.rw.Unlock()
	}

	return &s
}

func (ss *SessionStore) Get(sid string) *Session {
	ss.rw.Lock()