das
This commit is contained in:
parent
47d013fbc2
commit
a636fd4176
@ -105,7 +105,7 @@ class SyncServerProtocol(CommandProtocol):
|
|||||||
@state('connected')
|
@state('connected')
|
||||||
@argumentCount(1)
|
@argumentCount(1)
|
||||||
def playing(self, args):
|
def playing(self, args):
|
||||||
self.factory.playing_received(self, args[0])
|
self.factory.playing_received(self.__protocol, args[0])
|
||||||
|
|
||||||
|
|
||||||
@state('connected')
|
@state('connected')
|
||||||
@ -118,12 +118,12 @@ class SyncServerProtocol(CommandProtocol):
|
|||||||
if not watcher.room in self.factory.paused:
|
if not watcher.room in self.factory.paused:
|
||||||
self.factory.paused[watcher.room] = True
|
self.factory.paused[watcher.room] = True
|
||||||
self.factory.remove_room_if_empty(old_room)
|
self.factory.remove_room_if_empty(old_room)
|
||||||
watcher = self.factory.watchers.get(self)
|
watcher = self.factory.watchers.get(self.__protocol)
|
||||||
|
|
||||||
@state('connected')
|
@state('connected')
|
||||||
@argumentCount(0)
|
@argumentCount(0)
|
||||||
def list(self, args):
|
def list(self, args):
|
||||||
watcher = self.factory.watchers.get(self)
|
watcher = self.factory.watchers.get(self.__protocol)
|
||||||
for w in self.factory.watchers.itervalues():
|
for w in self.factory.watchers.itervalues():
|
||||||
if w == watcher:
|
if w == watcher:
|
||||||
continue
|
continue
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user