runtime/internal/flow/conn: Rename addRecieveBuffers to release.
Change-Id: I495595cf18b4eac598bf95bb2b2d66db242c5722
diff --git a/runtime/internal/flow/conn/conn.go b/runtime/internal/flow/conn/conn.go
index 4e9079c..ebe4535 100644
--- a/runtime/internal/flow/conn/conn.go
+++ b/runtime/internal/flow/conn/conn.go
@@ -184,13 +184,13 @@
}
err := c.fc.Run(ctx, expressPriority, func(_ int) (int, bool, error) {
- err := c.mp.writeMsg(ctx, &addRecieveBuffers{
+ err := c.mp.writeMsg(ctx, &release{
counters: counts,
})
return 0, true, err
})
if err != nil {
- c.Close(ctx, NewErrSend(ctx, "addRecieveBuffers", c.remote.String(), err))
+ c.Close(ctx, NewErrSend(ctx, "release", c.remote.String(), err))
}
}
@@ -216,7 +216,7 @@
c.mu.Unlock()
c.handler.HandleFlow(f)
- case *addRecieveBuffers:
+ case *release:
release := make([]flowcontrol.Release, 0, len(msg.counters))
c.mu.Lock()
for fid, val := range msg.counters {
diff --git a/runtime/internal/flow/conn/message.go b/runtime/internal/flow/conn/message.go
index d30c52e..e1bc1f3 100644
--- a/runtime/internal/flow/conn/message.go
+++ b/runtime/internal/flow/conn/message.go
@@ -33,7 +33,7 @@
setupCmd
tearDownCmd
openFlowCmd
- addRecieveBuffersCmd
+ releaseCmd
)
// setup options.
@@ -132,21 +132,21 @@
return nil
}
-// addRecieveBuffers is sent as flows are read from locally. The counters
+// release is sent as flows are read from locally. The counters
// inform remote writers that there is local buffer space available.
-type addRecieveBuffers struct {
+type release struct {
counters map[flowID]uint64
}
-func (m *addRecieveBuffers) write(ctx *context.T, p *messagePipe) error {
+func (m *release) write(ctx *context.T, p *messagePipe) error {
p.controlBuf = p.controlBuf[:0]
for fid, val := range m.counters {
p.controlBuf = writeVarUint64(uint64(fid), p.controlBuf)
p.controlBuf = writeVarUint64(val, p.controlBuf)
}
- return p.write([][]byte{{controlType}}, [][]byte{{addRecieveBuffersCmd}, p.controlBuf})
+ return p.write([][]byte{{controlType}}, [][]byte{{releaseCmd}, p.controlBuf})
}
-func (m *addRecieveBuffers) read(ctx *context.T, orig []byte) error {
+func (m *release) read(ctx *context.T, orig []byte) error {
var (
data = orig
valid bool
@@ -159,10 +159,10 @@
m.counters = map[flowID]uint64{}
for len(data) > 0 {
if fid, data, valid = readVarUint64(ctx, data); !valid {
- return NewErrInvalidControlMsg(ctx, addRecieveBuffersCmd, int64(len(orig)), n)
+ return NewErrInvalidControlMsg(ctx, releaseCmd, int64(len(orig)), n)
}
if val, data, valid = readVarUint64(ctx, data); !valid {
- return NewErrInvalidControlMsg(ctx, addRecieveBuffersCmd, int64(len(orig)), n+1)
+ return NewErrInvalidControlMsg(ctx, releaseCmd, int64(len(orig)), n+1)
}
m.counters[flowID(fid)] = val
n += 2
@@ -300,8 +300,8 @@
m = &tearDown{}
case openFlowCmd:
m = &openFlow{}
- case addRecieveBuffersCmd:
- m = &addRecieveBuffers{}
+ case releaseCmd:
+ m = &release{}
default:
return nil, NewErrUnknownControlMsg(ctx, msg[0])
}
diff --git a/runtime/internal/flow/conn/message_test.go b/runtime/internal/flow/conn/message_test.go
index 416ba3d..ab715ae 100644
--- a/runtime/internal/flow/conn/message_test.go
+++ b/runtime/internal/flow/conn/message_test.go
@@ -96,8 +96,8 @@
func TestAddReceiveBuffers(t *testing.T) {
testMessages(t, []message{
- &addRecieveBuffers{},
- &addRecieveBuffers{counters: map[flowID]uint64{
+ &release{},
+ &release{counters: map[flowID]uint64{
4: 233,
9: 423242,
}},
