msg_codec.go 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. // Copyright 2015 The etcd Authors
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. package rafthttp
  15. import (
  16. "encoding/binary"
  17. "io"
  18. "github.com/coreos/etcd/pkg/pbutil"
  19. "github.com/coreos/etcd/raft/raftpb"
  20. )
  21. // messageEncoder is a encoder that can encode all kinds of messages.
  22. // It MUST be used with a paired messageDecoder.
  23. type messageEncoder struct {
  24. w io.Writer
  25. }
  26. func (enc *messageEncoder) encode(m raftpb.Message) error {
  27. if err := binary.Write(enc.w, binary.BigEndian, uint64(m.Size())); err != nil {
  28. return err
  29. }
  30. _, err := enc.w.Write(pbutil.MustMarshal(&m))
  31. return err
  32. }
  33. // messageDecoder is a decoder that can decode all kinds of messages.
  34. type messageDecoder struct {
  35. r io.Reader
  36. }
  37. func (dec *messageDecoder) decode() (raftpb.Message, error) {
  38. var m raftpb.Message
  39. var l uint64
  40. if err := binary.Read(dec.r, binary.BigEndian, &l); err != nil {
  41. return m, err
  42. }
  43. buf := make([]byte, int(l))
  44. if _, err := io.ReadFull(dec.r, buf); err != nil {
  45. return m, err
  46. }
  47. return m, m.Unmarshal(buf)
  48. }