Issue with socket recieve

[Tim]

Hi all,

I'm having a really terrible bug that seemed to come from nowhere 
and is really hard to narrow down. I have a threaded message 
service that works via local TcpSocket. Every time I run it, 
either an error saying:
>Unable to open 'recv.c': Unable to read file 
>'/build/glibc-ZN95T4/glibc-2.31/sysdeps/unix/sysv/linux/recv.c' 
>(Error: Unable to resolve non-existing file 
>'/build/glibc-ZN95T4/glibc-2.31/sysdeps/unix/sysv/linux/recv.c').
when socket.receive() is called. Sometimes I get the same thing 
but for socket.accept() instead (different file). This seems to 
generate a core.exception.InvalidMemoryOperationError that I 
can't catch.

Yesterday, this came up after a couple of minutes of the program 
running, now it happens straight away. I haven't touched this 
class in a week or so and can't think of why all of a sudden it 
has come up with this issue. Code dump below

---------------------------------------------


>module message_service;
>
>import std.stdio;
>import std.socket;
>import core.thread;
>
>
>/**
>Threaded socket manager to serve inter-service communication
>
>Calls delegates when the appropriate command is received
>*/
>class MessageService : Thread{
>    /// The socket over which communication is possible
>    private Socket server;
>    /// The connection to the client that sends commands
>    private Socket client;
>    /// Associative array of command strings and relative 
> functions to call
>    private void delegate()[string] commands;
>    /// Global buffer. Holds the command being recieved
>    private char[1024] buffer = 0;
> 
>
>    ///
>    this(ushort port, void delegate()[string] _commands){
>        commands = _commands;
>        server = new TcpSocket();
>        server.setOption(SocketOptionLevel.SOCKET, 
> SocketOption.REUSEADDR, true);
>        server.bind(new InternetAddress(port));
>        writefln("Message service started on port %d", port);
>        super(&mainLoop);
>        start();
>    }
>
>
>    /// Loops over polling the client socket for commands
>    void mainLoop(){
>        while(true){
>            pollMessages();
>        }
>    }
>
>
>    /**
>    Polls the client socket for characters to build up the 
> message buffer
> 
>    When a string command is found, it calls the appropriate 
> function
>    */
>    void pollMessages(){
>        server.listen(1);
>        if(client is null) client = server.accept();
>
>        // Add to the message buffer
>        auto buffLength = client.receive(buffer);
>
>        if(buffLength){
>            auto message = cast(string) buffer[0 .. buffLength];
> 
>            foreach(cmd; commands.byKey){
>                if(cmd == message){
>                    // Reset the message buffer
>                    buffer = 0;
>                    commands[cmd]();
>                    return;
>                }
>            }
>        }
>    }
>}