Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
branch: master
45 lines (37 sloc) 1.379 kb
(in-package #:tpd2.io)
(defun make-mux-array (len)
(make-array len :element-type '(or null con) :initial-element nil))
(defstruct mux
(fd-to-con (make-mux-array 128)
:type (simple-array (or null con))))
(my-defun mux empty ()
(my-declare-fast-inline)
(every #'not (my fd-to-con)))
(my-defun mux find-fd (fd)
(my-declare-fast-inline)
(declare (type (or null fixnum) fd))
(when fd
(when (> (length (my fd-to-con)) fd)
(aref (my fd-to-con) fd))))
(my-defun mux add (fd con)
(declare (type (or null fixnum) fd))
(when fd
(debug-assert (not (my find-fd fd)) (me con fd))
(when (>= fd (length (my fd-to-con)))
(let ((new (make-mux-array
(loop for length = (* 2 (length (my fd-to-con))) then (* 2 length)
thereis (when (> length fd) length)))))
(replace new (my fd-to-con))
(setf (my fd-to-con) new))
(debug-assert (> (length (my fd-to-con)) fd) (me fd)))
(setf (aref (my fd-to-con) fd) con)))
(my-defun mux del (fd)
(my-declare-fast-inline)
(declare (fixnum fd))
(when (my find-fd fd)
;(debug-assert (= (con-socket (aref (my fd-to-con) fd)) fd) (me fd)) ;; not vaild when ssl involved
(setf (aref (my fd-to-con) fd) nil)))
(my-defun mux close-all ()
(loop for x across (my fd-to-con)
when x
do (hangup x)))
Jump to Line
Something went wrong with that request. Please try again.