search for: open_connection

...NECTIONS | THREAD_MODEL_SERIALIZE_ALL_REQUESTS @@ -78,10 +84,13 @@ type 'a plugin = { after_fork : (unit -> unit) option; preconnect : (bool -> unit) option; + list_exports : (bool -> bool -> export list) option; + default_export : (bool -> bool -> string) option; open_connection : (bool -> 'a) option; (* required *) close : ('a -> unit) option; get_size : ('a -> int64) option; (* required *) + export_description : ('a -> string) option; can_cache : ('a -> cache_flag) option; can_extents : ('a -&g...

...NECTIONS | THREAD_MODEL_SERIALIZE_ALL_REQUESTS @@ -78,10 +84,13 @@ type 'a plugin = { after_fork : (unit -> unit) option; preconnect : (bool -> unit) option; + list_exports : (bool -> bool -> export list) option; + default_export : (bool -> bool -> string) option; open_connection : (bool -> 'a) option; (* required *) close : ('a -> unit) option; get_size : ('a -> int64) option; (* required *) + export_description : ('a -> string) option; can_cache : ('a -> cache_flag) option; can_extents : ('a -&g...

...reen): def process_input(self, page): if page is CONNECTION_LIST_PAGE: logging.info("Changing libvirt connection to %s" % self.get_selected_connection()) - libvirtworker.set_default_url(self.get_selected_connection()) self.get_libvirt().open_connection(self.get_selected_connection()) elif page is CONNECTED_PAGE: self.set_finished() diff --git a/nodeadmin/configscreen.py b/nodeadmin/configscreen.py index 02ab5b4..7a23325 100644 --- a/nodeadmin/configscreen.py +++ b/nodeadmin/configscreen.py @@ -37,6 +37,9 @@ class ConfigScreen:...

...e "/usr/bin/virt-install", line 1004, in <module> sys.exit(main()) File "/usr/bin/virt-install", line 984, in main conn = cli.getConnection(options.connect) File "/usr/lib/python2.6/site-packages/virtinst/cli.py", line 327, in getConnection conn = open_connection(uri) File "/usr/lib/python2.6/site-packages/virtinst/cli.py", line 342, in open_connection open_flags) File "/usr/lib64/python2.6/site-packages/libvirt.py", line 102, in openAuth if ret is None:raise libvirtError(''virConnectOpenAuth() failed'') libvi...

...e "/usr/bin/virt-install", line 1004, in <module> sys.exit(main()) File "/usr/bin/virt-install", line 984, in main conn = cli.getConnection(options.connect) File "/usr/lib/python2.6/site-packages/virtinst/cli.py", line 327, in getConnection conn = open_connection(uri) File "/usr/lib/python2.6/site-packages/virtinst/cli.py", line 342, in open_connection open_flags) File "/usr/lib64/python2.6/site-packages/libvirt.py", line 102, in openAuth if ret is None:raise libvirtError(''virConnectOpenAuth() failed'') libvi...

This picks up python and ocaml. Some of our languages are lacking a number of bindings (for example, lua and perl lack .extents, so I didn't have anything to copy from), and I felt less comfortable with golang and rust. But for python and ocaml, I was able to test a working implementation. Eric Blake (2): python: Implement .list_exports and friends ocaml: Implement .list_exports and

...ent call last): File "/usr/bin/virt-install", line 943, in <module> main() File "/usr/bin/virt-install", line 715, in main conn = cli.getConnection(options.connect) File "/usr/lib/pymodules/python2.6/virtinst/cli.py", line 162, in getConnection conn = open_connection(connect) File "/usr/lib/pymodules/python2.6/virtinst/cli.py", line 177, in open_connection open_flags) File "/usr/lib/python2.6/dist-packages/libvirt.py", line 111, in openAuth if ret is None:raise libvirtError('virConnectOpenAuth() failed') libvirtError: unable...

