Skip to content

Commit bc22e25

Browse files
committed
Merge pull request #42 from djs55/name
Plumb through the `SR.create` name and description
2 parents f352030 + d354648 commit bc22e25

File tree

1 file changed

+28
-0
lines changed

1 file changed

+28
-0
lines changed

main.ml

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -505,6 +505,8 @@ let process root_dir name x =
505505
end
506506
| { R.name = "SR.create"; R.params = [ args ] } ->
507507
let args = Args.SR.Create.request_of_rpc args in
508+
let name_label = args.Args.SR.Create.name_label in
509+
let description = args.Args.SR.Create.name_description in
508510
let device_config = args.Args.SR.Create.device_config in
509511
begin match List.find device_config ~f:(fun (k, _) -> k = "uri") with
510512
| None ->
@@ -513,13 +515,39 @@ let process root_dir name x =
513515
let args = Storage.Volume.Types.SR.Create.In.make
514516
args.Args.SR.Create.dbg
515517
uri
518+
name_label
519+
description
516520
device_config in
517521
let args = Storage.Volume.Types.SR.Create.In.rpc_of_t args in
518522
let open Deferred.Result.Monad_infix in
519523
fork_exec_rpc root_dir (script root_dir name `Volume "SR.create") args Storage.Volume.Types.SR.Create.Out.t_of_rpc
520524
>>= fun response ->
521525
Deferred.Result.return (R.success (Args.SR.Create.rpc_of_response response))
522526
end
527+
| { R.name = "SR.set_name_label"; R.params = [ args ] } ->
528+
let open Deferred.Result.Monad_infix in
529+
let args = Args.SR.Set_name_label.request_of_rpc args in
530+
Attached_SRs.find args.Args.SR.Set_name_label.sr
531+
>>= fun sr ->
532+
let name_label = args.Args.SR.Set_name_label.new_name_label in
533+
let dbg = args.Args.SR.Set_name_label.dbg in
534+
let args = Storage.Volume.Types.SR.Set_name.In.make dbg sr name_label in
535+
let args = Storage.Volume.Types.SR.Set_name.In.rpc_of_t args in
536+
fork_exec_rpc root_dir (script root_dir name `Volume "SR.set_name") args Storage.Volume.Types.SR.Set_name.Out.t_of_rpc
537+
>>= fun () ->
538+
Deferred.Result.return (R.success (Args.SR.Set_name_label.rpc_of_response ()))
539+
| { R.name = "SR.set_name_description"; R.params = [ args ] } ->
540+
let open Deferred.Result.Monad_infix in
541+
let args = Args.SR.Set_name_description.request_of_rpc args in
542+
Attached_SRs.find args.Args.SR.Set_name_description.sr
543+
>>= fun sr ->
544+
let name_description = args.Args.SR.Set_name_description.new_name_description in
545+
let dbg = args.Args.SR.Set_name_description.dbg in
546+
let args = Storage.Volume.Types.SR.Set_description.In.make dbg sr name_description in
547+
let args = Storage.Volume.Types.SR.Set_description.In.rpc_of_t args in
548+
fork_exec_rpc root_dir (script root_dir name `Volume "SR.set_description") args Storage.Volume.Types.SR.Set_description.Out.t_of_rpc
549+
>>= fun () ->
550+
Deferred.Result.return (R.success (Args.SR.Set_name_label.rpc_of_response ()))
523551
| { R.name = "SR.destroy"; R.params = [ args ] } ->
524552
let open Deferred.Result.Monad_infix in
525553
let args = Args.SR.Destroy.request_of_rpc args in

0 commit comments

Comments
 (0)