parent\dotnet\Commands\Test\MTP\IPC\NamedPipeServer.cs (14)
96ResetBuffer(_messageBuffer);
104await _messageBuffer.WriteAsync(bytes, cancellationToken);
111await _messageBuffer.WriteAsync(bytes.AsMemory(0, sizeof(int)), cancellationToken);
112await _messageBuffer.WriteAsync(_serializationBuffer.GetBuffer().AsMemory(0, (int)_serializationBuffer.Position), cancellationToken);
116await _namedPipeServerStream.WriteAsync(_messageBuffer.GetBuffer().AsMemory(0, (int)_messageBuffer.Position), cancellationToken);
121ResetBuffer(_messageBuffer);
129ResetBuffer(_messageBuffer);
169await _messageBuffer.WriteAsync(_readBuffer.AsMemory(0, bytesRead), cancellationToken);
173_messageBuffer.Position = 0;
174int serializerId = BitConverter.ToInt32(_messageBuffer.GetBuffer(), 0);
176_messageBuffer.Position += sizeof(int);
177return (IRequest)requestNamedPipeSerializer.Deserialize(_messageBuffer);
181ResetBuffer(_messageBuffer);