Class: OsCtld::Container::RunConfiguration

Inherits:
Object
  • Object
show all
Includes:
OsCtl::Lib::Utils::File, OsCtl::Lib::Utils::Log, Lockable
Defined in:
lib/osctld/container/run_configuration.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Lockable

#exclusively, included, #inclusively, #init_lock, #lock, #unlock

Constructor Details

#initialize(ct, load_conf: true) ⇒ RunConfiguration

Returns a new instance of RunConfiguration.

Parameters:



31
32
33
34
35
36
37
38
39
40
 
# File 'lib/osctld/container/run_configuration.rb', line 31

def initialize(ct, load_conf: true)
  init_lock
  @ct = ct
  @cpu_package = nil
  @init_pid = nil
  @aborted = false
  @do_reboot = false
  @dist_network_configured = false
  self.load_conf(from_file: load_conf)
end

Instance Attribute Details

#aborted=(value) ⇒ Object (writeonly)

Sets the attribute aborted

Parameters:

  • value —

    the value to set the attribute aborted to.



135
136
137
 
# File 'lib/osctld/container/run_configuration.rb', line 135

def aborted=(value)
  @aborted = value
end

#arch ⇒ Object (readonly)

Returns the value of attribute arch



26
27
28
 
# File 'lib/osctld/container/run_configuration.rb', line 26

def arch
  @arch
end

#cpu_package ⇒ Object

Returns the value of attribute cpu_package



27
28
29
 
# File 'lib/osctld/container/run_configuration.rb', line 27

def cpu_package
  @cpu_package
end

#ct ⇒ Container (readonly)

Returns:



24
25
26
 
# File 'lib/osctld/container/run_configuration.rb', line 24

def ct
  @ct
end

#dataset ⇒ Object (readonly)

Returns the value of attribute dataset



26
27
28
 
# File 'lib/osctld/container/run_configuration.rb', line 26

def dataset
  @dataset
end

#dist_network_configured ⇒ Object

Returns the value of attribute dist_network_configured



27
28
29
 
# File 'lib/osctld/container/run_configuration.rb', line 27

def dist_network_configured
  @dist_network_configured
end

#distribution ⇒ Object (readonly)

Returns the value of attribute distribution



26
27
28
 
# File 'lib/osctld/container/run_configuration.rb', line 26

def distribution
  @distribution
end

#init_pid ⇒ Object

Returns the value of attribute init_pid



27
28
29
 
# File 'lib/osctld/container/run_configuration.rb', line 27

def init_pid
  @init_pid
end

#mounted ⇒ Object (protected)

Returns the value of attribute mounted



231
232
233
 
# File 'lib/osctld/container/run_configuration.rb', line 231

def mounted
  @mounted
end

#run_id ⇒ Container::RunId (readonly)

Returns:



21
22
23
 
# File 'lib/osctld/container/run_configuration.rb', line 21

def run_id
  @run_id
end

#variant ⇒ Object (readonly)

Returns the value of attribute variant



26
27
28
 
# File 'lib/osctld/container/run_configuration.rb', line 26

def variant
  @variant
end

#vendor ⇒ Object (readonly)

Returns the value of attribute vendor



26
27
28
 
# File 'lib/osctld/container/run_configuration.rb', line 26

def vendor
  @vendor
end

#version ⇒ Object (readonly)

Returns the value of attribute version



26
27
28
 
# File 'lib/osctld/container/run_configuration.rb', line 26

def version
  @version
end

Class Method Details

.load(ct) ⇒ Object

Parameters:



11
12
13
14
15
16
17
18
 
# File 'lib/osctld/container/run_configuration.rb', line 11

def self.load(ct)
  ctrc = new(ct, load_conf: false)

  return unless ctrc.exist?

  ctrc.load_conf
  ctrc
end

Instance Method Details

#aborted? ⇒ Boolean

Returns:

  • (Boolean) 


137
138
139
 
# File 'lib/osctld/container/run_configuration.rb', line 137

def aborted?
  @aborted
end

#assets(add) ⇒ Object 



42
43
44
45
46
47
48
49
50
51
 
# File 'lib/osctld/container/run_configuration.rb', line 42

def assets(add)
  add.file(
    file_path,
    desc: 'Container runtime configuration',
    user: 0,
    group: 0,
    mode: 0o400,
    optional: true
  )
end

#boot_from(dataset:, distribution:, version:, arch:, vendor:, variant:, destroy_dataset_on_stop: false) ⇒ Object

Set custom boot dataset



63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/osctld/container/run_configuration.rb', line 63

def boot_from(dataset:, distribution:, version:, arch:, vendor:, variant:, destroy_dataset_on_stop: false)
  exclusively do
    @dataset = dataset
    @distribution = distribution
    @version = version
    @arch = arch
    @vendor = vendor
    @variant = variant
    @destroy_dataset_on_stop = destroy_dataset_on_stop
  end
end

#destroy ⇒ Object 



223
224
225
226
227
 
# File 'lib/osctld/container/run_configuration.rb', line 223

def destroy
  File.unlink(file_path)
rescue Errno::ENOENT
  # ignore
end

#destroy_dataset_on_stop? ⇒ Boolean

Returns:

  • (Boolean) 


87
88
89
 
# File 'lib/osctld/container/run_configuration.rb', line 87

def destroy_dataset_on_stop?
  inclusively { @destroy_dataset_on_stop }
end

#dir ⇒ String

Countainer dataset mountpoint

Returns:

  • (String) 


93
94
95
 
