http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/events/IContextStop.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/events/IContextStop.cs b/lang/cs/Org.Apache.REEF.Common/events/IContextStop.cs deleted file mode 100644 index bdc5a73..0000000 --- a/lang/cs/Org.Apache.REEF.Common/events/IContextStop.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.Common.Events -{ - public interface IContextStop - { - string Id { get; set; } - } -} \ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/exceptions/EvaluatorException.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/exceptions/EvaluatorException.cs b/lang/cs/Org.Apache.REEF.Common/exceptions/EvaluatorException.cs deleted file mode 100644 index 33248ae..0000000 --- a/lang/cs/Org.Apache.REEF.Common/exceptions/EvaluatorException.cs +++ /dev/null @@ -1,75 +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.Utilities; -using System; - -namespace Org.Apache.REEF.Common.Exceptions -{ - public class EvaluatorException : System.Exception, IIdentifiable - { - private readonly string _evaluatorId; - - public EvaluatorException(string evaluatorId) - { - _evaluatorId = evaluatorId; - RunningTask = null; - } - - public EvaluatorException(string evaluatorId, string message, System.Exception cause) - : base(message, cause) - { - _evaluatorId = evaluatorId; - RunningTask = null; - } - - public EvaluatorException(string evaluatorId, string message) - : this(evaluatorId, message, (IRunningTask)null) - { - } - - public EvaluatorException(string evaluatorId, string message, IRunningTask runningTask) - : base(message) - { - _evaluatorId = evaluatorId; - RunningTask = runningTask; - } - - public EvaluatorException(string evaluatorId, System.Exception cause) - : this(evaluatorId, cause, null) - { - } - - public EvaluatorException(string evaluatorId, Exception cause, IRunningTask runningTask) - : base(string.Empty, cause) - { - _evaluatorId = evaluatorId; - RunningTask = runningTask; - } - - public IRunningTask RunningTask { get; set; } - - public string Id - { - get { return _evaluatorId; } - set { } - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/exceptions/JobException.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/exceptions/JobException.cs b/lang/cs/Org.Apache.REEF.Common/exceptions/JobException.cs deleted file mode 100644 index 0cceecc..0000000 --- a/lang/cs/Org.Apache.REEF.Common/exceptions/JobException.cs +++ /dev/null @@ -1,58 +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 System; - -namespace Org.Apache.REEF.Common -{ - public class JobException : Exception, IIdentifiable - { - private string _jobId; - - public JobException(string jobId) - { - _jobId = jobId; - } - - public JobException(string jobId, string message, Exception cause) - : base(message, cause) - { - _jobId = jobId; - } - - public JobException(string jobId, string message) - : base(message) - { - _jobId = jobId; - } - - public JobException(string jobId, Exception cause) - : base(string.Empty, cause) - { - _jobId = jobId; - } - - public string Id - { - get { return _jobId; } - set { } - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/io/INameClient.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/io/INameClient.cs b/lang/cs/Org.Apache.REEF.Common/io/INameClient.cs deleted file mode 100644 index 941d023..0000000 --- a/lang/cs/Org.Apache.REEF.Common/io/INameClient.cs +++ /dev/null @@ -1,71 +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; -using System.Collections.Generic; -using System.Net; - -namespace Org.Apache.REEF.Common.io -{ - /// <summary> - /// Client for the Reef name service. - /// Used to register, unregister, and lookup IP Addresses of known hosts. - /// </summary> - public interface INameClient : IDisposable - { - /// <summary> - /// Registers the identifier with the NameService. - /// Overwrites the previous mapping if the identifier has already - /// been registered. - /// </summary> - /// <param name="id">The key used to map the remote endpoint</param> - /// <param name="endpoint">The endpoint to map</param> - void Register(string id, IPEndPoint endpoint); - - /// <summary> - /// Unregisters the remote identifier with the NameService - /// </summary> - /// <param name="id">The identifier to unregister</param> - void Unregister(string id); - - /// <summary> - /// Looks up the IPEndpoint for the registered identifier. - /// </summary> - /// <param name="id">The identifier to look up</param> - /// <returns>The mapped IPEndpoint for the identifier, or null if - /// the identifier has not been registered with the NameService</returns> - IPEndPoint Lookup(string id); - - /// <summary> - /// Looks up the IPEndpoint for each of the registered identifiers in the list. - /// </summary> - /// <param name="ids">The list of identifiers to look up</param> - /// <returns>The list of NameAssignments representing a pair of identifer - /// and mapped IPEndpoint for that identifier. If any of the requested identifiers - /// are not registered with the NameService, their corresponding NameAssignment - /// IPEndpoint value will be null.</returns> - List<NameAssignment> Lookup(List<string> ids); - - /// <summary> - /// Restart the name client in case of failure. - /// </summary> - /// <param name="serverEndpoint">The new server endpoint to connect to</param> - void Restart(IPEndPoint serverEndpoint); - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/io/NameAssignment.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/io/NameAssignment.cs b/lang/cs/Org.Apache.REEF.Common/io/NameAssignment.cs deleted file mode 100644 index 8751244..0000000 --- a/lang/cs/Org.Apache.REEF.Common/io/NameAssignment.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 System.Net; -using System.Net.Sockets; - -namespace Org.Apache.REEF.Common.io -{ - /// <summary> - /// Tuple containing the string identifier and IPEndpoint. - /// Used by NameServer and NameClient - /// </summary> - public class NameAssignment - { - public NameAssignment(string id, IPEndPoint endpoint) - { - Identifier = id; - Endpoint = endpoint; - } - - public NameAssignment(string id, string address, int port) - { - Identifier = id; - IPAddress ipAddress; - if (!IPAddress.TryParse(address, out ipAddress)) - { - IPHostEntry hostEntry = Dns.GetHostEntry(address); - foreach (var ip in hostEntry.AddressList) - { - if (ip.AddressFamily == AddressFamily.InterNetwork) - { - ipAddress = ip; - break; - } - } - } - Endpoint = new IPEndPoint(ipAddress, port); - } - - public string Identifier { get; set; } - - public IPEndPoint Endpoint { get; set; } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/io/NamingConfiguration.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/io/NamingConfiguration.cs b/lang/cs/Org.Apache.REEF.Common/io/NamingConfiguration.cs deleted file mode 100644 index 9a73267..0000000 --- a/lang/cs/Org.Apache.REEF.Common/io/NamingConfiguration.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 System.Diagnostics.CodeAnalysis; -using Org.Apache.REEF.Tang.Formats; -using Org.Apache.REEF.Tang.Util; - -namespace Org.Apache.REEF.Common.io -{ - public class NamingConfiguration : ConfigurationModuleBuilder - { - [SuppressMessage("Microsoft.Security", "CA2104:Do not declare read only mutable reference types", Justification = "not applicable")] - public static readonly RequiredParameter<string> NameServerAddress = new RequiredParameter<string>(); - - [SuppressMessage("Microsoft.Security", "CA2104:Do not declare read only mutable reference types", Justification = "not applicable")] - public static readonly RequiredParameter<int> NameServerPort = new RequiredParameter<int>(); - - public static ConfigurationModule ConfigurationModule - { - get - { - return new NamingConfiguration() - .BindNamedParameter(GenericType<NamingConfigurationOptions.NameServerAddress>.Class, NameServerAddress) - .BindNamedParameter(GenericType<NamingConfigurationOptions.NameServerPort>.Class, NameServerPort) - .Build(); - } - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/io/NamingConfigurationOptions.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/io/NamingConfigurationOptions.cs b/lang/cs/Org.Apache.REEF.Common/io/NamingConfigurationOptions.cs deleted file mode 100644 index e1096cd..0000000 --- a/lang/cs/Org.Apache.REEF.Common/io/NamingConfigurationOptions.cs +++ /dev/null @@ -1,36 +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; - -namespace Org.Apache.REEF.Common.io -{ - public class NamingConfigurationOptions - { - [NamedParameter("IP address of NameServer")] - public class NameServerAddress : Name<string> - { - } - - [NamedParameter("Port of NameServer")] - public class NameServerPort : Name<int> - { - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ClientRuntime.pb.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ClientRuntime.pb.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ClientRuntime.pb.cs deleted file mode 100644 index 970dcc3..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ClientRuntime.pb.cs +++ /dev/null @@ -1,147 +0,0 @@ -//------------------------------------------------------------------------------ -// <auto-generated> -// This code was generated by a tool. -// -// Changes to this file may cause incorrect behavior and will be lost if -// the code is regenerated. -// </auto-generated> -//------------------------------------------------------------------------------ - -// Generated from: client_runtime.proto -// Note: requires additional types generated from: reef_service_protos.proto - -using Org.Apache.REEF.Common.ProtoBuf.ReefServiceProto; - -namespace Org.Apache.REEF.Common.ProtoBuf.ClienRuntimeProto{ - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"JobSubmissionProto")] - public partial class JobSubmissionProto : global::ProtoBuf.IExtensible - { - public JobSubmissionProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private string _remote_id; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"remote_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string remote_id - { - get { return _remote_id; } - set { _remote_id = value; } - } - private string _configuration; - [global::ProtoBuf.ProtoMember(5, IsRequired = true, Name=@"configuration", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string configuration - { - get { return _configuration; } - set { _configuration = value; } - } - private string _user_name; - [global::ProtoBuf.ProtoMember(6, IsRequired = true, Name=@"user_name", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string user_name - { - get { return _user_name; } - set { _user_name = value; } - } - private SIZE _driver_size = SIZE.SMALL; - [global::ProtoBuf.ProtoMember(7, IsRequired = false, Name=@"driver_size", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(SIZE.SMALL)] - public SIZE driver_size - { - get { return _driver_size; } - set { _driver_size = value; } - } - private int _driver_memory = default(int); - [global::ProtoBuf.ProtoMember(8, IsRequired = false, Name=@"driver_memory", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int driver_memory - { - get { return _driver_memory; } - set { _driver_memory = value; } - } - private int _priority = default(int); - [global::ProtoBuf.ProtoMember(9, IsRequired = false, Name=@"priority", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int priority - { - get { return _priority; } - set { _priority = value; } - } - private string _queue = ""; - [global::ProtoBuf.ProtoMember(10, IsRequired = false, Name=@"queue", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue("")] - public string queue - { - get { return _queue; } - set { _queue = value; } - } - private readonly global::System.Collections.Generic.List<FileResourceProto> _global_file = new global::System.Collections.Generic.List<FileResourceProto>(); - [global::ProtoBuf.ProtoMember(11, Name=@"global_file", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<FileResourceProto> global_file - { - get { return _global_file; } - } - - private readonly global::System.Collections.Generic.List<FileResourceProto> _local_File = new global::System.Collections.Generic.List<FileResourceProto>(); - [global::ProtoBuf.ProtoMember(12, Name=@"local_File", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<FileResourceProto> local_File - { - get { return _local_File; } - } - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"JobControlProto")] - public partial class JobControlProto : global::ProtoBuf.IExtensible - { - public JobControlProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private Signal _signal = Signal.SIG_TERMINATE; - [global::ProtoBuf.ProtoMember(2, IsRequired = false, Name=@"signal", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(Signal.SIG_TERMINATE)] - public Signal signal - { - get { return _signal; } - set { _signal = value; } - } - private byte[] _message = null; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"message", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] message - { - get { return _message; } - set { _message = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::ProtoBuf.ProtoContract(Name=@"Signal")] - public enum Signal - { - - [global::ProtoBuf.ProtoEnum(Name=@"SIG_TERMINATE", Value=1)] - SIG_TERMINATE = 1, - - [global::ProtoBuf.ProtoEnum(Name=@"SIG_SUSPEND", Value=2)] - SIG_SUSPEND = 2, - - [global::ProtoBuf.ProtoEnum(Name=@"SIG_RESUME", Value=3)] - SIG_RESUME = 3 - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/DriverRuntime.pb.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/DriverRuntime.pb.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/DriverRuntime.pb.cs deleted file mode 100644 index 6a12cf1..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/DriverRuntime.pb.cs +++ /dev/null @@ -1,339 +0,0 @@ -//------------------------------------------------------------------------------ -// <auto-generated> -// This code was generated by a tool. -// -// Changes to this file may cause incorrect behavior and will be lost if -// the code is regenerated. -// </auto-generated> -//------------------------------------------------------------------------------ - -// Generated from: driver_runtime.proto -// Note: requires additional types generated from: reef_service_protos.proto - -using Org.Apache.REEF.Common.ProtoBuf.ReefServiceProto; - -namespace Org.Apache.REEF.Common.ProtoBuf.DriverRuntimeProto -{ - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"DriverProcessRegistrationProto")] - public partial class DriverProcessRegistrationProto : global::ProtoBuf.IExtensible - { - public DriverProcessRegistrationProto() {} - - private string _remote_identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"remote_identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string remote_identifier - { - get { return _remote_identifier; } - set { _remote_identifier = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"NodeDescriptorProto")] - public partial class NodeDescriptorProto : global::ProtoBuf.IExtensible - { - public NodeDescriptorProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private string _host_name; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"host_name", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string host_name - { - get { return _host_name; } - set { _host_name = value; } - } - private int _port; - [global::ProtoBuf.ProtoMember(3, IsRequired = true, Name=@"port", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public int port - { - get { return _port; } - set { _port = value; } - } - private int _memory_size; - [global::ProtoBuf.ProtoMember(4, IsRequired = true, Name=@"memory_size", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public int memory_size - { - get { return _memory_size; } - set { _memory_size = value; } - } - private string _rack_name = ""; - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name=@"rack_name", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue("")] - public string rack_name - { - get { return _rack_name; } - set { _rack_name = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ResourceAllocationProto")] - public partial class ResourceAllocationProto : global::ProtoBuf.IExtensible - { - public ResourceAllocationProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private int _resource_memory; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"resource_memory", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public int resource_memory - { - get { return _resource_memory; } - set { _resource_memory = value; } - } - private string _node_id; - [global::ProtoBuf.ProtoMember(3, IsRequired = true, Name=@"node_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string node_id - { - get { return _node_id; } - set { _node_id = value; } - } - private int _virtual_cores = default(int); - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"virtual_cores", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int virtual_cores - { - get { return _virtual_cores; } - set { _virtual_cores = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ResourceStatusProto")] - public partial class ResourceStatusProto : global::ProtoBuf.IExtensible - { - public ResourceStatusProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private State _state; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"state", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public State state - { - get { return _state; } - set { _state = value; } - } - private string _diagnostics = ""; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"diagnostics", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue("")] - public string diagnostics - { - get { return _diagnostics; } - set { _diagnostics = value; } - } - private int _exit_code = default(int); - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"exit_code", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int exit_code - { - get { return _exit_code; } - set { _exit_code = value; } - } - private bool _is_from_previous_driver = default(bool); - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name=@"is_from_previous_driver", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(default(bool))] - public bool is_from_previous_driver - { - get { return _is_from_previous_driver; } - set { _is_from_previous_driver = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"RuntimeStatusProto")] - public partial class RuntimeStatusProto : global::ProtoBuf.IExtensible - { - public RuntimeStatusProto() {} - - private string _name; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"name", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string name - { - get { return _name; } - set { _name = value; } - } - private State _state; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"state", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public State state - { - get { return _state; } - set { _state = value; } - } - private RuntimeErrorProto _error = null; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"error", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public RuntimeErrorProto error - { - get { return _error; } - set { _error = value; } - } - private int _outstanding_container_requests = default(int); - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name=@"outstanding_container_requests", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int outstanding_container_requests - { - get { return _outstanding_container_requests; } - set { _outstanding_container_requests = value; } - } - private readonly global::System.Collections.Generic.List<string> _container_allocation = new global::System.Collections.Generic.List<string>(); - [global::ProtoBuf.ProtoMember(6, Name=@"container_allocation", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<string> container_allocation - { - get { return _container_allocation; } - } - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ResourceRequestProto")] - public partial class ResourceRequestProto : global::ProtoBuf.IExtensible - { - public ResourceRequestProto() {} - - private int _memory_size = default(int); - [global::ProtoBuf.ProtoMember(2, IsRequired = false, Name=@"memory_size", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int memory_size - { - get { return _memory_size; } - set { _memory_size = value; } - } - private int _priority = default(int); - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"priority", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int priority - { - get { return _priority; } - set { _priority = value; } - } - private int _virtual_cores = default(int); - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"virtual_cores", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - [global::System.ComponentModel.DefaultValue(default(int))] - public int virtual_cores - { - get { return _virtual_cores; } - set { _virtual_cores = value; } - } - private int _resource_count; - [global::ProtoBuf.ProtoMember(5, IsRequired = true, Name=@"resource_count", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public int resource_count - { - get { return _resource_count; } - set { _resource_count = value; } - } - private readonly global::System.Collections.Generic.List<string> _node_name = new global::System.Collections.Generic.List<string>(); - [global::ProtoBuf.ProtoMember(6, Name=@"node_name", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<string> node_name - { - get { return _node_name; } - } - - private readonly global::System.Collections.Generic.List<string> _rack_name = new global::System.Collections.Generic.List<string>(); - [global::ProtoBuf.ProtoMember(7, Name=@"rack_name", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<string> rack_name - { - get { return _rack_name; } - } - - private bool _relax_locality = default(bool); - [global::ProtoBuf.ProtoMember(10, IsRequired = false, Name=@"relax_locality", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(default(bool))] - public bool relax_locality - { - get { return _relax_locality; } - set { _relax_locality = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ResourceReleaseProto")] - public partial class ResourceReleaseProto : global::ProtoBuf.IExtensible - { - public ResourceReleaseProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ResourceLaunchProto")] - public partial class ResourceLaunchProto : global::ProtoBuf.IExtensible - { - public ResourceLaunchProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private string _remote_id; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"remote_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string remote_id - { - get { return _remote_id; } - set { _remote_id = value; } - } - private string _evaluator_conf; - [global::ProtoBuf.ProtoMember(3, IsRequired = true, Name=@"evaluator_conf", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string evaluator_conf - { - get { return _evaluator_conf; } - set { _evaluator_conf = value; } - } - private ProcessType _type; - [global::ProtoBuf.ProtoMember(4, IsRequired = true, Name=@"type", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public ProcessType type - { - get { return _type; } - set { _type = value; } - } - private readonly global::System.Collections.Generic.List<FileResourceProto> _file = new global::System.Collections.Generic.List<FileResourceProto>(); - [global::ProtoBuf.ProtoMember(10, Name=@"file", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<FileResourceProto> file - { - get { return _file; } - } - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/EvaluatorRunTime.pb.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/EvaluatorRunTime.pb.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/EvaluatorRunTime.pb.cs deleted file mode 100644 index 2e7ae9d..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/EvaluatorRunTime.pb.cs +++ /dev/null @@ -1,305 +0,0 @@ -//------------------------------------------------------------------------------ -// <auto-generated> -// This code was generated by a tool. -// -// Changes to this file may cause incorrect behavior and will be lost if -// the code is regenerated. -// </auto-generated> -//------------------------------------------------------------------------------ - -using Org.Apache.REEF.Common.ProtoBuf.ReefServiceProto; -// Generated from: evaluator_runtime.proto -// Note: requires additional types generated from: reef_service_protos.proto -namespace Org.Apache.REEF.Common.ProtoBuf.EvaluatorRunTimeProto -{ - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"StopEvaluatorProto")] - public partial class StopEvaluatorProto : global::ProtoBuf.IExtensible - { - public StopEvaluatorProto() {} - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"KillEvaluatorProto")] - public partial class KillEvaluatorProto : global::ProtoBuf.IExtensible - { - public KillEvaluatorProto() {} - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"StartTaskProto")] - public partial class StartTaskProto : global::ProtoBuf.IExtensible - { - public StartTaskProto() {} - - private string _context_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"context_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string context_id - { - get { return _context_id; } - set { _context_id = value; } - } - private string _configuration; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"configuration", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string configuration - { - get { return _configuration; } - set { _configuration = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"AddContextProto")] - public partial class AddContextProto : global::ProtoBuf.IExtensible - { - public AddContextProto() {} - - private string _parent_context_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"parent_context_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string parent_context_id - { - get { return _parent_context_id; } - set { _parent_context_id = value; } - } - private string _context_configuration; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"context_configuration", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string context_configuration - { - get { return _context_configuration; } - set { _context_configuration = value; } - } - private string _service_configuration = ""; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"service_configuration", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue("")] - public string service_configuration - { - get { return _service_configuration; } - set { _service_configuration = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"RemoveContextProto")] - public partial class RemoveContextProto : global::ProtoBuf.IExtensible - { - public RemoveContextProto() {} - - private string _context_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"context_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string context_id - { - get { return _context_id; } - set { _context_id = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"StopTaskProto")] - public partial class StopTaskProto : global::ProtoBuf.IExtensible - { - public StopTaskProto() {} - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"SuspendTaskProto")] - public partial class SuspendTaskProto : global::ProtoBuf.IExtensible - { - public SuspendTaskProto() {} - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ContextMessageProto")] - public partial class ContextMessageProto : global::ProtoBuf.IExtensible - { - public ContextMessageProto() {} - - private string _context_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"context_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string context_id - { - get { return _context_id; } - set { _context_id = value; } - } - private byte[] _message; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"message", DataFormat = global::ProtoBuf.DataFormat.Default)] - public byte[] message - { - get { return _message; } - set { _message = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ContextControlProto")] - public partial class ContextControlProto : global::ProtoBuf.IExtensible - { - public ContextControlProto() {} - - private byte[] _task_message = null; - [global::ProtoBuf.ProtoMember(1, IsRequired = false, Name=@"task_message", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] task_message - { - get { return _task_message; } - set { _task_message = value; } - } - private ContextMessageProto _context_message = null; - [global::ProtoBuf.ProtoMember(2, IsRequired = false, Name=@"context_message", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public ContextMessageProto context_message - { - get { return _context_message; } - set { _context_message = value; } - } - private AddContextProto _add_context = null; - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name=@"add_context", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public AddContextProto add_context - { - get { return _add_context; } - set { _add_context = value; } - } - private RemoveContextProto _remove_context = null; - [global::ProtoBuf.ProtoMember(6, IsRequired = false, Name=@"remove_context", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public RemoveContextProto remove_context - { - get { return _remove_context; } - set { _remove_context = value; } - } - private StartTaskProto _start_task = null; - [global::ProtoBuf.ProtoMember(7, IsRequired = false, Name=@"start_task", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public StartTaskProto start_task - { - get { return _start_task; } - set { _start_task = value; } - } - private StopTaskProto _stop_task = null; - [global::ProtoBuf.ProtoMember(8, IsRequired = false, Name=@"stop_task", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public StopTaskProto stop_task - { - get { return _stop_task; } - set { _stop_task = value; } - } - private SuspendTaskProto _suspend_task = null; - [global::ProtoBuf.ProtoMember(9, IsRequired = false, Name=@"suspend_task", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public SuspendTaskProto suspend_task - { - get { return _suspend_task; } - set { _suspend_task = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"EvaluatorHeartbeatProto")] - public partial class EvaluatorHeartbeatProto : global::ProtoBuf.IExtensible - { - public EvaluatorHeartbeatProto() {} - - private long _timestamp; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"timestamp", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public long timestamp - { - get { return _timestamp; } - set { _timestamp = value; } - } - private EvaluatorStatusProto _evaluator_status; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"evaluator_status", DataFormat = global::ProtoBuf.DataFormat.Default)] - public EvaluatorStatusProto evaluator_status - { - get { return _evaluator_status; } - set { _evaluator_status = value; } - } - private readonly global::System.Collections.Generic.List<ContextStatusProto> _context_status = new global::System.Collections.Generic.List<ContextStatusProto>(); - [global::ProtoBuf.ProtoMember(3, Name=@"context_status", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<ContextStatusProto> context_status - { - get { return _context_status; } - } - - private TaskStatusProto _task_status = null; - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"task_status", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public TaskStatusProto task_status - { - get { return _task_status; } - set { _task_status = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - - private bool _recovery; - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name = @"recovery", DataFormat = global::ProtoBuf.DataFormat.Default)] - public bool recovery - { - get { return _recovery; } - set { _recovery = value; } - } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"EvaluatorControlProto")] - public partial class EvaluatorControlProto : global::ProtoBuf.IExtensible - { - public EvaluatorControlProto() {} - - private long _timestamp; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"timestamp", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public long timestamp - { - get { return _timestamp; } - set { _timestamp = value; } - } - private string _identifier; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private ContextControlProto _context_control = null; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"context_control", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public ContextControlProto context_control - { - get { return _context_control; } - set { _context_control = value; } - } - private KillEvaluatorProto _kill_evaluator = null; - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"kill_evaluator", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public KillEvaluatorProto kill_evaluator - { - get { return _kill_evaluator; } - set { _kill_evaluator = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefProtocol.pb.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefProtocol.pb.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefProtocol.pb.cs deleted file mode 100644 index 1ade6de..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefProtocol.pb.cs +++ /dev/null @@ -1,78 +0,0 @@ -//------------------------------------------------------------------------------ -// <auto-generated> -// This code was generated by a tool. -// -// Changes to this file may cause incorrect behavior and will be lost if -// the code is regenerated. -// </auto-generated> -//------------------------------------------------------------------------------ - -// Generated from: reef_protocol.proto -// Note: requires additional types generated from: client_runtime.proto -// Note: requires additional types generated from: evaluator_runtime.proto -// Note: requires additional types generated from: reef_service_protos.proto -using Org.Apache.REEF.Common.ProtoBuf.ClienRuntimeProto; -using Org.Apache.REEF.Common.ProtoBuf.EvaluatorRunTimeProto; -using Org.Apache.REEF.Common.ProtoBuf.ReefServiceProto; - -namespace Org.Apache.REEF.Common.ProtoBuf.ReefProtocol -{ - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"REEFMessage")] - public partial class REEFMessage : global::ProtoBuf.IExtensible - { - public REEFMessage() {} - - private JobSubmissionProto _jobSubmission = null; - [global::ProtoBuf.ProtoMember(1, IsRequired = false, Name=@"jobSubmission", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public JobSubmissionProto jobSubmission - { - get { return _jobSubmission; } - set { _jobSubmission = value; } - } - private JobControlProto _jobControl = null; - [global::ProtoBuf.ProtoMember(2, IsRequired = false, Name=@"jobControl", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public JobControlProto jobControl - { - get { return _jobControl; } - set { _jobControl = value; } - } - private RuntimeErrorProto _runtimeError = null; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"runtimeError", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public RuntimeErrorProto runtimeError - { - get { return _runtimeError; } - set { _runtimeError = value; } - } - private JobStatusProto _jobStatus = null; - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"jobStatus", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public JobStatusProto jobStatus - { - get { return _jobStatus; } - set { _jobStatus = value; } - } - private EvaluatorControlProto _evaluatorControl = null; - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name=@"evaluatorControl", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public EvaluatorControlProto evaluatorControl - { - get { return _evaluatorControl; } - set { _evaluatorControl = value; } - } - private EvaluatorHeartbeatProto _evaluatorHeartBeat = null; - [global::ProtoBuf.ProtoMember(6, IsRequired = false, Name=@"evaluatorHeartBeat", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public EvaluatorHeartbeatProto evaluatorHeartBeat - { - get { return _evaluatorHeartBeat; } - set { _evaluatorHeartBeat = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefService.pb.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefService.pb.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefService.pb.cs deleted file mode 100644 index 383467e..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/ReefService.pb.cs +++ /dev/null @@ -1,393 +0,0 @@ -//------------------------------------------------------------------------------ -// <auto-generated> -// This code was generated by a tool. -// -// Changes to this file may cause incorrect behavior and will be lost if -// the code is regenerated. -// </auto-generated> -//------------------------------------------------------------------------------ - -// Generated from: reef_service_protos.proto -namespace Org.Apache.REEF.Common.ProtoBuf.ReefServiceProto - -{ - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"FileResourceProto")] - public partial class FileResourceProto : global::ProtoBuf.IExtensible - { - public FileResourceProto() {} - - private FileType _type; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"type", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public FileType type - { - get { return _type; } - set { _type = value; } - } - private string _name; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"name", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string name - { - get { return _name; } - set { _name = value; } - } - private string _path; - [global::ProtoBuf.ProtoMember(3, IsRequired = true, Name=@"path", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string path - { - get { return _path; } - set { _path = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"RuntimeErrorProto")] - public partial class RuntimeErrorProto : global::ProtoBuf.IExtensible - { - public RuntimeErrorProto() {} - - private string _name; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"name", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string name - { - get { return _name; } - set { _name = value; } - } - private string _message; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"message", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string message - { - get { return _message; } - set { _message = value; } - } - private byte[] _exception = null; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"exception", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] exception - { - get { return _exception; } - set { _exception = value; } - } - private string _identifier = ""; - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue("")] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"JobStatusProto")] - public partial class JobStatusProto : global::ProtoBuf.IExtensible - { - public JobStatusProto() {} - - private string _identifier; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string identifier - { - get { return _identifier; } - set { _identifier = value; } - } - private State _state; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"state", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public State state - { - get { return _state; } - set { _state = value; } - } - private byte[] _message = null; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"message", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] message - { - get { return _message; } - set { _message = value; } - } - private byte[] _exception = null; - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"exception", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] exception - { - get { return _exception; } - set { _exception = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ContextStatusProto")] - public partial class ContextStatusProto : global::ProtoBuf.IExtensible - { - public ContextStatusProto() {} - - private ContextStatusProto.State _context_state; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"context_state", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public ContextStatusProto.State context_state - { - get { return _context_state; } - set { _context_state = value; } - } - private string _context_id; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"context_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string context_id - { - get { return _context_id; } - set { _context_id = value; } - } - private string _parent_id = ""; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"parent_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue("")] - public string parent_id - { - get { return _parent_id; } - set { _parent_id = value; } - } - private byte[] _error = null; - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name=@"error", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] error - { - get { return _error; } - set { _error = value; } - } - private bool _recovery = false; - [global::ProtoBuf.ProtoMember(6, IsRequired = false, Name = @"recovery", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(false)] - public bool recovery - { - get { return _recovery; } - set { _recovery = value; } - } - private readonly global::System.Collections.Generic.List<ContextStatusProto.ContextMessageProto> _context_message = new global::System.Collections.Generic.List<ContextStatusProto.ContextMessageProto>(); - [global::ProtoBuf.ProtoMember(7, Name=@"context_message", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<ContextStatusProto.ContextMessageProto> context_message - { - get { return _context_message; } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"ContextMessageProto")] - public partial class ContextMessageProto : global::ProtoBuf.IExtensible - { - public ContextMessageProto() {} - - private string _source_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"source_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string source_id - { - get { return _source_id; } - set { _source_id = value; } - } - private byte[] _message; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"message", DataFormat = global::ProtoBuf.DataFormat.Default)] - public byte[] message - { - get { return _message; } - set { _message = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::ProtoBuf.ProtoContract(Name=@"State")] - public enum State - { - - [global::ProtoBuf.ProtoEnum(Name=@"READY", Value=0)] - READY = 0, - - [global::ProtoBuf.ProtoEnum(Name=@"DONE", Value=1)] - DONE = 1, - - [global::ProtoBuf.ProtoEnum(Name=@"FAIL", Value=2)] - FAIL = 2 - } - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"TaskStatusProto")] - public partial class TaskStatusProto : global::ProtoBuf.IExtensible - { - public TaskStatusProto() {} - - private string _task_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"task_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string task_id - { - get { return _task_id; } - set { _task_id = value; } - } - private string _context_id; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"context_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string context_id - { - get { return _context_id; } - set { _context_id = value; } - } - private State _state; - [global::ProtoBuf.ProtoMember(3, IsRequired = true, Name=@"state", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public State state - { - get { return _state; } - set { _state = value; } - } - private byte[] _result = null; - [global::ProtoBuf.ProtoMember(4, IsRequired = false, Name=@"result", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] result - { - get { return _result; } - set { _result = value; } - } - private bool _recovery = false; - [global::ProtoBuf.ProtoMember(5, IsRequired = false, Name = @"recovery", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(false)] - public bool recovery - { - get { return _recovery; } - set { _recovery = value; } - } - private readonly global::System.Collections.Generic.List<TaskStatusProto.TaskMessageProto> _task_message = new global::System.Collections.Generic.List<TaskStatusProto.TaskMessageProto>(); - [global::ProtoBuf.ProtoMember(6, Name=@"task_message", DataFormat = global::ProtoBuf.DataFormat.Default)] - public global::System.Collections.Generic.List<TaskStatusProto.TaskMessageProto> task_message - { - get { return _task_message; } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"TaskMessageProto")] - public partial class TaskMessageProto : global::ProtoBuf.IExtensible - { - public TaskMessageProto() {} - - private string _source_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"source_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string source_id - { - get { return _source_id; } - set { _source_id = value; } - } - private byte[] _message; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"message", DataFormat = global::ProtoBuf.DataFormat.Default)] - public byte[] message - { - get { return _message; } - set { _message = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"EvaluatorStatusProto")] - public partial class EvaluatorStatusProto : global::ProtoBuf.IExtensible - { - public EvaluatorStatusProto() {} - - private string _evaluator_id; - [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"evaluator_id", DataFormat = global::ProtoBuf.DataFormat.Default)] - public string evaluator_id - { - get { return _evaluator_id; } - set { _evaluator_id = value; } - } - private State _state; - [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"state", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)] - public State state - { - get { return _state; } - set { _state = value; } - } - private byte[] _error = null; - [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"error", DataFormat = global::ProtoBuf.DataFormat.Default)] - [global::System.ComponentModel.DefaultValue(null)] - public byte[] error - { - get { return _error; } - set { _error = value; } - } - private global::ProtoBuf.IExtension extensionObject; - global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing) - { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); } - } - - [global::ProtoBuf.ProtoContract(Name=@"State")] - public enum State - { - - [global::ProtoBuf.ProtoEnum(Name=@"INIT", Value=0)] - INIT = 0, - - [global::ProtoBuf.ProtoEnum(Name=@"RUNNING", Value=1)] - RUNNING = 1, - - [global::ProtoBuf.ProtoEnum(Name=@"DONE", Value=2)] - DONE = 2, - - [global::ProtoBuf.ProtoEnum(Name=@"SUSPEND", Value=3)] - SUSPEND = 3, - - [global::ProtoBuf.ProtoEnum(Name=@"FAILED", Value=4)] - FAILED = 4, - - [global::ProtoBuf.ProtoEnum(Name=@"KILLED", Value=5)] - KILLED = 5 - } - - [global::ProtoBuf.ProtoContract(Name=@"FileType")] - public enum FileType - { - - [global::ProtoBuf.ProtoEnum(Name=@"PLAIN", Value=0)] - PLAIN = 0, - - [global::ProtoBuf.ProtoEnum(Name=@"LIB", Value=1)] - LIB = 1, - - [global::ProtoBuf.ProtoEnum(Name=@"ARCHIVE", Value=2)] - ARCHIVE = 2 - } - - [global::ProtoBuf.ProtoContract(Name=@"SIZE")] - public enum SIZE - { - - [global::ProtoBuf.ProtoEnum(Name=@"SMALL", Value=0)] - SMALL = 0, - - [global::ProtoBuf.ProtoEnum(Name=@"MEDIUM", Value=1)] - MEDIUM = 1, - - [global::ProtoBuf.ProtoEnum(Name=@"LARGE", Value=2)] - LARGE = 2, - - [global::ProtoBuf.ProtoEnum(Name=@"XLARGE", Value=3)] - XLARGE = 3 - } - - [global::ProtoBuf.ProtoContract(Name=@"ProcessType")] - public enum ProcessType - { - - [global::ProtoBuf.ProtoEnum(Name=@"JVM", Value=0)] - JVM = 0, - - [global::ProtoBuf.ProtoEnum(Name=@"CLR", Value=1)] - CLR = 1 - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/Serializer.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/Serializer.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/Serializer.cs deleted file mode 100644 index 6bd90e8..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/Serializer.cs +++ /dev/null @@ -1,130 +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.Common.ProtoBuf.ReefServiceProto; -using Org.Apache.REEF.Utilities; - -using ProtoBuf; -using System; -using System.Diagnostics.CodeAnalysis; -using System.Globalization; -using System.IO; -using System.Text; - -[module: SuppressMessage("StyleCop.CSharp.MaintainabilityRules", "SA1403:FileMayOnlyContainASingleNamespace", Justification = "Serializers for all protobuf types")] -[module: SuppressMessage("StyleCop.CSharp.MaintainabilityRules", "SA1402:FileMayOnlyContainASingleClass", Justification = "Serializers for all protobuf types")] - -namespace Org.Apache.REEF.Common.ProtoBuf.ReefProtocol -{ - /// <summary> - /// Add serializer/deserializer to REEFMessage - /// </summary> - public partial class REEFMessage - { - public REEFMessage(EvaluatorHeartbeatProto evaluatorHeartbeatProto) - { - _evaluatorHeartBeat = evaluatorHeartbeatProto; - } - - public static REEFMessage Deserialize(byte[] bytes) - { - REEFMessage pbuf = null; - using (var s = new MemoryStream(bytes)) - { - pbuf = Serializer.Deserialize<REEFMessage>(s); - } - return pbuf; - } - - public byte[] Serialize() - { - byte[] b = null; - using (var s = new MemoryStream()) - { - Serializer.Serialize<REEFMessage>(s, this); - b = new byte[s.Position]; - var fullBuffer = s.GetBuffer(); - Array.Copy(fullBuffer, b, b.Length); - } - return b; - } - } -} - -namespace Org.Apache.REEF.Common.ProtoBuf.EvaluatorRunTimeProto -{ - /// <summary> - /// Add serializer/deserializer to EvaluatorHeartbeatProto - /// </summary> - public partial class EvaluatorHeartbeatProto - { - public static EvaluatorHeartbeatProto Deserialize(byte[] bytes) - { - EvaluatorHeartbeatProto pbuf = null; - using (var s = new MemoryStream(bytes)) - { - pbuf = Serializer.Deserialize<EvaluatorHeartbeatProto>(s); - } - return pbuf; - } - - public byte[] Serialize() - { - byte[] b = null; - using (var s = new MemoryStream()) - { - Serializer.Serialize<EvaluatorHeartbeatProto>(s, this); - b = new byte[s.Position]; - var fullBuffer = s.GetBuffer(); - Array.Copy(fullBuffer, b, b.Length); - } - return b; - } - - public override string ToString() - { - string contextStatus = string.Empty; - string taskStatusMessage = string.Empty; - foreach (ContextStatusProto contextStatusProto in context_status) - { - contextStatus += string.Format(CultureInfo.InvariantCulture, "evaluator {0} has context {1} in state {2} with recovery flag {3}", - evaluator_status.evaluator_id, - contextStatusProto.context_id, - contextStatusProto.context_state, - contextStatusProto.recovery); - } - if (task_status != null && task_status.task_message != null && task_status.task_message.Count > 0) - { - foreach (TaskStatusProto.TaskMessageProto taskMessageProto in task_status.task_message) - { - taskStatusMessage += ByteUtilities.ByteArrarysToString(taskMessageProto.message); - } - } - return string.Format(CultureInfo.InvariantCulture, "EvaluatorHeartbeatProto: task_id=[{0}], task_status=[{1}], task_message=[{2}], evaluator_status=[{3}], context_status=[{4}], timestamp=[{5}], recoveryFlag =[{6}]", - task_status == null ? string.Empty : task_status.task_id, - task_status == null ? string.Empty : task_status.state.ToString(), - taskStatusMessage, - evaluator_status.state.ToString(), - contextStatus, - timestamp, - recovery); - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/EvaluatorHeartbeatProtoCodec.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/EvaluatorHeartbeatProtoCodec.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/EvaluatorHeartbeatProtoCodec.cs deleted file mode 100644 index 0f997a4..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/EvaluatorHeartbeatProtoCodec.cs +++ /dev/null @@ -1,41 +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.Wake.Remote; - -namespace Org.Apache.REEF.Common.ProtoBuf.ReefProtocol -{ - public class EvaluatorHeartbeatProtoCodec : ICodec<EvaluatorHeartbeatProto> - { - public byte[] Encode(EvaluatorHeartbeatProto obj) - { - EvaluatorHeartbeatProto pbuf = new EvaluatorHeartbeatProto(); - - pbuf.evaluator_status = obj.evaluator_status; - return pbuf.Serialize(); - } - - public EvaluatorHeartbeatProto Decode(byte[] data) - { - EvaluatorHeartbeatProto pbuf = EvaluatorHeartbeatProto.Deserialize(data); - return pbuf; - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/REEFMessageCodec.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/REEFMessageCodec.cs b/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/REEFMessageCodec.cs deleted file mode 100644 index 41109e3..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/cs/codec/REEFMessageCodec.cs +++ /dev/null @@ -1,37 +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.Wake.Remote; - -namespace Org.Apache.REEF.Common.ProtoBuf.ReefProtocol -{ - public class REEFMessageCodec : ICodec<REEFMessage> - { - public byte[] Encode(REEFMessage obj) - { - return obj.Serialize(); - } - - public REEFMessage Decode(byte[] data) - { - REEFMessage pbuf = REEFMessage.Deserialize(data); - return pbuf; - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/proto/client_runtime.proto ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/proto/client_runtime.proto b/lang/cs/Org.Apache.REEF.Common/protobuf/proto/client_runtime.proto deleted file mode 100644 index 3d1f927..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/proto/client_runtime.proto +++ /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. - */ -option java_package = "org.apache.reef.proto"; -option java_outer_classname = "ClientRuntimeProtocol"; -option java_generic_services = true; -option java_generate_equals_and_hash = true; - -import "reef_service_protos.proto"; - -// Messages from REEF Client -> Driver Runtime - -message JobSubmissionProto { - required string identifier = 1; // the job identifier - required string remote_id = 2; // the remote identifier - required string configuration = 5; // the runtime configuration - required string user_name = 6; // the user name - - optional SIZE driver_size = 7; - optional int32 driver_memory = 8; - optional int32 priority = 9; - optional string queue = 10; - - repeated FileResourceProto global_file = 11; // files that should be placed on the driver and all subsequent evaluators - repeated FileResourceProto local_File = 12; // files that should be placed on the driver only - -} - -enum Signal { - SIG_TERMINATE = 1; - SIG_SUSPEND = 2; - SIG_RESUME = 3; -} - -message JobControlProto { - required string identifier = 1; - optional Signal signal = 2; - optional bytes message = 3; -} - - http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/7edb8570/lang/cs/Org.Apache.REEF.Common/protobuf/proto/driver_runtime.proto ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.Common/protobuf/proto/driver_runtime.proto b/lang/cs/Org.Apache.REEF.Common/protobuf/proto/driver_runtime.proto deleted file mode 100644 index 2b21ac7..0000000 --- a/lang/cs/Org.Apache.REEF.Common/protobuf/proto/driver_runtime.proto +++ /dev/null @@ -1,90 +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. - */ -option java_package = "org.apache.reef.proto"; -option java_outer_classname = "DriverRuntimeProtocol"; -option java_generic_services = true; -option java_generate_equals_and_hash = true; - - -import "reef_service_protos.proto"; - -// Messages from Driver Runtime -> Driver Process - -message DriverProcessRegistrationProto { - required string remote_identifier = 1; -} - - -message NodeDescriptorProto { - required string identifier = 1; - required string host_name = 2; // e.g., IP address - required int32 port = 3; // e.g., IP port - required int32 memory_size = 4; - optional string rack_name = 5; // e.g., /default-rack -} - -message ResourceAllocationProto { - required string identifier = 1; // e.g., the container id, or the thread id - required int32 resource_memory = 2; // megabytes - required string node_id = 3; -} - -message ResourceStatusProto { - required string identifier = 1; - required State state = 2; - optional string diagnostics = 3; - optional int32 exit_code = 4; - optional bool is_from_previous_driver = 5; -} - -message RuntimeStatusProto { - required string name = 1; // e.g., local, yarn21 - required State state = 2; - optional RuntimeErrorProto error = 3; // runtime (e.g., YARN) error - - optional int32 outstanding_container_requests = 5; - repeated string container_allocation = 6; -} - -////////////////////////////////////////////////////// -// Messages from Driver Process -> Driver Runtime - -message ResourceRequestProto { - // optional SIZE resource_size = 1; // Removed in REEF 0.3 in favor of memory_size. - optional int32 memory_size = 2; // Memory size of the evaluator in MB - optional int32 priority = 3; - - required int32 resource_count = 5; - repeated string node_name = 6; // a list of specific nodes - repeated string rack_name = 7; // a list of specific racks - - optional bool relax_locality = 10; -} - -message ResourceReleaseProto { - required string identifier = 1; -} - -message ResourceLaunchProto { - required string identifier = 1; - required string remote_id = 2; - required string evaluator_conf = 3; - required ProcessType type = 4; - repeated FileResourceProto file = 10; -}
