NamedPipeServerStream.EndWaitForConnection() po prostu zawiesza się po użyciu

Question

Próbuję użyć nazwanych potoków po raz pierwszy. W dokumentacji MS stwierdzono here, stwierdza, że:

EndWaitForConnection musi być wywołana dokładnie jeden raz na każde wezwanie do BeginWaitForConnection.

Więc staram się być dobrą trochę programista i postępuj zgodnie z dokumentacją, ale EndWaitForConnection() prostu wisi w nieskończoność, kiedy go używać.

Więc rozebrałem mój kod do absolutnego minimum, więc zobacz, czy mógłbym wyizolować problem, ale nie ma kości. Wyciągnąłem poniższy kod z klasy, którą napisałem. I zostały zmodyfikowane tak, że zaczyna oczekiwanie na połączenie rury natychmiast próbuje przestać czekać na tego połączenia rur:

private void WaitForConnectionCallBack(IAsyncResult result) 
{ 

} 

public void Start() 
{ 
    var tempPipe = new NamedPipeServerStream("TempPipe", 
              PipeDirection.In, 
              254, 
              PipeTransmissionMode.Message, 
              PipeOptions.Asynchronous); 

    IAsyncResult result = tempPipe.BeginWaitForConnection(
            new AsyncCallback(WaitForConnectionCallBack), this); 

    tempPipe.EndWaitForConnection(result); // <----- Hangs on this line right here 
} 

---

1) Dlaczego to powiesić na EndWaitForConnection()? Jeśli chcę wyłączyć serwer, zanim otrzymam połączenie, jak zasadniczo anulować to wywołanie zwrotne od BeginWaitForConnection()?

2) Załóżmy, że nie miałem wyżej wymienionego problemu. Co się stanie, jeśli 2 klienci bardzo szybko spróbują połączyć się z moją nazwaną siecią?

Czy otrzymuję wywołanie zwrotne dla każdego z nich, czy muszę czekać na otrzymanie pierwszego powiadomienia o połączeniu, a następnie szybko ponownie zadzwonić pod numer EndWaitForConnection(), a następnie WaitForConnectionCallBack(), aby ponownie zacząć słuchać następnego klienta?

Ten ostatni wydaje się być dla mnie warunkiem wyścigowym, ponieważ może nie ustawić wystarczająco szybko odbiornika połączenia.

Answer 1

Więc podstawowy szkielet rozwiązania, które pracuje dla mnie jest następująca:

private void WaitForConnectionCallBack(IAsyncResult result) 
{ 
    try 
    { 
     PipeServer.EndWaitForConnection(result); 

     /// ... 
     /// Some arbitrary code 
     /// ... 
    } 
    catch 
    { 
     // If the pipe is closed before a client ever connects, 
     // EndWaitForConnection() will throw an exception. 

     // If we are in here that is probably the case so just return. 
     return; 
    } 
} 

Oto kod serwera.

public void Start() 
{ 
    var server= new NamedPipeServerStream("TempPipe", 
              PipeDirection.In, 
              254, 
              PipeTransmissionMode.Message, 
              PipeOptions.Asynchronous); 

    // If nothing ever connects, the callback will never be called. 
    server.BeginWaitForConnection(new AsyncCallback(WaitForConnectionCallBack), this); 

    // ... arbitrary code 

// EndWaitForConnection() was not the right answer here, it would just wait indefinitely 
// if you called it. As Hans Passant mention, its meant to be used in the callback. 
// Which it now is. Instead, we are going to close the pipe. This will trigger 
// the callback to get called. 

// However, the EndWaitForConnection() that will excecute in the callback will fail 
// with an exception since the pipe is closed by time it gets invoked, 
// thus you must capture it with a try/catch 

    server.Close(); // <--- effectively closes our pipe and gets our 
         //  BeginWaitForConnection() moving, even though any future 
         //  operations on the pipe will fail. 
}