DNET/dnetd_old
1
0
Fork 0
mirror of https://github.com/deavminet/dnetd synced 2024-09-21 17:53:39 +02:00
Code Issues Releases Activity

remove inbound server links when the connection breaks

Browse Source
This commit is contained in:
Tristan B. Kildaire 2021-01-30 16:57:19 +02:00
parent 6e75f84ba5
commit 4cd2528ca9
2 changed files with 34 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnetd/dconnection.d
View File

@ -227,7 +227,7 @@ public class DConnection : Thread
{ {
if(connType == ConnectionType.SERVER) if(connType == ConnectionType.SERVER)
{ {
server.getLinkManager().removeLinkInbounded(this);
} }
} }

34
source/dnetd/dlink.d
View File

@ -223,7 +223,7 @@ public final class DLink : Thread
this(server, name, address=null); this(server, name, address=null);
/* Save connection */ /* Save connection */
//this.connection = connection; this.connection = connection;
} }
public string getName() public string getName()
@ -305,6 +305,38 @@ public final class DMeyer : Thread
return linkGood; return linkGood;
} }
/**
* Remove a link via DConnection (inbounded)
*/
public void removeLinkInbounded(DConnection connection)
{
linksMutex.lock();
DLink[] newList;
DLink removedLink;
foreach(DLink link; links)
{
if(link.connection != connection)
{
newList ~= link;
}
else
{
removedLink = link;
}
}
links = newList;
linksMutex.unlock();
gprintln("Removed inbounded peer from link manager "~to!(string)(removedLink));
}
public DLink[] getLinks() public DLink[] getLinks()
{ {
return links; return links;