Author: ctian Date: Fri Oct 3 08:49:40 2008 New Revision: 426 Added: usocket/branches/experimental-udp/rtt-client.lisp (contents, props changed) usocket/branches/experimental-udp/rtt.lisp (contents, props changed) usocket/branches/experimental-udp/server.lisp (contents, props changed) Modified: usocket/branches/experimental-udp/backend/allegro.lisp usocket/branches/experimental-udp/backend/cmucl.lisp usocket/branches/experimental-udp/backend/lispworks.lisp usocket/branches/experimental-udp/backend/openmcl.lisp usocket/branches/experimental-udp/backend/sbcl.lisp usocket/branches/experimental-udp/condition.lisp usocket/branches/experimental-udp/package.lisp usocket/branches/experimental-udp/usocket.asd usocket/branches/experimental-udp/usocket.lisp Log: [experimental-udp] initial commit, no support on scl/clisp/armedbear, buggy on others. Modified: usocket/branches/experimental-udp/backend/allegro.lisp ============================================================================== --- usocket/branches/experimental-udp/backend/allegro.lisp (original) +++ usocket/branches/experimental-udp/backend/allegro.lisp Fri Oct 3 08:49:40 2008 @@ -49,7 +49,7 @@ :text :binary)) -(defun socket-connect (host port &key (element-type 'character) +(defun socket-connect (host port &key (protocol :tcp) (element-type 'character) timeout deadline (nodelay t) ;; nodelay == t is the ACL default local-host local-port) @@ -59,22 +59,38 @@ (let ((socket)) (setf socket (with-mapped-conditions (socket) - (if timeout - (mp:with-timeout (timeout nil) - (socket:make-socket :remote-host (host-to-hostname host) - :remote-port port - :local-host (when local-host (host-to-hostname local-host)) - :local-port local-port - :format (to-format element-type) - :nodelay nodelay)) - (socket:make-socket :remote-host (host-to-hostname host) - :remote-port port - :local-host local-host - :local-port local-port - :format (to-format element-type) - :nodelay nodelay)))) - (make-stream-socket :socket socket :stream socket))) - + (ecase protocol + (:tcp (if timeout + (mp:with-timeout (timeout nil) + (socket:make-socket :remote-host (host-to-hostname host) + :remote-port port + :local-host (when local-host (host-to-hostname local-host)) + :local-port local-port + :format (to-format element-type) + :nodelay nodelay)) + (socket:make-socket :remote-host (host-to-hostname host) + :remote-port port + :local-host (when local-host (host-to-hostname local-host)) + :local-port local-port + :format (to-format element-type) + :nodelay nodelay))) + (:udp (if (and host port) + (socket:make-socket :type :datagram + :address-family :internet + :connect :active + :remote-host (host-to-hostname host) + :remote-port port + :local-host (when local-host (host-to-hostname local-host)) + :local-port local-port + :format (to-format element-type)) + (socket:make-socket :type :datagram + :address-family :internet + :local-host local-host + :local-port (when local-host (host-to-hostname local-host)) + :format (to-format element-type))))))) + (ecase protocol + (:tcp (make-stream-socket :socket socket :stream socket)) + (:udp (make-datagram-socket socket))))) ;; One socket close method is sufficient, ;; because socket-streams are also sockets. @@ -113,6 +129,16 @@ (socket:accept-connection (socket socket))))) (make-stream-socket :socket stream-sock :stream stream-sock))) +(defmethod socket-send ((socket datagram-usocket) buffer length &key address port) + (with-mapped-conditions (socket) + (let ((s (socket socket))) + (socket:send-to s buffer length :remote-host address :remote-port port)))) + +(defmethod socket-receive ((socket datagram-usocket) buffer length) + (with-mapped-conditions (socket) + (let ((s (socket socket))) + (socket:receive-from s length :buffer buffer :extract t)))) + (defmethod get-local-address ((usocket usocket)) (hbo-to-vector-quad (socket:local-host (socket usocket)))) Modified: usocket/branches/experimental-udp/backend/cmucl.lisp ============================================================================== --- usocket/branches/experimental-udp/backend/cmucl.lisp (original) +++ usocket/branches/experimental-udp/backend/cmucl.lisp Fri Oct 3 08:49:40 2008 @@ -50,7 +50,7 @@ :socket socket :condition condition)))) -(defun socket-connect (host port &key (element-type 'character) +(defun socket-connect (host port &key (protocol :tcp) (element-type 'character) timeout deadline (nodelay t nodelay-specified) local-host local-port) (declare (ignore nodelay)) @@ -61,20 +61,43 @@ (unsupported 'local-host 'socket-connect) (unsupported 'local-port 'socket-connect)) - (let* ((socket)) - (setf socket - (with-mapped-conditions (socket) - (ext:connect-to-inet-socket (host-to-hbo host) port :stream))) - (if socket - (let* ((stream (sys:make-fd-stream socket :input t :output t - :element-type element-type - :buffering :full)) - ;;###FIXME the above line probably needs an :external-format - (usocket (make-stream-socket :socket socket - :stream stream))) - usocket) - (let ((err (unix:unix-errno))) - (when err (cmucl-map-socket-error err)))))) + (let ((socket)) + (ecase protocol + (:tcp (progn + (setf socket + (with-mapped-conditions (socket) + (ext:connect-to-inet-socket (host-to-hbo host) port + (cdr (assoc protocol +protocol-map+)) + :local-host (if local-host + (host-to-hbo local-host)) + :local-port local-port))) + (if socket + (let* ((stream (sys:make-fd-stream socket :input t :output t + :element-type element-type + :buffering :full)) + ;;###FIXME the above line probably needs an :external-format + (usocket (make-stream-socket :socket socket + :stream stream))) + usocket) + (let ((err (unix:unix-errno))) + (when err (cmucl-map-socket-error err)))))) + (:udp (progn + (if (and host port) + (setf socket (with-mapped-conditions (socket) + (ext:connect-to-inet-socket (host-to-hbo host) port :datagram + :local-host (if local-host + (host-to-hbo local-host)) + :local-port local-port))) + (progn + (setf socket (with-mapped-conditions (socket) + (ext:create-inet-socket :datagram))) + (when (and local-host local-port) + (with-mapped-conditions (socket) + (ext:bind-inet-socket socket local-host local-port))))) + (let ((usocket (make-datagram-socket socket))) + (ext:finalize usocket #'(lambda () (unless (%closed-p usocket) + (ext:close-socket socket)))) + usocket)))))) (defun socket-listen (host port &key reuseaddress @@ -119,6 +142,24 @@ (with-mapped-conditions (usocket) (ext:close-socket (socket usocket)))) +(defmethod socket-close :after ((socket datagram-usocket)) + (setf (%closed-p socket) t)) + +(defmethod socket-send ((usocket datagram-usocket) buffer length &key address port) + (with-mapped-conditions (usocket) + (ext:inet-sendto (socket usocket) buffer length (if address (host-to-hbo address)) port))) + +(defmethod socket-receive ((usocket datagram-usocket) buffer length) + (let ((real-buffer (or buffer + (make-array length :element-type '(unsigned-byte 8)))) + (real-length (or length + (length buffer)))) + (multiple-value-bind (nbytes remote-host remote-port) + (with-mapped-conditions (usocket) + (ext:inet-recvfrom (socket usocket) real-buffer real-length)) + (when (plusp nbytes) + (values real-buffer nbytes remote-host remote-port))))) + (defmethod get-local-name ((usocket usocket)) (multiple-value-bind (address port) Modified: usocket/branches/experimental-udp/backend/lispworks.lisp ============================================================================== --- usocket/branches/experimental-udp/backend/lispworks.lisp (original) +++ usocket/branches/experimental-udp/backend/lispworks.lisp Fri Oct 3 08:49:40 2008 @@ -73,7 +73,7 @@ (declare (ignore host port err-msg)) (raise-usock-err errno socket condition))))) -(defun socket-connect (host port &key (element-type 'base-char) +(defun socket-connect (host port &key (protocol :tcp) (element-type 'base-char) timeout deadline (nodelay t nodelay-specified) local-host local-port) (declare (ignorable nodelay)) @@ -87,23 +87,36 @@ (unsupported 'local-host 'socket-connect :minimum "LispWorks 5.0+ (verified)") (unsupported 'local-port 'socket-connect :minimum "LispWorks 5.0+ (verified)")) - (let ((hostname (host-to-hostname host)) - (stream)) - (setf stream - (with-mapped-conditions () - (comm:open-tcp-stream hostname port - :element-type element-type - #-lispworks4 #-lispworks4 - #-lispworks4 #-lispworks4 - :local-address (when local-host (host-to-hostname local-host)) - :local-port local-port - #+(and (not lispworks4) (not lispworks5.0)) - #+(and (not lispworks4) (not lispworks5.0)) - :nodelay nodelay))) - (if stream - (make-stream-socket :socket (comm:socket-stream-socket stream) - :stream stream) - (error 'unknown-error)))) + (ecase protocol + (:tcp (let ((hostname (host-to-hostname host)) + (stream)) + (setf stream + (with-mapped-conditions () + (comm:open-tcp-stream hostname port + :element-type element-type + #-lispworks4 #-lispworks4 + #-lispworks4 #-lispworks4 + :local-address (when local-host (host-to-hostname local-host)) + :local-port local-port + #+(and (not lispworks4) (not lispworks5.0)) + #+(and (not lispworks4) (not lispworks5.0)) + :nodelay nodelay))) + (if stream + (make-stream-socket :socket (comm:socket-stream-socket stream) + :stream stream) + (error 'unknown-error)))) + (:udp (let ((usocket (make-datagram-socket + (if (and host port) + (comm:connect-to-udp-server host port + :errorp t + :local-address local-host + :local-port local-port) + (comm:open-udp-socket :errorp t + :local-address local-host + :local-port local-port)) + :connected-p t))) + (hcl:flag-special-free-action usocket) + usocket)))) (defun socket-listen (host port &key reuseaddress @@ -152,6 +165,27 @@ (with-mapped-conditions (usocket) (comm::close-socket (socket usocket)))) +(defmethod socket-close :after ((socket datagram-usocket)) + "Additional socket-close method for datagram-usocket" + (setf (%closed-p socket) t)) + +;; Register a special free action for closing datagram usocket when being GCed +(defun usocket-special-free-action (object) + (when (and (typep object 'datagram-usocket) + (not (closed-p object))) + (socket-close object))) + +(eval-when (:load-toplevel :execute) + (hcl:add-special-free-action 'usocket-special-free-action)) + +(defmethod socket-send ((socket datagram-usocket) buffer length &key address port) + (let ((s (socket socket))) + (comm:send-message s buffer length address port))) + +(defmethod socket-receive ((socket datagram-usocket) buffer length) + (let ((s (socket socket))) + (comm:receive-message s buffer length))) + (defmethod get-local-name ((usocket usocket)) (multiple-value-bind (address port) Modified: usocket/branches/experimental-udp/backend/openmcl.lisp ============================================================================== --- usocket/branches/experimental-udp/backend/openmcl.lisp (original) +++ usocket/branches/experimental-udp/backend/openmcl.lisp Fri Oct 3 08:49:40 2008 @@ -74,21 +74,36 @@ :text :binary)) -(defun socket-connect (host port &key (element-type 'character) timeout deadline nodelay +(defun socket-connect (host port &key (protocol :tcp) (element-type 'character) + timeout deadline nodelay local-host local-port) (with-mapped-conditions () - (let ((mcl-sock - (openmcl-socket:make-socket :remote-host (host-to-hostname host) - :remote-port port - :local-host (when local-host (host-to-hostname local-host)) - :local-port local-port - :format (to-format element-type) - :deadline deadline - :nodelay nodelay - :connect-timeout (and timeout - (* timeout internal-time-units-per-second))))) - (openmcl-socket:socket-connect mcl-sock) - (make-stream-socket :stream mcl-sock :socket mcl-sock)))) + (ecase protocol + (:tcp + (let ((mcl-sock + (openmcl-socket:make-socket :remote-host (host-to-hostname host) + :remote-port port + :local-host (when local-host (host-to-hostname local-host)) + :local-port local-port + :format (to-format element-type) + :deadline deadline + :nodelay nodelay + :connect-timeout (and timeout + (* timeout internal-time-units-per-second))))) + (openmcl-socket:socket-connect mcl-sock) + (make-stream-socket :stream mcl-sock :socket mcl-sock))) + (:udp + (let ((mcl-sock + (openmcl-socket:make-socket :address-family :internet + :type :datagram + :local-host (if local-host + (host-to-hbo local-host)) + :local-port local-port))) + (when (and host port) + (ccl::inet-connect (ccl::socket-device mcl-sock) + (ccl::host-as-inet-host host) + (ccl::port-as-inet-port port "udp"))) + (make-datagram-socket mcl-sock)))))) (defun socket-listen (host port &key reuseaddress @@ -122,6 +137,16 @@ (with-mapped-conditions (usocket) (close (socket usocket)))) +(defmethod socket-send ((usocket datagram-usocket) buffer length &key address port) + (with-mapped-conditions (usocket) + (openmcl-socket:send-to (socket usocket) buffer length + :remote-host (if address (host-to-hbo address)) + :remote-port port))) + +(defmethod socket-receive ((usocket datagram-usocket) buffer length) + (with-mapped-conditions (usocket) + (openmcl-socket:receive-from (socket usocket) length :buffer buffer))) + (defmethod get-local-address ((usocket usocket)) (hbo-to-vector-quad (openmcl-socket:local-host (socket usocket)))) Modified: usocket/branches/experimental-udp/backend/sbcl.lisp ============================================================================== --- usocket/branches/experimental-udp/backend/sbcl.lisp (original) +++ usocket/branches/experimental-udp/backend/sbcl.lisp Fri Oct 3 08:49:40 2008 @@ -199,8 +199,7 @@ (if usock-cond (signal usock-cond :socket socket)))))) - -(defun socket-connect (host port &key (element-type 'character) +(defun socket-connect (host port &key (protocol :tcp) (element-type 'character) timeout deadline (nodelay t nodelay-specified) local-host local-port) (when deadline (unsupported 'deadline 'socket-connect)) @@ -214,28 +213,38 @@ (unsupported 'nodelay 'socket-connect)) (let ((socket (make-instance 'sb-bsd-sockets:inet-socket - :type :stream :protocol :tcp))) + :type (cdr (assoc protocol +protocol-map+)) + :protocol protocol))) (handler-case - (let* ((stream - (sb-bsd-sockets:socket-make-stream socket - :input t - :output t - :buffering :full - :element-type element-type)) - ;;###FIXME: The above line probably needs an :external-format - (usocket (make-stream-socket :stream stream :socket socket)) - (ip (host-to-vector-quad host))) - (when (and nodelay-specified - (fboundp 'sb-bsd-sockets::sockopt-tcp-nodelay)) - (setf (sb-bsd-sockets:sockopt-tcp-nodelay socket) nodelay)) - (when (or local-host local-port) - (sb-bsd-sockets:socket-bind socket - (host-to-vector-quad - (or local-host *wildcard-host*)) - (or local-port *auto-port*))) - (with-mapped-conditions (usocket) - (sb-bsd-sockets:socket-connect socket ip port)) - usocket) + (ecase protocol + (:tcp (let* ((stream + (sb-bsd-sockets:socket-make-stream socket + :input t + :output t + :buffering :full + :element-type element-type)) + ;;###FIXME: The above line probably needs an :external-format + (usocket (make-stream-socket :stream stream :socket socket)) + (ip (host-to-vector-quad host))) + (when (and nodelay-specified + (fboundp 'sb-bsd-sockets::sockopt-tcp-nodelay)) + (setf (sb-bsd-sockets:sockopt-tcp-nodelay socket) nodelay)) + (when (or local-host local-port) + (sb-bsd-sockets:socket-bind socket + (host-to-vector-quad + (or local-host *wildcard-host*)) + (or local-port *auto-port*))) + (with-mapped-conditions (usocket) + (sb-bsd-sockets:socket-connect socket ip port)) + usocket)) + (:udp (progn + (when (and local-host local-port) + (sb-bsd-sockets:socket-bind socket + (host-to-vector-quad local-host) + local-port)) + (when (and host port) + (sb-bsd-sockets:socket-connect socket (host-to-hbo host) port)) + (make-datagram-socket socket)))) (t (c) ;; Make sure we don't leak filedescriptors (sb-bsd-sockets:socket-close socket) @@ -287,6 +296,18 @@ (with-mapped-conditions (usocket) (close (socket-stream usocket)))) +(defmethod socket-send ((socket datagram-usocket) buffer length &key address port) + (with-mapped-conditions (socket) + (let* ((s (socket socket)) + (dest (if (and address port) (list (host-to-vector-quad address) port) nil))) + (sb-bsd-sockets:socket-send s buffer length :address dest)))) + +(defmethod socket-receive ((socket datagram-usocket) buffer length + &key (element-type '(unsigned-byte 8))) + (with-mapped-conditions (socket) + (let ((s (socket socket))) + (sb-bsd-sockets:socket-receive s buffer length :element-type element-type)))) + (defmethod get-local-name ((usocket usocket)) (sb-bsd-sockets:socket-name (socket usocket))) Modified: usocket/branches/experimental-udp/condition.lisp ============================================================================== --- usocket/branches/experimental-udp/condition.lisp (original) +++ usocket/branches/experimental-udp/condition.lisp Fri Oct 3 08:49:40 2008 @@ -197,4 +197,44 @@ :context ,context :minimum ,minimum)) (defmacro unimplemented (feature context) - `(signal 'unimplemented :feature ,feature :context ,context)) \ No newline at end of file + `(signal 'unimplemented :feature ,feature :context ,context)) + +;;; binghe: socket-warning for UDP retransmit support + +(define-condition socket-warning (socket-condition warning) + () ;; no slots (yet) + (:documentation "Parent warning for all socket related warnings")) + +(define-condition rtt-timeout-warning (socket-warning) + ((old-rto :type short-float + :reader old-rto-of + :initarg :old-rto) + (new-rto :type short-float + :reader new-rto-of + :initarg :new-rto)) + (:report (lambda (condition stream) + (format stream "Receive timeout (~As), next: ~As.~%" + (old-rto-of condition) + (new-rto-of condition)))) + (:documentation "RTT timeout warning")) + +(define-condition rtt-seq-mismatch-warning (socket-warning) + ((send-seq :type integer + :reader send-seq-of + :initarg :send-seq) + (recv-seq :type integer + :reader recv-seq-of + :initarg :recv-seq)) + (:report (lambda (condition stream) + (format stream "Sequence number mismatch (~A -> ~A), try read again.~%" + (send-seq-of condition) + (recv-seq-of condition)))) + (:documentation "RTT sequence mismatch warning")) + +(define-condition rtt-timeout-error (socket-error) + () + (:report (lambda (condition stream) + (declare (ignore condition)) + (format stream "Max retransmit times (~A) reached, give up.~%" + *rtt-maxnrexmt*))) + (:documentation "RTT timeout error")) Modified: usocket/branches/experimental-udp/package.lisp ============================================================================== --- usocket/branches/experimental-udp/package.lisp (original) +++ usocket/branches/experimental-udp/package.lisp Fri Oct 3 08:49:40 2008 @@ -11,6 +11,9 @@ (:export #:*wildcard-host* #:*auto-port* + #:*remote-host* ; special variables (udp) + #:*remote-port* + #:socket-connect ; socket constructors and methods #:socket-listen #:socket-accept @@ -22,6 +25,11 @@ #:get-local-name #:get-peer-name + #:socket-send ; udp function (send) + #:socket-receive ; udp function (receive) + #:socket-sync ; udp client (high-level) + #:socket-server ; udp server + #:wait-for-input ; waiting for input-ready state (select() like) #:make-wait-list #:add-waiter @@ -65,6 +73,7 @@ #:ns-unknown-condition #:unknown-error #:ns-unknown-error + #:socket-warning ; warnings (udp) #:insufficient-implementation ; conditions regarding usocket support level #:unsupported Added: usocket/branches/experimental-udp/rtt-client.lisp ============================================================================== --- (empty file) +++ usocket/branches/experimental-udp/rtt-client.lisp Fri Oct 3 08:49:40 2008 @@ -0,0 +1,50 @@ +;;;; $Id$ +;;;; $URL$ + +(in-package :usocket) + +(defun default-rtt-function (message) (values message 0)) + +(defmethod socket-sync ((socket datagram-usocket) message &key address port + (max-receive-length +max-datagram-packet-size+) + (encode-function #'default-rtt-function) + (decode-function #'default-rtt-function)) + (rtt-newpack socket) + (multiple-value-bind (data send-seq) (funcall encode-function message) + (let ((data-length (length data))) + (loop + with send-ts = (rtt-ts socket) + and recv-message = nil + and recv-seq = -1 + and continue-p = t + do (progn + (socket-send socket data data-length :address address :port port) + (multiple-value-bind (sockets real-time) + (wait-for-input socket :timeout (rtt-start socket)) + (declare (ignore sockets)) + (if real-time + ;; message received + (loop + do (multiple-value-setq (recv-message recv-seq) + (funcall decode-function + (socket-receive socket nil max-receive-length))) + until (or (= recv-seq send-seq) + (warn 'rtt-seq-mismatch-warning + :socket socket + :send-seq send-seq + :recv-seq recv-seq)) + finally (let ((recv-ts (rtt-ts socket))) + (rtt-stop socket (- recv-ts send-ts)) + (return nil))) + ;; message not received + (let ((old-rto (slot-value socket 'rto))) + (setf continue-p (rtt-timeout socket)) + (warn 'rtt-timeout-warning + :socket socket + :old-rto old-rto + :new-rto (slot-value socket 'rto)) + (unless continue-p + (error 'rtt-timeout-error) + (rtt-init socket)))))) + until (or recv-message (not continue-p)) + finally (return recv-message))))) Added: usocket/branches/experimental-udp/rtt.lisp ============================================================================== --- (empty file) +++ usocket/branches/experimental-udp/rtt.lisp Fri Oct 3 08:49:40 2008 @@ -0,0 +1,80 @@ +;;;; $Id$ +;;;; $URL$ + +;;;; UDP retransmit support by Chun Tian (binghe) +;;;; See the LICENSE file for licensing information. + +(in-package :usocket) + +;;; UNIX Network Programming v1 - Networking APIs: Sockets and XTI +;;; Chapter 20: Advance UDP Sockets +;;; Adding Reliability to a UDP Application + +(defclass rtt-info-mixin () + ((rtt :type short-float + :documentation "most recent measured RTT, seconds") + (srtt :type short-float + :documentation "smoothed RTT estimator, seconds") + (rttvar :type short-float + :documentation "smoothed mean deviation, seconds") + (rto :type short-float + :documentation "current RTO to use, seconds") + (nrexmt :type fixnum + :documentation "#times retransmitted: 0, 1, 2, ...") + (base :type integer + :documentation "#sec since 1/1/1970 at start, but we use Lisp time here")) + (:documentation "RTT Info Class")) + +(defvar *rtt-rxtmin* 2.0 "min retransmit timeout value, seconds") +(defvar *rtt-rxtmax* 60.0 "max retransmit timeout value, seconds") +(defvar *rtt-maxnrexmt* 3 "max #times to retransmit") + +(defmethod rtt-rtocalc ((instance rtt-info-mixin)) + "Calculate the RTO value based on current estimators: + smoothed RTT plus four times the deviation." + (with-slots (srtt rttvar) instance + (+ srtt (* 4.0 rttvar)))) + +(defun rtt-minmax (rto) + "rtt-minmax makes certain that the RTO is between the upper and lower limits." + (declare (type short-float rto)) + (cond ((< rto *rtt-rxtmin*) *rtt-rxtmin*) + ((> rto *rtt-rxtmax*) *rtt-rxtmax*) + (t rto))) + +(defmethod initialize-instance :after ((instance rtt-info-mixin) &rest initargs + &key &allow-other-keys) + (declare (ignore initargs)) + (rtt-init instance)) + +(defmethod rtt-init ((instance rtt-info-mixin)) + (with-slots (base rtt srtt rttvar rto) instance + (setf base (get-internal-real-time) + rtt 0.0 + srtt 0.0 + rttvar 0.75 + rto (rtt-minmax (rtt-rtocalc instance))))) + +(defmethod rtt-ts ((instance rtt-info-mixin)) + (* (- (get-internal-real-time) (slot-value instance 'base)) + #.(/ 1000 internal-time-units-per-second))) + +(defmethod rtt-start ((instance rtt-info-mixin)) + "return value can be used as: alarm(rtt_start(&foo))" + (round (slot-value instance 'rto))) + +(defmethod rtt-stop ((instance rtt-info-mixin) (ms number)) + (with-slots (rtt srtt rttvar rto) instance + (setf rtt (/ ms 1000.0)) + (let ((delta (- rtt srtt))) + (incf srtt (/ delta 8.0)) + (incf rttvar (/ (- (abs delta) rttvar) 4.0))) + (setf rto (rtt-minmax (rtt-rtocalc instance))))) + +(defmethod rtt-timeout ((instance rtt-info-mixin)) + (with-slots (rto nrexmt) instance + (setf rto (* rto 2.0)) + (< (incf nrexmt) *rtt-maxnrexmt*))) + +(defmethod rtt-newpack ((instance rtt-info-mixin)) + (setf (slot-value instance 'nrexmt) 0)) Added: usocket/branches/experimental-udp/server.lisp ============================================================================== --- (empty file) +++ usocket/branches/experimental-udp/server.lisp Fri Oct 3 08:49:40 2008 @@ -0,0 +1,43 @@ +;;;; $Id$ +;;;; $URL$ + +(in-package :usocket) + +(defvar *remote-host*) +(defvar *remote-port*) + +(defun socket-server (host port function &optional arguments + &key (element-type '(unsigned-byte 8)) (timeout 1) + (max-buffer-size +max-datagram-packet-size+)) + (let ((socket (socket-connect nil nil + :protocol :udp + :local-host host + :local-port port + :element-type element-type)) + (buffer (make-array max-buffer-size + :element-type '(unsigned-byte 8) + :initial-element 0))) + (unwind-protect + (loop (progn + (multiple-value-bind (sockets real-time) + (wait-for-input socket :timeout timeout) + (declare (ignore sockets)) + (when real-time + (multiple-value-bind (recv n *remote-host* *remote-port*) + (socket-receive socket buffer max-buffer-size) + (declare (ignore recv)) + (if (plusp n) + (progn + (let ((reply + (apply function + (cons (subseq buffer 0 n) arguments)))) + (when reply + (replace buffer reply) + (let ((n (socket-send socket buffer (length reply) + :address *remote-host* + :port *remote-port*))) + (when (minusp n) + (error "send error: ~A~%" n)))))) + (error "receive error: ~A" n)))) + #+(and cmu mp) (mp:process-yield)))) + (socket-close socket)))) Modified: usocket/branches/experimental-udp/usocket.asd ============================================================================== --- usocket/branches/experimental-udp/usocket.asd (original) +++ usocket/branches/experimental-udp/usocket.asd Fri Oct 3 08:49:40 2008 @@ -1,4 +1,4 @@ - +;;;; -*- Mode: Lisp -*- ;;;; $Id$ ;;;; $URL$ @@ -18,26 +18,26 @@ :licence "MIT" :description "Universal socket library for Common Lisp" :depends-on (:split-sequence - #+sbcl :sb-bsd-sockets) + #+sbcl :sb-bsd-sockets + #+lispworks :lispworks-udp) :components ((:file "package") + (:file "rtt" + :depends-on ("package")) (:file "usocket" - :depends-on ("package")) + :depends-on ("package" "rtt")) (:file "condition" - :depends-on ("usocket")) - #+clisp (:file "clisp" :pathname "backend/clisp" - :depends-on ("condition")) - #+cmu (:file "cmucl" :pathname "backend/cmucl" - :depends-on ("condition")) - #+scl (:file "scl" :pathname "backend/scl" - :depends-on ("condition")) - #+(or sbcl ecl) (:file "sbcl" :pathname "backend/sbcl" - :depends-on ("condition")) - #+lispworks (:file "lispworks" :pathname "backend/lispworks" - :depends-on ("condition")) - #+openmcl (:file "openmcl" :pathname "backend/openmcl" - :depends-on ("condition")) - #+allegro (:file "allegro" :pathname "backend/allegro" - :depends-on ("condition")) - #+armedbear (:file "armedbear" :pathname "backend/armedbear" - :depends-on ("condition")) - )) + :depends-on ("usocket" "rtt")) + (:module "backend" + :components (#+clisp (:file "clisp") + #+cmu (:file "cmucl") + #+scl (:file "scl") + #+(or sbcl ecl) (:file "sbcl") + #+lispworks (:file "lispworks") + #+openmcl (:file "openmcl") + #+allegro (:file "allegro") + #+armedbear (:file "armedbear")) + :depends-on ("condition")) + (:file "rtt-client" + :depends-on ("rtt" "backend" "condition")) + (:file "server" + :depends-on ("backend")))) Modified: usocket/branches/experimental-udp/usocket.lisp ============================================================================== --- usocket/branches/experimental-udp/usocket.lisp (original) +++ usocket/branches/experimental-udp/usocket.lisp Fri Oct 3 08:49:40 2008 @@ -11,6 +11,9 @@ (defparameter *auto-port* 0 "Port number to pass when an auto-assigned port number is wanted.") +(defconstant +max-datagram-packet-size+ 65536) +(defconstant +protocol-map+ '((:tcp . :stream) (:udp . :datagram))) + (defclass usocket () ((socket :initarg :socket @@ -82,10 +85,17 @@ (:documentation "Socket which listens for stream connections to be initiated from remote sockets.")) -(defclass datagram-usocket (usocket) - ((connected-p :initarg :connected-p :accessor connected-p)) -;; ###FIXME: documentation to be added. - (:documentation "")) +(defclass datagram-usocket (usocket rtt-info-mixin) + ((connected-p :type boolean + :accessor connected-p + :initarg :connected-p) + #+(or cmu lispworks) + (%closed-p :type boolean + :accessor %closed-p + :initform nil + :documentation "Flag to indicate if this usocket is closed, +for GC on LispWorks/CMUCL")) + (:documentation "UDP (inet-datagram) socket")) (defun usocket-p (socket) (typep socket 'usocket))