luciano/nippy
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Experimental compressable-lzma2: fix thaw bug

Browse source
This commit is contained in:
Peter Taoussanis 2013-11-07 12:44:32 +07:00
parent 360e4a77bd
commit 0fd9275e37
1 changed files with 13 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/taoensso/nippy.clj
View file

@ -446,7 +446,8 @@
(defrecord Compressable-LZMA2 [value]) (defrecord Compressable-LZMA2 [value])
(extend-freeze Compressable-LZMA2 128 [x st] (extend-freeze Compressable-LZMA2 128 [x st]
(let [ba (freeze (:value x) {:compressor nil :legacy-mode true}) (let [[_ ^bytes ba] (-> (freeze (:value x) {:compressor nil})
(utils/ba-split 4))
ba-len (alength ba) ba-len (alength ba)
compress? (> ba-len 1024)] compress? (> ba-len 1024)]
(.writeBoolean st compress?) (.writeBoolean st compress?)
@ -463,11 +464,18 @@
ba-len (.readLong st) ba-len (.readLong st)
ba (byte-array ba-len)] ba (byte-array ba-len)]
(.read st ba 0 ba-len) (.read st ba 0 ba-len)
(thaw ba {:compressor (when compressed? compression/lzma2-compressor)}))) (thaw (wrap-header ba {:compressed? compressed? :encrypted? false})
{:compressor compression/lzma2-compressor})))
(comment (count (freeze (apply str (repeatedly 1000 rand)))) (comment
(count (freeze (->> (apply str (repeatedly 1000 rand)) (->> (apply str (repeatedly 1000 rand))
(->Compressable-LZMA2))))) (->Compressable-LZMA2)
(freeze)
(thaw))
(count (->> (apply str (repeatedly 1000 rand)) (freeze)))
(count (->> (apply str (repeatedly 1000 rand))
(->Compressable-LZMA2)
(freeze))))
;;;; Stress data ;;;; Stress data