Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport에 대한 상속 다이어그램 :

[범례]

Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport에 대한 협력 다이어그램:

[범례]

Public 멤버 함수
async Task< PlcResult >	ConnectAsync (string host, int port, int timeoutMs, CancellationToken cancellationToken=default)
async Task< PlcResult >	DisconnectAsync (CancellationToken cancellationToken=default)
async Task< PlcResult< byte[]> >	SendAndReceiveAsync (IReadOnlyList< byte > requestFrame, int receiveTimeoutMs, int retryCount, CancellationToken cancellationToken=default)
async ValueTask	DisposeAsync ()

속성
bool	IsConnected `[get]`

Private 멤버 함수
Task	CloseCoreAsync ()
void	ThrowIfDisposed ()

정적 Private 멤버 함수
static async Task< byte[]>	ReceiveBinary3EFrameAsync (NetworkStream stream, CancellationToken cancellationToken)
static async Task	ReadExactlyAsync (NetworkStream stream, byte[] buffer, CancellationToken cancellationToken)

Private 속성
readonly SemaphoreSlim	_syncLock = new(1, 1)
TcpClient?	_tcpClient
NetworkStream?	_stream
bool	_disposed

상세한 설명

Mitsubishi MC 프로토콜용 TCP 전송을 제공합니다.

TcpMitsubishiMcTransport.cs 파일의 14 번째 라인에서 정의되었습니다.

멤버 함수 문서화

◆ CloseCoreAsync()

Task Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.CloseCoreAsync ( )

inlineprivate

내부 TCP 스트림과 클라이언트를 닫고 참조를 지웁니다.

반환값: 완료된 작업입니다.

TcpMitsubishiMcTransport.cs 파일의 520 번째 라인에서 정의되었습니다.

    {
        try
        {
            _stream?.Close();
            _stream?.Dispose();
 
            _tcpClient?.Close();
            _tcpClient?.Dispose();
        }
        finally
        {
            _stream = null;
            _tcpClient = null;
        }
 
        return Task.CompletedTask;
    }

다음을 참조함 : _stream, _tcpClient.

다음에 의해서 참조됨 : ConnectAsync(), DisconnectAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ ConnectAsync()

async Task< PlcResult > Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.ConnectAsync	(	string	host,
		int	port,
		int	timeoutMs,
		CancellationToken	cancellationToken = default )

inline

제한 시간 내 대상 TCP 끝점에 연결합니다.

매개변수

host	호스트입니다.
port	포트입니다.
timeoutMs	제한 시간입니다.
cancellationToken	취소 토큰입니다.

반환값: 연결 결과입니다.

예외

ArgumentException	호스트가 비어 있는 경우 발생합니다.
OperationCanceledException	동기화 잠금 대기 중 취소된 경우 발생합니다.

Dreamine.PLC.Mitsubishi.MC.Transport.IMitsubishiMcTransport를 구현.

TcpMitsubishiMcTransport.cs 파일의 120 번째 라인에서 정의되었습니다.

    {
        ArgumentException.ThrowIfNullOrWhiteSpace(host);
 
        if (port is <= 0 or > 65535)
        {
            return PlcResult.Failure($"Invalid TCP port: {port}");
        }
 
        if (timeoutMs <= 0)
        {
            return PlcResult.Failure("The connection timeout must be greater than zero.");
        }
 
        await _syncLock.WaitAsync(cancellationToken).ConfigureAwait(false);
 
        try
        {
            ThrowIfDisposed();
 
            if (IsConnected)
            {
                return PlcResult.Success();
            }
 
            await CloseCoreAsync().ConfigureAwait(false);
 
            _tcpClient = new TcpClient
            {
                NoDelay = true
            };
 
            using var timeoutCts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
            timeoutCts.CancelAfter(timeoutMs);
 
            await _tcpClient.ConnectAsync(host, port, timeoutCts.Token).ConfigureAwait(false);
            _stream = _tcpClient.GetStream();
 
            return PlcResult.Success();
        }
        catch (OperationCanceledException ex)
        {
            await CloseCoreAsync().ConfigureAwait(false);
            return PlcResult.Failure(ex.Message);
        }
        catch (Exception ex)
        {
            await CloseCoreAsync().ConfigureAwait(false);
            return PlcResult.Failure(ex.Message);
        }
        finally
        {
            _syncLock.Release();
        }
    }

다음을 참조함 : _stream, _syncLock, _tcpClient, CloseCoreAsync(), IsConnected, ThrowIfDisposed().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

◆ DisconnectAsync()

async Task< PlcResult > Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.DisconnectAsync ( CancellationToken cancellationToken = default )

inline

TCP 스트림과 클라이언트를 닫습니다.

매개변수

cancellationToken 취소 토큰입니다.

