Class: Wsman

Inherits:
Object
  • Object
show all
Defined in:
lib/wsman.rb,
lib/wsman/version.rb

Constant Summary collapse

BIOS_SVC_CLASS = 
"DCIM_BIOSService"
RAID_SVC_CLASS = 
"DCIM_RAIDService"
JOB_SVC_CLASS = 
"DCIM_JOBService"
LC_SVC_CLASS = 
"DCIM_LCService"
SOFT_SVC_CLASS = 
"DCIM_SoftwareInstallationService"
BASE_URI = 
"http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2"
URI_NS = 
"#{BASE_URI}/root/dcim"
SOFT_IDEN_URI = 
"#{URI_NS}/DCIM_SoftwareIdentity"
SOFT_SVC_URI = 
"#{URI_NS}/DCIM_SoftwareInstallationService"
SYS_VIEW_URI = 
"#{URI_NS}/DCIM_SystemView"
BIOS_ENUM_URI = 
"#{URI_NS}/DCIM_BIOSEnumeration"
CHANGE_BOOT_ORDER_CMD = 
"ChangeBootOrderByInstanceID"
CHANGE_BOOT_STATE_CMD = 
"ChangeBootSourceState"
RETURN_CFG_OK = 
0
RETURN_VAL_OK = 
'0'
RETURN_CONFIG_VAL_OK = 
4096
RETURN_CFG_JOB = 
4096
RETURN_VAL_FAIL = 
'2'
RETURN_VAL_NO_ACTION = 
'-1'
ENUMERATE_CMD = 
'enumerate'
VERSION = 
'0.0.3'

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ Wsman

Returns a new instance of Wsman.



38
39
40
41
42
43
44
45
 
# File 'lib/wsman.rb', line 38

def initialize(opts = {})
  @host = opts[:host]
  @user = opts[:user]
  @password = opts[:password]
  @port = opts[:port] || 443
  @debug_time = opts[:debug_time] || false
  @debug = opts[:debug] || false
end

Instance Attribute Details

#debug_time ⇒ Object (readonly)

Returns the value of attribute debug_time.



36
37
38
 
# File 'lib/wsman.rb', line 36

def debug_time
  @debug_time
end

#host ⇒ Object (readonly)

Returns the value of attribute host.



32
33
34
 
# File 'lib/wsman.rb', line 32

def host
  @host
end

#password ⇒ Object (readonly)

Returns the value of attribute password.



34
35
36
 
# File 'lib/wsman.rb', line 34

def password
  @password
end

#port ⇒ Object (readonly)

Returns the value of attribute port.



35
36
37
 
# File 'lib/wsman.rb', line 35

def port
  @port
end

#user ⇒ Object (readonly)

Returns the value of attribute user.



33
34
35
 
# File 'lib/wsman.rb', line 33

def user
  @user
end

Class Method Details

.certname(host) ⇒ Object 



47
48
49
 
# File 'lib/wsman.rb', line 47

def self.certname(host)
  "/tmp/cer-#{host}.cer"
end

.setup_env(host, user, password) ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/wsman.rb', line 51