# File 'lib/osctld/container/run_configuration.rb', line 93

def dir
  dataset.mountpoint
end

#dir_path ⇒ Object (protected) 



233
234
235
 
# File 'lib/osctld/container/run_configuration.rb', line 233

def dir_path
  File.join(ct.pool.ct_dir, ct.id)
end

#dist_configure_network? ⇒ Boolean

Returns:

  • (Boolean) 


150
151
152
153
154
 
# File 'lib/osctld/container/run_configuration.rb', line 150

def dist_configure_network?
  inclusively do
    !dist_network_configured && can_dist_configure_network?
  end
end

#dump ⇒ Object 



160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
 
# File 'lib/osctld/container/run_configuration.rb', line 160

def dump
  inclusively do
    {
      'id' => run_id.dump,
      'dataset' => dataset.to_s,
      'distribution' => distribution,
      'version' => version,
      'arch' => arch,
      'vendor' => vendor,
      'variant' => variant,
      'cpu_package' => cpu_package,
      'destroy_dataset_on_stop' => destroy_dataset_on_stop?
    }
  end
end

#exist? ⇒ Boolean

Returns:

  • (Boolean) 


156
157
158
 
# File 'lib/osctld/container/run_configuration.rb', line 156

def exist?
  File.exist?(file_path)
end

#file_path ⇒ Object (protected) 



237
238
239
 
# File 'lib/osctld/container/run_configuration.rb', line 237

def file_path
  File.join(dir_path, 'config.yml')
end

#load_conf(from_file: true) ⇒ Object 



176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
 
# File 'lib/osctld/container/run_configuration.rb', line 176

def load_conf(from_file: true)
  cfg =
    if from_file && File.exist?(file_path)
      OsCtl::Lib::ConfigFile.load_yaml_file(file_path)
    else
      {}
    end

  @run_id =
    if cfg.has_key?('id')
      Container::RunId.load(cfg['id'])
    else
      Container::RunId.new(pool_name: pool.name, container_id: id)
    end
  @dataset =
    if cfg['dataset']
      OsCtl::Lib::Zfs::Dataset.new(cfg['dataset'], base: cfg['dataset'])
    else
      ct.dataset
    end
  @distribution = cfg['distribution'] || ct.distribution
  @version = cfg['version'] || ct.version
  @arch = cfg['arch'] || ct.arch
  @vendor = cfg['vendor'] || ct.vendor
  @variant = cfg['variant'] || ct.variant
  @cpu_package = cfg['cpu_package']
  @destroy_dataset_on_stop =
    if cfg.has_key?('destroy_dataset_on_stop')
      cfg['destroy_dataset_on_stop']
    else
      false
    end
  nil
end

#mount(force: false) ⇒ Object

Mount the container’s dataset

Parameters:

  • force (Boolean) (defaults to: false) —

    ensure the datasets are mounted even if osctld already mounted them



110
111
112
113
114
115
 
# File 'lib/osctld/container/run_configuration.rb', line 110

def mount(force: false)
  return if !force && mounted

  dataset.mount(recursive: true)
  self.mounted = true
end

#mounted?(force: false) ⇒ Boolean

Check if the container’s dataset is mounted

Parameters:

  • force (Boolean) (defaults to: false) —

    check if the dataset is mounted even if osctld already mounted it

Returns:

  • (Boolean) 


120
121
122
123
124
125
126
 
# File 'lib/osctld/container/run_configuration.rb', line 120

def mounted?(force: false)
  if force || mounted.nil?
    self.mounted = dataset.mounted?(recursive: true)
  else
    mounted
  end
end

#reboot? ⇒ Boolean

Returns:

  • (Boolean) 


146
147
148
 
# File 'lib/osctld/container/run_configuration.rb', line 146

def reboot?
  @do_reboot
end

#request_reboot ⇒ Object

After the current container run stops, start it again



142
143
144
 
# File 'lib/osctld/container/run_configuration.rb', line 142

def request_reboot
  @do_reboot = true
end

#rootfs ⇒ String

Container rootfs path

Returns:

  • (String) 


99
100
101
102
103
104
105
 
# File 'lib/osctld/container/run_configuration.rb', line 99

def rootfs
  File.join(dir, 'private')
rescue SystemCommandFailed
  # Dataset for staged containers does not have to exist yet, relevant
  # primarily for ct show/list
  nil
end

#runtime_rootfs ⇒ Object 



128
129
130
131
132
133
 
# File 'lib/osctld/container/run_configuration.rb', line 128

def runtime_rootfs
  pid = init_pid
  raise 'init_pid not set' unless pid

  File.join('/proc', pid.to_s, 'root')
end

#save ⇒ Object 



211
212
213
214
215
216
217
218
219
220
221
 
# File 'lib/osctld/container/run_configuration.rb', line 211

def save
  begin
    Dir.mkdir(dir_path)
  rescue Errno::EEXIST
    # ignore
  end

  regenerate_file(file_path, 0o400) do |new|
    new.write(OsCtl::Lib::ConfigFile.dump_yaml(dump))
  end
end

#set_distribution(distribution:, version:, arch:, vendor:, variant:) ⇒ Object

Update distribution info



76
77
78
79
80
81
82
83
84
85
 
# File 'lib/osctld/container/run_configuration.rb', line 76

def set_distribution(distribution:, version:, arch:, vendor:, variant:)
  exclusively do
    @distribution = distribution
    @version = version
    @arch = arch
    @vendor = vendor
    @variant = variant
    save
  end
end