반환값: 연결 해제 결과입니다.

예외

OperationCanceledException 잠금 대기 중 취소된 경우 발생합니다.

Dreamine.PLC.Mitsubishi.MC.Transport.IMitsubishiMcTransport를 구현.

TcpMitsubishiMcTransport.cs 파일의 209 번째 라인에서 정의되었습니다.

    {
        await _syncLock.WaitAsync(cancellationToken).ConfigureAwait(false);
 
        try
        {
            await CloseCoreAsync().ConfigureAwait(false);
            return PlcResult.Success();
        }
        catch (Exception ex)
        {
            return PlcResult.Failure(ex.Message);
        }
        finally
        {
            _syncLock.Release();
        }
    }

다음을 참조함 : _syncLock, CloseCoreAsync().

다음에 의해서 참조됨 : DisposeAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ DisposeAsync()

async ValueTask Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.DisposeAsync ( )

inline

연결과 동기화 리소스를 비동기 해제합니다.

반환값: 비동기 해제 작업입니다.

TcpMitsubishiMcTransport.cs 파일의 355 번째 라인에서 정의되었습니다.

    {
        if (_disposed)
        {
            return;
        }
 
        await DisconnectAsync().ConfigureAwait(false);
 
        _syncLock.Dispose();
        _disposed = true;
 
        GC.SuppressFinalize(this);
    }

다음을 참조함 : _disposed, _syncLock, DisconnectAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

◆ ReadExactlyAsync()

async Task Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.ReadExactlyAsync	(	NetworkStream	stream,
		byte[]	buffer,
		CancellationToken	cancellationToken )

inlinestaticprivate

버퍼가 찰 때까지 스트림을 반복해서 읽습니다.

매개변수

stream	스트림입니다.
buffer	대상 버퍼입니다.
cancellationToken	취소 토큰입니다.

반환값: 비동기 읽기 작업입니다.

예외

IOException 버퍼가 차기 전에 연결이 닫힌 경우 발생합니다.

TcpMitsubishiMcTransport.cs 파일의 483 번째 라인에서 정의되었습니다.

    {
        var offset = 0;
 
        while (offset < buffer.Length)
        {
            var read = await stream.ReadAsync(
                buffer.AsMemory(offset, buffer.Length - offset),
                cancellationToken).ConfigureAwait(false);
 
            if (read == 0)
            {
                throw new IOException("The remote PLC closed the TCP connection.");
            }
 
            offset += read;
        }
    }

다음에 의해서 참조됨 : ReceiveBinary3EFrameAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ ReceiveBinary3EFrameAsync()

async Task< byte[]> Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.ReceiveBinary3EFrameAsync	(	NetworkStream	stream,
		CancellationToken	cancellationToken )

inlinestaticprivate

Binary 3E 헤더와 선언된 길이의 본문을 정확히 읽습니다.

매개변수

stream	네트워크 스트림입니다.
cancellationToken	취소 토큰입니다.

반환값: 완전한 응답 프레임입니다.

예외

InvalidOperationException	응답 데이터 길이가 2 미만인 경우 발생합니다.
IOException	응답 도중 원격 연결이 닫힌 경우 발생합니다.

TcpMitsubishiMcTransport.cs 파일의 413 번째 라인에서 정의되었습니다.

    {
        var header = new byte[9];
 
        await ReadExactlyAsync(stream, header, cancellationToken).ConfigureAwait(false);
 
        var responseDataLength = header[7] | (header[8] << 8);
        if (responseDataLength < 2)
        {
            throw new InvalidOperationException(
                $"Invalid Mitsubishi MC response data length: {responseDataLength}");
        }
 
        var body = new byte[responseDataLength];
 
        await ReadExactlyAsync(stream, body, cancellationToken).ConfigureAwait(false);
 
        var frame = new byte[header.Length + body.Length];
 
        Buffer.BlockCopy(header, 0, frame, 0, header.Length);
        Buffer.BlockCopy(body, 0, frame, header.Length, body.Length);
 
        return frame;
    }

다음을 참조함 : ReadExactlyAsync().

다음에 의해서 참조됨 : SendAndReceiveAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ SendAndReceiveAsync()

async Task< PlcResult< byte[]> > Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.SendAndReceiveAsync	(	IReadOnlyList< byte >	requestFrame,
		int	receiveTimeoutMs,
		int	retryCount,
		CancellationToken	cancellationToken = default )

inline

Binary 3E 요청을 보내고 길이 헤더에 따라 완전한 응답을 읽습니다.

매개변수

requestFrame	요청 프레임입니다.
receiveTimeoutMs	수신 제한 시간입니다.
retryCount	TCP에서 사용하지 않는 재시도 수입니다.
cancellationToken	취소 토큰입니다.

반환값: 응답 프레임 결과입니다.

