DreamineVMS.Services.Agent.HlsSegmentPusherService에 대한 상속 다이어그램 :

DreamineVMS.Services.Agent.HlsSegmentPusherService에 대한 협력 다이어그램:

[범례]

Public 멤버 함수
	HlsSegmentPusherService (AgentApiClient api, IVmsCameraRepository repository, IConfiguration config, ILogger< HlsSegmentPusherService > logger)

Protected 멤버 함수
override async Task	ExecuteAsync (CancellationToken stoppingToken)

Private 멤버 함수
async Task	RunCameraLoopAsync (string cameraId, string outputRoot, CancellationToken ct)
async Task	LoginWithRetryAsync (CancellationToken ct)
async Task	EnsureLoggedInAsync (CancellationToken ct)
async Task	SyncCamerasAsync ()
async Task< bool >	TryPushFileAsync (string cameraId, string filePath, string filename)
string	GetOutputRoot ()

정적 Private 멤버 함수
static List< string >	ParseSegmentsFromM3u8 (byte[] bytes)

Private 속성
readonly AgentApiClient	_api
readonly IVmsCameraRepository	_repository
readonly IConfiguration	_config
readonly ILogger< HlsSegmentPusherService >	_logger
readonly SemaphoreSlim	_loginLock = new(1, 1)

상세한 설명

에이전트 모드: 자동 로그인 → 로컬 카메라를 서버에 등록 → HLS 세그먼트 업로드. 카메라별로 독립 루프를 병렬 실행하여 한 카메라 업로드가 다른 카메라를 블로킹하지 않음.

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

생성자 & 소멸자 문서화

◆ HlsSegmentPusherService()

DreamineVMS.Services.Agent.HlsSegmentPusherService.HlsSegmentPusherService	(	AgentApiClient	api,
		IVmsCameraRepository	repository,
		IConfiguration	config,
		ILogger< HlsSegmentPusherService >	logger )

inline

지정한 설정으로 HlsSegmentPusherService 클래스의 새 인스턴스를 초기화합니다.

매개변수

api	api에 사용할 `AgentApiClient` 값입니다.
repository	repository에 사용할 `IVmsCameraRepository` 값입니다.
config	config에 사용할 `IConfiguration` 값입니다.
logger	logger에 사용할 `ILogger<HlsSegmentPusherService>` 값입니다.

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

    {
        _api = api;
        _repository = repository;
        _config = config;
        _logger = logger;
    }

다음을 참조함 : _api, _config, _logger, _repository.

멤버 함수 문서화

◆ EnsureLoggedInAsync()

async Task DreamineVMS.Services.Agent.HlsSegmentPusherService.EnsureLoggedInAsync ( CancellationToken ct )

inlineprivate

Ensure Logged In Async 작업을 수행합니다.

매개변수

ct	취소 요청을 감시하는 토큰입니다.

반환값: Ensure Logged In Async 작업에서 생성한 Task 결과입니다.

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

    {
        if (_api.Token is not null)
        {
            return;
        }
 
        await _loginLock.WaitAsync(ct);
        try
        {
            if (_api.Token is not null)
            {
                return;
            }
 
            await LoginWithRetryAsync(ct);
        }
        finally
        {
            _loginLock.Release();
        }
    }

다음을 참조함 : _api, _loginLock, LoginWithRetryAsync().

다음에 의해서 참조됨 : ExecuteAsync(), RunCameraLoopAsync().

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

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

◆ ExecuteAsync()

override async Task DreamineVMS.Services.Agent.HlsSegmentPusherService.ExecuteAsync ( CancellationToken stoppingToken )

inlineprotected

Execute Async 작업을 수행합니다.

매개변수

stoppingToken stopping Token에 사용할 CancellationToken 값입니다.

