- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for ack (0.04 sec)
-
internal/grid/muxserver.go
} // Acknowledge Mux created. // Send async. var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() var ack message ack.Op = OpAckMux ack.Flags = m.BaseFlags ack.MuxID = m.ID m.send(ack) if debugPrint { fmt.Println("connected stream mux:", ack.MuxID) } }() // Data inbound to the handler var handlerIn chan []byte if inboundCap > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
xds.ExpiredNonce.With(typeTag.Value(v3.GetMetricType(request.TypeUrl))).Increment() return false } // If it comes here, that means nonce match. This an ACK. We should record // the ack details and respond if there is a change in resource names. var previousResources, currentResources []string var alwaysRespond bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
assert.Equal(t, resp.RemovedResources, []string{"outbound|80||test-1.default"}) // Another removal should behave the same s.MemRegistry.RemoveService("eds.test.svc.cluster.local") resp = ads.ExpectResponse() // ACK ads.Request(&discovery.DeltaDiscoveryRequest{ TypeUrl: resp.TypeUrl, ResponseNonce: resp.Nonce, }) assertResources(resp)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
internal/grid/muxclient.go
func (m *muxClient) error(err RemoteErr) { if debugPrint { fmt.Printf("mux %d: got remote err:%v\n", m.MuxID, string(err)) } m.addResponse(Response{Err: &err}) } func (m *muxClient) ack(seq uint32) { if !m.checkSeq(seq) { return } if m.acked || m.outBlock == nil { return } available := cap(m.outBlock) for i := 0; i < available; i++ { m.outBlock <- struct{}{} }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
src/net/http/h2_bundle.go
http2FlagHeadersEndHeaders: "END_HEADERS", http2FlagHeadersPadded: "PADDED", http2FlagHeadersPriority: "PRIORITY", }, http2FrameSettings: { http2FlagSettingsAck: "ACK", }, http2FramePing: { http2FlagPingAck: "ACK", }, http2FrameContinuation: { http2FlagContinuationEndHeaders: "END_HEADERS", }, http2FramePushPromise: { http2FlagPushPromiseEndHeaders: "END_HEADERS",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/net/http/server.go
// that we have received the client's ACK, and at any rate we don't want to // allow a misbehaving client to soak up server connections indefinitely by // withholding an ACK, nor do we want to go through the complexity or overhead // of using low-level APIs to figure out when a TCP round-trip has completed. // // Instead, we declare that we are “reasonably certain” that we received the // ACK if maxRSTAvoidanceDelay has elapsed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
internal/grid/connection.go
gridLogIf(ctx, c.queueMsg(message{Op: OpDisconnectClientMux, MuxID: m.MuxID}, nil)) } return } if debugPrint { fmt.Println(c.Local, "Mux", m.MuxID, "Acknowledged") } v.ack(m.Seq) } func (c *Connection) handleRequest(ctx context.Context, m message, subID *subHandlerID) { if !m.Handler.valid() { gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler"})) return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
doc/go_spec.html
</pre> <p> A function literal can be assigned to a variable or invoked directly. </p> <pre> f := func(x, y int) int { return x + y } func(ch chan int) { ch <- ACK }(replyChan) </pre> <p> Function literals are <i>closures</i>: they may refer to variables defined in a surrounding function. Those variables are then shared between
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 21:07:21 UTC 2024 - 281.5K bytes - Viewed (0)