frereth.cp.message.from-child — com.frereth/cp 0.0.3-g3b13aae

blocks-not-sent? clj

(blocks-not-sent? {{:keys [:frereth.cp.message.specs/un-sent-blocks]}
                     :frereth.cp.message.specs/outgoing
                   :as state})

Are there pending blocks from the child that haven't been sent once?

buffer-size clj

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

build-byte-consumer clj

(build-byte-consumer monitor-id external-log-state bs-or-eof)

Accepts a byte-array from the child.

build-individual-block clj

(build-individual-block buf)

byte-consumer clj

(byte-consumer monitor-id
               log-state
               block
               eof?
               buf-size
               bs-or-eof
               {{:keys [:frereth.cp.message.specs/ackd-addr
                        :frereth.cp.message.specs/max-block-length
                        :frereth.cp.message.specs/strm-hwm
                        :frereth.cp.message.specs/un-sent-blocks]
                 :as outgoing}
                  :frereth.cp.message.specs/outgoing
                :keys [:frereth.cp.message.specs/message-loop-name]
                :as state})

count-buffered-bytes clj

(count-buffered-bytes blocks)

forward-bytes-from-child! clj

(forward-bytes-from-child! monitor-id log-state stream on-completion bs-or-eof)

initial-child-monitor-loop clj

(initial-child-monitor-loop {:keys [:frereth.cp.message.specs/message-loop-name]
                             :as state}
                            logger
                            client-waiting-on-response
                            monitor-id
                            child-out
                            stream
                            eof?-atom)

monitor-loop clj

(monitor-loop {:keys [:frereth.cp.message.specs/message-loop-name] :as state}
              logger
              monitor-id
              child-out
              stream
              eof?-atom)

process-next-bytes-from-child! clj

(process-next-bytes-from-child! monitor-id
                                log-state
                                child-out
                                stream
                                max-to-read
                                on-bytes-forwarded)

read-next-bytes-from-child! clj

(read-next-bytes-from-child! monitor-id
                             log-state
                             child-out
                             available-bytes
                             max-to-read)

(read-next-bytes-from-child! monitor-id
                             log-state
                             child-out
                             prefix
                             available-bytes
                             max-to-read)

room-for-child-bytes? clj

(room-for-child-bytes? {{:keys [:frereth.cp.message.specs/ackd-addr
                                :frereth.cp.message.specs/strm-hwm]}
                          :frereth.cp.message.specs/outgoing
                        :as state})

Does send-buf have enough space left for any message from child?

start-child-monitor! clj

(start-child-monitor!
  {:keys [:frereth.cp.message.specs/message-loop-name]
   {:keys [:frereth.cp.message.specs/client-waiting-on-response]
    :as flow-control}
     :frereth.cp.message.specs/flow-control
   log-state :frereth.weald.specs/state
   :as initial-state}
  {:keys [:frereth.weald.specs/logger :frereth.cp.message.specs/child-out
          :frereth.cp.message.specs/stream]
   :as io-handle})

try-multiple-sends clj

(try-multiple-sends monitor-id
                    stream
                    bs-or-eof
                    blocker
                    log-state
                    attempts
                    timeout)

The parameters are weird because I refactored it out of a lexical closure