예외

ArgumentNullException	요청이 `null`인 경우 발생합니다.
OperationCanceledException	잠금 대기 중 취소된 경우 발생합니다.

Dreamine.PLC.Mitsubishi.MC.Transport.IMitsubishiMcTransport를 구현.

TcpMitsubishiMcTransport.cs 파일의 285 번째 라인에서 정의되었습니다.

    {
        ArgumentNullException.ThrowIfNull(requestFrame);
 
        if (requestFrame.Count == 0)
        {
            return PlcResult<byte[]>.Failure("The request frame must not be empty.");
        }
 
        if (receiveTimeoutMs <= 0)
        {
            return PlcResult<byte[]>.Failure("The receive timeout must be greater than zero.");
        }
 
        await _syncLock.WaitAsync(cancellationToken).ConfigureAwait(false);
 
        try
        {
            ThrowIfDisposed();
 
            if (_stream is null || _tcpClient is null || !_tcpClient.Connected)
            {
                return PlcResult<byte[]>.Failure("The TCP transport is not connected.");
            }
 
            var requestBuffer = requestFrame as byte[] ?? requestFrame.ToArray();
 
            using var timeoutCts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
            timeoutCts.CancelAfter(receiveTimeoutMs);
 
            await _stream.WriteAsync(requestBuffer, timeoutCts.Token).ConfigureAwait(false);
            await _stream.FlushAsync(timeoutCts.Token).ConfigureAwait(false);
 
            var response = await ReceiveBinary3EFrameAsync(_stream, timeoutCts.Token).ConfigureAwait(false);
 
            return PlcResult<byte[]>.Success(response);
        }
        catch (OperationCanceledException ex)
        {
            return PlcResult<byte[]>.Failure(ex.Message);
        }
        catch (Exception ex)
        {
            return PlcResult<byte[]>.Failure(ex.Message);
        }
        finally
        {
            _syncLock.Release();
        }
    }

다음을 참조함 : _stream, _syncLock, _tcpClient, ReceiveBinary3EFrameAsync(), ThrowIfDisposed().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

◆ ThrowIfDisposed()

void Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.ThrowIfDisposed ( )

inlineprivate

전송이 이미 해제되었으면 예외를 발생시킵니다.

예외

ObjectDisposedException 해제된 경우 발생합니다.

TcpMitsubishiMcTransport.cs 파일의 554 번째 라인에서 정의되었습니다.

    {
        ObjectDisposedException.ThrowIf(_disposed, GetType().Name);
    }

다음을 참조함 : _disposed.

다음에 의해서 참조됨 : ConnectAsync(), SendAndReceiveAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

멤버 데이터 문서화

◆ _disposed

bool Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport._disposed

private

disposed 값을 보관합니다.

TcpMitsubishiMcTransport.cs 파일의 51 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : DisposeAsync(), ThrowIfDisposed().

◆ _stream

NetworkStream? Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport._stream

private

stream 값을 보관합니다.

TcpMitsubishiMcTransport.cs 파일의 42 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : CloseCoreAsync(), ConnectAsync(), SendAndReceiveAsync().

◆ _syncLock

readonly SemaphoreSlim Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport._syncLock = new(1, 1)

private

sync Lock 값을 보관합니다.

TcpMitsubishiMcTransport.cs 파일의 24 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectAsync(), DisconnectAsync(), DisposeAsync(), SendAndReceiveAsync().

◆ _tcpClient

TcpClient? Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport._tcpClient

private

tcp Client 값을 보관합니다.

TcpMitsubishiMcTransport.cs 파일의 33 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : CloseCoreAsync(), ConnectAsync(), SendAndReceiveAsync().

속성 문서화

◆ IsConnected

bool Dreamine.PLC.Mitsubishi.MC.Transport.TcpMitsubishiMcTransport.IsConnected

get

TCP 클라이언트와 스트림의 연결 여부를 가져옵니다.

Dreamine.PLC.Mitsubishi.MC.Transport.IMitsubishiMcTransport를 구현.

TcpMitsubishiMcTransport.cs 파일의 61 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectAsync().

이 클래스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

TcpMitsubishiMcTransport.cs

Public 멤버 함수

속성

Private 멤버 함수

정적 Private 멤버 함수

Private 속성

상세한 설명

멤버 함수 문서화

◆ CloseCoreAsync()

◆ ConnectAsync()

◆ DisconnectAsync()

◆ DisposeAsync()

◆ ReadExactlyAsync()

◆ ReceiveBinary3EFrameAsync()

◆ SendAndReceiveAsync()

◆ ThrowIfDisposed()

멤버 데이터 문서화

◆ _disposed

◆ _stream

◆ _syncLock

◆ _tcpClient

속성 문서화

◆ IsConnected