1 files changed, 150 insertions, 0 deletions
diff --git a/.local/src/blesh/contrib/prompt-defer.bash b/.local/src/blesh/contrib/prompt-defer.bash
new file mode 100644
index 0000000..ea289ff
--- /dev/null
+++ b/.local/src/blesh/contrib/prompt-defer.bash
@@ -0,0 +1,150 @@
+# blesh/contrib/prompt-defer.bash (C) 2021, akinomyoga
+
+function ble/contrib/prompt-defer/.worker {
+  local prefix=$1
+  local tmpfile=$_ble_base_run/$$.prompt.defer.$prefix
+  ble/contrib/prompt-defer:"$prefix"/worker
+  ble/util/put "$?" >| "$tmpfile"
+}
+
+function ble/contrib/prompt-defer/.finalize {
+  local prefix=$1
+  local tmpfile=$_ble_base_run/$$.prompt.defer.$prefix
+  ble/util/set "${prefix}_DEFER_bgpid" ''
+
+  local ext
+  ble/util/readfile ext "$tmpfile"
+  ble/util/setexit "$ext"
+  ble/contrib/prompt-defer:"$prefix"/callback
+
+  local ret; ble/util/clock
+  ble/util/set "${prefix}_DEFER_clock" "$ret"
+}
+
+function ble/contrib/prompt-defer/clear {
+  local prefix=$1 script='
+    [[ $PREFIX_DEFER_bgpid ]] &&
+      builtin kill -9 "$PREFIX_DEFER_bgpid" &>/dev/null
+    PREFIX_DEFER_index=
+    PREFIX_DEFER_hash1=
+    PREFIX_DEFER_hash2=
+    PREFIX_DEFER_clock=
+    PREFIX_DEFER_bgpid='
+  builtin eval -- "${script//PREFIX/$prefix}"
+}
+
+## @fn ble/contrib/prompt-defer/submit prefix [hash1] [hash2] [opts]
+##   @param[in] prefix
+##     関連変数の接頭辞を指定します。
+##
+##     @fn ble/comtrib/prompt-defer:$prefix/clear
+##       これまでに取得した情報を初期化します。後述の hash1 が前回の呼
+##       び出しと異なる際に親シェルで呼び出されます。
+##
+##     @fn ble/comtrib/prompt-defer:$prefix/worker
+##       バックグラウンドの別プロセスで実行する処理を記述します。bash
+##       4.0 以降ではサブシェルで呼び出されます。bash 4.0 未満では非同
+##       期に処理できない為、親シェルで実行されます。
+##
+##     @fn ble/comtrib/prompt-defer:$prefix/callback
+##       バックグラウンドの処理が完了した時に親シェルで呼び出される関
+##       数です。$? に worker の終了ステータスが設定された状態で呼び出
+##       されます。
+##
+##     @var[internal] ${prefix}_DEFER_index
+##     @var[internal] ${prefix}_DEFER_hash1
+##     @var[internal] ${prefix}_DEFER_hash2
+##     @var[internal] ${prefix}_DEFER_clock
+##     @var[internal] ${prefix}_DEFER_bgpid
+##       内部で使用する変数です。
+##
+##   @param[in] hash1
+##     この値が前回の呼び出しと異なる時に強制的に情報の更新を行います。
+##
+##   @param[in] hash2
+##     この値が前回の呼び出しと異なりかつ前回の呼び出しから十分時間が
+##     経っている時に情報の更新を行います。
+##
+##   @param[in,opt] opts
+##     コロン区切りのオプションです。
+##
+##     cooling=NUM
+##       ミリ秒(整数)で情報のタイムアウトを指定します。プロンプト番号
+##       または hash2 が前回と異なりかつ此処で指定した時間経過している
+##       場合に再度情報更新を行います。
+##
+##     cooling-lines=NUM
+##       プロンプト更新回数を指定します。プロンプト番号が此処で指定し
+##       た回数以上変化している場合に再度情報更新を行います。
+##
+##     expires[=NUM]
+##       ミリ秒(整数)で情報のタイムアウトを指定します。プロンプト更新
+##       の際に指定した時間経過している場合、強制的に情報更新を行いま
+##       す。既定値は 60000 (1分) です。
+##
+##     sync=NUM
+##       ミリ秒(整数)で同期的な情報取得のタイムアウトを指定します。
+##
+function ble/contrib/prompt-defer/submit {
+  local prefix=$1 opts=$4
+  local tmpfile=$_ble_base_run/$$.prompt.defer.$prefix
+  local rbgpid=${prefix}_DEFER_bgpid
+
+  local opt_cooling=1000 opt_expires=none opt_nprompt=10 opt_sync=5 ret
+  ble/opts#extract-last-optarg "$opts" cooling && opt_cooling=$ret
+  ble/opts#extract-last-optarg "$opts" cooling-lines && opt_nprompt=$ret
+  ble/opts#extract-last-optarg "$opts" expires 60000 && opt_expires=$ret
+  ble/opts#extract-last-optarg "$opts" sync 60000 && opt_sync=$ret
+
+  local oindex=${prefix}_DEFER_index; oindex=${!oindex-}
+  local ohash1=${prefix}_DEFER_hash1; ohash1=${!ohash1-}
+  local ohash2=${prefix}_DEFER_hash2; ohash2=${!ohash2-}
+  local oclock=${prefix}_DEFER_clock; oclock=${!oclock-}
+
+  local nindex=$_ble_prompt_version
+  local nhash1=${2-done} # 強制 update を誘起する hashref
+  local nhash2=${3-done} # 
+
+  local update=
+  if [[ $nhash1 != "$ohash1" ]]; then
+    update=1
+    ble/contrib/prompt-defer:"$prefix"/clear
+  elif [[ ! ${!rbgpid} ]]; then
+    if [[ $nindex:$nhash2 != "$oindex:$ohash2" ]]; then
+      if ((nindex<=oindex-opt_nprompt||oindex+opt_nprompt<=nindex)) || { local ret; ble/util/clock; ((ret>=oclock+opt_cooling)); }; then
+        update=1
+      fi
+    elif [[ $opt_expires && $opt_expires != none ]]; then
+      if local ret; ble/util/clock; ((ret>=oclock+opt_expires)); then
+        update=1
+      fi
+    fi
+  fi
+
+  if [[ $update ]]; then
+    ble/util/set "${prefix}_DEFER_index" "$nindex"
+    ble/util/set "${prefix}_DEFER_hash1" "$nhash1"
+    ble/util/set "${prefix}_DEFER_hash2" "$nhash2"
+
+    if ble/is-function ble/util/idle.push; then
+      if [[ ${!rbgpid} ]]; then
+        builtin kill -9 "${!rbgpid}" &>/dev/null
+        ble/util/idle.cancel "ble/contrib/prompt-defer/.finalize $prefix"
+        ble/util/set "$rbgpid" ''
+      fi
+
+      : >| "$tmpfile"
+      ble/util/set "$rbgpid" "$(shopt -u huponexit; ble/contrib/prompt-defer/.worker $prefix < /dev/null &> /dev/null & ble/util/print $!)"
+      ((opt_sync>0)) && ble/util/msleep "$opt_sync"
+      if [[ -s $tmpfile ]]; then
+        ble/contrib/prompt-defer/.finalize "$prefix"
+      else
+        ble/util/idle.push -F "$tmpfile" "ble/contrib/prompt-defer/.finalize $prefix"
+      fi
+
+    else
+      ble/contrib/prompt-defer:"$prefix"/worker
+      ble/contrib/prompt-defer:"$prefix"/callback
+    fi
+  fi
+}