deavmi/tristanable
deavmi
/
tristanable
mirror of https://github.com/deavmi/tristanable.git
1
0
Fork 0
Code Issues 2 Projects Releases Wiki Activity

Renamed

This commit is contained in:
Tristan B. Kildaire 2020-09-29 19:18:53 +02:00
parent 96e755d3cc
commit 41199e96fc
2 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/tristanable/manager2.d → source/tristanable/manager.d
View File

@ -1,6 +1,9 @@
module tristanable.manager;
import std.socket : Socket;
import core.sync.mutex : Mutex;
import bmessage : bSendMessage = sendMessage;
import tristanable.queue : Queue;
public final class Manager
{

11
source/tristanable/watcher2.d → source/tristanable/watcher.d
View File

@ -1,5 +1,14 @@
module tristanable.watcher;
import std.socket : Socket;
import core.sync.mutex : Mutex;
import bmessage : receiveMessage;
import tristanable.queue : Queue;
import tristanable.queueitem : QueueItem;
import tristanable.manager : Manager;
import core.thread : Thread;
import tristanable.encoding;
public final class Watcher : Thread
{
/* The manager */
@ -24,7 +33,7 @@ public final class Watcher : Thread
byte[] receivedPayload;
/* Block for socket response */
bool recvStatus = receiveMessage(endpoint, receivedPayload);
bool recvStatus = receiveMessage(socket, receivedPayload);
/* If the receive was successful */
if(recvStatus)