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

Quick test modifivcaiton to toString

Browse Source
This commit is contained in:
Tristan B. Kildaire 2021-01-30 14:35:42 +02:00
parent 998f8060bf
commit 315fcb8ac9
2 changed files with 19 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/app.d
View File

@ -78,7 +78,7 @@ void main(string[] args)
gprintln("Links I will be opening: " ~to!(string)(serverLinks)); gprintln("Links I will be opening: " ~to!(string)(serverLinks));
/* Create a new Meyer (link manager) and attach the links to it */ /* Create a new Meyer (link manager) and attach the links to it */
DMeyer meyer = new DMeyer(dserver, serverLinks); DMeyer meyer = new DMeyer(dserver);
/* Attach the Meyer to the server */ /* Attach the Meyer to the server */
dserver.attachLinkManager(meyer); dserver.attachLinkManager(meyer);

27
source/dnetd/dlink.d
View File

@ -210,7 +210,8 @@ public final class DLink : Thread
override public string toString() override public string toString()
{ {
return "Server: "~name~", Address: "~to!(string)(address); return name;
// return "Server: "~name~", Address: "~to!(string)(address);
} }
@ -235,7 +236,7 @@ public final class DLink : Thread
} }
/* TODO: Remove this from here and put it in DServer */ /* TODO: Remove this from here and put it in DServer */
public final class DMeyer public final class DMeyer : Thread
{ {
/* Direct peers */ /* Direct peers */
private DLink[] links; private DLink[] links;
@ -244,21 +245,29 @@ public final class DMeyer
/* Associated server */ /* Associated server */
private DServer server; private DServer server;
this(DServer server, DLink[] links) this(DServer server)
{ {
super(&worker);
/* save shit */
this.server = server; this.server = server;
/* Initialize the locks */ /* Initialize the locks */
initLocks(); initLocks();
/* Open a connection to the server */ start();
/* TODO: Open connections to all servers we are yet to open a connection to (check the `links` array) */
//this.links = links;
} }
private void worker()
{
while(true)
{
linksMutex.lock();
gprintln("Linked servers: "~to!(string)(links), DebugType.WARNING);
linksMutex.unlock();
Thread.sleep(dur!("seconds")(3));
}
}
/* Initialize locks */ /* Initialize locks */
private void initLocks() private void initLocks()