代码拉取完成,页面将自动刷新
// Copyright 2015 CoreOS, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package rafthttp
import (
"encoding/binary"
"io"
"github.com/coreos/etcd/pkg/metrics"
"github.com/coreos/etcd/pkg/types"
"github.com/coreos/etcd/raft/raftpb"
)
type entryReader struct {
r io.Reader
id types.ID
ents *metrics.Counter
bytes *metrics.Counter
lastIndex *metrics.Gauge
}
func newEntryReader(r io.Reader, id types.ID) *entryReader {
return &entryReader{
r: r,
id: id,
ents: metrics.GetMap("rafthttp.stream.entries_received").NewCounter(id.String()),
bytes: metrics.GetMap("rafthttp.stream.bytes_received").NewCounter(id.String()),
lastIndex: metrics.GetMap("rafthttp.stream.last_index_received").NewGauge(id.String()),
}
}
func (er *entryReader) readEntries() ([]raftpb.Entry, error) {
var l uint64
if err := binary.Read(er.r, binary.BigEndian, &l); err != nil {
return nil, err
}
er.bytes.AddBy(8)
ents := make([]raftpb.Entry, int(l))
for i := 0; i < int(l); i++ {
if err := er.readEntry(&ents[i]); err != nil {
return nil, err
}
er.ents.Add()
}
er.lastIndex.Set(int64(ents[l-1].Index))
return ents, nil
}
func (er *entryReader) readEntry(ent *raftpb.Entry) error {
var l uint64
if err := binary.Read(er.r, binary.BigEndian, &l); err != nil {
return err
}
buf := make([]byte, int(l))
if _, err := io.ReadFull(er.r, buf); err != nil {
return err
}
er.bytes.AddBy(8 + int64(l))
return ent.Unmarshal(buf)
}
func (er *entryReader) stop() {
metrics.GetMap("rafthttp.stream.entries_received").Delete(er.id.String())
metrics.GetMap("rafthttp.stream.bytes_received").Delete(er.id.String())
metrics.GetMap("rafthttp.stream.last_index_received").Delete(er.id.String())
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。