Repository: incubator-reef Updated Branches: refs/heads/master 05a00e126 -> 1d6563e53
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/LogicalTimer.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/LogicalTimer.cs b/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/LogicalTimer.cs index b1cb543..c118ace 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/LogicalTimer.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/LogicalTimer.cs @@ -17,13 +17,7 @@ * under the License. */ -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; using Org.Apache.REEF.Tang.Annotations; -using Org.Apache.REEF.Wake.Time.Runtime.Event; namespace Org.Apache.REEF.Wake.Time.Runtime { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RealTimer.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RealTimer.cs b/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RealTimer.cs index 6b5213b..a9688d5 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RealTimer.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RealTimer.cs @@ -18,13 +18,7 @@ */ using System; -using System.Collections.Generic; -using System.Diagnostics; -using System.Linq; -using System.Text; -using System.Threading.Tasks; using Org.Apache.REEF.Tang.Annotations; -using Org.Apache.REEF.Wake.Time.Runtime.Event; namespace Org.Apache.REEF.Wake.Time.Runtime { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RuntimeClock.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RuntimeClock.cs b/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RuntimeClock.cs index b0eb2c9..48f7388 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RuntimeClock.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Time/Runtime/RuntimeClock.cs @@ -35,15 +35,15 @@ namespace Org.Apache.REEF.Wake.Time.Runtime { private static readonly Logger LOGGER = Logger.GetLogger(typeof(RuntimeClock)); - private ITimer _timer; - private PubSubSubject<Time> _handlers; - private ISet<Time> _schedule; + private readonly ITimer _timer; + private readonly PubSubSubject<Time> _handlers; + private readonly ISet<Time> _schedule; - private IInjectionFuture<ISet<IObserver<StartTime>>> _startHandler; - private IInjectionFuture<ISet<IObserver<StopTime>>> _stopHandler; + private readonly IInjectionFuture<ISet<IObserver<StartTime>>> _startHandler; + private readonly IInjectionFuture<ISet<IObserver<StopTime>>> _stopHandler; private IInjectionFuture<ISet<IObserver<RuntimeStart>>> _runtimeStartHandler; private IInjectionFuture<ISet<IObserver<RuntimeStop>>> _runtimeStopHandler; - private IInjectionFuture<ISet<IObserver<IdleClock>>> _idleHandler; + private readonly IInjectionFuture<ISet<IObserver<IdleClock>>> _idleHandler; private bool _disposed; http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Util/Disposable.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Util/Disposable.cs b/lang/cs/Org.Apache.REEF.Wake/Util/Disposable.cs index c289eea..82ebcc7 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Util/Disposable.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Util/Disposable.cs @@ -18,10 +18,6 @@ */ using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; namespace Org.Apache.REEF.Wake.Util { @@ -30,8 +26,8 @@ namespace Org.Apache.REEF.Wake.Util /// </summary> internal class Disposable : IDisposable { - private Action _disposeFunction; - private bool _disposed; + private readonly Action _disposeFunction; + private readonly bool _disposed; private Disposable(Action disposeFunction) { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Util/FixedThreadPoolTaskService.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Util/FixedThreadPoolTaskService.cs b/lang/cs/Org.Apache.REEF.Wake/Util/FixedThreadPoolTaskService.cs index 49f9a11..f797858 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Util/FixedThreadPoolTaskService.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Util/FixedThreadPoolTaskService.cs @@ -19,13 +19,10 @@ using System; using System.Collections.Generic; -using System.Linq; -using System.Text; using System.Threading; using System.Threading.Tasks; using Org.Apache.REEF.Utilities.Diagnostics; using Org.Apache.REEF.Utilities.Logging; -using Org.Apache.REEF.Wake.Time.Runtime.Event; namespace Org.Apache.REEF.Wake.Util { @@ -33,9 +30,9 @@ namespace Org.Apache.REEF.Wake.Util { private static readonly Logger LOGGER = Logger.GetLogger(typeof(FixedThreadPoolTaskService)); - TaskFactory factory; + readonly TaskFactory factory; - List<Task> tasks = new List<Task>(); + readonly List<Task> tasks = new List<Task>(); bool shuttingDown; internal FixedThreadPoolTaskService(int maxDegreeOfParallelism) http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Util/IStartable.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Util/IStartable.cs b/lang/cs/Org.Apache.REEF.Wake/Util/IStartable.cs index 81214a4..8603ee0 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Util/IStartable.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Util/IStartable.cs @@ -17,12 +17,6 @@ * under the License. */ -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; - namespace Org.Apache.REEF.Wake.Util { public interface IStartable http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Util/NetworkUtils.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Util/NetworkUtils.cs b/lang/cs/Org.Apache.REEF.Wake/Util/NetworkUtils.cs index bd35952..f1fb45a 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Util/NetworkUtils.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Util/NetworkUtils.cs @@ -18,19 +18,16 @@ */ using System; -using System.Collections.Generic; using System.Linq; using System.Net; using System.Net.Sockets; -using System.Text; -using System.Threading.Tasks; namespace Org.Apache.REEF.Wake.Util { public class NetworkUtils { private static IPAddress _localAddress; - private static Random _random = new Random(); + private static readonly Random _random = new Random(); /// <summary> /// Returns the first usable IP Address for the machine. http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Util/SerializationHelper.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Util/SerializationHelper.cs b/lang/cs/Org.Apache.REEF.Wake/Util/SerializationHelper.cs index 1c29382..2bb730f 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Util/SerializationHelper.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Util/SerializationHelper.cs @@ -17,10 +17,8 @@ * under the License. */ -using ProtoBuf; -using System; using System.IO; -using System.Runtime.Serialization; +using ProtoBuf; namespace Org.Apache.REEF.Wake.Util { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Util/TaskExtensions.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Util/TaskExtensions.cs b/lang/cs/Org.Apache.REEF.Wake/Util/TaskExtensions.cs index 69e4972..b64b175 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Util/TaskExtensions.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Util/TaskExtensions.cs @@ -17,10 +17,6 @@ * under the License. */ -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; using System.Threading.Tasks; namespace Org.Apache.REEF.Wake.Util http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/1d6563e5/lang/cs/Org.Apache.REEF.Wake/Util/TimeHelper.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Wake/Util/TimeHelper.cs b/lang/cs/Org.Apache.REEF.Wake/Util/TimeHelper.cs index 2f913cc..2ac374e 100644 --- a/lang/cs/Org.Apache.REEF.Wake/Util/TimeHelper.cs +++ b/lang/cs/Org.Apache.REEF.Wake/Util/TimeHelper.cs @@ -18,7 +18,6 @@ */ using System; -using System.Threading; namespace Org.Apache.REEF.Wake.Util {
