besterprotocol/besterd
1
0
Fork 0
mirror of https://github.com/besterprotocol/besterd synced 2023-12-13 21:00:32 +01:00
Code Issues Releases Wiki Activity

Fixed compile errors.

Browse source
This commit is contained in:
Tristan B. Kildaire 2020-05-04 15:27:16 +02:00
parent 3d1607ee9e
commit 86ce419db6
2 changed files with 24 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
source/server/informer/client.d
View file

@ -1,8 +1,28 @@
module server.informer.client;
import core.thread : Thread;
import server.server : BesterServer;
import std.socket;
public class BesterInformerClient : Thread
{
/* The associated `BesterServer` */
private BesterServer server;
/* The socket to the handler */
private Socket handlerSocket;
this(BesterServer server, Socket handlerSocket)
{
super(&worker);
this.server = server;
this.handlerSocket = handlerSocket;
}
private void worker()
{
/* TODO: Implement me */
}
}

4
source/server/informer/informer.d
View file

@ -3,6 +3,7 @@ module server.informer.informer;
import core.thread : Thread;
import server.server : BesterServer;
import std.socket;
import server.informer.client : BesterInformerClient;
/**
* The `BesterInformer` allows handlers to query (out-of-band)
@ -35,6 +36,9 @@ public final class BesterInformer : Thread
while(1)
{
Socket handler = informerSocket.accept();
BesterInformerClient newInformer = new BesterInformerClient(server, handler);
newInformer.start();
}
}