Index: filter/dscache/serialize.go |
diff --git a/filter/dscache/serialize.go b/filter/dscache/serialize.go |
index ecf685a028c64f28d66051510c3e2f18d25fb4c5..38cca7e505ef67f78243f29c3924a95f487358a3 100644 |
--- a/filter/dscache/serialize.go |
+++ b/filter/dscache/serialize.go |
@@ -10,6 +10,7 @@ import ( |
"io/ioutil" |
ds "github.com/luci/gae/service/datastore" |
+ "github.com/luci/gae/service/datastore/serialize" |
) |
func encodeItemValue(pm ds.PropertyMap) []byte { |
@@ -18,7 +19,7 @@ func encodeItemValue(pm ds.PropertyMap) []byte { |
buf := bytes.Buffer{} |
// errs can't happen, since we're using a byte buffer. |
_ = buf.WriteByte(byte(NoCompression)) |
- _ = pm.Write(&buf, ds.WithoutContext) |
+ _ = serialize.WritePropertyMap(&buf, serialize.WithoutContext, pm) |
data := buf.Bytes() |
if buf.Len() > CompressionThreshold { |
@@ -55,7 +56,5 @@ func decodeItemValue(val []byte, ns, aid string) (ds.PropertyMap, error) { |
} |
buf = bytes.NewBuffer(data) |
} |
- ret := ds.PropertyMap{} |
- err = ret.Read(buf, ds.WithoutContext, ns, aid) |
- return ret, err |
+ return serialize.ReadPropertyMap(buf, serialize.WithoutContext, ns, aid) |
} |