|
|
@@ -34,8 +34,8 @@ import (
|
|
|
"github.com/coreos/etcd/pkg/debugutil"
|
|
|
"github.com/coreos/etcd/pkg/transport"
|
|
|
|
|
|
- "github.com/cockroachdb/cmux"
|
|
|
gw "github.com/grpc-ecosystem/grpc-gateway/runtime"
|
|
|
+ "github.com/soheilhy/cmux"
|
|
|
"golang.org/x/net/context"
|
|
|
"golang.org/x/net/trace"
|
|
|
"google.golang.org/grpc"
|
|
|
@@ -152,7 +152,7 @@ func (sctx *serveCtx) serve(s *etcdserver.EtcdServer, tlsinfo *transport.TLSInfo
|
|
|
}
|
|
|
|
|
|
// grpcHandlerFunc returns an http.Handler that delegates to grpcServer on incoming gRPC
|
|
|
-// connections or otherHandler otherwise. Copied from cockroachdb.
|
|
|
+// connections or otherHandler otherwise. Given in gRPC docs.
|
|
|
func grpcHandlerFunc(grpcServer *grpc.Server, otherHandler http.Handler) http.Handler {
|
|
|
if otherHandler == nil {
|
|
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|