mirror of
https://github.com/markqvist/Reticulum.git
synced 2024-10-01 03:15:44 -04:00
Work on I2P Interface
This commit is contained in:
parent
4b3ead3db2
commit
c357f7a94e
@ -363,6 +363,8 @@ class I2PInterfacePeer(Interface):
|
|||||||
while True:
|
while True:
|
||||||
data_in = self.socket.recv(4096)
|
data_in = self.socket.recv(4096)
|
||||||
if len(data_in) > 0:
|
if len(data_in) > 0:
|
||||||
|
# TODO: Remove
|
||||||
|
RNS.log("Read "+str(len(data_in)))
|
||||||
pointer = 0
|
pointer = 0
|
||||||
while pointer < len(data_in):
|
while pointer < len(data_in):
|
||||||
byte = data_in[pointer]
|
byte = data_in[pointer]
|
||||||
@ -508,6 +510,7 @@ class I2PInterface(Interface):
|
|||||||
for peer_addr in peers:
|
for peer_addr in peers:
|
||||||
interface_name = peer_addr
|
interface_name = peer_addr
|
||||||
peer_interface = I2PInterfacePeer(self, interface_name, peer_addr)
|
peer_interface = I2PInterfacePeer(self, interface_name, peer_addr)
|
||||||
|
RNS.Transport.interfaces.append(peer_interface)
|
||||||
|
|
||||||
self.online = True
|
self.online = True
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user