jepsen-foundationdb-cas-register.clj

      :cas   (timeout 5000 (assoc op :type :info :value :timed-out)
          (let [cas (reify Function
            (apply [this, tr]
              (let [
                [value value'] (:value op)
                key_var (byte-array (map byte key))
                old_value (.getLong (Tuple/fromBytes (.get (.get tr (byte-array (map byte key))))) 0)
                new_value (.pack (Tuple/from (into-array [value'])))]
              (if (= old_value value)
                (do
                  (.set tr key_var new_value)
                  (assoc op :type :ok))
                (assoc op :type :fail))
              )))]
              (try
                (.run client cas)
              (catch RuntimeException e
                (assoc op :type :fail :value (.getMessage e))))))))