반환값: Execute Async 작업에서 생성한 Task 결과입니다.

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

    {
        // 자격증명이 설정될 때까지 대기 (앱 실행 후 Agent Settings에서 입력해도 동작)
        while (!stoppingToken.IsCancellationRequested)
        {
            if (!string.IsNullOrWhiteSpace(_config["Agent:Email"]) &&
                !string.IsNullOrWhiteSpace(_config["Agent:Password"]))
                break;
 
            _logger.LogInformation("[Agent] Agent:Email/Password 미설정 — 30초 후 재확인.");
            await Task.Delay(TimeSpan.FromSeconds(30), stoppingToken);
        }
 
        if (stoppingToken.IsCancellationRequested) return;
 
        var outputRoot = GetOutputRoot();
        _logger.LogInformation("[Agent] 세그먼트 업로드 시작. 루트: {Root}", outputRoot);
 
        // 카메라 목록을 동적으로 관리하는 메인 루프
        var runningCameras = new Dictionary<string, CancellationTokenSource>();
 
        while (!stoppingToken.IsCancellationRequested)
        {
            await EnsureLoggedInAsync(stoppingToken);
            if (_api.Token is null) { await Task.Delay(5000, stoppingToken); continue; }
 
            await SyncCamerasAsync();
 
            // 활성 카메라 목록과 비교해서 추가/제거
            var currentIds = _repository.GetAll()
                .Where(c => c.Enabled && !c.IsDirectHls)
                .Select(c => c.Id)
                .ToHashSet();
 
            // 제거된 카메라 루프 취소
            foreach (var id in runningCameras.Keys.Except(currentIds).ToList())
            {
                runningCameras[id].Cancel();
                runningCameras.Remove(id);
                _logger.LogInformation("[Agent] 카메라 루프 중지: {Id}", id);
            }
 
            // 새 카메라 루프 시작
            foreach (var id in currentIds.Except(runningCameras.Keys))
            {
                var cts = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken);
                runningCameras[id] = cts;
                _ = Task.Run(() => RunCameraLoopAsync(id, outputRoot, cts.Token), cts.Token);
                _logger.LogInformation("[Agent] 카메라 루프 시작: {Id}", id);
            }
 
            await Task.Delay(TimeSpan.FromSeconds(30), stoppingToken);
        }
 
        // 종료 시 모든 루프 취소
        foreach (var cts in runningCameras.Values) cts.Cancel();
    }

다음을 참조함 : _api, _config, _logger, _repository, EnsureLoggedInAsync(), GetOutputRoot(), RunCameraLoopAsync(), SyncCamerasAsync().

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

◆ GetOutputRoot()

string DreamineVMS.Services.Agent.HlsSegmentPusherService.GetOutputRoot ( )

inlineprivate

Output Root 값을 가져옵니다.

반환값: Get Output Root 작업에서 생성한 string 결과입니다.

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

    {
        var root = _config["Ffmpeg:OutputRoot"] ?? "hls";
        return Path.IsPathRooted(root) ? root : Path.Combine(AppContext.BaseDirectory, root);
    }

다음을 참조함 : _config.

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

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

◆ LoginWithRetryAsync()

async Task DreamineVMS.Services.Agent.HlsSegmentPusherService.LoginWithRetryAsync ( CancellationToken ct )

inlineprivate

Login With Retry Async 작업을 수행합니다.

매개변수

ct	취소 요청을 감시하는 토큰입니다.

반환값: Login With Retry Async 작업에서 생성한 Task 결과입니다.

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

    {
        while (!ct.IsCancellationRequested && _api.Token is null)
        {
            var (ok, err) = await _api.LoginWithStoredCredentialsAsync();
            if (ok) { _logger.LogInformation("[Agent] 로그인 성공."); return; }
            _logger.LogWarning("[Agent] 로그인 실패: {Err}. 10초 후 재시도.", err);
            await Task.Delay(TimeSpan.FromSeconds(10), ct);
        }
    }

다음을 참조함 : _api, _logger.

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

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

◆ ParseSegmentsFromM3u8()

List< string > DreamineVMS.Services.Agent.HlsSegmentPusherService.ParseSegmentsFromM3u8 ( byte[] bytes )

inlinestaticprivate

Parse Segments From M3u8 작업을 수행합니다.

매개변수

bytes bytes에 사용할 byte[] 값입니다.

