X-Git-Url: http://www.average.org/gitweb/?p=loctrkd.git;a=blobdiff_plain;f=gps303%2Fwsgateway.py;h=8a5af7f43ec37c94d1500c9ab3a46bf934991e33;hp=7756fe9d52ae10d0bcdb8012869ac7e78f3393b9;hb=97c5fc86f9fbab5df74879b9b2a705dbb8dcba63;hpb=96538346bd332d76d2cac5d6a0ef2b4e4a40de30 diff --git a/gps303/wsgateway.py b/gps303/wsgateway.py index 7756fe9..8a5af7f 100644 --- a/gps303/wsgateway.py +++ b/gps303/wsgateway.py @@ -277,8 +277,9 @@ def runserver(conf): log.debug("Received from %d: %s", sk, msg) if msg.get("type", None) == "subscribe": imei = msg.get("imei") - if imei: - tosend.extend(backlog(imei[0], 5)) + numback = msg.get("backlog", 5) + for elem in imei: + tosend.extend(backlog(elem, numback)) towrite.add(sk) elif fl & zmq.POLLOUT: log.debug("Write now open for fd %d", sk)