akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

channeldb/codec: exposes Read/WriteElements

Browse Source
This commit is contained in:
Conner Fromknecht 2018-06-27 16:29:38 -07:00
parent 9205720bea
commit ec029ac7fd
No known key found for this signature in database
GPG Key ID: 39DE78FBE6ACB0EF
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
channeldb/codec.go
View File

@ -43,11 +43,11 @@ func readOutpoint(r io.Reader, o *wire.OutPoint) error {
return nil return nil
} }
// writeElement is a one-stop shop to write the big endian representation of // WriteElement is a one-stop shop to write the big endian representation of
// any element which is to be serialized for storage on disk. The passed // any element which is to be serialized for storage on disk. The passed
// io.Writer should be backed by an appropriately sized byte slice, or be able // io.Writer should be backed by an appropriately sized byte slice, or be able
// to dynamically expand to accommodate additional data. // to dynamically expand to accommodate additional data.
func writeElement(w io.Writer, element interface{}) error { func WriteElement(w io.Writer, element interface{}) error {
switch e := element.(type) { switch e := element.(type) {
case keychain.KeyDescriptor: case keychain.KeyDescriptor:
if err := binary.Write(w, byteOrder, e.Family); err != nil { if err := binary.Write(w, byteOrder, e.Family); err != nil {
@ -61,7 +61,7 @@ func writeElement(w io.Writer, element interface{}) error {
if err := binary.Write(w, byteOrder, true); err != nil { if err := binary.Write(w, byteOrder, true); err != nil {
} }
return writeElement(w, e.PubKey) return WriteElement(w, e.PubKey)
} }
return binary.Write(w, byteOrder, false) return binary.Write(w, byteOrder, false)
@ -164,17 +164,17 @@ func writeElement(w io.Writer, element interface{}) error {
} }
default: default:
return fmt.Errorf("Unknown type in writeElement: %T", e) return fmt.Errorf("Unknown type in WriteElement: %T", e)
} }
return nil return nil
} }
// writeElements is writes each element in the elements slice to the passed // WriteElements is writes each element in the elements slice to the passed
// io.Writer using writeElement. // io.Writer using WriteElement.
func writeElements(w io.Writer, elements ...interface{}) error { func WriteElements(w io.Writer, elements ...interface{}) error {
for _, element := range elements { for _, element := range elements {
err := writeElement(w, element) err := WriteElement(w, element)
if err != nil { if err != nil {
return err return err
} }
@ -182,9 +182,9 @@ func writeElements(w io.Writer, elements ...interface{}) error {
return nil return nil
} }
// readElement is a one-stop utility function to deserialize any datastructure // ReadElement is a one-stop utility function to deserialize any datastructure
// encoded using the serialization format of the database. // encoded using the serialization format of the database.
func readElement(r io.Reader, element interface{}) error { func ReadElement(r io.Reader, element interface{}) error {
switch e := element.(type) { switch e := element.(type) {
case *keychain.KeyDescriptor: case *keychain.KeyDescriptor:
if err := binary.Read(r, byteOrder, &e.Family); err != nil { if err := binary.Read(r, byteOrder, &e.Family); err != nil {
@ -200,7 +200,7 @@ func readElement(r io.Reader, element interface{}) error {
} }
if hasPubKey { if hasPubKey {
return readElement(r, &e.PubKey) return ReadElement(r, &e.PubKey)
} }
case *ChannelType: case *ChannelType:
@ -343,18 +343,18 @@ func readElement(r io.Reader, element interface{}) error {
} }
default: default:
return fmt.Errorf("Unknown type in readElement: %T", e) return fmt.Errorf("Unknown type in ReadElement: %T", e)
} }
return nil return nil
} }
// readElements deserializes a variable number of elements into the passed // ReadElements deserializes a variable number of elements into the passed
// io.Reader, with each element being deserialized according to the readElement // io.Reader, with each element being deserialized according to the ReadElement
// function. // function.
func readElements(r io.Reader, elements ...interface{}) error { func ReadElements(r io.Reader, elements ...interface{}) error {
for _, element := range elements { for _, element := range elements {
err := readElement(r, element) err := ReadElement(r, element)
if err != nil { if err != nil {
return err return err
} }