반환값: Parse Segments From M3u8 작업에서 생성한 List<string> 결과입니다.

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

    {
        try
        {
            return System.Text.Encoding.UTF8.GetString(bytes)
                .Split('\n')
                .Where(l => l.TrimEnd().EndsWith(".ts", StringComparison.OrdinalIgnoreCase))
                .Select(l => Path.GetFileName(l.Trim()))
                .Where(f => !string.IsNullOrEmpty(f))
                .ToList()!;
        }
        catch { return []; }
    }

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

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

◆ RunCameraLoopAsync()

async Task DreamineVMS.Services.Agent.HlsSegmentPusherService.RunCameraLoopAsync	(	string	cameraId,
		string	outputRoot,
		CancellationToken	ct )

inlineprivate

Run Camera Loop Async 작업을 수행합니다.

매개변수

cameraId	camera Id에 사용할 `string` 값입니다.
outputRoot	output Root에 사용할 `string` 값입니다.
ct	취소 요청을 감시하는 토큰입니다.

반환값: Run Camera Loop Async 작업에서 생성한 Task 결과입니다.

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

    {
        var pushed = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
        var camDir = Path.Combine(outputRoot, cameraId);
        byte[]? lastPushedM3u8 = null;
 
        while (!ct.IsCancellationRequested)
        {
            try
            {
                if (_api.Token is null)
                {
                    await EnsureLoggedInAsync(ct);
                    if (_api.Token is null)
                    {
                        await Task.Delay(2000, ct);
                        continue;
                    }
 
                    await SyncCamerasAsync();
                }
 
                if (!Directory.Exists(camDir))
                {
                    await Task.Delay(1000, ct);
                    continue;
                }
 
                var m3u8Path = Path.Combine(camDir, "index.m3u8");
                if (!File.Exists(m3u8Path))
                {
                    await Task.Delay(500, ct);
                    continue;
                }
 
                byte[] m3u8Bytes;
                List<string> refs;
                try
                {
                    m3u8Bytes = await File.ReadAllBytesAsync(m3u8Path, ct);
                    refs = ParseSegmentsFromM3u8(m3u8Bytes);
                }
                catch (IOException)
                {
                    await Task.Delay(100, ct);
                    continue;
                }
 
                if (refs.Count == 0)
                {
                    await Task.Delay(500, ct);
                    continue;
                }
 
                bool allRefsPushed = true;
                foreach (string filename in refs)
                {
                    if (ct.IsCancellationRequested || _api.Token is null)
                    {
                        allRefsPushed = false;
                        break;
                    }
 
                    if (pushed.Contains(filename))
                    {
                        continue;
                    }
 
                    string segmentPath = Path.Combine(camDir, filename);
                    if (!File.Exists(segmentPath))
                    {
                        allRefsPushed = false;
                        break;
                    }
 
                    bool ok = await TryPushFileAsync(cameraId, segmentPath, filename);
                    if (ok)
                    {
                        pushed.Add(filename);
                    }
                    else
                    {
                        allRefsPushed = false;
                        break;
                    }
                }
 
                if (allRefsPushed && !m3u8Bytes.AsSpan().SequenceEqual(lastPushedM3u8))
                {
                    bool ok = await _api.PushSegmentAsync(cameraId, "index.m3u8", m3u8Bytes);
                    if (ok)
                    {
                        lastPushedM3u8 = m3u8Bytes;
                    }
                }
 
                if (pushed.Count > 200)
                {
                    pushed.RemoveWhere(filename => !refs.Contains(filename, StringComparer.OrdinalIgnoreCase));
                }
            }
            catch (OperationCanceledException) { break; }
            catch (Exception ex)
            {
                _logger.LogWarning(ex, "[Agent] [{Cam}] 스캔 중 오류", cameraId);
            }
 
            await Task.Delay(200, ct);
        }
    }

다음을 참조함 : _api, _logger, EnsureLoggedInAsync(), ParseSegmentsFromM3u8(), SyncCamerasAsync(), TryPushFileAsync().

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

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

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

◆ SyncCamerasAsync()

async Task DreamineVMS.Services.Agent.HlsSegmentPusherService.SyncCamerasAsync ( )

inlineprivate

Sync Cameras Async 작업을 수행합니다.

