port now optional

This commit is contained in:
madsenco committed 2011-03-18 14:01:52 +01:00
1 parent 4f989fec6a
commit 185ee01ca0
1 file changed
+14 -10
+14 -10
View File
@@ -139,17 +139,21 @@ function NmeaNode:start(str)
end
if not self.mPortNo then return end
local sock, err = socket.bind("0.0.0.0", self.mPortNo)
self.mPortSock = assert(sock, ("Can not open listen on %d: %t"):_(self.mPortNo, err))
local subscr = appc.addFileIO(self.mPortSock:getfd(), function(subscr)
local inp = self.mPortSock:accept()
log.notice(("PORT:%-12s Connection %d opened from %s"):
_(self.mName, inp:getfd(), inp:getpeername()))
local subscr = appc.addFileIO(inp:getfd(), function(subscr) self:readClient(subscr, inp) end)
if self.mPortNo then
local sock, err = socket.bind("0.0.0.0", self.mPortNo)
self.mPortSock = assert(sock, ("Can not open listen on %d: %t"):_(self.mPortNo, err))
local subscr = appc.addFileIO(self.mPortSock:getfd(), function(subscr)
local inp = self.mPortSock:accept()
log.notice(("PORT:%-12s Connection %d opened from %s"):
_(self.mName, inp:getfd(), inp:getpeername()))
local subscr = appc.addFileIO(inp:getfd(), function(subscr)
self:readClient(subscr, inp)
end)
self.mSubscriptions[subscr] = true
self.mListeners[inp] = true
end)
self.mSubscriptions[subscr] = true
self.mListeners[inp] = true
end)
self.mSubscriptions[subscr] = true
end
end
---