82 module:log("debug", "target connected ... "); |
82 module:log("debug", "target connected ... "); |
83 elseif transfers[sha].target ~= nil then |
83 elseif transfers[sha].target ~= nil then |
84 transfers[sha].initiator = conn; |
84 transfers[sha].initiator = conn; |
85 session.sha = sha; |
85 session.sha = sha; |
86 module:log("debug", "initiator connected ... "); |
86 module:log("debug", "initiator connected ... "); |
87 throttle_sending(conn, transfers[sha].target); |
87 throttle_sending(conn, transfers[sha].target); |
88 throttle_sending(transfers[sha].target, conn); |
88 throttle_sending(transfers[sha].target, conn); |
89 end |
89 end |
90 conn:write(string.char(5, 0, 0, 3, sha:len()) .. sha .. string.char(0, 0)); -- VER, REP, RSV, ATYP, BND.ADDR (sha), BND.PORT (2 Byte) |
90 conn:write(string.char(5, 0, 0, 3, sha:len()) .. sha .. string.char(0, 0)); -- VER, REP, RSV, ATYP, BND.ADDR (sha), BND.PORT (2 Byte) |
91 conn:lock_read(true) |
91 conn:lock_read(true) |
92 else |
92 else |
93 module:log("warn", "Neither data transfer nor initial connect of a participator of a transfer.") |
93 module:log("warn", "Neither data transfer nor initial connect of a participator of a transfer.") |