mirror of
https://github.com/BililiveRecorder/BililiveRecorder.git
synced 2024-11-15 19:22:19 +08:00
269 lines
11 KiB
C#
269 lines
11 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.ComponentModel;
|
||
using System.Runtime.CompilerServices;
|
||
|
||
#nullable enable
|
||
namespace BililiveRecorder.Core
|
||
{
|
||
public class RoomStats : INotifyPropertyChanged
|
||
{
|
||
#region IO Stats Fields
|
||
private string? ___StreamHost;
|
||
private DateTimeOffset ___StartTime;
|
||
private DateTimeOffset ___EndTime;
|
||
private TimeSpan ___Duration;
|
||
private int ___NetworkBytesDownloaded;
|
||
private double ___NetworkMbps;
|
||
private TimeSpan ___DiskWriteDuration;
|
||
private int ___DiskBytesWritten;
|
||
private double ___DiskMBps;
|
||
#endregion
|
||
|
||
#region Recording Stats Fields
|
||
private TimeSpan ___SessionDuration;
|
||
private long ___TotalInputBytes;
|
||
private long ___TotalOutputBytes;
|
||
private long ___CurrentFileSize;
|
||
private TimeSpan ___SessionMaxTimestamp;
|
||
private TimeSpan ___FileMaxTimestamp;
|
||
private double ___AddedDuration;
|
||
private double ___PassedTime;
|
||
private double ___DurationRatio;
|
||
|
||
private long ___InputVideoBytes;
|
||
private long ___InputAudioBytes;
|
||
|
||
private int ___OutputVideoFrames;
|
||
private int ___OutputAudioFrames;
|
||
private long ___OutputVideoBytes;
|
||
private long ___OutputAudioBytes;
|
||
|
||
private long ___TotalInputVideoBytes;
|
||
private long ___TotalInputAudioBytes;
|
||
|
||
private int ___TotalOutputVideoFrames;
|
||
private int ___TotalOutputAudioFrames;
|
||
private long ___TotalOutputVideoBytes;
|
||
private long ___TotalOutputAudioBytes;
|
||
#endregion
|
||
|
||
public RoomStats()
|
||
{
|
||
this.Reset();
|
||
}
|
||
|
||
#region IO Stats Properties
|
||
|
||
/// <summary>
|
||
/// 直播服务器域名
|
||
/// </summary>
|
||
public string? StreamHost { get => this.___StreamHost; set => this.SetField(ref this.___StreamHost, value); }
|
||
|
||
/// <summary>
|
||
/// 当前统计区间的开始时间
|
||
/// </summary>
|
||
public DateTimeOffset StartTime { get => this.___StartTime; set => this.SetField(ref this.___StartTime, value); }
|
||
|
||
/// <summary>
|
||
/// 当前统计区间的结束时间
|
||
/// </summary>
|
||
public DateTimeOffset EndTime { get => this.___EndTime; set => this.SetField(ref this.___EndTime, value); }
|
||
|
||
/// <summary>
|
||
/// 当前统计区间的时长
|
||
/// </summary>
|
||
public TimeSpan Duration { get => this.___Duration; set => this.SetField(ref this.___Duration, value); }
|
||
|
||
/// <summary>
|
||
/// 下载了的数据量
|
||
/// </summary>
|
||
public int NetworkBytesDownloaded { get => this.___NetworkBytesDownloaded; set => this.SetField(ref this.___NetworkBytesDownloaded, value); }
|
||
|
||
/// <summary>
|
||
/// 平均下载速度，mibi-bits per second
|
||
/// </summary>
|
||
public double NetworkMbps { get => this.___NetworkMbps; set => this.SetField(ref this.___NetworkMbps, value); }
|
||
|
||
/// <summary>
|
||
/// 统计区间内的磁盘写入耗时
|
||
/// </summary>
|
||
public TimeSpan DiskWriteDuration { get => this.___DiskWriteDuration; set => this.SetField(ref this.___DiskWriteDuration, value); }
|
||
|
||
/// <summary>
|
||
/// 统计区间内写入磁盘的数据量
|
||
/// </summary>
|
||
public int DiskBytesWritten { get => this.___DiskBytesWritten; set => this.SetField(ref this.___DiskBytesWritten, value); }
|
||
|
||
/// <summary>
|
||
/// 平均写入速度，mibi-bytes per second
|
||
/// </summary>
|
||
public double DiskMBps { get => this.___DiskMBps; set => this.SetField(ref this.___DiskMBps, value); }
|
||
|
||
#endregion
|
||
#region Recording Stats Properties
|
||
|
||
/// <summary>
|
||
/// 从录制开始到现在一共经过的时间
|
||
/// </summary>
|
||
public TimeSpan SessionDuration { get => this.___SessionDuration; set => this.SetField(ref this.___SessionDuration, value); }
|
||
|
||
/// <summary>
|
||
/// 总接受字节数
|
||
/// </summary>
|
||
public long TotalInputBytes { get => this.___TotalInputBytes; set => this.SetField(ref this.___TotalInputBytes, value); }
|
||
|
||
/// <summary>
|
||
/// 总写入字节数
|
||
/// </summary>
|
||
public long TotalOutputBytes { get => this.___TotalOutputBytes; set => this.SetField(ref this.___TotalOutputBytes, value); }
|
||
|
||
/// <summary>
|
||
/// 当前文件的大小
|
||
/// </summary>
|
||
public long CurrentFileSize { get => this.___CurrentFileSize; set => this.SetField(ref this.___CurrentFileSize, value); }
|
||
|
||
/// <summary>
|
||
/// 本次直播流收到的最大时间戳（已修复过，相当于总时长）
|
||
/// </summary>
|
||
public TimeSpan SessionMaxTimestamp { get => this.___SessionMaxTimestamp; set => this.SetField(ref this.___SessionMaxTimestamp, value); }
|
||
|
||
/// <summary>
|
||
/// 当前文件的最大时间戳（相当于总时长）
|
||
/// </summary>
|
||
public TimeSpan FileMaxTimestamp { get => this.___FileMaxTimestamp; set => this.SetField(ref this.___FileMaxTimestamp, value); }
|
||
|
||
/// <summary>
|
||
/// 当前这一个统计区间的直播数据时长
|
||
/// </summary>
|
||
public double AddedDuration { get => this.___AddedDuration; set => this.SetField(ref this.___AddedDuration, value); }
|
||
|
||
/// <summary>
|
||
/// 当前这一个统计区间所经过的时间长度
|
||
/// </summary>
|
||
public double PassedTime { get => this.___PassedTime; set => this.SetField(ref this.___PassedTime, value); }
|
||
|
||
/// <summary>
|
||
/// 录制速度比例
|
||
/// </summary>
|
||
public double DurationRatio { get => this.___DurationRatio; set => this.SetField(ref this.___DurationRatio, value); }
|
||
|
||
//----------------------------------------
|
||
|
||
/// <summary>
|
||
/// 当前统计区间新收到的视频数据大小
|
||
/// </summary>
|
||
public long InputVideoBytes { get => this.___InputVideoBytes; set => this.SetField(ref this.___InputVideoBytes, value); }
|
||
/// <summary>
|
||
/// 当前统计区间新收到的音频数据大小
|
||
/// </summary>
|
||
public long InputAudioBytes { get => this.___InputAudioBytes; set => this.SetField(ref this.___InputAudioBytes, value); }
|
||
|
||
/// <summary>
|
||
/// 当前统计区间新写入的视频帧数量
|
||
/// </summary>
|
||
public int OutputVideoFrames { get => this.___OutputVideoFrames; set => this.SetField(ref this.___OutputVideoFrames, value); }
|
||
/// <summary>
|
||
/// 当前统计区间新写入的音频帧数量
|
||
/// </summary>
|
||
public int OutputAudioFrames { get => this.___OutputAudioFrames; set => this.SetField(ref this.___OutputAudioFrames, value); }
|
||
/// <summary>
|
||
/// 当前统计区间新写入的视频数据大小
|
||
/// </summary>
|
||
public long OutputVideoBytes { get => this.___OutputVideoBytes; set => this.SetField(ref this.___OutputVideoBytes, value); }
|
||
/// <summary>
|
||
/// 当前统计区间新写入的音频数据大小
|
||
/// </summary>
|
||
public long OutputAudioBytes { get => this.___OutputAudioBytes; set => this.SetField(ref this.___OutputAudioBytes, value); }
|
||
|
||
/// <summary>
|
||
/// 总共收到的视频数据大小
|
||
/// </summary>
|
||
public long TotalInputVideoBytes { get => this.___TotalInputVideoBytes; set => this.SetField(ref this.___TotalInputVideoBytes, value); }
|
||
/// <summary>
|
||
/// 总共收到的音频数据大小
|
||
/// </summary>
|
||
public long TotalInputAudioBytes { get => this.___TotalInputAudioBytes; set => this.SetField(ref this.___TotalInputAudioBytes, value); }
|
||
|
||
/// <summary>
|
||
/// 总共写入的视频帧数量
|
||
/// </summary>
|
||
public int TotalOutputVideoFrames { get => this.___TotalOutputVideoFrames; set => this.SetField(ref this.___TotalOutputVideoFrames, value); }
|
||
/// <summary>
|
||
/// 总共写入的音频帧数量
|
||
/// </summary>
|
||
public int TotalOutputAudioFrames { get => this.___TotalOutputAudioFrames; set => this.SetField(ref this.___TotalOutputAudioFrames, value); }
|
||
/// <summary>
|
||
/// 总共写入的视频数据大小
|
||
/// </summary>
|
||
public long TotalOutputVideoBytes { get => this.___TotalOutputVideoBytes; set => this.SetField(ref this.___TotalOutputVideoBytes, value); }
|
||
/// <summary>
|
||
/// 总共写入的音频数据大小
|
||
/// </summary>
|
||
public long TotalOutputAudioBytes { get => this.___TotalOutputAudioBytes; set => this.SetField(ref this.___TotalOutputAudioBytes, value); }
|
||
|
||
#endregion
|
||
|
||
public void Reset()
|
||
{
|
||
this.SessionDuration = TimeSpan.Zero;
|
||
this.SessionMaxTimestamp = TimeSpan.Zero;
|
||
this.FileMaxTimestamp = TimeSpan.Zero;
|
||
//this.DurationRatio = double.NaN;
|
||
|
||
// ------------------------------
|
||
|
||
this.StreamHost = null;
|
||
|
||
this.StartTime = default;
|
||
this.EndTime = default;
|
||
this.Duration = default;
|
||
this.NetworkBytesDownloaded = default;
|
||
this.NetworkMbps = default;
|
||
this.DiskWriteDuration = default;
|
||
this.DiskBytesWritten = default;
|
||
this.DiskMBps = default;
|
||
|
||
// ------------------------------
|
||
|
||
this.SessionDuration = default;
|
||
this.TotalInputBytes = default;
|
||
this.TotalOutputBytes = default;
|
||
this.CurrentFileSize = default;
|
||
this.SessionMaxTimestamp = default;
|
||
this.FileMaxTimestamp = default;
|
||
this.AddedDuration = default;
|
||
this.PassedTime = default;
|
||
this.DurationRatio = double.NaN;
|
||
|
||
this.InputVideoBytes = default;
|
||
this.InputAudioBytes = default;
|
||
|
||
this.OutputVideoFrames = default;
|
||
this.OutputAudioFrames = default;
|
||
this.OutputVideoBytes = default;
|
||
this.OutputAudioBytes = default;
|
||
|
||
this.TotalInputVideoBytes = default;
|
||
this.TotalInputAudioBytes = default;
|
||
|
||
this.TotalOutputVideoFrames = default;
|
||
this.TotalOutputAudioFrames = default;
|
||
this.TotalOutputVideoBytes = default;
|
||
this.TotalOutputAudioBytes = default;
|
||
|
||
}
|
||
|
||
public event PropertyChangedEventHandler? PropertyChanged;
|
||
protected virtual void OnPropertyChanged(string propertyName) => PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName));
|
||
protected bool SetField<T>(ref T location, T value, [CallerMemberName] string propertyName = "")
|
||
{
|
||
if (EqualityComparer<T>.Default.Equals(location, value))
|
||
return false;
|
||
location = value;
|
||
this.OnPropertyChanged(propertyName);
|
||
return true;
|
||
}
|
||
}
|
||
}
|