summaryrefslogtreecommitdiff
path: root/vendor/google.golang.org/grpc/internal/channelz/funcs.go
diff options
context:
space:
mode:
authorLibravatar dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>2024-04-29 09:18:16 +0000
committerLibravatar GitHub <noreply@github.com>2024-04-29 09:18:16 +0000
commit1375a86919b7a47de14b3d99cb4e389158d6c94d (patch)
tree9017301dda253cf023df1ef747770aa606b967ba /vendor/google.golang.org/grpc/internal/channelz/funcs.go
parent[chore]: Bump go.opentelemetry.io/otel/sdk from 1.25.0 to 1.26.0 (#2879) (diff)
downloadgotosocial-1375a86919b7a47de14b3d99cb4e389158d6c94d.tar.xz
[chore]: Bump go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc (#2878)
Diffstat (limited to 'vendor/google.golang.org/grpc/internal/channelz/funcs.go')
-rw-r--r--vendor/google.golang.org/grpc/internal/channelz/funcs.go21
1 files changed, 11 insertions, 10 deletions
diff --git a/vendor/google.golang.org/grpc/internal/channelz/funcs.go b/vendor/google.golang.org/grpc/internal/channelz/funcs.go
index f461e9bc3..03e24e150 100644
--- a/vendor/google.golang.org/grpc/internal/channelz/funcs.go
+++ b/vendor/google.golang.org/grpc/internal/channelz/funcs.go
@@ -143,20 +143,21 @@ func RegisterChannel(parent *Channel, target string) *Channel {
// Returns a unique channelz identifier assigned to this subChannel.
//
// If channelz is not turned ON, the channelz database is not mutated.
-func RegisterSubChannel(pid int64, ref string) *SubChannel {
+func RegisterSubChannel(parent *Channel, ref string) *SubChannel {
id := IDGen.genID()
- if !IsOn() {
- return &SubChannel{ID: id}
- }
-
sc := &SubChannel{
- RefName: ref,
ID: id,
- sockets: make(map[int64]string),
- parent: db.getChannel(pid),
- trace: &ChannelTrace{CreationTime: time.Now(), Events: make([]*traceEvent, 0, getMaxTraceEntry())},
+ RefName: ref,
+ parent: parent,
}
- db.addSubChannel(id, sc, pid)
+
+ if !IsOn() {
+ return sc
+ }
+
+ sc.sockets = make(map[int64]string)
+ sc.trace = &ChannelTrace{CreationTime: time.Now(), Events: make([]*traceEvent, 0, getMaxTraceEntry())}
+ db.addSubChannel(id, sc, parent.ID)
return sc
}