Packages

ferricstore

0.9.1
0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.8.0 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.2.0 0.1.0

FerricFlow durable workflows and queues with native-protocol storage, Raft durability, and Bitcask persistence.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
10 Dependencies
Dependants
Files
Activity
ferricstore lib ferricstore store segment_lock.ex
Raw

lib/ferricstore/store/segment_lock.ex 

defmodule Ferricstore.Store.SegmentLock do

  @moduledoc false



  @spec with_lock(binary(), (-> result)) :: result | {:error, term()} when result: term()

  def with_lock(path, fun) when is_binary(path) and is_function(fun, 0) do

    resource = {__MODULE__, Path.expand(path)}



    case :global.trans({resource, self()}, fun, [node()]) do

      {:aborted, reason} -> {:error, {:segment_lock_aborted, reason}}

      result -> result

    end

  end

end