cl-stream/unistd-stream/unistd-output-stream.lisp

• Show log

  Commit

• Hash : 0593bb51
  Author : Thomas de Grivel
  Date : 2018-04-27T14:47:28
  

  fix buffered output

Download

• unistd-output-stream.lisp

• 
  (in-package :unistd-stream)
  
  (defclass unistd-output-stream (unistd-stream buffered-output-stream)
    ()
    (:documentation "A buffered output stream using UNISTD:WRITE."))
  
  (defmethod make-stream-output-buffer ((stream unistd-output-stream))
    (cffi:foreign-alloc :unsigned-char
                        :count (stream-output-buffer-size stream)))
  
  (defmethod discard-stream-output-buffer ((stream unistd-output-stream))
    (cffi:foreign-free (stream-output-buffer stream))
    (setf (stream-output-buffer stream) nil))
  
  (defmethod stream-flush-output ((stream unistd-output-stream))
    (let ((buffer (stream-output-buffer stream)))
      (let* ((fd (stream-fd stream))
             (index (stream-output-index stream))
             (buf (cffi:mem-aptr buffer :unsigned-char index))
             (buflen (- (stream-output-length stream) index))
             (r (if (stream-blocking-p stream)
                    (unistd:write fd buf buflen)
                    (unistd:write-non-blocking fd buf buflen))))
        (cond ((eq :non-blocking r)
               :non-blocking)
              ((= 0 r)
               :eof)
              ((< r 0)
               (error 'stream-output-error :stream stream))
              (t
               (incf (stream-output-index stream) r)
               (when (= (stream-output-index stream)
                        (stream-output-length stream))
                 (setf (stream-output-index stream) 0
                       (stream-output-length stream) 0))
               nil)))))
  
  (defmethod stream-write-element-to-buffer ((stream unistd-output-stream)
                                             element)
    (setf (cffi:mem-aref (stream-output-buffer stream) :unsigned-char
                         (stream-output-length stream))
          element)
    (incf (stream-output-length stream))
    nil)
  
  (defun unistd-output-stream (fd)
    "Creates a buffered output stream for file descriptor FD."
    (make-instance 'unistd-output-stream :fd fd))
  

Download