Docs GODI Archive
Projects Blog Knowledge

Look up function:

(e.g. "List.find" or "keysym")
More options

Module Nn_push


module Nn_push: sig .. end
Push updates to the slaves (client)

type client = Rpc_proxy.ManagedClient.mclient 
type commit_id = int 
val create_client : Rpc_client.connector ->
Pfs_auth.client_auth -> float -> Unixqueue.event_system -> client
Creates a new client. The float arg is the message timeout
val begin_transaction_e : client ->
commit_id -> string -> string -> unit Uq_engines.engine
Starts the transaction: begin_transaction_e c clustername exp_rev. Also transmits the datastore cache (set_ds_cache).
val push_e : Nn_db.modification ->
client -> commit_id -> unit Uq_engines.engine
Pushes the db modification to the slave which the client connects to
val prepare_commit_e : client -> commit_id -> bool Uq_engines.engine
Prepares the commit. The resulting bool value is true if the commit is possible and allowed.
val commit_e : client -> commit_id -> unit Uq_engines.engine
Commits the transaction
val trigger_shutdown : client -> unit
Triggers the shutdown of this client
val wait_until_ready_e : Rpc_client.connector -> Unixqueue.event_system -> unit Uq_engines.engine
Busy-waits until the nameslave program is available
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml