- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for startPush (0.19 sec)
-
pilot/pkg/xds/ads.go
// Make sure the ConfigsUpdated map exists if req.ConfigsUpdated == nil { req.ConfigsUpdated = make(sets.Set[model.ConfigKey]) } } s.StartPush(req) } // Send a signal to all connections, with a push event. func (s *DiscoveryServer) StartPush(req *model.PushRequest) { // Push config changes, iterating over connected envoys. if log.DebugEnabled() { currentlyPending := s.pushQueue.Pending()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
tensorflow/compiler/aot/benchmark.cc
const int64_t start_us = NowMicros(); int64_t iters = 0; while (true) { const int64_t iter_start_us = NowMicros(); fn(); const int64_t end_us = NowMicros(); // Collect stats and decide whether to stop. stats->per_iter_us.push_back(end_us - iter_start_us); const int64_t total_us = end_us - start_us; ++iters; if ((max_us > 0 && total_us >= max_us) ||
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Sep 12 19:45:29 UTC 2023 - 4.5K bytes - Viewed (0) -
src/net/http/h2_bundle.go
sc.startGracefulShutdownInternal() case http2handlerDoneMsg: sc.handlerDone() default: panic("unknown timer") } case *http2startPushRequest: sc.startPush(v) case func(*http2serverConn): v(sc) default: panic(fmt.Sprintf("unexpected type %T", v)) } } // If the peer is causing us to generate a lot of control frames,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0)