mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
Merge pull request #9497 from gyuho/cmux
vendor: upgrade "soheilhy/cmux" to "v0.1.4"
This commit is contained in:
commit
053bab06db
@ -65,6 +65,7 @@ See [code changes](https://github.com/coreos/etcd/compare/v3.3.0...v3.4.0) and [
|
||||
### Dependency
|
||||
|
||||
- TODO: Upgrade [`google.golang.org/grpc`](https://github.com/grpc/grpc-go/releases) from [**`v1.7.5`**](https://github.com/grpc/grpc-go/releases/tag/v1.7.5) to [**`v1.11.0`**](https://github.com/grpc/grpc-go/releases/tag/v1.11.0).
|
||||
- Upgrade [`github.com/soheilhy/cmux`](https://github.com/soheilhy/cmux/releases) from [**`v0.1.3`**](https://github.com/soheilhy/cmux/releases/tag/v0.1.3) to [**`v0.1.4`**](https://github.com/soheilhy/cmux/releases/tag/v0.1.4).
|
||||
|
||||
### Metrics, Monitoring
|
||||
|
||||
|
4
Gopkg.lock
generated
4
Gopkg.lock
generated
@ -203,8 +203,8 @@
|
||||
[[projects]]
|
||||
name = "github.com/soheilhy/cmux"
|
||||
packages = ["."]
|
||||
revision = "bb79a83465015a27a175925ebd155e660f55e9f1"
|
||||
version = "v0.1.3"
|
||||
revision = "e09e9389d85d8492d313d73d1469c029e710623f"
|
||||
version = "v0.1.4"
|
||||
|
||||
[[projects]]
|
||||
name = "github.com/spf13/cobra"
|
||||
|
3
vendor/github.com/soheilhy/cmux/cmux.go
generated
vendored
3
vendor/github.com/soheilhy/cmux/cmux.go
generated
vendored
@ -116,8 +116,9 @@ type cMux struct {
|
||||
func matchersToMatchWriters(matchers []Matcher) []MatchWriter {
|
||||
mws := make([]MatchWriter, 0, len(matchers))
|
||||
for _, m := range matchers {
|
||||
cm := m
|
||||
mws = append(mws, func(w io.Writer, r io.Reader) bool {
|
||||
return m(r)
|
||||
return cm(r)
|
||||
})
|
||||
}
|
||||
return mws
|
||||
|
5
vendor/github.com/soheilhy/cmux/matchers.go
generated
vendored
5
vendor/github.com/soheilhy/cmux/matchers.go
generated
vendored
@ -240,6 +240,11 @@ func matchHTTP2Field(w io.Writer, r io.Reader, name string, matches func(string)
|
||||
|
||||
switch f := f.(type) {
|
||||
case *http2.SettingsFrame:
|
||||
// Sender acknoweldged the SETTINGS frame. No need to write
|
||||
// SETTINGS again.
|
||||
if f.IsAck() {
|
||||
break
|
||||
}
|
||||
if err := framer.WriteSettings(); err != nil {
|
||||
return false
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user