def self.setup_env(host, user, password)
  filename = self.class.certname(host)
  return true if File.exists?(filename)

  output = %x{ping -W 3 -c 2 #{host} 2>/dev/null >/dev/null}

  if $?.exitstatus != 0
    puts "Failed to ping host: #{host}"
    return false
  end

  output = %x{echo | openssl s_client -connect #{host}:443 2>&1 | sed -ne '/-BEGIN CERTIFICATE-/,/-END CERTIFICATE-/p' >#{filename} 2>&1}

  if $?.exitstatus != 0
    puts output
    return false
  end

  true
end

Instance Method Details

#change_boot_source_state(boot_src_list, state) ⇒ Object 



686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
 
# File 'lib/wsman.rb', line 686

def change_boot_source_state(boot_src_list, state)
  ret_val = false
  return_val = RETURN_VAL_FAIL

  boot_svc_uri = "#{URI_NS}/DCIM_BootConfigSetting?InstanceID=UEFI"

  cmd = "invoke -a #{CHANGE_BOOT_STATE_CMD}"
  input_file = "/tmp/#{CHANGE_BOOT_STATE_CMD}.xml"
  if boot_src_list and boot_src_list.length > 0
    ret_val = write_enable_boot_src_file(input_file, state, boot_src_list)

    if ret_val
      output = self.command(cmd, boot_svc_uri , "-J #{input_file}")

      if output
        puts "DBG: Output from #{CHANGE_BOOT_STATE_CMD} is #{output}"
        return_val = self.current_value(output, CHANGE_BOOT_STATE_CMD)
      end
    else
      puts "DBG: Failed to create boot source enablement input file"
    end
  else
    puts "DBG: No boot sources to change state on"
  end

  return_val
end

#clear_all_jobs ⇒ Object 



145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
 
# File 'lib/wsman.rb', line 145

def clear_all_jobs
  job_svc_uri = find_instance_uri(JOB_SVC_CLASS)
  output = self.command("invoke -a DeleteJobQueue",job_svc_uri, " -m 256 -k JobID=\"JID_CLEARALL\"")

  return false unless output

  hash = XmlSimple.xml_in(output, "ForceArray" => false)
  t = hash["Body"]

  if t["Fault"]
    return false, t["Fault"]
  end

  if t["DeleteJobQueue_OUTPUT"]["ReturnValue"].instance_of? Hash
    return true, "nil value"
  end

  ret = t["DeleteJobQueue_OUTPUT"]["ReturnValue"].to_i == 0 rescue false
  return ret, t["DeleteJobQueue_OUTPUT"]["Message"]
end

#command(action, url, args = "", count = 0) ⇒ Object 



83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/wsman.rb', line 83

def command(action, url, args = "", count = 0)
  retVal = self.setup_env

  if !retVal
    puts "Unable to ping system...exiting"
    return false
  end

  filename = self.class.certname(@host)
  output = ""
  ret = 0
  stdargs = "-N root/dcim -v -V -o -j utf-8 -y basic"

  self.measure_time "WSMAN #{action} #{url} call" do
    cmd = "wsman #{action} #{url} -h #{@host} -P #{@port} -u #{@user} -p #{@password} -c #{filename} #{stdargs} #{args} 2>&1"
    output = %x{#{cmd}}
    ret = $?.exitstatus
  end

  if ret != 0
    puts "wsman command failed: #{action}"
    puts output

    return false
  end

  if output =~ /Connection failed. response code = 0/
    return false if count >= 3

    puts "Retrying the command: #{count} #{action}"
    sleep 20

    return command(action, url, args, count + 1)
  end

  return output
end

#create_reboot_job ⇒ Object 



389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
 
# File 'lib/wsman.rb', line 389

def create_reboot_job
  retVal = false
  jobID = ""

  puts "Creating reboot job for stacking in job queue..."

  method = "CreateRebootJob"
  cmd  = "#{INVOKE_CMD} -a #{method}"
  instURI = find_instance_uri(JOB_SVC_CLASS)
  output = self.command(cmd, instURI , "-k RebootJobType=3")

  puts "Debug: create reboot job failed no output" unless output
  return [ false, "Failed to create update job" ] unless output

  retVal = self.current_value(output,method)

  if retVal.to_i == RETURN_CFG_OK
    puts "No RID returned...invocation of createrebootjob failed"
  elsif retVal.to_i == RETURN_CFG_JOB
    wsInstance = self.process_response(output, '["Body"]["CreateRebootJob_OUTPUT"]["Job"]')
    jobID = get_job_id(wsInstance)
    retVal = true
  else
    puts "Error encountered in job creation..."
  end

  [retVal, jobID]
end

#create_targeted_config_job(svc_class_uri, fqdd) ⇒ Object 



456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
 
# File 'lib/wsman.rb', line 456

def create_targeted_config_job(svc_class_uri, fqdd)
  puts "Creating targeted config job..."

  cmd = "#{INVOKE_CMD} -a CreateTargetedConfigJob -k Target=#{fqdd} -k ScheduledStartTime=TIME_NOW -k RebootJobType=1"
  output = self.command(cmd, svc_class_uri)
  returnVal = self.current_value(output, "CreateTargetedConfigJob")

  if returnVal.to_i == RETURN_CFG_JOB
    puts "Successfully created a config job..."

    wsInstance = self.process_response(output,'["Body"]["CreateTargetedConfigJob_OUTPUT"]["Job"]')
    jobURI = get_job_selector(wsInstance)

    if jobURI.nil?
      puts "Unable to parse JID for targeted config job on #{fqdd}...Exiting"
    else
      poll_job_for_completion(jobURI)
    end
  end
end

#create_update_reboot_job ⇒ Object 



350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
 
# File 'lib/wsman.rb', line 350

def create_update_reboot_job
  retVal = false
  jobID = ""

  puts "Creating reboot job for updates..."

  method = "CreateRebootJob"
  inputFile = "/tmp/#{method}.xml"

  File.open(inputFile, "w+") do |ff|
    ff.write %Q[
      <p:#{method}_INPUT xmlns:p="#{URI_NS}/DCIM_SoftwareInstallationService">
        <p:RebootJobType>3</p:RebootJobType>
      </p:#{method}_INPUT>
    ]
  end

  cmd = "#{INVOKE_CMD} -a #{method}"
  instURI = find_instance_uri(SOFT_SVC_CLASS)
  output = self.command(cmd, instURI , "-J #{inputFile}")

  puts "Debug: create reboot job failed no output" unless output
  return [ false, "Failed to create update job" ] unless output

  retVal = self.current_value(output,method)

  if retVal.to_i == RETURN_CFG_OK
    puts "No RID returned...invocation of downgrade failed"
  elsif retVal.to_i == RETURN_CFG_JOB
    wsInstance = self.process_response(output, '["Body"]["CreateRebootJob_OUTPUT"]["RebootJobID"]')
    jobID = get_job_id(wsInstance)
    retVal = true
  else
    puts "Error encountered in job creation..."
  end

  [retVal, jobID]
end

#current_value(xml, cmd) ⇒ Object 



743
744
745
746
 
# File 'lib/wsman.rb', line 743

def current_value(xml,cmd)
  path = '["Body"]["' + cmd + '_OUTPUT"]["ReturnValue"]'
  process_response(xml , path)
end

#enable_boot_sources(boot_src_list) ⇒ Object 



673
674
675
676
677
678
679
680
681
682
683
684
 
# File 'lib/wsman.rb', line 673

def enable_boot_sources(boot_src_list)
  return_val = false
  flip_state = 1

  if boot_src_list and boot_src_list.length > 0
    return_val = change_boot_source_state(boot_src_list, flip_state)
  else
    puts "DBG: No boot sources to enable"
  end

  return_val
end

#find_base_instance_uri(serviceClass) ⇒ Object 



231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
 
# File 'lib/wsman.rb', line 231

def find_base_instance_uri(serviceClass)
  url = "#{BASE_URI}/#{serviceClass}"
  xml = self.command(ENUMERATE_CMD, url, " -m 512 -M epr")
  selectorStr = "#{url}?"
  content = self.process_response(xml,'["Body"]["EnumerateResponse"]["Items"]')

  if content
    selectorSet = content["EndpointReference"]["ReferenceParameters"]["SelectorSet"]

    selectorSet["Selector"].each do |selector|
      selectorStr += "," unless selectorStr == "#{url}?"
      selectorStr += selector["Name"] + "=" + selector["content"] unless selector["Name"] == "__cimnamespace"
    end
  end

  selectorStr
end

#find_instance_uri(serviceClass) ⇒ Object 



213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
 
# File 'lib/wsman.rb', line 213

def find_instance_uri(serviceClass)
  url = "#{URI_NS}/#{serviceClass}"
  xml = self.command("enumerate", url, " -m 512 -M epr")
  selectorStr = "#{url}?"
  content = self.process_response(xml,'["Body"]["EnumerateResponse"]["Items"]')

  if content
    selectorSet = content["EndpointReference"]["ReferenceParameters"]["SelectorSet"]

    selectorSet["Selector"].each do |selector|
      selectorStr += "," unless selectorStr == "#{url}?"
      selectorStr += selector["Name"] + "=" + selector["content"] unless selector["Name"] == "__cimnamespace"
    end
  end

  selectorStr
end

#find_instance_uri_from_objepr(content) ⇒ Object 



249
250
251
252
253
254
255
256
257
258
259
260
261
262
 
# File 'lib/wsman.rb', line 249

def find_instance_uri_from_objepr(content)
  selectorStr = "?"

  if content
    selectorSet = content["EndpointReference"]["ReferenceParameters"]["SelectorSet"]

    selectorSet["Selector"].each do |selector|
      selectorStr += "," unless selectorStr == "?"
      selectorStr += selector["Name"] + "=" + selector["content"] unless selector["Name"] == "__cimnamespace"
    end
  end

  selectorStr
end

#get_bios_boot_source_settings ⇒ Object 



576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
 
# File 'lib/wsman.rb', line 576

def get_bios_boot_source_settings
  puts "Determining BIOS boot source settings."

  bss = nil
  biosbss = []

  url = "#{URI_NS}/DCIM_BootSourceSetting"
  xml = self.command(ENUMERATE_CMD, url, "-m 512")

  if xml
    bss = self.process_response(xml, '["Body"]["EnumerateResponse"]["Items"]["DCIM_BootSourceSetting"]')

    if bss
      bss.each do |setting|
        if setting['BootSourceType'] and (setting['BootSourceType'] == "IPL" or setting['BootSourceType'] == "BCV")
          biosbss << setting
        end
      end
    end
  else
    puts "No boot source settings found...Returning empty array of boot source settings"
  end

  biosbss
end

#get_current_and_pending_bootmode ⇒ Object 



525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
 
# File 'lib/wsman.rb', line 525

def get_current_and_pending_bootmode
  current_mode = nil
  pending_mode = nil

  begin
    output = self.command(
      ENUMERATE_CMD,
      BIOS_ENUM_URI,
      " -m 512 --dialect \"http://schemas.dmtf.org/wbem/cql/1/dsp0202.pdf\" --filter \"select * from DCIM_BIOSEnumeration where AttributeName='BootMode'\" "
    )

    if output
      wsInstance = self.process_response(output, '["Body"]["EnumerateResponse"]["Items"]')
      current_mode = wsInstance["DCIM_BIOSEnumeration"]["CurrentValue"]
      pending_mode = wsInstance["DCIM_BIOSEnumeration"]["PendingValue"]
    else
      puts "No data returned from enumeration of boot mode attribute"
    end
  rescue Exception => e
    puts "Exception determining boot mode...#{e.message}"
  end

  [current_mode, pending_mode]
end

#get_job_id(instHash) ⇒ Object 



282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
 
# File 'lib/wsman.rb', line 282

def get_job_id(instHash)
  jobID = ""
  selectorSet = ""
  testFor12G = instHash["EndpointReference"]

  if testFor12G.nil?
    selectorSet = instHash["ReferenceParameters"]["SelectorSet"]
  else
    selectorSet = instHash["EndpointReference"]["ReferenceParameters"]["SelectorSet"]
  end

  if selectorSet["Selector"].is_a?(Array)
    selectorSet["Selector"].each do |selector|
      if !selector.nil?
        jobID = selector["content"] if selector["Name"] != "__cimnamespace"
      end
    end
  elsif selectorSet["Selector"].is_a?(Hash)
    jobID = selectorSet["Selector"]["content"]
  end

  puts "parsed job id string is #{jobID}"
  jobID
end

#get_job_selector(instHash) ⇒ Object 



307
308
309
310
311
312
313
314
315
316
317
318
 
# File 'lib/wsman.rb', line 307

def get_job_selector(instHash)
  puts "Parsing job selector string"

  selectorStr = instHash["ReferenceParameters"]["ResourceURI"] + "?"
  selectorSet = instHash["ReferenceParameters"]["SelectorSet"]

  selectorSet["Selector"].each do |selector|
    selectorStr += selector["Name"] + "=" + selector["content"] unless selector["Name"] == "__cimnamespace"
  end

  selectorStr
end

#get_job_status(jid) ⇒ Object 



166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
 
# File 'lib/wsman.rb', line 166

def get_job_status(jid)
  output = self.command("get","#{URI_NS}/DCIM_LifecycleJob?InstanceID=#{jid}")
  return false unless output

  hash = XmlSimple.xml_in(output, "ForceArray" => false)
  t = hash["Body"]
  if t["Fault"]
    return false, t["Fault"]["Reason"]["Text"]["content"]
  end

  js = t["DCIM_LifecycleJob"]["JobStatus"]
  if js == "New"
    if t["DCIM_LifecycleJob"]["MessageID"] == "RED023"
      return false, "In Use"
    end
  end

  return true, js
end

#get_selector_string(instHash) ⇒ Object 



264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
 
# File 'lib/wsman.rb', line 264

def get_selector_string(instHash)
  selectorStr = ""
  selectorSet = instHash["EndpointReference"]["ReferenceParameters"]["SelectorSet"]

  if selectorSet["Selector"].is_a?(Array)
    selectorSet["Selector"].each do |selector|
      if (!selector.nil?)
        selectorStr += %Q[<w:Selector Name="#{selector["Name"]}">#{selector["content"]}</w:Selector>] unless selector["Name"] == "__cimnamespace"
      end
    end
  elsif selectorSet["Selector"].is_a?(Hash)
    selectorStr += %Q[<w:Selector Name="#{selectorSet["Selector"]["Name"]}">#{selectorSet["Selector"]["content"]}</w:Selector>]
  end

  puts "selector string is #{selectorStr}"
  selectorStr
end

#get_uefi_boot_source_settings ⇒ Object 



550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
 
# File 'lib/wsman.rb', line 550

def get_uefi_boot_source_settings
  puts "Determining UEFI boot source settings."

  bss = nil
  uefibss = []

  url = "#{URI_NS}/DCIM_BootSourceSetting"
  xml = self.command(ENUMERATE_CMD, url, "-m 512")

  if xml
    bss = self.process_response(xml, '["Body"]["EnumerateResponse"]["Items"]["DCIM_BootSourceSetting"]')

    if bss
      bss.each do |setting|
        if setting['BootSourceType'] and setting['BootSourceType'] == "UEFI"
          uefibss << setting
        end
      end
    end
  else
    puts "No boot source settings found...Returning empty array of boot source settings"
  end

  uefibss
end

#is_RS_ready? ⇒ Boolean

Returns:

  • (Boolean) 


186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
 
# File 'lib/wsman.rb', line 186

def is_RS_ready?
  lc_svc_uri = find_instance_uri(LC_SVC_CLASS)
  output = self.command("invoke -a GetRSStatus", lc_svc_uri)

  return false unless output

  hash = XmlSimple.xml_in(output, "ForceArray" => false)
  t = hash["Body"]

  if t["Fault"]
    return false, t["Fault"]
  end

  if t["GetRSStatus_OUTPUT"]["ReturnValue"].instance_of? Hash
    return true, "Ready"
  end

  if t["GetRSStatus_OUTPUT"]["ReturnValue"] != "0"
    return false, t["GetRSStatus_OUTPUT"]["Message"]
  end

  status = t["GetRSStatus_OUTPUT"]["Status"]
  puts "Status from getrsstatus is #{status}"

  return status == "Ready", status
end

#measure_time(msg) ⇒ Object 



72
73
74
75
76
 
# File 'lib/wsman.rb', line 72

def measure_time(msg)
  start = Time.now if @debug_time
  yield
  puts "#{msg}: #{Time.now - start}" if @debug_time
end

#poll_job_for_completion(uri) ⇒ Object 



502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
 
# File 'lib/wsman.rb', line 502

def poll_job_for_completion(uri)
  puts "Polling config job status... "

  for i in 0..20
    output = self.command("get", uri)
    jobStatus = self.process_response(output, '["Body"]["DCIM_LifecycleJob"]["JobStatus"]')

    if jobStatus.downcase =~ /completed/
      puts "Job completed successfully...."
      break
    elsif jobStatus.downcase =~ /fail/
      failReason = self.process_response(output,'["Body"]["DCIM_LifecycleJob"]["Message"]')
      failReasonID = self.process_response(output,'["Body"]["DCIM_LifecycleJob"]["MessageID"]')

      puts "Job failed..#{failReasonID}:#{failReason}"
      break
    else
      puts "Job status = #{jobStatus}...Continue to poll"
      sleep(30)
    end
  end
end

#poll_multiple_jobs(jobArray) ⇒ Object 



477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
 
# File 'lib/wsman.rb', line 477

def poll_multiple_jobs(jobArray)
  while jobArray.length != 0
    jobArray.each do |jobID|
      puts "Polling job id #{jobID}"

      jobURI = "#{URI_NS}/DCIM_LifecycleJob?InstanceID=#{jobID}"
      output = self.command("get", jobURI)
      jobStatus = self.process_response(output,'["Body"]["DCIM_LifecycleJob"]["JobStatus"]')

      if jobStatus.downcase =~ /.*completed.*/
        puts "Job #{jobID} completed successfully...."
        jobArray.delete(jobID)
      elsif jobStatus.downcase =~ /fail/
        failReason = self.process_response(output,'["Body"]["DCIM_LifecycleJob"]["Message"]')
        failReasonID = self.process_response(output,'["Body"]["DCIM_LifecycleJob"]["MessageID"]')
        puts "Job failed..#{failReasonID}:#{failReason}"
        jobArray.delete(jobID)
      else
        puts "Job status = #{jobStatus}...Continue to poll"
        sleep(30)
      end
    end
  end
end

#power_down_system ⇒ Object 



320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
 
# File 'lib/wsman.rb', line 320

def power_down_system
  retVal = false
  method = "RequestStateChange"

  xml = self.command(ENUMERATE_CMD, CS_INST_URI, " -m 512 -M objepr")
  instanceList = self.process_response(xml,'["Body"]["EnumerateResponse"]["Items"]["Item"]')
  instanceList = (instanceList.instance_of?(Array)) ? instanceList : [instanceList]

  instanceList.each do |instance|
    if instance.is_a?(Hash)
      classNames = instance.keys
      classNames.delete("EndpointReference")

      if (instance[classNames[0]]['Dedicated']).to_i == 0
        newcsinst = "#{URI_NS}/#{classNames[0]}"
        csuri = newcsinst + find_instance_uri_from_objepr(instance)

        xml = self.command("#{INVOKE_CMD} -a #{method} -k RequestedState='3'", csuri)
        returnVal = self.current_value(xml,method)

        if returnVal.to_i == RETURN_CFG_OK
          retVal = true
        end
      end
    end
  end

  retVal
end

#process_response(xml, path, options = { "ForceArray" => false }) ⇒ Object 



738
739
740
741
 
# File 'lib/wsman.rb', line 738

def  process_response(xml, path, options = { "ForceArray" => false })
  hash = XmlSimple.xml_in(xml, options)
  eval("hash#{path}")
end

#schedule_job(jid, time) ⇒ Object 



121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
 
# File 'lib/wsman.rb', line 121

def schedule_job(jid, time)
  job_svc_uri = find_instance_uri(JOB_SVC_CLASS)
  output = self.command("invoke -a SetupJobQueue",job_svc_uri, " -k JobArray=\"#{jid}\" -k StartTimeInterval=\"#{time}\"")

  return false unless output

  hash = XmlSimple.xml_in(output, "ForceArray" => false)
  t = hash["Body"]

  if t["Fault"]
    return false, t["Fault"]
  end

  if t["SetupJobQueue_OUTPUT"]["ReturnValue"].instance_of? Hash
    return true, "nil value"
  end

  if t["SetupJobQueue_OUTPUT"]["ReturnValue"] != "0"
    return false, t["SetupJobQueue_OUTPUT"]["Message"]
  end

  return true, 0
end

#set_boot_sources(boot_mode, boot_source_settings, nic_first = true) ⇒ Object 



602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
 
# File 'lib/wsman.rb', line 602

def set_boot_sources(boot_mode, boot_source_settings, nic_first = true)
  puts "Setting boot sources - #{boot_mode}, #{nic_first}"

  boot_source_list = []
  emb_nics = []
  int_nics = []
  all_other_nics = []
  other_boot_srcs = []
  enable_nic_srcs = []

  return boot_source_list if not boot_source_settings or boot_source_settings.length == 0
  return boot_source_list if boot_mode != "UEFI" and boot_mode != "BIOS"

  if nic_first
    boot_source_settings.each do |bss|
      boot_src_instance_id = bss['InstanceID']
      puts "DBG: Processing boot source - #{boot_src_instance_id}"

      emb_nics << boot_src_instance_id if boot_src_instance_id.include?("NIC.Embedded")
      int_nics << boot_src_instance_id if boot_src_instance_id.include?("NIC.Integrated")
      all_other_nics << boot_src_instance_id if boot_src_instance_id.include?("NIC") and !emb_nics.include?(boot_src_instance_id) and !int_nics.include?(boot_src_instance_id)
      other_boot_srcs << boot_src_instance_id if !emb_nics.include?(boot_src_instance_id) and !int_nics.include?(boot_src_instance_id) and !all_other_nics.include?(boot_src_instance_id)

      if boot_src_instance_id and !other_boot_srcs.include?(boot_src_instance_id)
        if boot_mode == "UEFI"
          puts "DBG: Current state of #{boot_src_instance_id} is #{bss['CurrentEnabledStatus'].to_i}"
          enable_nic_srcs << boot_src_instance_id if bss['CurrentEnabledStatus'].to_i == 0
        else
          puts "Not enabling or checking disabled boot sources for BIOS boot mode"
        end
      end
    end

    boot_source_list = emb_nics.sort if emb_nics and emb_nics.length > 0
    boot_source_list = boot_source_list | int_nics.sort if int_nics and int_nics.length > 0
    boot_source_list = boot_source_list | all_other_nics.sort if all_other_nics and all_other_nics.length > 0
    boot_source_list = boot_source_list | other_boot_srcs.sort if other_boot_srcs and other_boot_srcs.length > 0
  else
    puts "nic_first = false. Returning current boot order"
    boot_source_list = boot_source_settings
  end

  puts "DBG: Re-ordered boot source settings list is #{boot_source_list}"
  puts "DBG: Disabled boot source list is #{enable_nic_srcs}"

  [boot_source_list, enable_nic_srcs]
end

#setup_env ⇒ Object 



78
79
80
81
 
# File 'lib/wsman.rb', line 78

def setup_env
  retVal  = self.class.setup_env(@host, @user, @password)
  return retVal
end

#setup_job_queue_multi(jobArray) ⇒ Object 



418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
 
# File 'lib/wsman.rb', line 418

def setup_job_queue_multi(jobArray)
  retVal = false
  jobStr = ""
  method = "SetupJobQueue"

  if jobArray.nil?
    puts "Input job array is nil...exiting"
  else
    inputFile = "/tmp/#{method}.xml"

    File.open("#{inputFile}", "w+") do |ff|
      ff.write %Q[<p:#{method}_INPUT xmlns:p="#{URI_NS}/#{JOB_SVC_CLASS}">]

      jobArray.each do |jobID|
        ff.write %Q[<p:JobArray>#{jobID}</p:JobArray>]
      end

      ff.write %Q[<p:StartTimeInterval>TIME_NOW</p:StartTimeInterval>]
      ff.write %Q[</p:#{method}_INPUT>]
    end

    cmd = "#{INVOKE_CMD} -a #{method}"
    svcUri = find_instance_uri(JOB_SVC_CLASS)
    output = self.command(cmd, svcUri, "-J #{inputFile}")

    puts output

    returnVal = self.current_value(output,method)

    if returnVal.to_i == RETURN_CFG_OK
      puts "Successfully set up job queue"
      retVal = true
    end
  end

  retVal
end

#write_enable_boot_src_file(input_file, state, instance_ids) ⇒ Object 



714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
 
# File 'lib/wsman.rb', line 714

def write_enable_boot_src_file(input_file, state, instance_ids)
  File.open(input_file, "w+") do |f|
    f.write %Q[
      <p:#{CHANGE_BOOT_STATE_CMD}_INPUT xmlns:p="http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/root/dcim/DCIM_BootConfigSetting">
      <p:EnabledState>#{state}</p:EnabledState>
    ]

    instance_ids.each do |instance_id|
      next unless instance_id
      next if instance_id.empty?

      f.write %Q[
        <p:source>#{instance_id}</p:source>
      ]
    end

    f.write %Q[
      </p:#{CHANGE_BOOT_STATE_CMD}_INPUT>
    ]
  end

  true
end

#writeBootSourceFile(input_file, instance_ids) ⇒ Object 



650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
 
# File 'lib/wsman.rb', line 650

def writeBootSourceFile(input_file, instance_ids)
  File.open(input_file, "w+") do |f|
    f.write %Q[
      <p:#{CHANGE_BOOT_ORDER_CMD}_INPUT xmlns:p="http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/root/dcim/DCIM_BootConfigSetting">
    ]

    instance_ids.each do |instance_id|
      next unless instance_id
      next if instance_id.empty?

      f.write %Q[
        <p:source>#{instance_id}</p:source>
      ]
    end

    f.write %Q[
      </p:#{CHANGE_BOOT_ORDER_CMD}_INPUT>
    ]
  end

  true
end