Fix Session Update
Change-Id: Icaa94f2812e0c7d3b05297c57d1c339f7c7bde35
This commit is contained in:
parent
cbc3e8d3a1
commit
4d11b00e56
|
@ -53,7 +53,8 @@ class SessionWP(base.IotronicObject):
|
|||
if strutils.is_int_like(session_or_board_uuid):
|
||||
return cls.get_by_id(context, session_or_board_uuid)
|
||||
elif uuidutils.is_uuid_like(session_or_board_uuid):
|
||||
return cls.get_by_uuid(context, session_or_board_uuid)
|
||||
return cls.get_session_by_board_uuid(context,
|
||||
session_or_board_uuid)
|
||||
else:
|
||||
raise exception.InvalidIdentity(identity=session_or_board_uuid)
|
||||
|
||||
|
@ -76,7 +77,6 @@ class SessionWP(base.IotronicObject):
|
|||
:param context: Security context
|
||||
:returns: a :class:`SessionWP` object.
|
||||
"""
|
||||
|
||||
db_session = cls.dbapi.get_session_by_board_uuid(board_uuid, valid)
|
||||
session = SessionWP._from_db_object(cls(context), db_session)
|
||||
return session
|
||||
|
@ -161,4 +161,4 @@ class SessionWP(base.IotronicObject):
|
|||
if (hasattr(
|
||||
self, base.get_attrname(field))
|
||||
and self[field] != current[field]):
|
||||
self[field] = current[field]
|
||||
self[field] = current[field]
|
||||
|
|
|
@ -75,20 +75,18 @@ def update_sessions(session_list):
|
|||
|
||||
def board_on_leave(session_id):
|
||||
LOG.debug('A board with %s disconnectd', session_id)
|
||||
|
||||
try:
|
||||
old_session = objects.SessionWP.get(ctxt, session_id)
|
||||
old_session.valid = False
|
||||
old_session.save()
|
||||
LOG.debug('Session %s deleted', session_id)
|
||||
board = objects.Board.get_by_uuid(ctxt, old_session.board_uuid)
|
||||
board.status = states.OFFLINE
|
||||
board.save()
|
||||
LOG.debug('Session updated. Board %s is now %s', board.uuid,
|
||||
states.OFFLINE)
|
||||
except Exception:
|
||||
LOG.debug('session %s not found', session_id)
|
||||
|
||||
board = objects.Board.get_by_uuid(ctxt, old_session.board_uuid)
|
||||
board.status = states.OFFLINE
|
||||
board.save()
|
||||
LOG.debug('Board %s is now %s', board.uuid, states.OFFLINE)
|
||||
|
||||
|
||||
def connection(uuid, session):
|
||||
LOG.debug('Received registration from %s with session %s',
|
||||
|
|
Loading…
Reference in New Issue