PVE/CLI/pveceph.pm

   1 package PVE::CLI::pveceph;
   2
   3 use strict;
   4 use warnings;
   5
   6 use Fcntl ':flock';
   7 use File::Path;
   8 use IO::File;
   9 use JSON;
  10 use Data::Dumper;
  11 use LWP::UserAgent;
  12
  13 use PVE::SafeSyslog;
  14 use PVE::Cluster;
  15 use PVE::INotify;
  16 use PVE::RPCEnvironment;
  17 use PVE::Storage;
  18 use PVE::Tools qw(run_command);
  19 use PVE::JSONSchema qw(get_standard_option);
  20 use PVE::CephTools;
  21 use PVE::API2::Ceph;
  22
  23 use PVE::CLIHandler;
  24
  25 use base qw(PVE::CLIHandler);
  26
  27 my $nodename = PVE::INotify::nodename();
  28
  29 my $upid_exit = sub {
  30     my $upid = shift;
  31     my $status = PVE::Tools::upid_read_status($upid);
  32     exit($status eq 'OK' ? 0 : -1);
  33 };
  34
  35 sub setup_environment {
  36     PVE::RPCEnvironment->setup_default_cli_env();
  37 }
  38
  39 __PACKAGE__->register_method ({
  40     name => 'purge',
  41     path => 'purge',
  42     method => 'POST',
  43     description => "Destroy ceph related data and configuration files.",
  44     parameters => {
  45         additionalProperties => 0,
  46         properties => {
  47         },
  48     },
  49     returns => { type => 'null' },
  50     code => sub {
  51         my ($param) = @_;
  52
  53         my $monstat;
  54
  55         eval {
  56             my $rados = PVE::RADOS->new();
  57             my $monstat = $rados->mon_command({ prefix => 'mon_status' });
  58         };
  59         my $err = $@;
  60
  61         die "detected running ceph services- unable to purge data\n"
  62             if !$err;
  63
  64         # fixme: this is dangerous - should we really support this function?
  65         PVE::CephTools::purge_all_ceph_files();
  66
  67         return undef;
  68     }});
  69
  70 __PACKAGE__->register_method ({
  71     name => 'install',
  72     path => 'install',
  73     method => 'POST',
  74     description => "Install ceph related packages.",
  75     parameters => {
  76         additionalProperties => 0,
  77         properties => {
  78             version => {
  79                 type => 'string',
  80                 #enum => ['hammer', 'jewel'], # for jessie
  81                 enum => ['luminous',], # for stretch
  82                 optional => 1,
  83             }
  84         },
  85     },
  86     returns => { type => 'null' },
  87     code => sub {
  88         my ($param) = @_;
  89
  90         my $cephver = $param->{version} || 'luminous';
  91
  92         local $ENV{DEBIAN_FRONTEND} = 'noninteractive';
  93
  94         if ($cephver eq 'luminous') {
  95             PVE::Tools::file_set_contents("/etc/apt/sources.list.d/ceph.list",
  96                 "deb http://download.proxmox.com/debian/ceph-luminous stretch main\n");
  97         } else {
  98             # use fixed devel repo for now, because there is no officila repo for jessie
  99             my $devrepo = undef;
 100
 101             my $keyurl = $devrepo ?
 102                 "https://git.ceph.com/?p=ceph.git;a=blob_plain;f=keys/autobuild.asc" :
 103                 "https://git.ceph.com/?p=ceph.git;a=blob_plain;f=keys/release.asc";
 104
 105             print "download and import ceph repository keys\n";
 106
 107             # Note: wget on Debian wheezy cannot handle new ceph.com certificates, so
 108             # we use LWP::UserAgent
 109             #system("wget -q -O- '$keyurl'| apt-key add - 2>&1 >/dev/null") == 0 ||
 110             #die "unable to download ceph release key\n";
 111
 112             my $tmp_key_file = "/tmp/ceph-release-keys.asc";
 113             my $ua = LWP::UserAgent->new(protocols_allowed => ['http', 'https'], timeout => 120);
 114             $ua->env_proxy;
 115             my $response = $ua->get($keyurl);
 116             if ($response->is_success) {
 117                 my $data = $response->decoded_content;
 118                 PVE::Tools::file_set_contents($tmp_key_file, $data);
 119             } else {
 120                 die "unable to download ceph release key: " . $response->status_line . "\n";
 121             }
 122
 123             system("apt-key add $tmp_key_file 2>&1 >/dev/null") == 0 ||
 124                 die "unable to download ceph release key\n";
 125
 126             unlink $tmp_key_file;
 127
 128             my $source = $devrepo ?
 129                 "deb http://gitbuilder.ceph.com/ceph-deb-jessie-x86_64-basic/ref/$devrepo jessie main\n" :
 130                 "deb http://download.ceph.com/debian-$cephver jessie main\n";
 131
 132             PVE::Tools::file_set_contents("/etc/apt/sources.list.d/ceph.list", $source);
 133         }
 134
 135         print "update available package list\n";
 136         eval { run_command(['apt-get', '-q', 'update'], outfunc => sub {}, errfunc => sub {}); };
 137
 138         system('apt-get', '--no-install-recommends',
 139                 '-o', 'Dpkg::Options::=--force-confnew',
 140                 'install', '--',
 141                 'ceph', 'ceph-common', 'gdisk');
 142
 143         if (PVE::CephTools::systemd_managed() && ! -e '/etc/systemd/system/ceph.service') {
 144             #to disable old SysV init scripts.
 145             print "replacing ceph init script with own ceph.service\n";
 146             eval {
 147                 PVE::Tools::run_command('cp -v /usr/share/doc/pve-manager/examples/ceph.service /etc/systemd/system/ceph.service');
 148                 PVE::Tools::run_command('systemctl daemon-reload');
 149                 PVE::Tools::run_command('systemctl enable ceph.service');
 150             };
 151             warn "could not install ceph.service\n" if $@;
 152         }
 153
 154         return undef;
 155     }});
 156
 157 our $cmddef = {
 158     init => [ 'PVE::API2::Ceph', 'init', [], { node => $nodename } ],
 159     lspools => [ 'PVE::API2::Ceph', 'lspools', [], { node => $nodename }, sub {
 160         my $res = shift;
 161
 162         printf("%-20s %10s %10s %20s\n", "Name", "size", "pg_num", "used");
 163         foreach my $p (sort {$a->{pool_name} cmp $b->{pool_name}} @$res) {
 164             printf("%-20s %10d %10d %20d\n", $p->{pool_name}, $p->{size}, $p->{pg_num}, $p->{bytes_used});
 165         }
 166     }],
 167     createpool => [ 'PVE::API2::Ceph', 'createpool', ['name'], { node => $nodename }],
 168     destroypool => [ 'PVE::API2::Ceph', 'destroypool', ['name'], { node => $nodename } ],
 169     createosd => [ 'PVE::API2::CephOSD', 'createosd', ['dev'], { node => $nodename }, $upid_exit],
 170     destroyosd => [ 'PVE::API2::CephOSD', 'destroyosd', ['osdid'], { node => $nodename }, $upid_exit],
 171     createmon => [ 'PVE::API2::Ceph', 'createmon', [], { node => $nodename }, $upid_exit],
 172     destroymon => [ 'PVE::API2::Ceph', 'destroymon', ['monid'], { node => $nodename }, $upid_exit],
 173     createmgr => [ 'PVE::API2::Ceph', 'createmgr', [], { node => $nodename }, $upid_exit],
 174     destroymgr => [ 'PVE::API2::Ceph', 'destroymgr', ['id'], { node => $nodename }, $upid_exit],
 175     start => [ 'PVE::API2::Ceph', 'start', ['service'], { node => $nodename }, $upid_exit],
 176     stop => [ 'PVE::API2::Ceph', 'stop', ['service'], { node => $nodename }, $upid_exit],
 177     install => [ __PACKAGE__, 'install', [] ],
 178     purge => [  __PACKAGE__, 'purge', [] ],
 179     status => [ 'PVE::API2::Ceph', 'status', [], { node => $nodename }, sub {
 180         my $res = shift;
 181         my $json = JSON->new->allow_nonref;
 182         print $json->pretty->encode($res) . "\n";
 183     }],
 184 };
 185
 186 1;