반환값: Sync Cameras Async 작업에서 생성한 Task 결과입니다.

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

    {
        var localCams = _repository.GetAll()
            .Where(c => c.Enabled && !c.IsDirectHls)
            .Select(c => new AgentCameraInfo
            {
                Id = c.Id, Name = c.Name, Host = c.Host,
                RtspUrl = c.RtspUrl, AutoReconnect = c.AutoReconnect, IsPublic = c.IsPublic
            }).ToList();
 
        var ok = await _api.SyncCamerasAsync(localCams);
        _logger.LogInformation("[Agent] 카메라 {Count}개 서버 동기화 {Result}.",
            localCams.Count, ok ? "성공" : "실패");
    }

다음을 참조함 : _api, _logger, _repository.

다음에 의해서 참조됨 : ExecuteAsync(), RunCameraLoopAsync().

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

◆ TryPushFileAsync()

async Task< bool > DreamineVMS.Services.Agent.HlsSegmentPusherService.TryPushFileAsync	(	string	cameraId,
		string	filePath,
		string	filename )

inlineprivate

Push File Async 작업을 시도하고 성공 여부를 반환합니다.

매개변수

cameraId	camera Id에 사용할 `string` 값입니다.
filePath	file Path에 사용할 `string` 값입니다.
filename	filename에 사용할 `string` 값입니다.

반환값: Try Push File Async 작업에서 생성한 Task<bool> 결과입니다.

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

    {
        try
        {
            var data = await File.ReadAllBytesAsync(filePath);
            return await _api.PushSegmentAsync(cameraId, filename, data);
        }
        catch (Exception ex)
        {
            _logger.LogWarning(ex, "[Agent] [{Cam}] 세그먼트 파일 읽기 실패: {File}", cameraId, filename);
            return false;
        }
    }

다음을 참조함 : _api, _logger.

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

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

멤버 데이터 문서화

◆ _api

readonly AgentApiClient DreamineVMS.Services.Agent.HlsSegmentPusherService._api

private

api 값을 보관합니다.

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

다음에 의해서 참조됨 : EnsureLoggedInAsync(), ExecuteAsync(), HlsSegmentPusherService(), LoginWithRetryAsync(), RunCameraLoopAsync(), SyncCamerasAsync(), TryPushFileAsync().

◆ _config

readonly IConfiguration DreamineVMS.Services.Agent.HlsSegmentPusherService._config

private

config 값을 보관합니다.

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

다음에 의해서 참조됨 : ExecuteAsync(), GetOutputRoot(), HlsSegmentPusherService().

◆ _logger

readonly ILogger<HlsSegmentPusherService> DreamineVMS.Services.Agent.HlsSegmentPusherService._logger

private

logger 값을 보관합니다.

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

다음에 의해서 참조됨 : ExecuteAsync(), HlsSegmentPusherService(), LoginWithRetryAsync(), RunCameraLoopAsync(), SyncCamerasAsync(), TryPushFileAsync().

◆ _loginLock

readonly SemaphoreSlim DreamineVMS.Services.Agent.HlsSegmentPusherService._loginLock = new(1, 1)

private

login Lock 값을 보관합니다.

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

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

◆ _repository

readonly IVmsCameraRepository DreamineVMS.Services.Agent.HlsSegmentPusherService._repository

private

repository 값을 보관합니다.

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

다음에 의해서 참조됨 : ExecuteAsync(), HlsSegmentPusherService(), SyncCamerasAsync().

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

HlsSegmentPusherService.cs

Public 멤버 함수

Protected 멤버 함수

Private 멤버 함수

정적 Private 멤버 함수

Private 속성

상세한 설명

생성자 & 소멸자 문서화

◆ HlsSegmentPusherService()

멤버 함수 문서화

◆ EnsureLoggedInAsync()

◆ ExecuteAsync()

◆ GetOutputRoot()

◆ LoginWithRetryAsync()

◆ ParseSegmentsFromM3u8()

◆ RunCameraLoopAsync()

◆ SyncCamerasAsync()

◆ TryPushFileAsync()

멤버 데이터 문서화

◆ _api

◆ _config

◆ _logger

◆ _loginLock

◆ _repository