nathanAjacobs Comments - Answer Overflow

nathanAjacobs

Posts Comments

CC#

•Created by nathanAjacobs on 6/5/2024 in #help

NamedPipeClientStream.ReadAsync() continuously reads after the first message arrives

I was being dumb and called dispose in the finally block instead of the catch

5 replies

CC#

•Created by nathanAjacobs on 6/5/2024 in #help

NamedPipeClientStream.ReadAsync() continuously reads after the first message arrives

After the first message arrives it continuously reads null as the line

5 replies

CC#

•Created by nathanAjacobs on 6/5/2024 in #help

NamedPipeClientStream.ReadAsync() continuously reads after the first message arrives

I don't believe I'm intentionally finishing the server stream, here is my code:

public class ServerPipe : IDisposable
{
    readonly SemaphoreSlim semapohre = new SemaphoreSlim(0, 1);

    readonly NamedPipeServerStream server;

    readonly StreamWriter writer;

    private volatile bool _disposed;

    public ServerPipe()
    {
        server = new NamedPipeServerStream("MyTestPipe", PipeDirection.Out);
        writer = new StreamWriter(server, System.Text.Encoding.Unicode);
        _ = WaitForConnectiionAsync();
    }

    private async Task WaitForConnectiionAsync()
    {
        try
        {
            await server.WaitForConnectionAsync().ConfigureAwait(false);
            semapohre.Release();
        }
        catch (Exception ex)
        {
            Debug.LogException(ex);
        }
    }

    public async void WriteMessage(string message)
    {
        if (_disposed)
            return;

        try
        {
            await semapohre.WaitAsync().ConfigureAwait(false);
            await writer.WriteLineAsync(message).ConfigureAwait(false);
            await writer.FlushAsync().ConfigureAwait(false);
        }
        catch (Exception ex)
        {
            Debug.LogException(ex);
        }
        finally
        {
            semapohre.Release();
            Dispose();
        }
    }

    public void Dispose()
    {
        _disposed = true;
        semapohre.Dispose();
        writer.Dispose();
        server.Dispose();
    }
}

public class ClientPipe : IDisposable
{
    readonly NamedPipeClientStream client;
    readonly StreamReader reader;

    public ClientPipe()
    {
        client = new NamedPipeClientStream(".", "MyTestPipe", PipeDirection.In);
        reader = new StreamReader(client);
        _ = RunReadLoopAsync();
    }

    private async Task RunReadLoopAsync()
    {
        try
        {
            await client.ConnectAsync();

            while (true)
            {
                string line = await reader.ReadLineAsync();
                Debug.Log(line);
            }
        }
        catch (Exception ex)
        {
            Debug.LogException(ex);
        }
    }

    public void Dispose()
    {
        reader.Dispose();
        client.Dispose();
    }
}

public class ServerPipe : IDisposable
{
    readonly SemaphoreSlim semapohre = new SemaphoreSlim(0, 1);

    readonly NamedPipeServerStream server;

    readonly StreamWriter writer;

    private volatile bool _disposed;

    public ServerPipe()
    {
        server = new NamedPipeServerStream("MyTestPipe", PipeDirection.Out);
        writer = new StreamWriter(server, System.Text.Encoding.Unicode);
        _ = WaitForConnectiionAsync();
    }

    private async Task WaitForConnectiionAsync()
    {
        try
        {
            await server.WaitForConnectionAsync().ConfigureAwait(false);
            semapohre.Release();
        }
        catch (Exception ex)
        {
            Debug.LogException(ex);
        }
    }

    public async void WriteMessage(string message)
    {
        if (_disposed)
            return;

        try
        {
            await semapohre.WaitAsync().ConfigureAwait(false);
            await writer.WriteLineAsync(message).ConfigureAwait(false);
            await writer.FlushAsync().ConfigureAwait(false);
        }
        catch (Exception ex)
        {
            Debug.LogException(ex);
        }
        finally
        {
            semapohre.Release();
            Dispose();
        }
    }

    public void Dispose()
    {
        _disposed = true;
        semapohre.Dispose();
        writer.Dispose();
        server.Dispose();
    }
}

public class ClientPipe : IDisposable
{
    readonly NamedPipeClientStream client;
    readonly StreamReader reader;

    public ClientPipe()
    {
        client = new NamedPipeClientStream(".", "MyTestPipe", PipeDirection.In);
        reader = new StreamReader(client);
        _ = RunReadLoopAsync();
    }

    private async Task RunReadLoopAsync()
    {
        try
        {
            await client.ConnectAsync();

            while (true)
            {
                string line = await reader.ReadLineAsync();
                Debug.Log(line);
            }
        }
        catch (Exception ex)
        {
            Debug.LogException(ex);
        }
    }

    public void Dispose()
    {
        reader.Dispose();
        client.Dispose();
    }
}

5 replies

CC#

•Created by nathanAjacobs on 5/6/2024 in #help

Can Memory<T> be created from a pointer?

This allocates a managed array and has to perform a copy. The MemoryManager<T> is the better solution

15 replies

CC#

•Created by nathanAjacobs on 5/6/2024 in #help

Can Memory<T> be created from a pointer?

Yeah I tried asking copilot earlier and got a lot of stuff that was incorrect

15 replies

CC#

•Created by nathanAjacobs on 5/6/2024 in #help

Can Memory<T> be created from a pointer?

Ty this will work! I was going crazy looking for a something in the BCL that does this.

15 replies

CC#