X-Git-Url: http://repo.macrolet.net/gitweb/?a=blobdiff_plain;f=contrib%2Fsb-simple-streams%2Ffile.lisp;h=48d48ade5b164f8ca28c521eb1e10d78429e6f4d;hb=7572e0506af331534e6f97b027d56e8bea09410c;hp=9dbe8f83f8fee1a68b349428fd38fe4085babf09;hpb=54b330585ed41edeb93a289f0e59aec67fa9ded9;p=sbcl.git diff --git a/contrib/sb-simple-streams/file.lisp b/contrib/sb-simple-streams/file.lisp index 9dbe8f8..48d48ad 100644 --- a/contrib/sb-simple-streams/file.lisp +++ b/contrib/sb-simple-streams/file.lisp @@ -80,7 +80,8 @@ (format *terminal-io* "~&;;; ** closed ~S (fd ~D)~%" namestring fd) (when original - (revert-file namestring original)))) + (revert-file namestring original))) + :dont-save t) stream))))))) (defmethod device-open ((stream file-simple-stream) options) @@ -151,15 +152,18 @@ (defmethod device-close ((stream file-simple-stream) abort) (with-stream-class (file-simple-stream stream) - (let ((fd (or (sm input-handle stream) (sm output-handle stream)))) + (let ((fd (or (sm input-handle stream) (sm output-handle stream))) + (closed nil)) (when (sb-int:fixnump fd) (cond (abort (when (any-stream-instance-flags stream :output) + #+win32 (progn (sb-unix:unix-close fd) (setf closed t)) (revert-file (sm filename stream) (sm original stream)))) (t (when (sm delete-original stream) (delete-original (sm filename stream) (sm original stream))))) - (sb-unix:unix-close fd)) + (unless closed + (sb-unix:unix-close fd))) (when (sm buffer stream) (free-buffer (sm buffer stream)) (setf (sm buffer stream) nil)))) @@ -221,9 +225,20 @@ (warn "Unable to memory-map entire file.") (setf size (1- most-positive-fixnum))) (let ((buffer + #-win32 (handler-case - (sb-posix:mmap nil size prot sb-posix::MAP-SHARED fd 0) - (sb-posix:syscall-error nil)))) + (sb-posix:mmap nil size prot sb-posix::MAP-SHARED fd 0) + (sb-posix:syscall-error nil)) + #+win32 + (let ((mapping + (sb-win32:create-file-mapping + (sb-win32:get-osfhandle fd) nil 2 0 size nil))) + (typecase mapping + ((integer -1 0) nil) + (t (let ((sap (prog1 (sb-win32:map-view-of-file + mapping 4 0 0 size) + (sb-win32:close-handle mapping)))) + (and (not (zerop (sb-sys:sap-int sap))) sap))))))) (when (null buffer) (sb-unix:unix-close fd) (sb-ext:cancel-finalization stream) @@ -243,15 +258,18 @@ (melding-stream stream) efmt 'mapped)) (sb-ext:finalize stream (lambda () - (sb-posix:munmap buffer size) - (format *terminal-io* "~&;;; ** unmapped ~S" buffer)))))) + #+win32 (sb-win32:unmap-view-of-file buffer) + #-win32 (sb-posix:munmap buffer size) + (format *terminal-io* "~&;;; ** unmapped ~S" buffer)) + :dont-save t)))) stream))) (defmethod device-close ((stream mapped-file-simple-stream) abort) (with-stream-class (mapped-file-simple-stream stream) (when (sm buffer stream) - (sb-posix:munmap (sm buffer stream) (sm buf-len stream)) + #+win32 (sb-win32:unmap-view-of-file (sm buffer stream)) + #-win32 (sb-posix:munmap (sm buffer stream) (sm buf-len stream)) (setf (sm buffer stream) nil)) (sb-unix:unix-close (or (sm input-handle stream) (sm output-handle stream)))) t) @@ -267,6 +285,6 @@ (let ((pathname (getf options :filename))) (with-stream-class (probe-simple-stream stream) (add-stream-instance-flags stream :simple) - (when (sb-unix:unix-access (sb-int:unix-namestring pathname nil) sb-unix:f_ok) + (when (sb-unix:unix-access (file-namestring pathname) sb-unix:f_ok) (setf (sm pathname stream) pathname) t))))