renun/koreader
1
0
Fork 0
mirror of https://github.com/koreader/koreader.git synced 2025-08-10 00:52:38 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

more luacheck fixes

Browse Source
This commit is contained in:
Qingping Hou
2016-02-15 22:34:28 -08:00
parent 3c647ff244
commit 6a6469fa09
9 changed files with 23 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
frontend/ui/message/streammessagequeue.lua
View File

@@ -1,6 +1,5 @@
local ffi = require("ffi")
local DEBUG = require("dbg")
local Event = require("ui/event")
local MessageQueue = require("ui/message/messagequeue")
local _ = require("ffi/zeromq_h")
@@ -24,7 +23,8 @@ function StreamMessageQueue:start()
end
local id_size = ffi.new("size_t[1]", 256)
local buffer = ffi.new("uint8_t[?]", id_size[0])
rc = zmq.zmq_getsockopt(self.socket, ffi.C.ZMQ_IDENTITY, buffer, id_size)
-- @todo: check return of zmq_getsockopt
zmq.zmq_getsockopt(self.socket, ffi.C.ZMQ_IDENTITY, buffer, id_size)
self.id = ffi.string(buffer, id_size[0])
DEBUG("id", #self.id, self.id)
end
@@ -65,7 +65,7 @@ function StreamMessageQueue:waitEvent()
while czmq.zpoller_wait(self.poller, 0) ~= nil and wait_packages > 0 do
local id_frame = czmq.zframe_recv(self.socket)
if id_frame ~= nil then
local id = self:handleZframe(id_frame)
self:handleZframe(id_frame)
end
local frame = czmq.zframe_recv(self.socket)
if frame ~= nil then