]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
Merge remote-tracking branch 'origin/master' into wip-stretch-mode
authorGreg Farnum <gfarnum@redhat.com>
Mon, 14 Sep 2020 02:32:19 +0000 (02:32 +0000)
committerGreg Farnum <gfarnum@redhat.com>
Mon, 14 Sep 2020 02:32:19 +0000 (02:32 +0000)
22 files changed:
1  2 
qa/tasks/ceph.py
qa/workunits/cephtool/test.sh
src/common/options.cc
src/crush/CrushWrapper.h
src/mon/MgrStatMonitor.cc
src/mon/MonCommands.h
src/mon/MonMap.cc
src/mon/MonMap.h
src/mon/MonOpRequest.h
src/mon/Monitor.cc
src/mon/OSDMonitor.cc
src/mon/OSDMonitor.h
src/msg/Message.cc
src/msg/Message.h
src/osd/OSDMap.cc
src/osd/OSDMap.h
src/osd/PeeringState.cc
src/osd/PeeringState.h
src/osd/osd_types.cc
src/osd/osd_types.h
src/osdc/Objecter.cc
src/osdc/Objecter.h

index d3fb90ddd80081b36eb59b08e9dff55a753c54fb,516f144aa4570f1a8ba49cf6f2113b48994f8696..035b2554651f1807a98ed60b32818e8923224b20
@@@ -547,9 -558,20 +569,21 @@@ def create_simple_monmap(ctx, remote, c
      monmap_output = remote.sh(args)
      fsid = re.search("generated fsid (.+)$",
                       monmap_output, re.MULTILINE).group(1)
 +    teuthology.delete_file(remote, tmp_conf_path)
      return fsid
  
+ def maybe_redirect_stderr(config, type_, args, log_path):
+     if type_ == 'osd' and \
+        config.get('flavor', 'default') == 'crimson':
+         # teuthworker uses ubuntu:ubuntu to access the test nodes
+         create_log_cmd = \
+             f'sudo install -b -o ubuntu -g ubuntu /dev/null {log_path}'
+         return create_log_cmd, args + [run.Raw('2>>'), log_path]
+     else:
+         return None, args
  @contextlib.contextmanager
  def cluster(ctx, config):
      """
Simple merge
Simple merge
Simple merge
Simple merge
Simple merge
Simple merge
index e01d00e531b4d67ed4f2746f28532d41a14d5d18,44009663edb2e80f4a40996a872ea740ac5478ad..c409ff9e112b9cc3f34ea732ed5ccae4aff7bcf7
  #include "mon/mon_types.h"
  #include "msg/Message.h"
  
 +class health_check_map_t;
  
  #ifdef WITH_SEASTAR
- namespace ceph::common {
+ namespace crimson::common {
    class ConfigProxy;
  }
  #endif
@@@ -482,10 -454,20 +482,22 @@@ public
    void dump(ceph::Formatter *f) const;
    void dump_summary(ceph::Formatter *f) const;
  
 +  void check_health(health_check_map_t *checks) const;
 +
    static void generate_test_instances(std::list<MonMap*>& o);
  protected:
+   /**
+    * build a monmap from a list of entity_addrvec_t's
+    *
+    * Give mons dummy names.
+    *
+    * @param addrs  list of entity_addrvec_t's
+    * @param prefix prefix to prepend to generated mon names
+    * @return 0 for success, -errno on error
+    */
+   int init_with_addrs(const std::vector<entity_addrvec_t>& addrs,
+         bool for_mkfs,
+         std::string_view prefix);
    /**
     * build a monmap from a list of ips
     *
Simple merge
Simple merge
Simple merge
Simple merge
Simple merge
Simple merge
index 73302d6fb1429589299be3e409c93172046cd82d,e61780ccda2d645f104f4d928f403b6bb67655ef..1ca5c7cfc8d5fbc17a676dde453852c5a352ca63
@@@ -3360,10 -3301,10 +3360,10 @@@ void OSDMap::decode(ceph::buffer::list:
    }
  
    {
 -    DECODE_START(9, bl); // extended, osd-only data
 +    DECODE_START(10, bl); // extended, osd-only data
      decode(osd_addrs->hb_back_addrs, bl);
      decode(osd_info, bl);
-     decode(blacklist, bl);
+     decode(blocklist, bl);
      decode(osd_addrs->cluster_addrs, bl);
      decode(cluster_snapshot_epoch, bl);
      decode(cluster_snapshot, bl);
index 2e9dbcc8158e1da23e9832010db7676b78f5492e,2e0a3c8206fa00f04eab46307937a7760a77e22d..e0f496138c445d8eac854860c03eb8602ff756e2
@@@ -640,12 -629,10 +640,12 @@@ private
             primary_temp(std::make_shared<mempool::osdmap::map<pg_t,int32_t>>()),
             osd_uuid(std::make_shared<mempool::osdmap::vector<uuid_d>>()),
             cluster_snapshot_epoch(0),
-            new_blacklist_entries(false),
+            new_blocklist_entries(false),
             cached_up_osd_features(0),
             crc_defined(false), crc(0),
 -           crush(std::make_shared<CrushWrapper>()) {
 +           crush(std::make_shared<CrushWrapper>()),
 +           stretch_mode_enabled(false), stretch_bucket_count(0),
 +           degraded_stretch_mode(0), recovering_stretch_mode(0), stretch_mode_bucket(0) {
    }
  
  private:
Simple merge
Simple merge
Simple merge
Simple merge
Simple merge
Simple merge