Why NamedPipeClientStream not able to connect to open named pipe?

Swapnil Dave 41

I opened a named pipe (fifo file) in a golang process and I am trying to connect that pipe in a c# process using namedpipeclientstream. When I call the connect method it blocks forever. So, I'm not able to understand why won't the named pipe connect.

Jack J Jun 24,496 Reputation points Microsoft Vendor

2023-04-24T06:42:54.0933333+00:00

@Swapnil Dave , Welcome to Microsoft Q&A, if you meet the block problem when you use the connect method, it means that your NamedPipeClient could not detect the correspond server. If you open NamedPipeClient in c# process, will you still get the error? I recommend that you could try the code example in the following link and based on my test, it could call the connect method without the problem. https://stackoverflow.com/a/66766100
Jack J Jun 24,496 Reputation points Microsoft Vendor

2023-04-27T05:29:39.7433333+00:00

@Swapnil Dave, is any update?

Swapnil Dave 41

@Jack J Jun the article in stack overflow is suggesting to use async await which means at some point the pipe will connect but mine doesn't connect even when I wait for 5 to 10 minutes.

Below are two code snippets, if it helps. I start the golang process first and create the FIFO or Named pipe and then start the c# process which connects the pipe.

Can you please look into the snippet and tell me what am I doing wrong.


public static class Client
{
    private static Logger _logger = new Logger("client");

    public static void Main(string[] args)
    {
        var pipe = new NamedPipeClientStream(
            "/home/swapnil/workspace/Go_Workspace/Motadata_DB/src/motadatadb/poc/named-pipe");


        pipe.Connect();


        var reader = new StreamReader(pipe);

        Console.Write(reader.ReadToEnd());
    }
}


func main() {

	err := syscall.Mkfifo("named-pipe", 0777)

	if err != nil {

		fmt.Println(err.Error())
	}

	file, err := os.OpenFile("named-pipe", os.O_RDWR|syscall.O_NONBLOCK, os.ModeNamedPipe)

	if err != nil {

		fmt.Println(err.Error())
	}

	for {

		file.WriteString("hello")

		time.Sleep(time.Second)

	}

}

Share via

Why NamedPipeClientStream not able to connect to open named pipe?