i tried
This commit is contained in:
@@ -1,4 +1,4 @@
|
|||||||
local max_distance = 220
|
local max_distance = {}
|
||||||
|
|
||||||
local pullEvent = os.pullEventRaw
|
local pullEvent = os.pullEventRaw
|
||||||
local modem = peripheral.find("modem",function (s) return peripheral.wrap(s).isWireless() end)
|
local modem = peripheral.find("modem",function (s) return peripheral.wrap(s).isWireless() end)
|
||||||
@@ -11,11 +11,12 @@ if not modem then
|
|||||||
end
|
end
|
||||||
local message_queue = {}
|
local message_queue = {}
|
||||||
modem.open(15125)
|
modem.open(15125)
|
||||||
local canidate = {id = -1, distance = max_distance}
|
local canidate = {id = -1, distance = 764}
|
||||||
parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
|
parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
|
||||||
function ()
|
function ()
|
||||||
while true do
|
while true do
|
||||||
local _, _, channel, _, msg, distance = pullEvent("modem_message")
|
local _, _, channel, _, msg, distance = pullEvent("modem_message")
|
||||||
|
max_distance[msg.sender] = math.max(distance,max_distance[msg.sender] or 0)
|
||||||
if channel == 15125 then
|
if channel == 15125 then
|
||||||
if msg.protocol == "entrypoint_advertise" then
|
if msg.protocol == "entrypoint_advertise" then
|
||||||
if distance < canidate.distance then
|
if distance < canidate.distance then
|
||||||
@@ -36,9 +37,9 @@ local function receive()
|
|||||||
if msg.protocol == "heartbeat" and msg.target == os.getComputerID() and msg.sender == canidate.id then
|
if msg.protocol == "heartbeat" and msg.target == os.getComputerID() and msg.sender == canidate.id then
|
||||||
last_heartbeat = os.epoch("utc")
|
last_heartbeat = os.epoch("utc")
|
||||||
modem.transmit(15125,15125,{protocol="heartbeat_response",sender=os.getComputerID(),target=canidate.id})
|
modem.transmit(15125,15125,{protocol="heartbeat_response",sender=os.getComputerID(),target=canidate.id})
|
||||||
if distance > max_distance then
|
if distance > (max_distance[msg.sender]or 6)-5 then
|
||||||
modem.transmit(15125,15125,{protocol="entrypoint_disconnect",sender=os.getComputerID(),target=canidate.id})
|
modem.transmit(15125,15125,{protocol="entrypoint_disconnect",sender=os.getComputerID(),target=canidate.id})
|
||||||
canidate = {id = -1, distance = max_distance}
|
canidate = {id = -1, distance = (max_distance[msg.sender]or 6)-5}
|
||||||
parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
|
parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
|
||||||
function ()
|
function ()
|
||||||
while true do
|
while true do
|
||||||
@@ -78,7 +79,7 @@ end
|
|||||||
local function connect()
|
local function connect()
|
||||||
while true do
|
while true do
|
||||||
if os.epoch("utc") - last_heartbeat > 200 then
|
if os.epoch("utc") - last_heartbeat > 200 then
|
||||||
canidate = {id = -1, distance = max_distance}
|
canidate = {id = -1, distance = (max_distance[msg.sender]or 6)-5}
|
||||||
parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
|
parallel.waitForAny(function () repeat sleep(0.1) until canidate.id ~= -1 end,
|
||||||
function ()
|
function ()
|
||||||
while true do
|
while true do
|
||||||
|
|||||||
Reference in New Issue
Block a user