package dlm

You can search for identifiers within the package.

in-package search v0.2.0

On This Page

References.
Lockspaces
Locks
Example

package dlm

dlm
- Library dlm
  - Dlm
- Library dlm.bindings
  - Dlm_bindings
    
    Bindings
    
    Types
    
    Dlm_lksb
    
    Mode
    
    Flags
    
    Make
    
    Generated_types
    
    Intptr
    
    Ptrdiff
    
    Uintptr
    
    CArray
    
    FOREIGN
    
    TYPE
    
    Root
- Library dlm.bindings-structs
  - Bindings_structs_lib
    
    Bindings_structs
    
    Make
    
    Dlm_lksb
    
    Mode
    
    Flags
- Sources
  - dlm
    
    dlm.ml
    
    dlm__.ml
    
    generated.ml
  - dlm.bindings
    
    bindings.ml
    
    dlm_bindings.ml
    
    generated_types.ml
  - dlm.bindings-structs
    
    bindings_structs.ml
    
    bindings_structs_lib.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Dlm`Source

OCaml bindings for libdlm(3).

v0.3.3 - homepage.

All operations require DLM (Linux Distributed Lock Manager) to be running.

Consult the lockspaces, and locks documentation or read the example.

References.

Programming Locking Applications.

Lockspaces

Lockspaces are identified by a cluster-wide name, they are intended as private namespaces for locks belonging to a single application.

Sourcetype t

the type of a DLM lockspace

Sourceval join : ?mode:PosixTypes.mode_t -> string -> unit Lwt.t

join ?mode lockspace creates and joins the specified lockspace on the current node.

Requires CAP_SYSADMIN privileges, access to the created lockspace is controlled by mode.

raises Unix.Unix_error
on failure

Sourceval leave : ?force:bool -> string -> unit Lwt.t

leave ?force lockspace leaves the specified lockspace on the current node.

parameter force
will leave the lockspace even if the current node has active locks

Sourceval with_lockspace : string -> f:(t -> 'a Lwt.t) -> 'a Lwt.t

with_lockspace lockspace ~f opens an existing lockspace, calls f t with the lockspace handle t, and closes the lockspace after f terminates. The lockspace is also automatically closed on process exit.

Locks

Locks are a named cluster-wide resource inside a specific lockspace.

Only a simplified interface is provided that acquires a lock, performs an operation and releases it. Locking can be nested, even with same lock name, but note that trying to acquire an exclusive lock twice will fail.

It is recommended to use the LKM_PRMODE mode for reading and LKM_EXMODE for writing.

Sourcetype mode =

| LKM_NLMODE
(*
null lock - just allocate the lock, used internally by with_lock
*)
| LKM_CRMODE
(*
concurrent read - read while others can read/write.
*)
| LKM_CWMODE
(*
concurrent write - read/write while others can read/write.
*)
| LKM_PRMODE
(*
protected read - read, while others can only read.
*)
| LKM_PWMODE
(*
protected write - read/write, while others can only read
*)
| LKM_EXMODE
(*
exclusive - exclusive read/write, others have no access
*)

lock mode

Source

val with_lock : 
  t ->
  ?mode:mode ->
  ?try_:bool ->
  ?timeout:float ->
  string ->
  f:(unit -> 'a Lwt.t) ->
  'a Lwt.t

with_lock lshandle ?mode ?try_ ?timeout lockname ~f acquires lockname in lockmode and calls f when the lock is acquired. Releases the lock after f terminates.

parameter mode
lock mode defaults to LKM_EXMODE

parameter timeout
specifies how long to wait for the lock to be acquired

parameter try_
fail with EAGAIN if the lock cannot be granted immediately

raises Unix.Unix_error
if the lock cannot be granted

Example

Need to be run as root, and with a working DLM. You can use dlm_tool status to check for a working DLM.

  #use "topfind";;
  #require "dlm";;
  open Lwt.Infix;;

  let lockspace = "myapp" in
  Dlm.join lockspace >>= fun () ->
  Dlm.with_lockspace lockspace (fun ls ->
      Dlm.with_lock ls "mylock1" ~f:(fun () ->
          (* acquired exclusive lock *)
          Lwt.return_unit
        ) >>= fun () ->
      Dlm.with_lock ~mode:Dlm.LKM_PRMODE ls "mylock1" ~f:(fun () ->
          (* acquired shared read lock *)
          Lwt.return_unit
        )
    ) >>= fun () ->
  Dlm.leave lockspace

package dlm

Module DlmSource

References.

Lockspaces

Locks

Example

Module `Dlm`Source