- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 55 for ack (0.03 sec)
-
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) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat(countFrames(logs, "FINE: << 0x00000000 8 PING ")) .isEqualTo(1) assertThat(countFrames(logs, "FINE: >> 0x00000000 8 PING ACK")) .isEqualTo(1) assertThat(countFrames(logs, "FINE: << 0x00000000 8 PING ACK")) .isEqualTo(1) } @Flaky @ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class) fun missingPongsFailsConnection(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
Lock k8sresourcelock.Interface // LeaseDuration is the duration that non-leader candidates will // wait to force acquire leadership. This is measured against time of // last observed ack. // // A client needs to wait a full LeaseDuration without observing a change to // the record before it can attempt to take over. When all clients are
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
pkg/adsc/delta.go
var rejects []error allAdds := map[string]set.Set[string]{} allRemoves := map[string]set.Set[string]{} ctx := &handlerContext{} if isDebugType(d.TypeUrl) { // No need to ack and type check for debug types return nil } for _, r := range d.Resources { if d.TypeUrl != r.Resource.TypeUrl { deltaLog.Errorf("Invalid response: mismatch of type url: %v vs %v", d.TypeUrl, r.Resource.TypeUrl)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
if err := s.pushXds(con, w, pushRequest); err != nil { return err } } if pushRequest.Full { // Report all events for unwatched resources. Watched resources will be reported in pushXds or on ack. reportEventsForUnWatched(con, s.StatusReporter, pushRequest.Push.LedgerVersion) } proxiesConvergeDelay.Record(time.Since(pushRequest.Start).Seconds()) return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
guava/src/com/google/common/base/Ascii.java
/** * Acknowledge: A communication control character transmitted by a receiver as an affirmative * response to a sender. * * @since 8.0 */ public static final byte ACK = 6; /** * Bell ('\a'): A character for use when there is a need to call for human attention. It may * control alarm or attention devices. * * @since 8.0 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jul 19 15:43:07 UTC 2021 - 21.6K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
/** * Acknowledge: A communication control character transmitted by a receiver as an affirmative * response to a sender. * * @since 8.0 */ public static final byte ACK = 6; /** * Bell ('\a'): A character for use when there is a need to call for human attention. It may * control alarm or attention devices. * * @since 8.0 */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jul 19 15:43:07 UTC 2021 - 21.6K 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)