<commit_before>﻿/* ------------------------------------------------------------------------- */
//
// Copyright (c) 2010 CubeSoft, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//  http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
/* ------------------------------------------------------------------------- */
using Cube.Mixin.Logger;
using System;

namespace Cube.Net
{
    /* --------------------------------------------------------------------- */
    ///
    /// NetworkMonitorBase
    ///
    /// <summary>
    /// 定期的にネットワーク通信を実行するための基底クラスです。
    /// </summary>
    ///
    /// <remarks>
    /// このクラスは NetworkAwareTimer の簡易ラッパークラスとなります。
    /// 実際に何らかの処理を実装する場合はこのクラスを継承し、
    /// Timer.Subscribe() に必要な処理を登録して下さい。
    /// </remarks>
    ///
    /* --------------------------------------------------------------------- */
    public abstract class NetworkMonitorBase : DisposableBase
    {
        #region Constructors

        /* ----------------------------------------------------------------- */
        ///
        /// NetworkMonitorBase
        ///
        /// <summary>
        /// オブジェクトを初期化します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        protected NetworkMonitorBase() { }

        #endregion

        #region Properties

        /* ----------------------------------------------------------------- */
        ///
        /// State
        ///
        /// <summary>
        /// オブジェクトの状態を取得します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public TimerState State => Timer.State;

        /* ----------------------------------------------------------------- */
        ///
        /// LastPublished
        ///
        /// <summary>
        /// 最後に Publish が実行された日時を取得します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public DateTime? LastPublished => Timer.LastPublished;

        /* ----------------------------------------------------------------- */
        ///
        /// Interval
        ///
        /// <summary>
        /// 実行間隔を取得または設定します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public TimeSpan Interval
        {
            get => Timer.Interval;
            set => Timer.Interval = value;
        }

        /* --------------------------------------------------------------------- */
        ///
        /// RetryCount
        ///
        /// <summary>
        /// 通信失敗時に再試行する最大回数を取得または設定します。
        /// </summary>
        ///
        /* --------------------------------------------------------------------- */
        public int RetryCount { get; set; } = 5;

        /* --------------------------------------------------------------------- */
        ///
        /// RetryInterval
        ///
        /// <summary>
        /// 通信失敗時に再試行する間隔を取得または設定します。
        /// </summary>
        ///
        /* --------------------------------------------------------------------- */
        public TimeSpan RetryInterval { get; set; } = TimeSpan.FromSeconds(5);

        /* --------------------------------------------------------------------- */
        ///
        /// Timeout
        ///
        /// <summary>
        /// タイムアウト時間を取得または設定します。
        /// </summary>
        ///
        /* --------------------------------------------------------------------- */
        public TimeSpan Timeout { get; set; } = TimeSpan.FromMilliseconds(500);

        /* ----------------------------------------------------------------- */
        ///
        /// Timer
        ///
        /// <summary>
        /// 内部用タイマーを取得します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        protected WakeableTimer Timer { get; } = new WakeableTimer();

        #endregion

        #region Methods

        /* ----------------------------------------------------------------- */
        ///
        /// Start
        ///
        /// <summary>
        /// 監視を実行します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public void Start() => Start(TimeSpan.Zero);

        /* ----------------------------------------------------------------- */
        ///
        /// Start
        ///
        /// <summary>
        /// 監視を実行します。
        /// </summary>
        ///
        /// <param name="delay">初期遅延時間</param>
        ///
        /* ----------------------------------------------------------------- */
        public virtual void Start(TimeSpan delay)
        {
            var state = Timer.State;
            Timer.Start(delay);
            if (state != TimerState.Stop) return;
            this.LogDebug($"Start\tInterval:{Interval}\tInitialDelay:{delay}");
        }

        /* ----------------------------------------------------------------- */
        ///
        /// Stop
        ///
        /// <summary>
        /// 監視を停止します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public virtual void Stop()
        {
            var state = Timer.State;
            Timer.Stop();
            if (state == TimerState.Stop) return;
            this.LogDebug($"Stop\tLastPublished:{Timer.LastPublished}");
        }

        /* ----------------------------------------------------------------- */
        ///
        /// Suspend
        ///
        /// <summary>
        /// 監視を一時停止します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public void Suspend() => Timer.Suspend();

        /* ----------------------------------------------------------------- */
        ///
        /// Reset
        ///
        /// <summary>
        /// リセットします。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public virtual void Reset()
        {
            var state = State;
            Timer.Reset();
            if (state == TimerState.Run)
            {
                Stop();
                Start();
            }
        }

        /* ----------------------------------------------------------------- */
        ///
        /// Dispose
        ///
        /// <summary>
        /// リソースを解放します。
        /// </summary>
        ///
        /// <param name="disposing">
        /// マネージリソースを解放するかどうかを示す値
        /// </param>
        ///
        /* ----------------------------------------------------------------- */
        protected override void Dispose(bool disposing)
        {
            if (disposing) Timer.Dispose();
        }

        #endregion
    }
}
<commit_msg>Fix default value of RetryCount.<commit_after>﻿/* ------------------------------------------------------------------------- */
//
// Copyright (c) 2010 CubeSoft, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//  http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
/* ------------------------------------------------------------------------- */
using Cube.Mixin.Logger;
using System;

