File 0001-quote-the-maybe-type-s-atom.patch of Package ra

Overview Repositories Revisions Requests Users Attributes Meta

File 0001-quote-the-maybe-type-s-atom.patch of Package ra (Revision e6c7a8d25b340004a5da54a5fd67ffd9)

Currently displaying revision e6c7a8d25b340004a5da54a5fd67ffd9 , Show latest

From e00c661e80504b8feea1a933aca3d2436aea3652 Mon Sep 17 00:00:00 2001
From: Michael Davis <mcarsondavis@gmail.com>
Date: Wed, 29 Jun 2022 18:20:21 -0500
Subject: [PATCH] quote the 'maybe' type's atom

diff --git a/src/ra.hrl b/src/ra.hrl
index f6faf69..14503d4 100644
--- a/src/ra.hrl
+++ b/src/ra.hrl
@@ -4,7 +4,7 @@
 %%
 %% Copyright (c) 2017-2022 VMware, Inc. or its affiliates.  All rights reserved.
 %%
--type maybe(T) :: undefined | T.
+-type 'maybe'(T) :: undefined | T.
 
 %%
 %% Most of the records here are covered on Figure 2
diff --git a/src/ra_directory.erl b/src/ra_directory.erl
index 4b7ee88..3e680bb 100644
--- a/src/ra_directory.erl
+++ b/src/ra_directory.erl
@@ -63,7 +63,7 @@ deinit(#{directory := Name,
     _ = dets:close(NameRev),
     ok.
 
--spec register_name(ra_system:names() | atom(), ra_uid(), pid(), maybe(pid()), atom(),
+-spec register_name(ra_system:names() | atom(), ra_uid(), pid(), 'maybe'(pid()), atom(),
                     ra_cluster_name()) -> ok.
 register_name(System, UId, Pid, ParentPid, ServerName, ClusterName)
   when is_atom(System) ->
@@ -131,7 +131,7 @@ where_is_parent(#{directory := Dir}, UId) when is_binary(UId) ->
         [] -> undefined
     end.
 
--spec name_of(atom() | ra_system:names(), ra_uid()) -> maybe(atom()).
+-spec name_of(atom() | ra_system:names(), ra_uid()) -> 'maybe'(atom()).
 name_of(SystemOrNames, UId) ->
     Tbl = get_name(SystemOrNames),
     case ets:lookup(Tbl, UId) of
@@ -140,7 +140,7 @@ name_of(SystemOrNames, UId) ->
     end.
 
 -spec cluster_name_of(ra_system:names() | atom(), ra_uid()) ->
-    maybe(ra_cluster_name()).
+    'maybe'(ra_cluster_name()).
 cluster_name_of(SystemOrNames, UId) ->
     Tbl = get_name(SystemOrNames),
     case ets:lookup(Tbl, UId) of
@@ -149,7 +149,7 @@ cluster_name_of(SystemOrNames, UId) ->
     end.
 
 
--spec pid_of(atom() | ra_system:names(), ra_uid()) -> maybe(pid()).
+-spec pid_of(atom() | ra_system:names(), ra_uid()) -> 'maybe'(pid()).
 pid_of(SystemOrNames, UId) ->
     case ets:lookup(get_name(SystemOrNames), UId) of
         [{_, Pid, _, _, _}] -> Pid;
diff --git a/src/ra_log.erl b/src/ra_log.erl
index 1302c0f..9d6083f 100644
--- a/src/ra_log.erl
+++ b/src/ra_log.erl
@@ -99,7 +99,7 @@
          % if this is set a snapshot write is in progress for the
          % index specified
          cache = #{} :: #{ra_index() => {ra_index(), ra_term(), log_entry()}},
-         last_resend_time :: maybe(integer()),
+         last_resend_time :: 'maybe'(integer()),
          reader :: ra_log_reader:state(),
          readers = [] :: [pid()]
         }).
@@ -517,7 +517,7 @@ next_index(#?MODULE{last_index = LastIdx}) ->
     LastIdx + 1.
 
 -spec fetch(ra_index(), state()) ->
-    {maybe(log_entry()), state()}.
+    {'maybe'(log_entry()), state()}.
 fetch(Idx, State0) ->
     case take(Idx, 1, State0) of
         {[], _, State} ->
@@ -527,7 +527,7 @@ fetch(Idx, State0) ->
     end.
 
 -spec fetch_term(ra_index(), state()) ->
-    {maybe(ra_term()), state()}.
+    {'maybe'(ra_term()), state()}.
 fetch_term(Idx, #?MODULE{last_index = LastIdx,
                          first_index = FirstIdx} = State0)
   when Idx < FirstIdx orelse Idx > LastIdx ->
@@ -565,7 +565,7 @@ install_snapshot({SnapIdx, _} = IdxTerm, SnapState,
      Effs}.
 
 -spec recover_snapshot(State :: state()) ->
-    maybe({ra_snapshot:meta(), term()}).
+    'maybe'({ra_snapshot:meta(), term()}).
 recover_snapshot(#?MODULE{snapshot_state = SnapState}) ->
     case ra_snapshot:recover(SnapState) of
         {ok, Meta, MacState} ->
@@ -574,7 +574,7 @@ recover_snapshot(#?MODULE{snapshot_state = SnapState}) ->
             undefined
     end.
 
--spec snapshot_index_term(State :: state()) -> maybe(ra_idxterm()).
+-spec snapshot_index_term(State :: state()) -> 'maybe'(ra_idxterm()).
 snapshot_index_term(#?MODULE{snapshot_state = SS}) ->
     ra_snapshot:current(SS).
 
diff --git a/src/ra_log_segment.erl b/src/ra_log_segment.erl
index 82629e6..e554316 100644
--- a/src/ra_log_segment.erl
+++ b/src/ra_log_segment.erl
@@ -49,7 +49,7 @@
               max_count = ?DEFAULT_INDEX_MAX_COUNT :: non_neg_integer(),
               max_pending = ?DEFAULT_MAX_PENDING :: non_neg_integer(),
               filename :: file:filename_all(),
-              fd :: maybe(file:io_device()),
+              fd :: 'maybe'(file:io_device()),
               index_size :: pos_integer(),
               access_pattern :: sequential | random,
               mode = append :: read | append,
@@ -62,8 +62,8 @@
          data_start :: pos_integer(),
          data_offset :: pos_integer(),
          data_write_offset :: pos_integer(),
-         index = undefined :: maybe(ra_segment_index()),
-         range :: maybe({ra_index(), ra_index()}),
+         index = undefined :: 'maybe'(ra_segment_index()),
+         range :: 'maybe'({ra_index(), ra_index()}),
          pending_data = [] :: iodata(),
          pending_index = [] :: iodata(),
          pending_count = 0 :: non_neg_integer(),
@@ -325,7 +325,7 @@ prepare_cache(#cfg{fd = Fd} = _Cfg, [FirstIdx | Rem], SegIndex) ->
             {FstPos, byte_size(CacheData), CacheData}
     end.
 
--spec term_query(state(), Idx :: ra_index()) -> maybe(ra_term()).
+-spec term_query(state(), Idx :: ra_index()) -> 'maybe'(ra_term()).
 term_query(#state{index = Index}, Idx) ->
     case Index of
         #{Idx := {Term, _, _, _}} ->
@@ -361,7 +361,7 @@ pread_cons(Cfg, Cache0, Idx,
             pread_cons(Cfg, Cache0, Idx+1, FinalIdx, Index, Fun, Acc)
     end.
 
--spec range(state()) -> maybe({ra_index(), ra_index()}).
+-spec range(state()) -> 'maybe'({ra_index(), ra_index()}).
 range(#state{range = Range}) ->
     Range.
 
@@ -373,7 +373,7 @@ max_count(#state{cfg = #cfg{max_count = Max}}) ->
 filename(#state{cfg = #cfg{filename = Fn}}) ->
     Fn.
 
--spec segref(state()) -> maybe(ra_log:segment_ref()).
+-spec segref(state()) -> 'maybe'(ra_log:segment_ref()).
 segref(#state{range = undefined}) ->
     undefined;
 segref(#state{range = {Start, End},
diff --git a/src/ra_log_wal.erl b/src/ra_log_wal.erl
index 197c31f..3d2930b 100644
--- a/src/ra_log_wal.erl
+++ b/src/ra_log_wal.erl
@@ -91,8 +91,8 @@
                pre_allocate = false :: boolean()
               }).
 
--record(wal, {fd :: maybe(file:io_device()),
-              filename :: maybe(file:filename()),
+-record(wal, {fd :: 'maybe'(file:io_device()),
+              filename :: 'maybe'(file:filename()),
               writer_name_cache = {0, #{}} :: writer_name_cache(),
               max_size :: non_neg_integer(),
               entry_count = 0 :: non_neg_integer()
@@ -114,7 +114,7 @@
                 % and the last index seen
                 writers = #{} :: #{ra_uid() =>
                                    {in_seq | out_of_seq, ra_index()}},
-                batch :: maybe(#batch{})
+                batch :: 'maybe'(#batch{})
                }).
 
 -type state() :: #state{}.
diff --git a/src/ra_server.erl b/src/ra_server.erl
index 431987c..8cc630a 100644
--- a/src/ra_server.erl
+++ b/src/ra_server.erl
@@ -62,14 +62,14 @@
 
 -type ra_server_state() ::
     #{cfg := #cfg{},
-      leader_id => maybe(ra_server_id()),
+      leader_id => 'maybe'(ra_server_id()),
       cluster := ra_cluster(),
       cluster_change_permitted := boolean(),
       cluster_index_term := ra_idxterm(),
       previous_cluster => {ra_index(), ra_term(), ra_cluster()},
       current_term := ra_term(),
       log := term(),
-      voted_for => maybe(ra_server_id()), % persistent
+      voted_for => 'maybe'(ra_server_id()), % persistent
       votes => non_neg_integer(),
       commit_index := ra_index(),
       last_applied := ra_index(),
@@ -84,7 +84,7 @@
       query_index := non_neg_integer(),
       queries_waiting_heartbeats := queue:queue({non_neg_integer(), consistent_query_ref()}),
       pending_consistent_queries := [consistent_query_ref()],
-      commit_latency => maybe(non_neg_integer())
+      commit_latency => 'maybe'(non_neg_integer())
      }.
 
 -type ra_state() :: leader | follower | candidate
@@ -1433,7 +1433,7 @@ uid(#{cfg := #cfg{uid = UId}}) -> UId.
 -spec system_config(ra_server_state()) -> ra_system:config().
 system_config(#{cfg := #cfg{system_config = SC}}) -> SC.
 
--spec leader_id(ra_server_state()) -> maybe(ra_server_id()).
+-spec leader_id(ra_server_state()) -> 'maybe'(ra_server_id()).
 leader_id(State) ->
     maps:get(leader_id, State, undefined).
 
@@ -1441,7 +1441,7 @@ leader_id(State) ->
 clear_leader_id(State) ->
     State#{leader_id => undefined}.
 
--spec current_term(ra_server_state()) -> maybe(ra_term()).
+-spec current_term(ra_server_state()) -> 'maybe'(ra_term()).
 current_term(State) ->
     maps:get(current_term, State).
 
diff --git a/src/ra_server_proc.erl b/src/ra_server_proc.erl
index 746a60a..a95ddb8 100644
--- a/src/ra_server_proc.erl
+++ b/src/ra_server_proc.erl
@@ -87,7 +87,7 @@
 -type gen_statem_start_ret() :: {ok, pid()} | ignore | {error, term()}.
 
 %% ra_event types
--type ra_event_reject_detail() :: {not_leader, Leader :: maybe(ra_server_id()),
+-type ra_event_reject_detail() :: {not_leader, Leader :: 'maybe'(ra_server_id()),
                                    ra_server:command_correlation()}.
 
 -type ra_event_body() ::
diff --git a/src/ra_snapshot.erl b/src/ra_snapshot.erl
index c69bdd7..7813db4 100644
--- a/src/ra_snapshot.erl
+++ b/src/ra_snapshot.erl
@@ -56,9 +56,9 @@
          %% snapshot subdirs are store below
          %% this as <data_dir>/snapshots/Term_Index
          directory :: file:filename(),
-         pending :: maybe({pid(), ra_idxterm()}),
-         accepting :: maybe(#accept{}),
-         current :: maybe(ra_idxterm())}).
+         pending :: 'maybe'({pid(), ra_idxterm()}),
+         accepting :: 'maybe'(#accept{}),
+         current :: 'maybe'(ra_idxterm())}).
 
 -define(ETSTBL, ra_log_snapshot_state).
 
@@ -178,14 +178,14 @@ init_ets() ->
     _ = ets:new(?ETSTBL, TableFlags),
     ok.
 
--spec current(state()) -> maybe(ra_idxterm()).
+-spec current(state()) -> 'maybe'(ra_idxterm()).
 current(#?MODULE{current = Current}) -> Current.
 
--spec pending(state()) -> maybe({pid(), ra_idxterm()}).
+-spec pending(state()) -> 'maybe'({pid(), ra_idxterm()}).
 pending(#?MODULE{pending = Pending}) ->
     Pending.
 
--spec accepting(state()) -> maybe(ra_idxterm()).
+-spec accepting(state()) -> 'maybe'(ra_idxterm()).
 accepting(#?MODULE{accepting = undefined}) ->
     undefined;
 accepting(#?MODULE{accepting = #accept{idxterm = Accepting}}) ->
@@ -194,7 +194,7 @@ accepting(#?MODULE{accepting = #accept{idxterm = Accepting}}) ->
 -spec directory(state()) -> file:filename().
 directory(#?MODULE{directory = Dir}) -> Dir.
 
--spec last_index_for(ra_uid()) -> maybe(ra_index()).
+-spec last_index_for(ra_uid()) -> 'maybe'(ra_index()).
 last_index_for(UId) ->
     case ets:lookup(?ETSTBL, UId) of
         [] -> undefined;
@@ -360,7 +360,7 @@ read_meta(Module, Location) ->
     Module:read_meta(Location).
 
 -spec current_snapshot_dir(state()) ->
-    maybe(file:filename()).
+    'maybe'(file:filename()).
 current_snapshot_dir(#?MODULE{directory = Dir,
                               current = {Idx, Term}}) ->
     make_snapshot_dir(Dir, Idx, Term);
diff --git a/test/ra_fifo.erl b/test/ra_fifo.erl
index 1f5b4ca..c6b4c8b 100644
--- a/test/ra_fifo.erl
+++ b/test/ra_fifo.erl
@@ -89,7 +89,7 @@
                          cancel.
 
 -type protocol() ::
-    {enqueue, Sender :: maybe(pid()), MsgSeq :: maybe(msg_seqno()),
+    {enqueue, Sender :: 'maybe'(pid()), MsgSeq :: 'maybe'(msg_seqno()),
      Msg :: raw_msg()} |
     {checkout, Spec :: checkout_spec(), Customer :: customer_id()} |
     {settle, MsgIds :: [msg_id()], Customer :: customer_id()} |
@@ -160,10 +160,10 @@
          % customers that require further service are queued here
          % needs to be part of snapshot
          service_queue = queue:new() :: queue:queue(customer_id()),
-         dead_letter_handler :: maybe(applied_mfa()),
-         cancel_customer_handler :: maybe(applied_mfa()),
-         become_leader_handler :: maybe(applied_mfa()),
-         metrics_handler :: maybe(applied_mfa()),
+         dead_letter_handler :: 'maybe'(applied_mfa()),
+         cancel_customer_handler :: 'maybe'(applied_mfa()),
+         become_leader_handler :: 'maybe'(applied_mfa()),
+         metrics_handler :: 'maybe'(applied_mfa()),
          prefix_msg_count = 0 :: non_neg_integer()
         }).
 
diff --git a/test/ra_fifo_client.erl b/test/ra_fifo_client.erl
index 0c44f90..675bb25 100644
--- a/test/ra_fifo_client.erl
+++ b/test/ra_fifo_client.erl
@@ -30,9 +30,9 @@
 
 -record(state, {cluster_name :: ra_cluster_name(),
                 servers = [] :: [ra_server_id()],
-                leader :: maybe(ra_server_id()),
+                leader :: 'maybe'(ra_server_id()),
                 next_seq = 0 :: seq(),
-                last_applied :: maybe(seq()),
+                last_applied :: 'maybe'(seq()),
                 next_enqueue_seq = 1 :: seq(),
                 %% indicates that we've exceeded the soft limit
                 slow = false :: boolean(),
@@ -40,7 +40,7 @@
                                            {[seq()], [seq()], [seq()]}},
                 soft_limit = ?SOFT_LIMIT :: non_neg_integer(),
                 pending = #{} :: #{seq() =>
-                                   {maybe(term()), ra_fifo:command()}},
+                                   {'maybe'(term()), ra_fifo:command()}},
                 customer_deliveries = #{} :: #{ra_fifo:customer_tag() =>
                                                seq()},
                 priority = normal :: normal | low,
diff --git a/test/ra_log_memory.erl b/test/ra_log_memory.erl
index 08bdc8d..b125a00 100644
--- a/test/ra_log_memory.erl
+++ b/test/ra_log_memory.erl
@@ -45,7 +45,7 @@
                 last_written = {0, 0} :: ra_idxterm(), % only here to fake the async api of the file based one
                 entries = #{0 => {0, undefined}} :: #{ra_term() => {ra_index(), term()}},
                 meta = #{} :: ra_log_memory_meta(),
-                snapshot :: maybe(snapshot())}).
+                snapshot :: 'maybe'(snapshot())}).
 
 -type ra_log_memory_state() :: #state{} | ra_log:state().
 
@@ -120,7 +120,7 @@ sparse_take(Idx, Log, Num, Max, Res) ->
     end.
 
 
--spec last_index_term(ra_log_memory_state()) -> maybe(ra_idxterm()).
+-spec last_index_term(ra_log_memory_state()) -> 'maybe'(ra_idxterm()).
 last_index_term(#state{last_index = LastIdx,
                        entries = Log,
                        snapshot = Snapshot}) ->
@@ -177,7 +177,7 @@ next_index(#state{last_index = LastIdx}) ->
     LastIdx + 1.
 
 -spec fetch(ra_index(), ra_log_memory_state()) ->
-    {maybe(log_entry()), ra_log_memory_state()}.
+    {'maybe'(log_entry()), ra_log_memory_state()}.
 fetch(Idx, #state{entries = Log} = State) ->
     case Log of
         #{Idx := {T, D}} ->
@@ -186,7 +186,7 @@ fetch(Idx, #state{entries = Log} = State) ->
     end.
 
 -spec fetch_term(ra_index(), ra_log_memory_state()) ->
-    {maybe(ra_term()), ra_log_memory_state()}.
+    {'maybe'(ra_term()), ra_log_memory_state()}.
 fetch_term(Idx, #state{entries = Log} = State) ->
     case Log of
         #{Idx := {T, _}} ->
@@ -222,7 +222,7 @@ recover_snapshot(#state{snapshot = {Meta, Data}}) ->
 
 
 -spec read_meta(Key :: ra_log:ra_meta_key(), State :: ra_log_memory_state()) ->
-    maybe(term()).
+    'maybe'(term()).
 read_meta(Key, #state{meta = Meta}) ->
     maps:get(Key, Meta, undefined).
 
-- 
2.35.3

Places

File 0001-quote-the-maybe-type-s-atom.patch of Package ra (Revision e6c7a8d25b340004a5da54a5fd67ffd9)

Places