...it a/plugins/ocaml/nbdkit-ocaml-plugin.pod b/plugins/ocaml/nbdkit-ocaml-plugin.pod index a66cf26e..4b349612 100644 --- a/plugins/ocaml/nbdkit-ocaml-plugin.pod +++ b/plugins/ocaml/nbdkit-ocaml-plugin.pod @@ -36,12 +36,11 @@ Your OCaml code should call C<NBDKit.register_plugin> like this: open_connection = Some myplugin_open; get_size = Some myplugin_get_size; pread = Some myplugin_pread; + thread_model = Some (fun () -> NBDKit.THREAD_MODEL_SERIALIZE_CONNECTIONS); (* etc *) } - let thread_model = NBDKit.THREAD_MODEL_SERIALIZE_CONNECTIONS - - let ()...

...een) + + def process_input(self, page): + if page is CONNECTION_LIST_PAGE: + logging.info("Changing libvirt connection to %s" % self.get_selected_connection()) + libvirtworker.set_default_url(self.get_selected_connection()) + self.get_libvirt().open_connection(self.get_selected_connection()) + elif page is CONNECTED_PAGE: self.set_finished() + + def page_has_next(self, page): + if page is CONNECTION_LIST_PAGE: return self.has_selectable_connections() + return False + + def page_has_back(self, page): + return page > CO...

This set of patches have been rebased since the originals have grown stale.

This patch set includes both the host configuration patch and the node migration patch which depends on it. And the latter has a fix for missing files.

Hello ! 1) I have this error logged by bdrb: undefined method `send_request'' for nil:NilClass framework/packet_master.rb:58:in `ask_worker'' backgroundrb/server/master_worker.rb:59:in `process_work'' backgroundrb/server/master_worker.rb:16:in `receive_data'' backgroundrb/framework/bin_parser.rb:29:in `call'' backgroundrb/framework/bin_parser.rb:29:in

...een) + + def process_input(self, page): + if page is CONNECTION_LIST_PAGE: + logging.info("Changing libvirt connection to %s" % self.get_selected_connection()) + libvirtworker.set_default_url(self.get_selected_connection()) + self.get_libvirt().open_connection(self.get_selected_connection()) + elif page is CONNECTED_PAGE: self.set_finished() + + def page_has_next(self, page): + if page is CONNECTION_LIST_PAGE: return self.has_selectable_connections() + return False + + def page_has_back(self, page): + return page > CO...

I like this change. I think we were overloading the config_complete method before to do two different things (complete configuration; do any allocation/housekeeping necessary before we can start serving). The only questions in my mind are whether we want this before 1.18, and whether the name ("get_ready") is a good one. Rich.

The previous patch set had an error and one development branch's changes showed up twice, and two different change sets. So it was missing the bulk of the configuration work. This patch set fixes that.

...bf18f 100644 --- a/plugins/ocaml/NBDKit.mli +++ b/plugins/ocaml/NBDKit.mli @@ -75,6 +75,7 @@ type 'a plugin = { thread_model : (unit -> thread_model) option; get_ready : (unit -> unit) option; + after_fork : (unit -> unit) option; preconnect : (bool -> unit) option; open_connection : (bool -> 'a) option; (* required *) diff --git a/plugins/sh/methods.h b/plugins/sh/methods.h index f11e67e7..08a5ed17 100644 --- a/plugins/sh/methods.h +++ b/plugins/sh/methods.h @@ -42,6 +42,7 @@ extern const char *get_script (const char *method); extern void sh_dump_plugin (voi...

It's been several weeks since I posted v2 (I got distracted by improving libnbd to better test things, which in turn surfaced some major memory leak problems in nbdsh that are now fixed). Many of the patches are minor rebases from v2, with the biggest changes being fallout from: - patch 2: rename nbdkit_add_default_export to nbdkit_use_default_export - overall: this missed 1.22, so update

...inhttp: Change type of netconn_resolve from struct sockaddr_in * to struct sockaddr *. winhttp: Simplify netconn_resolve when using getaddrinfo. winhttp: Convert connect_t's address type from a struct sockaddr_in to a struct sockaddr_storage. winhttp: Support IPv6 addresses in open_connection. winhttp: Support IPv6 in netconn_resolve. wininet: Fix tests when running behind a proxy server. wininet: Change type of GetAddress from struct sockaddr_in * to struct sockaddr *. wininet: Simplify GetAddress when using getaddrinfo. wininet: Use struct sockaddr_storag...