namespace Cube.Net
{
    /* --------------------------------------------------------------------- */
    ///
    /// NetworkMonitorBase
    ///
    /// <summary>
    /// 定期的にネットワーク通信を実行するための基底クラスです。
    /// </summary>
    ///
    /// <remarks>
    /// このクラスは NetworkAwareTimer の簡易ラッパークラスとなります。
    /// 実際に何らかの処理を実装する場合はこのクラスを継承し、
    /// Timer.Subscribe() に必要な処理を登録して下さい。
    /// </remarks>
    ///
    /* --------------------------------------------------------------------- */
    public abstract class NetworkMonitorBase : DisposableBase
    {
        #region Constructors

        /* ----------------------------------------------------------------- */
        ///
        /// NetworkMonitorBase
        ///
        /// <summary>
        /// オブジェクトを初期化します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        protected NetworkMonitorBase() { }

        #endregion

        #region Properties

        /* ----------------------------------------------------------------- */
        ///
        /// State
        ///
        /// <summary>
        /// オブジェクトの状態を取得します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public TimerState State => Timer.State;

        /* ----------------------------------------------------------------- */
        ///
        /// LastPublished
        ///
        /// <summary>
        /// 最後に Publish が実行された日時を取得します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public DateTime? LastPublished => Timer.LastPublished;

        /* ----------------------------------------------------------------- */
        ///
        /// Interval
        ///
        /// <summary>
        /// 実行間隔を取得または設定します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public TimeSpan Interval
        {
            get => Timer.Interval;
            set => Timer.Interval = value;
        }

        /* --------------------------------------------------------------------- */
        ///
        /// RetryCount
        ///
        /// <summary>
        /// 通信失敗時に再試行する最大回数を取得または設定します。
        /// </summary>
        ///
        /* --------------------------------------------------------------------- */
        public int RetryCount { get; set; } = 3;

        /* --------------------------------------------------------------------- */
        ///
        /// RetryInterval
        ///
        /// <summary>
        /// 通信失敗時に再試行する間隔を取得または設定します。
        /// </summary>
        ///
        /* --------------------------------------------------------------------- */
        public TimeSpan RetryInterval { get; set; } = TimeSpan.FromSeconds(5);

        /* --------------------------------------------------------------------- */
        ///
        /// Timeout
        ///
        /// <summary>
        /// タイムアウト時間を取得または設定します。
        /// </summary>
        ///
        /* --------------------------------------------------------------------- */
        public TimeSpan Timeout { get; set; } = TimeSpan.FromMilliseconds(500);

        /* ----------------------------------------------------------------- */
        ///
        /// Timer
        ///
        /// <summary>
        /// 内部用タイマーを取得します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        protected WakeableTimer Timer { get; } = new WakeableTimer();

        #endregion

        #region Methods

        /* ----------------------------------------------------------------- */
        ///
        /// Start
        ///
        /// <summary>
        /// 監視を実行します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public void Start() => Start(TimeSpan.Zero);

        /* ----------------------------------------------------------------- */
        ///
        /// Start
        ///
        /// <summary>
        /// 監視を実行します。
        /// </summary>
        ///
        /// <param name="delay">初期遅延時間</param>
        ///
        /* ----------------------------------------------------------------- */
        public virtual void Start(TimeSpan delay)
        {
            var state = Timer.State;
            Timer.Start(delay);
            if (state != TimerState.Stop) return;
            this.LogDebug($"Start\tInterval:{Interval}\tInitialDelay:{delay}");
        }

        /* ----------------------------------------------------------------- */
        ///
        /// Stop
        ///
        /// <summary>
        /// 監視を停止します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public virtual void Stop()
        {
            var state = Timer.State;
            Timer.Stop();
            if (state == TimerState.Stop) return;
            this.LogDebug($"Stop\tLastPublished:{Timer.LastPublished}");
        }

        /* ----------------------------------------------------------------- */
        ///
        /// Suspend
        ///
        /// <summary>
        /// 監視を一時停止します。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public void Suspend() => Timer.Suspend();

        /* ----------------------------------------------------------------- */
        ///
        /// Reset
        ///
        /// <summary>
        /// リセットします。
        /// </summary>
        ///
        /* ----------------------------------------------------------------- */
        public virtual void Reset()
        {
            var state = State;
            Timer.Reset();
            if (state == TimerState.Run)
            {
                Stop();
                Start();
            }
        }

        /* ----------------------------------------------------------------- */
        ///
        /// Dispose
        ///
        /// <summary>
        /// リソースを解放します。
        /// </summary>
        ///
        /// <param name="disposing">
        /// マネージリソースを解放するかどうかを示す値
        /// </param>
        ///
        /* ----------------------------------------------------------------- */
        protected override void Dispose(bool disposing)
        {
            if (disposing) Timer.Dispose();
        }

        #endregion
    }
}

{'fraction_non_alphanumeric': 0.4049812350733538, 'fraction_numerical': 0.0017741385192766974, 'mean_word_length': 0.5279399499582986, 'pattern_counts': {'":': 0, '<': 75, '<?xml version=': 0, '>': 87, 'https://': 0, 'lorem ipsum': 0, 'www.': 2, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5553421', 'n_tokens_mistral': 3383, 'n_tokens_neox': 3258, 'n_words': 560}