|
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-API] [PATCH 3 of 3] Temporarily revert c/s 592:ea381898abee (session caching stuff)
# HG changeset patch
# User David Scott <dave.scott@xxxxxxxxxxxxx>
# Date 1264696399 0
# Node ID 857bd513232e60c1b3bf2339acfb966817f674fc
# Parent 43de234e7703f21b33442c0b716cc4d787448684
Temporarily revert c/s 592:ea381898abee (session caching stuff)
diff -r 43de234e7703 -r 857bd513232e ocaml/idl/ocaml_backend/context.ml
--- a/ocaml/idl/ocaml_backend/context.ml Thu Jan 28 16:33:19 2010 +0000
+++ b/ocaml/idl/ocaml_backend/context.ml Thu Jan 28 16:33:19 2010 +0000
@@ -45,11 +45,6 @@
match x.session_id with
| None -> failwith "Could not find a session_id"
| Some x -> x
-
-let has_session_id x =
- match x.session_id with
- | None -> false
- | Some _ -> true
let forwarded_task ctx =
ctx.forwarded_task
diff -r 43de234e7703 -r 857bd513232e ocaml/idl/ocaml_backend/context.mli
--- a/ocaml/idl/ocaml_backend/context.mli Thu Jan 28 16:33:19 2010 +0000
+++ b/ocaml/idl/ocaml_backend/context.mli Thu Jan 28 16:33:19 2010 +0000
@@ -48,7 +48,6 @@
(** [session_of_t __context] returns the session id stored in [__context]. In
case there is no session id in this
context, it fails with [Failure "Could not find a session_id"]. *)
val get_session_id : t -> API.ref_session
-val has_session_id : t -> bool
(** [get_task_id __context] returns the task id stored in [__context]. Such a
task can be either a task stored in
database or a tempory task (also called dummy). *)
diff -r 43de234e7703 -r 857bd513232e ocaml/xapi/helpers.ml
--- a/ocaml/xapi/helpers.ml Thu Jan 28 16:33:19 2010 +0000
+++ b/ocaml/xapi/helpers.ml Thu Jan 28 16:33:19 2010 +0000
@@ -94,43 +94,47 @@
(* Slave has to go back to master via network *)
Xmlrpcclient.do_secure_xml_rpc
~subtask_of
- ~use_stunnel_cache:true
+ ~use_stunnel_cache:true
~version:"1.1" ~host:(Pool_role.get_master_address ())
~port:!Xapi_globs.https_port ~path:"/" xml
(* No auth needed over unix domain socket *)
-let do_internal_login ~__context =
- let login =
- if Pool_role.is_master () then
- (fun () ->
- if Context.has_session_id __context &&
Db.Session.get_pool ~__context ~self:(Context.get_session_id __context) then
- Context.get_session_id __context
- else begin
- let rpc = make_rpc ~__context in
- let session_id =
Client.Client.Session.slave_login rpc (get_localhost ~__context)
!Xapi_globs.pool_secret in
- debug "local login done";
- session_id
- end)
- else
- (fun () ->
- let rpc = make_rpc ~__context in
- let session_id =
Client.Client.Session.slave_login rpc (get_localhost ~__context)
!Xapi_globs.pool_secret in
- debug "slave login done";
- session_id) in
- Xapi_globs.get_internal_session login
-
-let with_cached_session ~__context fn =
- try fn (do_internal_login ~__context)
- with Api_errors.Server_error (error,_) as e when error =
Api_errors.session_authentication_failed ->
- Xapi_globs.reset_internal_session_cache ();
- debug "remote client call finished with exception %s; cleaning
the session cache" (Printexc.to_string e);
- raise e
-
(** Log into pool master using the client code, call a function
passing it the rpc function and session id, logout when finished. *)
let call_api_functions ~__context f =
- let rpc = make_rpc ~__context in
- with_cached_session ~__context (fun session_id -> f rpc session_id)
+ let rpc = make_rpc ~__context in
+ let () = debug "logging into master" in
+ (* If we're the master then our existing session may be a client one without
'pool' flag set, so
+ we consider making a new one. If we're a slave then our existing session
(if we have one) must
+ have the 'pool' flag set because it would have been created for us in the
message forwarding layer
+ in the master, so we just re-use it. [If we haven't got an existing
session in our context then
+ we always make a new one *)
+ let require_explicit_logout = ref false in
+ let do_master_login () =
+ let session = Client.Client.Session.slave_login rpc (get_localhost
~__context) !Xapi_globs.pool_secret in
+ require_explicit_logout := true;
+ session
+ in
+ let session_id =
+ try
+ if Pool_role.is_master() then
+ begin
+ let session_id = Context.get_session_id __context in
+ if Db.Session.get_pool ~__context ~self:session_id
+ then session_id
+ else do_master_login ()
+ end
+ else Context.get_session_id __context
+ with _ ->
+ do_master_login ()
+ in
+ let () = debug "login done" in
+ finally
+ (fun () -> f rpc session_id)
+ (fun () ->
+ debug "remote client call finished; logging out";
+ if !require_explicit_logout
+ then Client.Client.Session.logout rpc session_id)
let call_emergency_mode_functions hostname f =
let rpc xml = Xmlrpcclient.do_secure_xml_rpc ~version:"1.0" ~host:hostname
diff -r 43de234e7703 -r 857bd513232e ocaml/xapi/message_forwarding.ml
--- a/ocaml/xapi/message_forwarding.ml Thu Jan 28 16:33:19 2010 +0000
+++ b/ocaml/xapi/message_forwarding.ml Thu Jan 28 16:33:19 2010 +0000
@@ -191,8 +191,11 @@
~port:!Xapi_globs.https_port ~path:"/" xml
let call_slave_with_session remote_rpc_fn __context host (task_opt:
API.ref_task option) f =
+ let session_id = Xapi_session.login_no_password ~__context ~uname:None ~host
~pool:true ~is_local_superuser:true ~subject:(Ref.null) ~auth_user_sid:""
~rbac_permissions:[] in
let hostname = Db.Host.get_address ~__context ~self:host in
- Helpers.with_cached_session ~__context (fun session_id -> f session_id
(remote_rpc_fn __context hostname task_opt))
+ Pervasiveext.finally
+ (fun ()->f session_id (remote_rpc_fn __context hostname task_opt))
+ (fun ()->Server_helpers.exec_with_new_task ~session_id "local logout in
message forwarder" (fun __context -> Xapi_session.logout ~__context))
let call_slave_with_local_session remote_rpc_fn __context host (task_opt:
API.ref_task option) f =
let hostname = Db.Host.get_address ~__context ~self:host in
diff -r 43de234e7703 -r 857bd513232e ocaml/xapi/xapi.ml
--- a/ocaml/xapi/xapi.ml Thu Jan 28 16:33:19 2010 +0000
+++ b/ocaml/xapi/xapi.ml Thu Jan 28 16:33:19 2010 +0000
@@ -394,7 +394,8 @@
debug "Master claims he has no record of us being a slave";
Xapi_host.set_emergency_mode_error
Api_errors.host_unknown_to_master [ localhost_uuid ];
Some Permanent
- | `ok -> None
+ | `ok ->
+ None
)
with
| Api_errors.Server_error(code, params) when code =
Api_errors.session_authentication_failed ->
diff -r 43de234e7703 -r 857bd513232e ocaml/xapi/xapi_globs.ml
--- a/ocaml/xapi/xapi_globs.ml Thu Jan 28 16:33:19 2010 +0000
+++ b/ocaml/xapi/xapi_globs.ml Thu Jan 28 16:33:19 2010 +0000
@@ -15,7 +15,6 @@
(** A central location for settings related to xapi *)
open Stringext
-open Threadext
open Printf
(* xapi process returns this code on exit when it wants to be restarted *)
@@ -23,19 +22,6 @@
let pool_secret_path = "/etc/xensource/ptoken"
let pool_secret = ref ""
-let internal_session : [`session] Ref.t option ref = ref None
-
-let internal_session_mutex = Mutex.create ()
-let get_internal_session login_fn =
- Mutex.execute internal_session_mutex (fun () ->
- match !internal_session with
- | None ->
- let session = login_fn () in
- internal_session := Some session;
- session
- | Some session -> session)
-let reset_internal_session_cache () =
- Mutex.execute internal_session_mutex (fun () -> internal_session :=
None)
let localhost_ref : [`host] Ref.t ref = ref Ref.null
6 files changed, 40 insertions(+), 52 deletions(-)
ocaml/idl/ocaml_backend/context.ml | 5 --
ocaml/idl/ocaml_backend/context.mli | 1
ocaml/xapi/helpers.ml | 64 ++++++++++++++++++-----------------
ocaml/xapi/message_forwarding.ml | 5 ++
ocaml/xapi/xapi.ml | 3 +
ocaml/xapi/xapi_globs.ml | 14 -------
Attachment:
xen-api.hg-3.patch _______________________________________________ xen-api mailing list xen-api@xxxxxxxxxxxxxxxxxxx http://lists.xensource.com/mailman/listinfo/xen-api
|
 |
Lists.xenproject.org is hosted with RackSpace, monitoring our |