You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by tm...@apache.org on 2015/02/10 21:10:41 UTC
[03/19] incubator-reef git commit: [REEF-136] Harmonize namespaces
and folder names in Org.Apache.REEF projects
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/EvaluatorContext.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/EvaluatorContext.cs b/lang/cs/Org.Apache.REEF.Driver/context/EvaluatorContext.cs
deleted file mode 100644
index f275900..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/EvaluatorContext.cs
+++ /dev/null
@@ -1,148 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.ProtoBuf.EvaluatorRunTimeProto;
-using Org.Apache.REEF.Driver.Bridge;
-using Org.Apache.REEF.Driver.Context;
-using Org.Apache.REEF.Driver.Evaluator;
-using Org.Apache.REEF.Utilities;
-using Org.Apache.REEF.Utilities.Diagnostics;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Interface;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.REEF.Driver
-{
- public class EvaluatorContext : IActiveContext
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(EvaluatorContext));
-
- private string _identifier;
-
- private Optional<string> _parentId;
-
- private EvaluatorManager _evaluatorManager;
-
- private bool _disposed = false;
-
- public EvaluatorContext(EvaluatorManager evaluatorManager, string id, Optional<string> parentId)
- {
- _identifier = id;
- _parentId = parentId;
- _evaluatorManager = evaluatorManager;
- }
-
- public string Id
- {
- get
- {
- return _identifier;
- }
-
- set
- {
- }
- }
-
- public string EvaluatorId
- {
- get
- {
- return _evaluatorManager.Id;
- }
-
- set
- {
- }
- }
-
- public Optional<string> ParentId
- {
- get
- {
- return _parentId;
- }
-
- set
- {
- }
- }
-
- public IEvaluatorDescriptor EvaluatorDescriptor
- {
- get
- {
- return _evaluatorManager.EvaluatorDescriptor;
- }
-
- set
- {
- }
- }
-
- public void Dispose()
- {
- if (_disposed)
- {
- var e = new InvalidOperationException(string.Format(CultureInfo.InvariantCulture, "Active context [{0}] already closed", _identifier));
- Exceptions.Throw(e, LOGGER);
- }
- LOGGER.Log(Level.Info, string.Format(CultureInfo.InvariantCulture, "Submit close context: RunningEvaluator id [{0}] for context id [{1}]", EvaluatorId, Id));
- RemoveContextProto removeContextProto = new RemoveContextProto();
- removeContextProto.context_id = Id;
- ContextControlProto contextControlProto = new ContextControlProto();
- contextControlProto.remove_context = removeContextProto;
- _evaluatorManager.Handle(contextControlProto);
- _disposed = true;
- }
-
- public ClosedContext GetClosedContext(IActiveContext parentContext)
- {
- //return new ClosedContext(parentContext, EvaluatorId, Id, ParentId, EvaluatorDescriptor);
- throw new NotImplementedException();
- }
-
- public FailedContext GetFailedContext(Optional<IActiveContext> parentContext, Exception cause)
- {
- //return new FailedContext(parentContext, Id, cause, EvaluatorId, ParentId, EvaluatorDescriptor);
- throw new NotImplementedException();
- }
-
- public void SubmitTask(IConfiguration taskConf)
- {
- throw new NotImplementedException();
- }
-
- public void SubmitContext(IConfiguration contextConfiguration)
- {
- throw new NotImplementedException();
- }
-
- public void SubmitContextAndService(IConfiguration contextConfiguration, IConfiguration serviceConfiguration)
- {
- throw new NotImplementedException();
- }
-
- public void SendMessage(byte[] message)
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/IActiveContext.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/IActiveContext.cs b/lang/cs/Org.Apache.REEF.Driver/context/IActiveContext.cs
deleted file mode 100644
index 87ae9d2..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/IActiveContext.cs
+++ /dev/null
@@ -1,29 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common;
-using System;
-
-namespace Org.Apache.REEF.Driver.Context
-{
- public interface IActiveContext : IDisposable, IContext, ITaskSubmittable, IContextSubmittable
- {
- void SendMessage(byte[] message);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/IClosedContext.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/IClosedContext.cs b/lang/cs/Org.Apache.REEF.Driver/context/IClosedContext.cs
deleted file mode 100644
index 1fc0213..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/IClosedContext.cs
+++ /dev/null
@@ -1,26 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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.
- */
-
-namespace Org.Apache.REEF.Driver.Context
-{
- public interface IClosedContext : IContext
- {
- IActiveContext ParentContext { get; set; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/IContext.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/IContext.cs b/lang/cs/Org.Apache.REEF.Driver/context/IContext.cs
deleted file mode 100644
index fd6006c..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/IContext.cs
+++ /dev/null
@@ -1,45 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Evaluator;
-using Org.Apache.REEF.Utilities;
-
-namespace Org.Apache.REEF.Driver.Context
-{
- /// <summary>
- /// A common base interface for Contexts, available or failed.
- /// </summary>
- public interface IContext : IIdentifiable
- {
- /// <summary>
- /// the identifier of the Evaluator this EvaluatorContext is instantiated on.
- /// </summary>
- string EvaluatorId { get; set; }
-
- /// <summary>
- /// ID of the parent context, if there is any.
- /// </summary>
- Optional<string> ParentId { get; set; }
-
- /// <summary>
- /// descriptor of the Evaluator this Context is on.
- /// </summary>
- IEvaluatorDescriptor EvaluatorDescriptor { get; set; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/IFailedContext.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/IFailedContext.cs b/lang/cs/Org.Apache.REEF.Driver/context/IFailedContext.cs
deleted file mode 100644
index 6e07788..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/IFailedContext.cs
+++ /dev/null
@@ -1,28 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Utilities;
-
-namespace Org.Apache.REEF.Driver.Context
-{
- public interface IFailedContext : IContext
- {
- Optional<IActiveContext> ParentContext { get; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextMessageSource.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextMessageSource.cs b/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextMessageSource.cs
deleted file mode 100644
index 6c762ab..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextMessageSource.cs
+++ /dev/null
@@ -1,42 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Context;
-using Org.Apache.REEF.Utilities;
-
-namespace Org.Apache.REEF.Driver.Context
-{
- /// <summary>
- /// Default ContextMessageSource: return nothing.
- /// </summary>
- public class DefaultContextMessageSource : IContextMessageSource
- {
- public Optional<Common.Context.ContextMessage> Message
- {
- get
- {
- return Optional<Common.Context.ContextMessage>.Empty();
- }
-
- set
- {
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStartHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStartHandler.cs b/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStartHandler.cs
deleted file mode 100644
index f1bc157..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStartHandler.cs
+++ /dev/null
@@ -1,48 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Events;
-using Org.Apache.REEF.Utilities.Logging;
-using System;
-
-namespace Org.Apache.REEF.Driver.Context
-{
- /// <summary>
- /// Default handler for ContextStart
- /// </summary>
- public class DefaultContextStartHandler : IObserver<IContextStart>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultContextStartHandler));
-
- public void OnNext(IContextStart contextStart)
- {
- LOGGER.Log(Level.Info, "DefaultContextStartHandler received for context: " + contextStart.Id);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStopHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStopHandler.cs b/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStopHandler.cs
deleted file mode 100644
index 82f3250..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/context/defaults/DefaultContextStopHandler.cs
+++ /dev/null
@@ -1,48 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Events;
-using Org.Apache.REEF.Utilities.Logging;
-using System;
-
-namespace Org.Apache.REEF.Driver.Context
-{
- /// <summary>
- /// Default event handler for ContextStop
- /// </summary>
- public class DefaultContextStopHandler : IObserver<IContextStop>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultContextStopHandler));
-
- public void OnNext(IContextStop contextStop)
- {
- LOGGER.Log(Level.Info, "DefaultContextStopHandler received for context: " + contextStop.Id);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/contract/IBridgeContract.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/contract/IBridgeContract.cs b/lang/cs/Org.Apache.REEF.Driver/contract/IBridgeContract.cs
deleted file mode 100644
index 2c08d0b..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/contract/IBridgeContract.cs
+++ /dev/null
@@ -1,26 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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.
- */
-
-namespace Org.Apache.REEF.Driver.Contract
-{
- public interface IBridgeContract
- {
- string InstanceId { get; set; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseHandler.cs
deleted file mode 100644
index a47a2b1..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseHandler.cs
+++ /dev/null
@@ -1,53 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default handler for close messages from the client: logging it
- /// </summary>
- public class DefaultClientCloseHandler : IObserver<byte[]>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultClientCloseHandler));
-
- [Inject]
- public DefaultClientCloseHandler()
- {
- }
-
- public void OnNext(byte[] value)
- {
- LOGGER.Log(Level.Info, "Closing the Client");
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseWithMessageHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseWithMessageHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseWithMessageHandler.cs
deleted file mode 100644
index 0dbb6f0..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientCloseWithMessageHandler.cs
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Utilities;
-using Org.Apache.REEF.Utilities.Diagnostics;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default handler for close messages from the client: Throw an Exception.
- /// </summary>
- public class DefaultClientCloseWithMessageHandler : IObserver<byte[]>
- {
- [Inject]
- public DefaultClientCloseWithMessageHandler()
- {
- }
-
- public void OnNext(byte[] value)
- {
- Exceptions.Throw(new InvalidOperationException("No handler bound for client Close With Message event:" + ByteUtilities.ByteArrarysToString(value)),
- Logger.GetLogger(typeof(DefaultClientCloseWithMessageHandler)));
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientMessageHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientMessageHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientMessageHandler.cs
deleted file mode 100644
index ca5ac0e..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultClientMessageHandler.cs
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Utilities;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// DDefault event handler for Client messages: Logging it.
- /// </summary>
- public class DefaultClientMessageHandler : IObserver<byte[]>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultClientMessageHandler));
-
- [Inject]
- public DefaultClientMessageHandler()
- {
- }
-
- public void OnNext(byte[] value)
- {
- LOGGER.Log(Level.Info, "Received message: " + ByteUtilities.ByteArrarysToString(value));
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextActiveHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextActiveHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextActiveHandler.cs
deleted file mode 100644
index 7bb27ad..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextActiveHandler.cs
+++ /dev/null
@@ -1,56 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Context;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default handler for ActiveContext: Close it.
- /// </summary>
- public class DefaultContextActiveHandler : IObserver<IActiveContext>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultContextActiveHandler));
-
- [Inject]
- public DefaultContextActiveHandler()
- {
- }
-
- public void OnNext(IActiveContext value)
- {
- LOGGER.Log(Level.Info, string.Format(CultureInfo.InvariantCulture, "Received ActiveContext :[{0}], closing it", value.Id));
- value.Dispose();
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextClosureHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextClosureHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextClosureHandler.cs
deleted file mode 100644
index aa957c7..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextClosureHandler.cs
+++ /dev/null
@@ -1,55 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Context;
-using Org.Apache.REEF.Driver.Context;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler for ClosedContext: Logging it.
- /// </summary>
- public class DefaultContextClosureHandler : IObserver<IClosedContext>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultContextClosureHandler));
-
- [Inject]
- public DefaultContextClosureHandler()
- {
- }
-
- public void OnNext(IClosedContext value)
- {
- LOGGER.Log(Level.Info, "Received ClosedContext :" + value.Id);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextFailureHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextFailureHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextFailureHandler.cs
deleted file mode 100644
index d8014c6..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextFailureHandler.cs
+++ /dev/null
@@ -1,51 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Context;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler used for FailedContext: It crashes the driver.
- /// </summary>
- public class DefaultContextFailureHandler : IObserver<IFailedContext>
- {
- [Inject]
- public DefaultContextFailureHandler()
- {
- }
-
- public void OnNext(IFailedContext value)
- {
- throw new InvalidOperationException("No handler bound for FailedContext: " + value.Id);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextMessageHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextMessageHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextMessageHandler.cs
deleted file mode 100644
index 0e6715c..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultContextMessageHandler.cs
+++ /dev/null
@@ -1,55 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Context;
-using Org.Apache.REEF.Utilities;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// efault event handler for ContextMessage: Logging it.
- /// </summary>
- public class DefaultContextMessageHandler : IObserver<IContextMessage>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultContextMessageHandler));
-
- [Inject]
- public DefaultContextMessageHandler()
- {
- }
-
- public void OnNext(IContextMessage value)
- {
- LOGGER.Log(Level.Info, "Received ContextMessage: " + ByteUtilities.ByteArrarysToString(value.Message));
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultCustomTraceListener.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultCustomTraceListener.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultCustomTraceListener.cs
deleted file mode 100644
index a1f897b..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultCustomTraceListener.cs
+++ /dev/null
@@ -1,45 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Tang.Annotations;
-using System.Diagnostics;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- public class DefaultCustomTraceListener : TraceListener
- {
- private readonly TraceListener _listener;
-
- [Inject]
- public DefaultCustomTraceListener()
- {
- _listener = new ConsoleTraceListener();
- }
-
- public override void Write(string message)
- {
- _listener.Write(message);
- }
-
- public override void WriteLine(string message)
- {
- _listener.WriteLine(message);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartContextActiveHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartContextActiveHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartContextActiveHandler.cs
deleted file mode 100644
index 5ceb271..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartContextActiveHandler.cs
+++ /dev/null
@@ -1,56 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Context;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default handler for ActiveContext received during driver restart: Close it.
- /// </summary>
- public class DefaultDriverRestartContextActiveHandler : IObserver<IActiveContext>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultDriverRestartContextActiveHandler));
-
- [Inject]
- public DefaultDriverRestartContextActiveHandler()
- {
- }
-
- public void OnNext(IActiveContext value)
- {
- LOGGER.Log(Level.Info, string.Format(CultureInfo.InvariantCulture, "Received ActiveContext during driver restart:[{0}], closing it", value.Id));
- value.Dispose();
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartHandler.cs
deleted file mode 100644
index a895251..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartHandler.cs
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using Org.Apache.REEF.Wake.Time;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler for driver restart: Logging it.
- /// </summary>
- public class DefaultDriverRestartHandler : IObserver<StartTime>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultDriverRestartHandler));
-
- [Inject]
- public DefaultDriverRestartHandler()
- {
- }
-
- public void OnNext(StartTime startTime)
- {
- LOGGER.Log(Level.Info, "Driver restarted at" + new DateTime(startTime.TimeStamp));
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartTaskRunningHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartTaskRunningHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartTaskRunningHandler.cs
deleted file mode 100644
index c202933..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultDriverRestartTaskRunningHandler.cs
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Task;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler for TaskRuntime received during driver restart: Logging it.
- /// </summary>
- public class DefaultDriverRestartTaskRunningHandler : IObserver<IRunningTask>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultDriverRestartTaskRunningHandler));
-
- [Inject]
- public DefaultDriverRestartTaskRunningHandler()
- {
- }
-
- public void OnNext(IRunningTask runningTask)
- {
- LOGGER.Log(Level.Info, "Received TaskRuntime during driver restart: " + runningTask.Id);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorAllocationHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorAllocationHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorAllocationHandler.cs
deleted file mode 100644
index 9216b64..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorAllocationHandler.cs
+++ /dev/null
@@ -1,57 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Evaluator;
-using Org.Apache.REEF.Driver.Evaluator;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default handler for AllocatedEvaluator: close it.
- /// </summary>
- public class DefaultEvaluatorAllocationHandler : IObserver<IAllocatedEvaluator>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultEvaluatorAllocationHandler));
-
- [Inject]
- public DefaultEvaluatorAllocationHandler()
- {
- }
-
- public void OnNext(IAllocatedEvaluator value)
- {
- LOGGER.Log(Level.Info, string.Format(CultureInfo.InvariantCulture, "Received AllocatedEvaluator : {0}, closing", value.Id));
- value.Dispose();
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorCompletionHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorCompletionHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorCompletionHandler.cs
deleted file mode 100644
index fcea53d..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorCompletionHandler.cs
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Evaluator;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler for CompletedEvaluator: Logging it.
- /// </summary>
- public class DefaultEvaluatorCompletionHandler : IObserver<ICompletedEvaluator>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultEvaluatorCompletionHandler));
-
- [Inject]
- public DefaultEvaluatorCompletionHandler()
- {
- }
-
- public void OnNext(ICompletedEvaluator value)
- {
- LOGGER.Log(Level.Info, "Received CompletedEvaluator: " + value.Id);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorFailureHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorFailureHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorFailureHandler.cs
deleted file mode 100644
index 82cfd26..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorFailureHandler.cs
+++ /dev/null
@@ -1,55 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Evaluator;
-using Org.Apache.REEF.Utilities.Diagnostics;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler used for FailedEvaluator: It crashes the driver.
- /// </summary>
- public class DefaultEvaluatorFailureHandler : IObserver<IFailedEvaluator>
- {
- [Inject]
- public DefaultEvaluatorFailureHandler()
- {
- }
-
- public void OnNext(IFailedEvaluator value)
- {
- var e = new InvalidOperationException(string.Format(CultureInfo.InvariantCulture, "Evaluator {0} failed, and no handler is bound for FailedEvaluator.", value.Id));
- Exceptions.Throw(e, Logger.GetLogger(typeof(DefaultEvaluatorFailureHandler)));
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorRequestorHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorRequestorHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorRequestorHandler.cs
deleted file mode 100644
index 465baa7..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultEvaluatorRequestorHandler.cs
+++ /dev/null
@@ -1,61 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Bridge;
-using Org.Apache.REEF.Driver.Evaluator;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default handler for close messages from the client: logging it
- /// </summary>
- public class DefaultEvaluatorRequestorHandler : IObserver<IEvaluatorRequestor>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultClientCloseHandler));
-
- [Inject]
- public DefaultEvaluatorRequestorHandler()
- {
- }
-
- public void OnNext(IEvaluatorRequestor value)
- {
- LOGGER.Log(Level.Info, "Default evaluator requstor: requesting 1 evaluator with 512 MB");
- int evaluatorsNumber = 1;
- int memory = 512;
- string rack = "WonderlandRack";
- EvaluatorRequest request = new EvaluatorRequest(evaluatorsNumber, memory, rack);
-
- value.Submit(request);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultHttpHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultHttpHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultHttpHandler.cs
deleted file mode 100644
index 831eebe..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultHttpHandler.cs
+++ /dev/null
@@ -1,49 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 System.Net;
-using Org.Apache.REEF.Driver.Bridge;
-using Org.Apache.REEF.Utilities;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- public class DefaultHttpHandler : IHttpHandler
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultHttpHandler));
-
- [Inject]
- public DefaultHttpHandler()
- {
- }
-
- public string GetSpecification()
- {
- return "Ping";
- }
-
- public void OnHttpRequest(ReefHttpRequest requet, ReefHttpResponse response)
- {
- LOGGER.Log(Level.Info, "OnHttpRequest in DefaultHttpHandler is called.");
- response.Status = HttpStatusCode.OK;
- response.OutputStream = ByteUtilities.StringToByteArrays("Byte array returned from DefaultHttpHandler in CLR!!!");
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskCompletionHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskCompletionHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskCompletionHandler.cs
deleted file mode 100644
index 33b6495..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskCompletionHandler.cs
+++ /dev/null
@@ -1,60 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Context;
-using Org.Apache.REEF.Common.Task;
-using Org.Apache.REEF.Driver.Context;
-using Org.Apache.REEF.Driver.Task;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// efault event handler for CompletedTask: Log it and close the context.
- /// </summary>
- public class DefaultTaskCompletionHandler : IObserver<ICompletedTask>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultTaskCompletionHandler));
-
- [Inject]
- public DefaultTaskCompletionHandler()
- {
- }
-
- public void OnNext(ICompletedTask value)
- {
- IActiveContext activeContext = value.ActiveContext;
- LOGGER.Log(Level.Info, string.Format(CultureInfo.InvariantCulture, "Received CompletedTask: {0} :: CLOSING context: {1}", value.Id, activeContext.Id));
- activeContext.Dispose();
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskFailureHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskFailureHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskFailureHandler.cs
deleted file mode 100644
index b39200f..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskFailureHandler.cs
+++ /dev/null
@@ -1,53 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Task;
-using Org.Apache.REEF.Driver.Task;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler used for FailedTask: It crashes the driver.
- /// </summary>
- public class DefaultTaskFailureHandler : IObserver<IFailedTask>
- {
- [Inject]
- public DefaultTaskFailureHandler()
- {
- }
-
- public void OnNext(IFailedTask value)
- {
- throw new InvalidOperationException(string.Format(CultureInfo.InvariantCulture, "Task {0} has failed, and no handler was bound for IFailedTask", value.Id) );
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskMessageHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskMessageHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskMessageHandler.cs
deleted file mode 100644
index cdaac06..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskMessageHandler.cs
+++ /dev/null
@@ -1,55 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Task;
-using Org.Apache.REEF.Driver.Task;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler for TaskMessage: Logging it.
- /// </summary>
- public class DefaultTaskMessageHandler : IObserver<ITaskMessage>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultTaskMessageHandler));
-
- [Inject]
- public DefaultTaskMessageHandler()
- {
- }
-
- public void OnNext(ITaskMessage value)
- {
- LOGGER.Log(Level.Info, "Default TaskMessage handler received message: " + value.Message);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskRunningHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskRunningHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskRunningHandler.cs
deleted file mode 100644
index e356b0e..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskRunningHandler.cs
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Driver.Task;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler for TaskRuntime: Logging it.
- /// </summary>
- public class DefaultTaskRunningHandler : IObserver<IRunningTask>
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DefaultTaskRunningHandler));
-
- [Inject]
- public DefaultTaskRunningHandler()
- {
- }
-
- public void OnNext(IRunningTask runningTask)
- {
- LOGGER.Log(Level.Info, "Received TaskRuntime: " + runningTask.Id);
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskSuspensionHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskSuspensionHandler.cs b/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskSuspensionHandler.cs
deleted file mode 100644
index 46ced71..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/defaults/DefaultTaskSuspensionHandler.cs
+++ /dev/null
@@ -1,53 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common;
-using Org.Apache.REEF.Utilities.Diagnostics;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-
-namespace Org.Apache.REEF.Driver.Defaults
-{
- /// <summary>
- /// Default event handler used for SuspendedTask: It crashes the driver.
- /// </summary>
- public class DefaultTaskSuspensionHandler : IObserver<ISuspendedTask>
- {
- [Inject]
- public DefaultTaskSuspensionHandler()
- {
- }
-
- public void OnNext(ISuspendedTask value)
- {
- Exceptions.Throw(new InvalidOperationException("No handler bound for SuspendedTask: " + value.Id), Logger.GetLogger(typeof(DefaultTaskSuspensionHandler)));
- }
-
- public void OnError(Exception error)
- {
- throw new NotImplementedException();
- }
-
- public void OnCompleted()
- {
- throw new NotImplementedException();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorDescriptorImpl.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorDescriptorImpl.cs b/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorDescriptorImpl.cs
deleted file mode 100644
index 0833431..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorDescriptorImpl.cs
+++ /dev/null
@@ -1,218 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Catalog;
-using Org.Apache.REEF.Common.Evaluator;
-using Org.Apache.REEF.Driver.Bridge;
-using Org.Apache.REEF.Utilities.Diagnostics;
-using Org.Apache.REEF.Utilities.Logging;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Net;
-
-namespace Org.Apache.REEF.Driver.Evaluator
-{
- public class EvaluatorDescriptorImpl : IEvaluatorDescriptor
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(EvaluatorDescriptorImpl));
-
- private INodeDescriptor _nodeDescriptor;
-
- private EvaluatorType _type;
-
- private int _megaBytes;
-
- private int _virtualCore;
-
- private string _rack = "default_rack";
-
- public EvaluatorDescriptorImpl(string serializedString)
- {
- FromString(serializedString);
- }
-
- public EvaluatorDescriptorImpl(INodeDescriptor nodeDescriptor, EvaluatorType type, int megaBytes, int core)
- {
- _nodeDescriptor = nodeDescriptor;
- _type = type;
- _megaBytes = megaBytes;
- _virtualCore = core;
- }
-
- public INodeDescriptor NodeDescriptor
- {
- get
- {
- return _nodeDescriptor;
- }
-
- set
- {
- }
- }
-
- public EvaluatorType EvaluatorType
- {
- get
- {
- return _type;
- }
-
- set
- {
- }
- }
-
- public int Memory
- {
- get
- {
- return _megaBytes;
- }
-
- set
- {
- }
- }
-
- public int VirtualCore
- {
- get
- {
- return _virtualCore;
- }
-
- set
- {
- }
- }
-
- public string Rack
- {
- get
- {
- return _rack;
- }
-
- set
- {
- }
- }
-
- public void FromString(string str)
- {
- Dictionary<string, string> settings = new Dictionary<string, string>();
- string[] components = str.Split(',');
- foreach (string component in components)
- {
- string[] pair = component.Trim().Split('=');
- if (pair == null || pair.Length != 2)
- {
- var e = new ArgumentException("invalid component to be used as key-value pair:", component);
- Exceptions.Throw(e, LOGGER);
- }
- settings.Add(pair[0], pair[1]);
- }
- string ipAddress;
- if (!settings.TryGetValue("IP", out ipAddress))
- {
- Exceptions.Throw(new ArgumentException("cannot find IP entry"), LOGGER);
- }
- ipAddress = ipAddress.Split('/').Last();
- string port;
- if (!settings.TryGetValue("Port", out port))
- {
- Exceptions.Throw(new ArgumentException("cannot find Port entry"), LOGGER);
- }
- int portNumber = 0;
- int.TryParse(port, out portNumber);
- string hostName;
- if (!settings.TryGetValue("HostName", out hostName))
- {
- Exceptions.Throw(new ArgumentException("cannot find HostName entry"), LOGGER);
- }
- string memory;
- if (!settings.TryGetValue("Memory", out memory))
- {
- Exceptions.Throw(new ArgumentException("cannot find Memory entry"), LOGGER);
- }
- int memoryInMegaBytes = 0;
- int.TryParse(memory, out memoryInMegaBytes);
-
- string core;
- if (!settings.TryGetValue("Core", out core))
- {
- Exceptions.Throw(new ArgumentException("cannot find Core entry"), LOGGER);
- }
- int vCore = 0;
- int.TryParse(core, out vCore);
-
- IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Parse(ipAddress), portNumber);
-
- _nodeDescriptor = new NodeDescriptorImpl();
- _nodeDescriptor.InetSocketAddress = ipEndPoint;
- _nodeDescriptor.HostName = hostName;
- _type = EvaluatorType.CLR;
- _megaBytes = memoryInMegaBytes;
- _virtualCore = vCore;
- }
-
- public void SetType(EvaluatorType type)
- {
- lock (this)
- {
- if (_type != EvaluatorType.UNDECIDED)
- {
- var e = new InvalidOperationException("Cannot change a set evaluator type: " + _type);
- Exceptions.Throw(e, LOGGER);
- }
- _type = type;
- }
- }
-
- public override bool Equals(object obj)
- {
- EvaluatorDescriptorImpl other = obj as EvaluatorDescriptorImpl;
- if (other == null)
- {
- return false;
- }
-
- return EquivalentMemory(other);
- // we don't care about rack now;
- // && string.Equals(_rack, other.Rack, StringComparison.OrdinalIgnoreCase);
- }
-
- public override int GetHashCode()
- {
- return base.GetHashCode();
- }
-
- private bool EquivalentMemory(EvaluatorDescriptorImpl other)
- {
- int granularity = ClrHandlerHelper.MemoryGranularity == 0
- ? Constants.DefaultMemoryGranularity
- : ClrHandlerHelper.MemoryGranularity;
- int m1 = (Memory - 1) / granularity;
- int m2 = (other.Memory - 1 ) / granularity;
- return (m1 == m2);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequest.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequest.cs b/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequest.cs
deleted file mode 100644
index b04e05b..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequest.cs
+++ /dev/null
@@ -1,108 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Capabilities;
-using Org.Apache.REEF.Common.Catalog;
-using Org.Apache.REEF.Driver.Evaluator;
-using System;
-using System.Collections.Generic;
-using System.Runtime.Serialization;
-
-namespace Org.Apache.REEF.Driver.Bridge
-{
- [DataContract]
- public class EvaluatorRequest : IEvaluatorRequest
- {
- public EvaluatorRequest()
- : this(0, 0, 1, string.Empty, Guid.NewGuid().ToString("N"))
- {
- }
-
- public EvaluatorRequest(int number, int megaBytes)
- : this(number, megaBytes, 1, string.Empty, Guid.NewGuid().ToString("N"))
- {
- }
-
- public EvaluatorRequest(int number, int megaBytes, int core)
- : this(number, megaBytes, core, string.Empty, Guid.NewGuid().ToString("N"))
- {
- }
-
- public EvaluatorRequest(int number, int megaBytes, string rack)
- : this(number, megaBytes, 1, rack, Guid.NewGuid().ToString("N"))
- {
- }
-
- public EvaluatorRequest(int number, int megaBytes, int core, string rack)
- : this(number, megaBytes, core, rack, Guid.NewGuid().ToString("N"))
- {
- }
-
- public EvaluatorRequest(int number, int megaBytes, int core, string rack, string evaluatorBatchId)
- {
- Number = number;
- MemoryMegaBytes = megaBytes;
- VirtualCore = core;
- Rack = rack;
- EvaluatorBatchId = evaluatorBatchId;
- }
-
- public EvaluatorRequest(int number, int megaBytes, int core, List<ICapability> capabilitieses, IResourceCatalog catalog)
- {
- Number = number;
- MemoryMegaBytes = megaBytes;
- Capabilities = capabilitieses;
- VirtualCore = core;
- Catalog = catalog;
- EvaluatorBatchId = Guid.NewGuid().ToString("N");
- }
-
- [DataMember]
- public string InstanceId { get; set; }
-
- [DataMember]
- public int MemoryMegaBytes { get; set; }
-
- [DataMember]
- public int Number { get; set; }
-
- [DataMember]
- public int VirtualCore { get; set; }
-
- [DataMember]
- public string Rack { get; set; }
-
- [DataMember]
- public string EvaluatorBatchId { get; set; }
-
- public List<ICapability> Capabilities { get; set; }
-
- public IResourceCatalog Catalog { get; set; }
-
- public static EvaluatorRequestBuilder NewBuilder()
- {
- return new EvaluatorRequestBuilder();
- }
-
- public static EvaluatorRequestBuilder NewBuilder(EvaluatorRequest request)
- {
- return new EvaluatorRequestBuilder(request);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequestBuilder.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequestBuilder.cs b/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequestBuilder.cs
deleted file mode 100644
index 95a1ee3..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/evaluator/EvaluatorRequestBuilder.cs
+++ /dev/null
@@ -1,60 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Capabilities;
-using Org.Apache.REEF.Common.Catalog;
-using Org.Apache.REEF.Driver.Bridge;
-using System.Collections.Generic;
-
-namespace Org.Apache.REEF.Driver.Evaluator
-{
- public class EvaluatorRequestBuilder
- {
- public EvaluatorRequestBuilder(EvaluatorRequest request)
- {
- foreach (ICapability capability in request.Capabilities)
- {
- Capabilities.Add(capability);
- }
- Number = request.Number;
- Catalog = request.Catalog;
- MegaBytes = request.MemoryMegaBytes;
- VirtualCore = request.VirtualCore;
- }
-
- internal EvaluatorRequestBuilder()
- {
- }
-
- public int Number { get; set; }
-
- public List<ICapability> Capabilities { get; set; }
-
- public IResourceCatalog Catalog { get; set; }
-
- public int MegaBytes { get; set; }
-
- public int VirtualCore { get; set; }
-
- public EvaluatorRequest Build()
- {
- return new EvaluatorRequest(Number, MegaBytes, VirtualCore, Capabilities, Catalog);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/evaluator/IAllocatedEvaluator.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/evaluator/IAllocatedEvaluator.cs b/lang/cs/Org.Apache.REEF.Driver/evaluator/IAllocatedEvaluator.cs
deleted file mode 100644
index 794987f..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/evaluator/IAllocatedEvaluator.cs
+++ /dev/null
@@ -1,55 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common;
-using Org.Apache.REEF.Common.Evaluator;
-using Org.Apache.REEF.Utilities;
-using System;
-using System.Net;
-
-namespace Org.Apache.REEF.Driver.Evaluator
-{
- /// <summary>
- /// Represents an Evaluator that is allocated, but is not running yet.
- /// </summary>
- public interface IAllocatedEvaluator : IDisposable, IIdentifiable, IContextSubmittable, IContextAndTaskSubmittable
- {
- EvaluatorType Type { get; set; }
-
- string NameServerInfo { get; set; }
-
- string EvaluatorBatchId { get; set; }
-
- IEvaluatorDescriptor GetEvaluatorDescriptor();
-
- /// <summary>
- /// Puts the given file into the working directory of the Evaluator.
- /// </summary>
- /// <param name="file">the file to be copied</param>
- void AddFile(string file);
-
- /// <summary>
- /// Puts the given file into the working directory of the Evaluator and adds it to its classpath.
- /// </summary>
- /// <param name="file">the file to be copied</param>
- void AddLibrary(string file);
-
- void AddFileResource(string file);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/evaluator/ICompletedEvaluator.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/evaluator/ICompletedEvaluator.cs b/lang/cs/Org.Apache.REEF.Driver/evaluator/ICompletedEvaluator.cs
deleted file mode 100644
index a4b3a69..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/evaluator/ICompletedEvaluator.cs
+++ /dev/null
@@ -1,30 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Utilities;
-
-namespace Org.Apache.REEF.Driver.Evaluator
-{
- /// <summary>
- /// Represents an Evaluator that has completed
- /// </summary>
- public interface ICompletedEvaluator : IIdentifiable
- {
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Driver/evaluator/IEvaluatorDescriptor.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Driver/evaluator/IEvaluatorDescriptor.cs b/lang/cs/Org.Apache.REEF.Driver/evaluator/IEvaluatorDescriptor.cs
deleted file mode 100644
index 9fadbd9..0000000
--- a/lang/cs/Org.Apache.REEF.Driver/evaluator/IEvaluatorDescriptor.cs
+++ /dev/null
@@ -1,57 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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 Org.Apache.REEF.Common.Catalog;
-using Org.Apache.REEF.Common.Evaluator;
-
-namespace Org.Apache.REEF.Driver.Evaluator
-{
- /// <summary>
- /// Metadata about an Evaluator.
- /// </summary>
- public interface IEvaluatorDescriptor
- {
- /// <summary>
- /// NodeDescriptor of the node where this Evaluator is running.
- /// </summary>
- INodeDescriptor NodeDescriptor { get; set; }
-
- /// <summary>
- /// type of Evaluator.
- /// </summary>
- EvaluatorType EvaluatorType { get; set; }
-
- /// <summary>
- /// the amount of memory allocated to this Evaluator.
- /// </summary>
- int Memory { get; set; }
-
- /// <summary>
- /// the virtual core allocated to this Evaluator.
- /// </summary>
- int VirtualCore { get; set; }
-
- /// <summary>
- /// rack on which the evaluator was allocated
- /// </summary>
- string Rack { get; set; }
-
- void FromString(string str);
- }
-}