frereth.cp.message.helpers — com.frereth/cp 0.0.5

Top-level message helpers

drop-ackd! clj

(drop-ackd! {:keys [:frereth.cp.message.specs/message-loop-name]
             {:keys [:frereth.cp.message.specs/ackd-addr
                     :frereth.cp.message.specs/send-eof
                     :frereth.cp.message.specs/un-ackd-blocks]
              :as outgoing}
               :frereth.cp.message.specs/outgoing
             :as state})

earliest-block-time clj

(earliest-block-time message-loop-name log-state un-acked-blocks)

Calculate the earliest time

Based on earliestblocktime_compute, in lines 138-153

flag-ackd-blocks clj

(flag-ackd-blocks start
                  stop
                  state
                  {:keys [:frereth.cp.message.specs/start-pos
                          :frereth.cp.message.specs/transmissions
                          :frereth.cp.message.specs/buf]
                   :as block})

mark-ackd-by-addr clj

(mark-ackd-by-addr {{:keys [:frereth.cp.message.specs/un-ackd-blocks
                            :frereth.cp.message.specs/send-eof
                            :frereth.cp.message.specs/send-eof-acked
                            :frereth.cp.message.specs/strm-hwm]}
                      :frereth.cp.message.specs/outgoing
                    :keys [:frereth.cp.message.specs/message-loop-name]
                    :as state}
                   start
                   stop)

Mark sent blocks between positions start and stop as ACK'd

Based [cleverly] on acknowledged(), running from lines 155-185

mark-block-ackd clj

(mark-block-ackd {:keys [:frereth.cp.message.specs/un-ackd-blocks] :as outgoing}
                 block)

Flag block ACK'd in the un-ackd set

read-int clj

(read-int bb)

read-long clj

(read-long bb)

read-short clj

(read-short bb)

read-uint clj

(read-uint bb)

read-ulong clj

(read-ulong bb)

read-ushort clj

(read-ushort bb)