singa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wan...@apache.org
Subject [07/10] incubator-singa git commit: SINGA-7 Implement shared memory Hogwild algorithm
Date Mon, 15 Jun 2015 06:42:35 GMT
SINGA-7 Implement shared memory Hogwild algorithm

fix bugs in param.cc


Project: http://git-wip-us.apache.org/repos/asf/incubator-singa/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-singa/commit/d5f9b9cd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-singa/tree/d5f9b9cd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-singa/diff/d5f9b9cd

Branch: refs/heads/master
Commit: d5f9b9cd0d1f028ead5155b2fdbd6e95c3026f33
Parents: 40a86ab
Author: wang sheng <wangsheng1001@gmail.com>
Authored: Mon Jun 15 14:19:53 2015 +0800
Committer: wang sheng <wangsheng1001@gmail.com>
Committed: Mon Jun 15 14:19:53 2015 +0800

----------------------------------------------------------------------
 src/proto/cluster.pb.h | 1139 ------
 src/proto/model.pb.h   | 8292 -------------------------------------------
 src/utils/param.cc     |   12 +-
 3 files changed, 5 insertions(+), 9438 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-singa/blob/d5f9b9cd/src/proto/cluster.pb.h
----------------------------------------------------------------------
diff --git a/src/proto/cluster.pb.h b/src/proto/cluster.pb.h
deleted file mode 100644
index 82ee8b2..0000000
--- a/src/proto/cluster.pb.h
+++ /dev/null
@@ -1,1139 +0,0 @@
-// Generated by the protocol buffer compiler.  DO NOT EDIT!
-// source: cluster.proto
-
-#ifndef PROTOBUF_cluster_2eproto__INCLUDED
-#define PROTOBUF_cluster_2eproto__INCLUDED
-
-#include <string>
-
-#include <google/protobuf/stubs/common.h>
-
-#if GOOGLE_PROTOBUF_VERSION < 2005000
-#error This file was generated by a newer version of protoc which is
-#error incompatible with your Protocol Buffer headers.  Please update
-#error your headers.
-#endif
-#if 2005000 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION
-#error This file was generated by an older version of protoc which is
-#error incompatible with your Protocol Buffer headers.  Please
-#error regenerate this file with a newer version of protoc.
-#endif
-
-#include <google/protobuf/generated_message_util.h>
-#include <google/protobuf/message.h>
-#include <google/protobuf/repeated_field.h>
-#include <google/protobuf/extension_set.h>
-#include <google/protobuf/unknown_field_set.h>
-// @@protoc_insertion_point(includes)
-
-namespace singa {
-
-// Internal implementation detail -- do not call these.
-void  protobuf_AddDesc_cluster_2eproto();
-void protobuf_AssignDesc_cluster_2eproto();
-void protobuf_ShutdownFile_cluster_2eproto();
-
-class ClusterProto;
-class ServerTopology;
-
-// ===================================================================
-
-class ClusterProto : public ::google::protobuf::Message {
- public:
-  ClusterProto();
-  virtual ~ClusterProto();
-
-  ClusterProto(const ClusterProto& from);
-
-  inline ClusterProto& operator=(const ClusterProto& from) {
-    CopyFrom(from);
-    return *this;
-  }
-
-  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
-    return _unknown_fields_;
-  }
-
-  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
-    return &_unknown_fields_;
-  }
-
-  static const ::google::protobuf::Descriptor* descriptor();
-  static const ClusterProto& default_instance();
-
-  void Swap(ClusterProto* other);
-
-  // implements Message ----------------------------------------------
-
-  ClusterProto* New() const;
-  void CopyFrom(const ::google::protobuf::Message& from);
-  void MergeFrom(const ::google::protobuf::Message& from);
-  void CopyFrom(const ClusterProto& from);
-  void MergeFrom(const ClusterProto& from);
-  void Clear();
-  bool IsInitialized() const;
-
-  int ByteSize() const;
-  bool MergePartialFromCodedStream(
-      ::google::protobuf::io::CodedInputStream* input);
-  void SerializeWithCachedSizes(
-      ::google::protobuf::io::CodedOutputStream* output) const;
-  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const;
-  int GetCachedSize() const { return _cached_size_; }
-  private:
-  void SharedCtor();
-  void SharedDtor();
-  void SetCachedSize(int size) const;
-  public:
-
-  ::google::protobuf::Metadata GetMetadata() const;
-
-  // nested types ----------------------------------------------------
-
-  // accessors -------------------------------------------------------
-
-  // optional int32 nworker_groups = 1;
-  inline bool has_nworker_groups() const;
-  inline void clear_nworker_groups();
-  static const int kNworkerGroupsFieldNumber = 1;
-  inline ::google::protobuf::int32 nworker_groups() const;
-  inline void set_nworker_groups(::google::protobuf::int32 value);
-
-  // optional int32 nserver_groups = 2;
-  inline bool has_nserver_groups() const;
-  inline void clear_nserver_groups();
-  static const int kNserverGroupsFieldNumber = 2;
-  inline ::google::protobuf::int32 nserver_groups() const;
-  inline void set_nserver_groups(::google::protobuf::int32 value);
-
-  // optional int32 nworkers_per_group = 3 [default = 1];
-  inline bool has_nworkers_per_group() const;
-  inline void clear_nworkers_per_group();
-  static const int kNworkersPerGroupFieldNumber = 3;
-  inline ::google::protobuf::int32 nworkers_per_group() const;
-  inline void set_nworkers_per_group(::google::protobuf::int32 value);
-
-  // optional int32 nservers_per_group = 4 [default = 1];
-  inline bool has_nservers_per_group() const;
-  inline void clear_nservers_per_group();
-  static const int kNserversPerGroupFieldNumber = 4;
-  inline ::google::protobuf::int32 nservers_per_group() const;
-  inline void set_nservers_per_group(::google::protobuf::int32 value);
-
-  // optional int32 nworkers_per_procs = 5 [default = 1];
-  inline bool has_nworkers_per_procs() const;
-  inline void clear_nworkers_per_procs();
-  static const int kNworkersPerProcsFieldNumber = 5;
-  inline ::google::protobuf::int32 nworkers_per_procs() const;
-  inline void set_nworkers_per_procs(::google::protobuf::int32 value);
-
-  // optional int32 nservers_per_procs = 6 [default = 1];
-  inline bool has_nservers_per_procs() const;
-  inline void clear_nservers_per_procs();
-  static const int kNserversPerProcsFieldNumber = 6;
-  inline ::google::protobuf::int32 nservers_per_procs() const;
-  inline void set_nservers_per_procs(::google::protobuf::int32 value);
-
-  // optional string hostfile = 10;
-  inline bool has_hostfile() const;
-  inline void clear_hostfile();
-  static const int kHostfileFieldNumber = 10;
-  inline const ::std::string& hostfile() const;
-  inline void set_hostfile(const ::std::string& value);
-  inline void set_hostfile(const char* value);
-  inline void set_hostfile(const char* value, size_t size);
-  inline ::std::string* mutable_hostfile();
-  inline ::std::string* release_hostfile();
-  inline void set_allocated_hostfile(::std::string* hostfile);
-
-  // optional bool server_worker_separate = 11 [default = false];
-  inline bool has_server_worker_separate() const;
-  inline void clear_server_worker_separate();
-  static const int kServerWorkerSeparateFieldNumber = 11;
-  inline bool server_worker_separate() const;
-  inline void set_server_worker_separate(bool value);
-
-  // optional int32 nprocs = 12;
-  inline bool has_nprocs() const;
-  inline void clear_nprocs();
-  static const int kNprocsFieldNumber = 12;
-  inline ::google::protobuf::int32 nprocs() const;
-  inline void set_nprocs(::google::protobuf::int32 value);
-
-  // optional int32 start_port = 13 [default = 6723];
-  inline bool has_start_port() const;
-  inline void clear_start_port();
-  static const int kStartPortFieldNumber = 13;
-  inline ::google::protobuf::int32 start_port() const;
-  inline void set_start_port(::google::protobuf::int32 value);
-
-  // required string workspace = 14;
-  inline bool has_workspace() const;
-  inline void clear_workspace();
-  static const int kWorkspaceFieldNumber = 14;
-  inline const ::std::string& workspace() const;
-  inline void set_workspace(const ::std::string& value);
-  inline void set_workspace(const char* value);
-  inline void set_workspace(const char* value, size_t size);
-  inline ::std::string* mutable_workspace();
-  inline ::std::string* release_workspace();
-  inline void set_allocated_workspace(::std::string* workspace);
-
-  // optional string log_dir = 15;
-  inline bool has_log_dir() const;
-  inline void clear_log_dir();
-  static const int kLogDirFieldNumber = 15;
-  inline const ::std::string& log_dir() const;
-  inline void set_log_dir(const ::std::string& value);
-  inline void set_log_dir(const char* value);
-  inline void set_log_dir(const char* value, size_t size);
-  inline ::std::string* mutable_log_dir();
-  inline ::std::string* release_log_dir();
-  inline void set_allocated_log_dir(::std::string* log_dir);
-
-  // optional string zookeeper_host = 16 [default = "localhost:2181"];
-  inline bool has_zookeeper_host() const;
-  inline void clear_zookeeper_host();
-  static const int kZookeeperHostFieldNumber = 16;
-  inline const ::std::string& zookeeper_host() const;
-  inline void set_zookeeper_host(const ::std::string& value);
-  inline void set_zookeeper_host(const char* value);
-  inline void set_zookeeper_host(const char* value, size_t size);
-  inline ::std::string* mutable_zookeeper_host();
-  inline ::std::string* release_zookeeper_host();
-  inline void set_allocated_zookeeper_host(::std::string* zookeeper_host);
-
-  // repeated .singa.ServerTopology server_group = 20;
-  inline int server_group_size() const;
-  inline void clear_server_group();
-  static const int kServerGroupFieldNumber = 20;
-  inline const ::singa::ServerTopology& server_group(int index) const;
-  inline ::singa::ServerTopology* mutable_server_group(int index);
-  inline ::singa::ServerTopology* add_server_group();
-  inline const ::google::protobuf::RepeatedPtrField< ::singa::ServerTopology >&
-      server_group() const;
-  inline ::google::protobuf::RepeatedPtrField< ::singa::ServerTopology >*
-      mutable_server_group();
-
-  // optional int32 stub_timeout = 30 [default = 5000];
-  inline bool has_stub_timeout() const;
-  inline void clear_stub_timeout();
-  static const int kStubTimeoutFieldNumber = 30;
-  inline ::google::protobuf::int32 stub_timeout() const;
-  inline void set_stub_timeout(::google::protobuf::int32 value);
-
-  // optional int32 worker_timeout = 31 [default = 5000];
-  inline bool has_worker_timeout() const;
-  inline void clear_worker_timeout();
-  static const int kWorkerTimeoutFieldNumber = 31;
-  inline ::google::protobuf::int32 worker_timeout() const;
-  inline void set_worker_timeout(::google::protobuf::int32 value);
-
-  // optional int32 server_timeout = 32 [default = 5000];
-  inline bool has_server_timeout() const;
-  inline void clear_server_timeout();
-  static const int kServerTimeoutFieldNumber = 32;
-  inline ::google::protobuf::int32 server_timeout() const;
-  inline void set_server_timeout(::google::protobuf::int32 value);
-
-  // optional bool server_update = 40 [default = true];
-  inline bool has_server_update() const;
-  inline void clear_server_update();
-  static const int kServerUpdateFieldNumber = 40;
-  inline bool server_update() const;
-  inline void set_server_update(bool value);
-
-  // optional bool share_memory = 41 [default = true];
-  inline bool has_share_memory() const;
-  inline void clear_share_memory();
-  static const int kShareMemoryFieldNumber = 41;
-  inline bool share_memory() const;
-  inline void set_share_memory(bool value);
-
-  // @@protoc_insertion_point(class_scope:singa.ClusterProto)
- private:
-  inline void set_has_nworker_groups();
-  inline void clear_has_nworker_groups();
-  inline void set_has_nserver_groups();
-  inline void clear_has_nserver_groups();
-  inline void set_has_nworkers_per_group();
-  inline void clear_has_nworkers_per_group();
-  inline void set_has_nservers_per_group();
-  inline void clear_has_nservers_per_group();
-  inline void set_has_nworkers_per_procs();
-  inline void clear_has_nworkers_per_procs();
-  inline void set_has_nservers_per_procs();
-  inline void clear_has_nservers_per_procs();
-  inline void set_has_hostfile();
-  inline void clear_has_hostfile();
-  inline void set_has_server_worker_separate();
-  inline void clear_has_server_worker_separate();
-  inline void set_has_nprocs();
-  inline void clear_has_nprocs();
-  inline void set_has_start_port();
-  inline void clear_has_start_port();
-  inline void set_has_workspace();
-  inline void clear_has_workspace();
-  inline void set_has_log_dir();
-  inline void clear_has_log_dir();
-  inline void set_has_zookeeper_host();
-  inline void clear_has_zookeeper_host();
-  inline void set_has_stub_timeout();
-  inline void clear_has_stub_timeout();
-  inline void set_has_worker_timeout();
-  inline void clear_has_worker_timeout();
-  inline void set_has_server_timeout();
-  inline void clear_has_server_timeout();
-  inline void set_has_server_update();
-  inline void clear_has_server_update();
-  inline void set_has_share_memory();
-  inline void clear_has_share_memory();
-
-  ::google::protobuf::UnknownFieldSet _unknown_fields_;
-
-  ::google::protobuf::int32 nworker_groups_;
-  ::google::protobuf::int32 nserver_groups_;
-  ::google::protobuf::int32 nworkers_per_group_;
-  ::google::protobuf::int32 nservers_per_group_;
-  ::google::protobuf::int32 nworkers_per_procs_;
-  ::google::protobuf::int32 nservers_per_procs_;
-  ::std::string* hostfile_;
-  ::google::protobuf::int32 nprocs_;
-  ::google::protobuf::int32 start_port_;
-  ::std::string* workspace_;
-  ::std::string* log_dir_;
-  ::std::string* zookeeper_host_;
-  static ::std::string* _default_zookeeper_host_;
-  ::google::protobuf::RepeatedPtrField< ::singa::ServerTopology > server_group_;
-  ::google::protobuf::int32 stub_timeout_;
-  bool server_worker_separate_;
-  bool server_update_;
-  bool share_memory_;
-  ::google::protobuf::int32 worker_timeout_;
-  ::google::protobuf::int32 server_timeout_;
-
-  mutable int _cached_size_;
-  ::google::protobuf::uint32 _has_bits_[(19 + 31) / 32];
-
-  friend void  protobuf_AddDesc_cluster_2eproto();
-  friend void protobuf_AssignDesc_cluster_2eproto();
-  friend void protobuf_ShutdownFile_cluster_2eproto();
-
-  void InitAsDefaultInstance();
-  static ClusterProto* default_instance_;
-};
-// -------------------------------------------------------------------
-
-class ServerTopology : public ::google::protobuf::Message {
- public:
-  ServerTopology();
-  virtual ~ServerTopology();
-
-  ServerTopology(const ServerTopology& from);
-
-  inline ServerTopology& operator=(const ServerTopology& from) {
-    CopyFrom(from);
-    return *this;
-  }
-
-  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
-    return _unknown_fields_;
-  }
-
-  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
-    return &_unknown_fields_;
-  }
-
-  static const ::google::protobuf::Descriptor* descriptor();
-  static const ServerTopology& default_instance();
-
-  void Swap(ServerTopology* other);
-
-  // implements Message ----------------------------------------------
-
-  ServerTopology* New() const;
-  void CopyFrom(const ::google::protobuf::Message& from);
-  void MergeFrom(const ::google::protobuf::Message& from);
-  void CopyFrom(const ServerTopology& from);
-  void MergeFrom(const ServerTopology& from);
-  void Clear();
-  bool IsInitialized() const;
-
-  int ByteSize() const;
-  bool MergePartialFromCodedStream(
-      ::google::protobuf::io::CodedInputStream* input);
-  void SerializeWithCachedSizes(
-      ::google::protobuf::io::CodedOutputStream* output) const;
-  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output)
const;
-  int GetCachedSize() const { return _cached_size_; }
-  private:
-  void SharedCtor();
-  void SharedDtor();
-  void SetCachedSize(int size) const;
-  public:
-
-  ::google::protobuf::Metadata GetMetadata() const;
-
-  // nested types ----------------------------------------------------
-
-  // accessors -------------------------------------------------------
-
-  // required int32 id = 1;
-  inline bool has_id() const;
-  inline void clear_id();
-  static const int kIdFieldNumber = 1;
-  inline ::google::protobuf::int32 id() const;
-  inline void set_id(::google::protobuf::int32 value);
-
-  // optional int32 sync_interval = 2;
-  inline bool has_sync_interval() const;
-  inline void clear_sync_interval();
-  static const int kSyncIntervalFieldNumber = 2;
-  inline ::google::protobuf::int32 sync_interval() const;
-  inline void set_sync_interval(::google::protobuf::int32 value);
-
-  // repeated int32 neighbor = 3;
-  inline int neighbor_size() const;
-  inline void clear_neighbor();
-  static const int kNeighborFieldNumber = 3;
-  inline ::google::protobuf::int32 neighbor(int index) const;
-  inline void set_neighbor(int index, ::google::protobuf::int32 value);
-  inline void add_neighbor(::google::protobuf::int32 value);
-  inline const ::google::protobuf::RepeatedField< ::google::protobuf::int32 >&
-      neighbor() const;
-  inline ::google::protobuf::RepeatedField< ::google::protobuf::int32 >*
-      mutable_neighbor();
-
-  // @@protoc_insertion_point(class_scope:singa.ServerTopology)
- private:
-  inline void set_has_id();
-  inline void clear_has_id();
-  inline void set_has_sync_interval();
-  inline void clear_has_sync_interval();
-
-  ::google::protobuf::UnknownFieldSet _unknown_fields_;
-
-  ::google::protobuf::int32 id_;
-  ::google::protobuf::int32 sync_interval_;
-  ::google::protobuf::RepeatedField< ::google::protobuf::int32 > neighbor_;
-
-  mutable int _cached_size_;
-  ::google::protobuf::uint32 _has_bits_[(3 + 31) / 32];
-
-  friend void  protobuf_AddDesc_cluster_2eproto();
-  friend void protobuf_AssignDesc_cluster_2eproto();
-  friend void protobuf_ShutdownFile_cluster_2eproto();
-
-  void InitAsDefaultInstance();
-  static ServerTopology* default_instance_;
-};
-// ===================================================================
-
-
-// ===================================================================
-
-// ClusterProto
-
-// optional int32 nworker_groups = 1;
-inline bool ClusterProto::has_nworker_groups() const {
-  return (_has_bits_[0] & 0x00000001u) != 0;
-}
-inline void ClusterProto::set_has_nworker_groups() {
-  _has_bits_[0] |= 0x00000001u;
-}
-inline void ClusterProto::clear_has_nworker_groups() {
-  _has_bits_[0] &= ~0x00000001u;
-}
-inline void ClusterProto::clear_nworker_groups() {
-  nworker_groups_ = 0;
-  clear_has_nworker_groups();
-}
-inline ::google::protobuf::int32 ClusterProto::nworker_groups() const {
-  return nworker_groups_;
-}
-inline void ClusterProto::set_nworker_groups(::google::protobuf::int32 value) {
-  set_has_nworker_groups();
-  nworker_groups_ = value;
-}
-
-// optional int32 nserver_groups = 2;
-inline bool ClusterProto::has_nserver_groups() const {
-  return (_has_bits_[0] & 0x00000002u) != 0;
-}
-inline void ClusterProto::set_has_nserver_groups() {
-  _has_bits_[0] |= 0x00000002u;
-}
-inline void ClusterProto::clear_has_nserver_groups() {
-  _has_bits_[0] &= ~0x00000002u;
-}
-inline void ClusterProto::clear_nserver_groups() {
-  nserver_groups_ = 0;
-  clear_has_nserver_groups();
-}
-inline ::google::protobuf::int32 ClusterProto::nserver_groups() const {
-  return nserver_groups_;
-}
-inline void ClusterProto::set_nserver_groups(::google::protobuf::int32 value) {
-  set_has_nserver_groups();
-  nserver_groups_ = value;
-}
-
-// optional int32 nworkers_per_group = 3 [default = 1];
-inline bool ClusterProto::has_nworkers_per_group() const {
-  return (_has_bits_[0] & 0x00000004u) != 0;
-}
-inline void ClusterProto::set_has_nworkers_per_group() {
-  _has_bits_[0] |= 0x00000004u;
-}
-inline void ClusterProto::clear_has_nworkers_per_group() {
-  _has_bits_[0] &= ~0x00000004u;
-}
-inline void ClusterProto::clear_nworkers_per_group() {
-  nworkers_per_group_ = 1;
-  clear_has_nworkers_per_group();
-}
-inline ::google::protobuf::int32 ClusterProto::nworkers_per_group() const {
-  return nworkers_per_group_;
-}
-inline void ClusterProto::set_nworkers_per_group(::google::protobuf::int32 value) {
-  set_has_nworkers_per_group();
-  nworkers_per_group_ = value;
-}
-
-// optional int32 nservers_per_group = 4 [default = 1];
-inline bool ClusterProto::has_nservers_per_group() const {
-  return (_has_bits_[0] & 0x00000008u) != 0;
-}
-inline void ClusterProto::set_has_nservers_per_group() {
-  _has_bits_[0] |= 0x00000008u;
-}
-inline void ClusterProto::clear_has_nservers_per_group() {
-  _has_bits_[0] &= ~0x00000008u;
-}
-inline void ClusterProto::clear_nservers_per_group() {
-  nservers_per_group_ = 1;
-  clear_has_nservers_per_group();
-}
-inline ::google::protobuf::int32 ClusterProto::nservers_per_group() const {
-  return nservers_per_group_;
-}
-inline void ClusterProto::set_nservers_per_group(::google::protobuf::int32 value) {
-  set_has_nservers_per_group();
-  nservers_per_group_ = value;
-}
-
-// optional int32 nworkers_per_procs = 5 [default = 1];
-inline bool ClusterProto::has_nworkers_per_procs() const {
-  return (_has_bits_[0] & 0x00000010u) != 0;
-}
-inline void ClusterProto::set_has_nworkers_per_procs() {
-  _has_bits_[0] |= 0x00000010u;
-}
-inline void ClusterProto::clear_has_nworkers_per_procs() {
-  _has_bits_[0] &= ~0x00000010u;
-}
-inline void ClusterProto::clear_nworkers_per_procs() {
-  nworkers_per_procs_ = 1;
-  clear_has_nworkers_per_procs();
-}
-inline ::google::protobuf::int32 ClusterProto::nworkers_per_procs() const {
-  return nworkers_per_procs_;
-}
-inline void ClusterProto::set_nworkers_per_procs(::google::protobuf::int32 value) {
-  set_has_nworkers_per_procs();
-  nworkers_per_procs_ = value;
-}
-
-// optional int32 nservers_per_procs = 6 [default = 1];
-inline bool ClusterProto::has_nservers_per_procs() const {
-  return (_has_bits_[0] & 0x00000020u) != 0;
-}
-inline void ClusterProto::set_has_nservers_per_procs() {
-  _has_bits_[0] |= 0x00000020u;
-}
-inline void ClusterProto::clear_has_nservers_per_procs() {
-  _has_bits_[0] &= ~0x00000020u;
-}
-inline void ClusterProto::clear_nservers_per_procs() {
-  nservers_per_procs_ = 1;
-  clear_has_nservers_per_procs();
-}
-inline ::google::protobuf::int32 ClusterProto::nservers_per_procs() const {
-  return nservers_per_procs_;
-}
-inline void ClusterProto::set_nservers_per_procs(::google::protobuf::int32 value) {
-  set_has_nservers_per_procs();
-  nservers_per_procs_ = value;
-}
-
-// optional string hostfile = 10;
-inline bool ClusterProto::has_hostfile() const {
-  return (_has_bits_[0] & 0x00000040u) != 0;
-}
-inline void ClusterProto::set_has_hostfile() {
-  _has_bits_[0] |= 0x00000040u;
-}
-inline void ClusterProto::clear_has_hostfile() {
-  _has_bits_[0] &= ~0x00000040u;
-}
-inline void ClusterProto::clear_hostfile() {
-  if (hostfile_ != &::google::protobuf::internal::kEmptyString) {
-    hostfile_->clear();
-  }
-  clear_has_hostfile();
-}
-inline const ::std::string& ClusterProto::hostfile() const {
-  return *hostfile_;
-}
-inline void ClusterProto::set_hostfile(const ::std::string& value) {
-  set_has_hostfile();
-  if (hostfile_ == &::google::protobuf::internal::kEmptyString) {
-    hostfile_ = new ::std::string;
-  }
-  hostfile_->assign(value);
-}
-inline void ClusterProto::set_hostfile(const char* value) {
-  set_has_hostfile();
-  if (hostfile_ == &::google::protobuf::internal::kEmptyString) {
-    hostfile_ = new ::std::string;
-  }
-  hostfile_->assign(value);
-}
-inline void ClusterProto::set_hostfile(const char* value, size_t size) {
-  set_has_hostfile();
-  if (hostfile_ == &::google::protobuf::internal::kEmptyString) {
-    hostfile_ = new ::std::string;
-  }
-  hostfile_->assign(reinterpret_cast<const char*>(value), size);
-}
-inline ::std::string* ClusterProto::mutable_hostfile() {
-  set_has_hostfile();
-  if (hostfile_ == &::google::protobuf::internal::kEmptyString) {
-    hostfile_ = new ::std::string;
-  }
-  return hostfile_;
-}
-inline ::std::string* ClusterProto::release_hostfile() {
-  clear_has_hostfile();
-  if (hostfile_ == &::google::protobuf::internal::kEmptyString) {
-    return NULL;
-  } else {
-    ::std::string* temp = hostfile_;
-    hostfile_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
-    return temp;
-  }
-}
-inline void ClusterProto::set_allocated_hostfile(::std::string* hostfile) {
-  if (hostfile_ != &::google::protobuf::internal::kEmptyString) {
-    delete hostfile_;
-  }
-  if (hostfile) {
-    set_has_hostfile();
-    hostfile_ = hostfile;
-  } else {
-    clear_has_hostfile();
-    hostfile_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
-  }
-}
-
-// optional bool server_worker_separate = 11 [default = false];
-inline bool ClusterProto::has_server_worker_separate() const {
-  return (_has_bits_[0] & 0x00000080u) != 0;
-}
-inline void ClusterProto::set_has_server_worker_separate() {
-  _has_bits_[0] |= 0x00000080u;
-}
-inline void ClusterProto::clear_has_server_worker_separate() {
-  _has_bits_[0] &= ~0x00000080u;
-}
-inline void ClusterProto::clear_server_worker_separate() {
-  server_worker_separate_ = false;
-  clear_has_server_worker_separate();
-}
-inline bool ClusterProto::server_worker_separate() const {
-  return server_worker_separate_;
-}
-inline void ClusterProto::set_server_worker_separate(bool value) {
-  set_has_server_worker_separate();
-  server_worker_separate_ = value;
-}
-
-// optional int32 nprocs = 12;
-inline bool ClusterProto::has_nprocs() const {
-  return (_has_bits_[0] & 0x00000100u) != 0;
-}
-inline void ClusterProto::set_has_nprocs() {
-  _has_bits_[0] |= 0x00000100u;
-}
-inline void ClusterProto::clear_has_nprocs() {
-  _has_bits_[0] &= ~0x00000100u;
-}
-inline void ClusterProto::clear_nprocs() {
-  nprocs_ = 0;
-  clear_has_nprocs();
-}
-inline ::google::protobuf::int32 ClusterProto::nprocs() const {
-  return nprocs_;
-}
-inline void ClusterProto::set_nprocs(::google::protobuf::int32 value) {
-  set_has_nprocs();
-  nprocs_ = value;
-}
-
-// optional int32 start_port = 13 [default = 6723];
-inline bool ClusterProto::has_start_port() const {
-  return (_has_bits_[0] & 0x00000200u) != 0;
-}
-inline void ClusterProto::set_has_start_port() {
-  _has_bits_[0] |= 0x00000200u;
-}
-inline void ClusterProto::clear_has_start_port() {
-  _has_bits_[0] &= ~0x00000200u;
-}
-inline void ClusterProto::clear_start_port() {
-  start_port_ = 6723;
-  clear_has_start_port();
-}
-inline ::google::protobuf::int32 ClusterProto::start_port() const {
-  return start_port_;
-}
-inline void ClusterProto::set_start_port(::google::protobuf::int32 value) {
-  set_has_start_port();
-  start_port_ = value;
-}
-
-// required string workspace = 14;
-inline bool ClusterProto::has_workspace() const {
-  return (_has_bits_[0] & 0x00000400u) != 0;
-}
-inline void ClusterProto::set_has_workspace() {
-  _has_bits_[0] |= 0x00000400u;
-}
-inline void ClusterProto::clear_has_workspace() {
-  _has_bits_[0] &= ~0x00000400u;
-}
-inline void ClusterProto::clear_workspace() {
-  if (workspace_ != &::google::protobuf::internal::kEmptyString) {
-    workspace_->clear();
-  }
-  clear_has_workspace();
-}
-inline const ::std::string& ClusterProto::workspace() const {
-  return *workspace_;
-}
-inline void ClusterProto::set_workspace(const ::std::string& value) {
-  set_has_workspace();
-  if (workspace_ == &::google::protobuf::internal::kEmptyString) {
-    workspace_ = new ::std::string;
-  }
-  workspace_->assign(value);
-}
-inline void ClusterProto::set_workspace(const char* value) {
-  set_has_workspace();
-  if (workspace_ == &::google::protobuf::internal::kEmptyString) {
-    workspace_ = new ::std::string;
-  }
-  workspace_->assign(value);
-}
-inline void ClusterProto::set_workspace(const char* value, size_t size) {
-  set_has_workspace();
-  if (workspace_ == &::google::protobuf::internal::kEmptyString) {
-    workspace_ = new ::std::string;
-  }
-  workspace_->assign(reinterpret_cast<const char*>(value), size);
-}
-inline ::std::string* ClusterProto::mutable_workspace() {
-  set_has_workspace();
-  if (workspace_ == &::google::protobuf::internal::kEmptyString) {
-    workspace_ = new ::std::string;
-  }
-  return workspace_;
-}
-inline ::std::string* ClusterProto::release_workspace() {
-  clear_has_workspace();
-  if (workspace_ == &::google::protobuf::internal::kEmptyString) {
-    return NULL;
-  } else {
-    ::std::string* temp = workspace_;
-    workspace_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
-    return temp;
-  }
-}
-inline void ClusterProto::set_allocated_workspace(::std::string* workspace) {
-  if (workspace_ != &::google::protobuf::internal::kEmptyString) {
-    delete workspace_;
-  }
-  if (workspace) {
-    set_has_workspace();
-    workspace_ = workspace;
-  } else {
-    clear_has_workspace();
-    workspace_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
-  }
-}
-
-// optional string log_dir = 15;
-inline bool ClusterProto::has_log_dir() const {
-  return (_has_bits_[0] & 0x00000800u) != 0;
-}
-inline void ClusterProto::set_has_log_dir() {
-  _has_bits_[0] |= 0x00000800u;
-}
-inline void ClusterProto::clear_has_log_dir() {
-  _has_bits_[0] &= ~0x00000800u;
-}
-inline void ClusterProto::clear_log_dir() {
-  if (log_dir_ != &::google::protobuf::internal::kEmptyString) {
-    log_dir_->clear();
-  }
-  clear_has_log_dir();
-}
-inline const ::std::string& ClusterProto::log_dir() const {
-  return *log_dir_;
-}
-inline void ClusterProto::set_log_dir(const ::std::string& value) {
-  set_has_log_dir();
-  if (log_dir_ == &::google::protobuf::internal::kEmptyString) {
-    log_dir_ = new ::std::string;
-  }
-  log_dir_->assign(value);
-}
-inline void ClusterProto::set_log_dir(const char* value) {
-  set_has_log_dir();
-  if (log_dir_ == &::google::protobuf::internal::kEmptyString) {
-    log_dir_ = new ::std::string;
-  }
-  log_dir_->assign(value);
-}
-inline void ClusterProto::set_log_dir(const char* value, size_t size) {
-  set_has_log_dir();
-  if (log_dir_ == &::google::protobuf::internal::kEmptyString) {
-    log_dir_ = new ::std::string;
-  }
-  log_dir_->assign(reinterpret_cast<const char*>(value), size);
-}
-inline ::std::string* ClusterProto::mutable_log_dir() {
-  set_has_log_dir();
-  if (log_dir_ == &::google::protobuf::internal::kEmptyString) {
-    log_dir_ = new ::std::string;
-  }
-  return log_dir_;
-}
-inline ::std::string* ClusterProto::release_log_dir() {
-  clear_has_log_dir();
-  if (log_dir_ == &::google::protobuf::internal::kEmptyString) {
-    return NULL;
-  } else {
-    ::std::string* temp = log_dir_;
-    log_dir_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
-    return temp;
-  }
-}
-inline void ClusterProto::set_allocated_log_dir(::std::string* log_dir) {
-  if (log_dir_ != &::google::protobuf::internal::kEmptyString) {
-    delete log_dir_;
-  }
-  if (log_dir) {
-    set_has_log_dir();
-    log_dir_ = log_dir;
-  } else {
-    clear_has_log_dir();
-    log_dir_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
-  }
-}
-
-// optional string zookeeper_host = 16 [default = "localhost:2181"];
-inline bool ClusterProto::has_zookeeper_host() const {
-  return (_has_bits_[0] & 0x00001000u) != 0;
-}
-inline void ClusterProto::set_has_zookeeper_host() {
-  _has_bits_[0] |= 0x00001000u;
-}
-inline void ClusterProto::clear_has_zookeeper_host() {
-  _has_bits_[0] &= ~0x00001000u;
-}
-inline void ClusterProto::clear_zookeeper_host() {
-  if (zookeeper_host_ != _default_zookeeper_host_) {
-    zookeeper_host_->assign(*_default_zookeeper_host_);
-  }
-  clear_has_zookeeper_host();
-}
-inline const ::std::string& ClusterProto::zookeeper_host() const {
-  return *zookeeper_host_;
-}
-inline void ClusterProto::set_zookeeper_host(const ::std::string& value) {
-  set_has_zookeeper_host();
-  if (zookeeper_host_ == _default_zookeeper_host_) {
-    zookeeper_host_ = new ::std::string;
-  }
-  zookeeper_host_->assign(value);
-}
-inline void ClusterProto::set_zookeeper_host(const char* value) {
-  set_has_zookeeper_host();
-  if (zookeeper_host_ == _default_zookeeper_host_) {
-    zookeeper_host_ = new ::std::string;
-  }
-  zookeeper_host_->assign(value);
-}
-inline void ClusterProto::set_zookeeper_host(const char* value, size_t size) {
-  set_has_zookeeper_host();
-  if (zookeeper_host_ == _default_zookeeper_host_) {
-    zookeeper_host_ = new ::std::string;
-  }
-  zookeeper_host_->assign(reinterpret_cast<const char*>(value), size);
-}
-inline ::std::string* ClusterProto::mutable_zookeeper_host() {
-  set_has_zookeeper_host();
-  if (zookeeper_host_ == _default_zookeeper_host_) {
-    zookeeper_host_ = new ::std::string(*_default_zookeeper_host_);
-  }
-  return zookeeper_host_;
-}
-inline ::std::string* ClusterProto::release_zookeeper_host() {
-  clear_has_zookeeper_host();
-  if (zookeeper_host_ == _default_zookeeper_host_) {
-    return NULL;
-  } else {
-    ::std::string* temp = zookeeper_host_;
-    zookeeper_host_ = const_cast< ::std::string*>(_default_zookeeper_host_);
-    return temp;
-  }
-}
-inline void ClusterProto::set_allocated_zookeeper_host(::std::string* zookeeper_host) {
-  if (zookeeper_host_ != _default_zookeeper_host_) {
-    delete zookeeper_host_;
-  }
-  if (zookeeper_host) {
-    set_has_zookeeper_host();
-    zookeeper_host_ = zookeeper_host;
-  } else {
-    clear_has_zookeeper_host();
-    zookeeper_host_ = const_cast< ::std::string*>(_default_zookeeper_host_);
-  }
-}
-
-// repeated .singa.ServerTopology server_group = 20;
-inline int ClusterProto::server_group_size() const {
-  return server_group_.size();
-}
-inline void ClusterProto::clear_server_group() {
-  server_group_.Clear();
-}
-inline const ::singa::ServerTopology& ClusterProto::server_group(int index) const {
-  return server_group_.Get(index);
-}
-inline ::singa::ServerTopology* ClusterProto::mutable_server_group(int index) {
-  return server_group_.Mutable(index);
-}
-inline ::singa::ServerTopology* ClusterProto::add_server_group() {
-  return server_group_.Add();
-}
-inline const ::google::protobuf::RepeatedPtrField< ::singa::ServerTopology >&
-ClusterProto::server_group() const {
-  return server_group_;
-}
-inline ::google::protobuf::RepeatedPtrField< ::singa::ServerTopology >*
-ClusterProto::mutable_server_group() {
-  return &server_group_;
-}
-
-// optional int32 stub_timeout = 30 [default = 5000];
-inline bool ClusterProto::has_stub_timeout() const {
-  return (_has_bits_[0] & 0x00004000u) != 0;
-}
-inline void ClusterProto::set_has_stub_timeout() {
-  _has_bits_[0] |= 0x00004000u;
-}
-inline void ClusterProto::clear_has_stub_timeout() {
-  _has_bits_[0] &= ~0x00004000u;
-}
-inline void ClusterProto::clear_stub_timeout() {
-  stub_timeout_ = 5000;
-  clear_has_stub_timeout();
-}
-inline ::google::protobuf::int32 ClusterProto::stub_timeout() const {
-  return stub_timeout_;
-}
-inline void ClusterProto::set_stub_timeout(::google::protobuf::int32 value) {
-  set_has_stub_timeout();
-  stub_timeout_ = value;
-}
-
-// optional int32 worker_timeout = 31 [default = 5000];
-inline bool ClusterProto::has_worker_timeout() const {
-  return (_has_bits_[0] & 0x00008000u) != 0;
-}
-inline void ClusterProto::set_has_worker_timeout() {
-  _has_bits_[0] |= 0x00008000u;
-}
-inline void ClusterProto::clear_has_worker_timeout() {
-  _has_bits_[0] &= ~0x00008000u;
-}
-inline void ClusterProto::clear_worker_timeout() {
-  worker_timeout_ = 5000;
-  clear_has_worker_timeout();
-}
-inline ::google::protobuf::int32 ClusterProto::worker_timeout() const {
-  return worker_timeout_;
-}
-inline void ClusterProto::set_worker_timeout(::google::protobuf::int32 value) {
-  set_has_worker_timeout();
-  worker_timeout_ = value;
-}
-
-// optional int32 server_timeout = 32 [default = 5000];
-inline bool ClusterProto::has_server_timeout() const {
-  return (_has_bits_[0] & 0x00010000u) != 0;
-}
-inline void ClusterProto::set_has_server_timeout() {
-  _has_bits_[0] |= 0x00010000u;
-}
-inline void ClusterProto::clear_has_server_timeout() {
-  _has_bits_[0] &= ~0x00010000u;
-}
-inline void ClusterProto::clear_server_timeout() {
-  server_timeout_ = 5000;
-  clear_has_server_timeout();
-}
-inline ::google::protobuf::int32 ClusterProto::server_timeout() const {
-  return server_timeout_;
-}
-inline void ClusterProto::set_server_timeout(::google::protobuf::int32 value) {
-  set_has_server_timeout();
-  server_timeout_ = value;
-}
-
-// optional bool server_update = 40 [default = true];
-inline bool ClusterProto::has_server_update() const {
-  return (_has_bits_[0] & 0x00020000u) != 0;
-}
-inline void ClusterProto::set_has_server_update() {
-  _has_bits_[0] |= 0x00020000u;
-}
-inline void ClusterProto::clear_has_server_update() {
-  _has_bits_[0] &= ~0x00020000u;
-}
-inline void ClusterProto::clear_server_update() {
-  server_update_ = true;
-  clear_has_server_update();
-}
-inline bool ClusterProto::server_update() const {
-  return server_update_;
-}
-inline void ClusterProto::set_server_update(bool value) {
-  set_has_server_update();
-  server_update_ = value;
-}
-
-// optional bool share_memory = 41 [default = true];
-inline bool ClusterProto::has_share_memory() const {
-  return (_has_bits_[0] & 0x00040000u) != 0;
-}
-inline void ClusterProto::set_has_share_memory() {
-  _has_bits_[0] |= 0x00040000u;
-}
-inline void ClusterProto::clear_has_share_memory() {
-  _has_bits_[0] &= ~0x00040000u;
-}
-inline void ClusterProto::clear_share_memory() {
-  share_memory_ = true;
-  clear_has_share_memory();
-}
-inline bool ClusterProto::share_memory() const {
-  return share_memory_;
-}
-inline void ClusterProto::set_share_memory(bool value) {
-  set_has_share_memory();
-  share_memory_ = value;
-}
-
-// -------------------------------------------------------------------
-
-// ServerTopology
-
-// required int32 id = 1;
-inline bool ServerTopology::has_id() const {
-  return (_has_bits_[0] & 0x00000001u) != 0;
-}
-inline void ServerTopology::set_has_id() {
-  _has_bits_[0] |= 0x00000001u;
-}
-inline void ServerTopology::clear_has_id() {
-  _has_bits_[0] &= ~0x00000001u;
-}
-inline void ServerTopology::clear_id() {
-  id_ = 0;
-  clear_has_id();
-}
-inline ::google::protobuf::int32 ServerTopology::id() const {
-  return id_;
-}
-inline void ServerTopology::set_id(::google::protobuf::int32 value) {
-  set_has_id();
-  id_ = value;
-}
-
-// optional int32 sync_interval = 2;
-inline bool ServerTopology::has_sync_interval() const {
-  return (_has_bits_[0] & 0x00000002u) != 0;
-}
-inline void ServerTopology::set_has_sync_interval() {
-  _has_bits_[0] |= 0x00000002u;
-}
-inline void ServerTopology::clear_has_sync_interval() {
-  _has_bits_[0] &= ~0x00000002u;
-}
-inline void ServerTopology::clear_sync_interval() {
-  sync_interval_ = 0;
-  clear_has_sync_interval();
-}
-inline ::google::protobuf::int32 ServerTopology::sync_interval() const {
-  return sync_interval_;
-}
-inline void ServerTopology::set_sync_interval(::google::protobuf::int32 value) {
-  set_has_sync_interval();
-  sync_interval_ = value;
-}
-
-// repeated int32 neighbor = 3;
-inline int ServerTopology::neighbor_size() const {
-  return neighbor_.size();
-}
-inline void ServerTopology::clear_neighbor() {
-  neighbor_.Clear();
-}
-inline ::google::protobuf::int32 ServerTopology::neighbor(int index) const {
-  return neighbor_.Get(index);
-}
-inline void ServerTopology::set_neighbor(int index, ::google::protobuf::int32 value) {
-  neighbor_.Set(index, value);
-}
-inline void ServerTopology::add_neighbor(::google::protobuf::int32 value) {
-  neighbor_.Add(value);
-}
-inline const ::google::protobuf::RepeatedField< ::google::protobuf::int32 >&
-ServerTopology::neighbor() const {
-  return neighbor_;
-}
-inline ::google::protobuf::RepeatedField< ::google::protobuf::int32 >*
-ServerTopology::mutable_neighbor() {
-  return &neighbor_;
-}
-
-
-// @@protoc_insertion_point(namespace_scope)
-
-}  // namespace singa
-
-#ifndef SWIG
-namespace google {
-namespace protobuf {
-
-
-}  // namespace google
-}  // namespace protobuf
-#endif  // SWIG
-
-// @@protoc_insertion_point(global_scope)
-
-#endif  // PROTOBUF_cluster_2eproto__INCLUDED



Mime
View raw message