- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 236 for impacted (0.28 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
fun flush() { writer.flush() } /** * Degrades this connection such that new streams can neither be created locally, nor accepted * from the remote peer. Existing streams are not impacted. This is intended to permit an endpoint * to gracefully stop accepting new requests without harming previously established streams. */ @Throws(IOException::class) fun shutdown(statusCode: ErrorCode) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
e.registry.Add(evaluator) klog.Infof("quota admission added evaluator for: %s", gr) } // for this kind, check if the operation could mutate any quota resources // if no resources tracked by quota are impacted, then just return if !evaluator.Handles(a) { return nil } waiter := newAdmissionWaiter(a) e.addWork(waiter) // wait for completion or timeout select { case <-waiter.finished:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
pilot/pkg/model/telemetry.go
// generate them we need to merge many telemetry specs and perform 2 Any marshals. // To improve performance, we store a cache based on the Telemetries that impacted the filter, as well as // its class and protocol. This is protected by mu. // Currently, this only applies to metrics, but a similar concept can likely be applied to logging and // tracing for performance.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
cmd/data-scanner.go
} scanFolder := func(folder cachedFolder) { if contextCanceled(ctx) { return } dst := into if !into.Compacted { dst = &dataUsageEntry{Compacted: false} } if err := f.scanFolder(ctx, folder, dst); err != nil { return } if !into.Compacted { h := dataUsageHash(folder.name) into.addChild(h) // We scanned a folder, optionally send update.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
src/go/internal/gcimporter/gcimporter_test.go
imported := importPkg(t, "./testdata/"+pkgName, tmpdir) checked := checkFile(t, filename, src) seen := make(map[string]bool) for _, name := range imported.Scope().Names() { if !token.IsExported(name) { continue // ignore synthetic names like .inittask and .dict.* } seen[name] = true importedObj := imported.Scope().Lookup(name)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 16:22:59 UTC 2024 - 21.9K bytes - Viewed (0) -
src/go/types/object.go
return &PkgName{object{nil, pos, pkg, name, Typ[Invalid], 0, black, nopos}, imported, false} } // Imported returns the package that was imported. // It is distinct from Pkg(), which is the package containing the import statement. func (obj *PkgName) Imported() *Package { return obj.imported } // A Const represents a declared constant. type Const struct { object val constant.Value
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 20:08:23 UTC 2024 - 20.1K bytes - Viewed (0) -
src/cmd/compile/internal/types2/resolver.go
} // merge imported scope with file scope for name, obj := range imp.scope.elems { // Note: Avoid eager resolve(name, obj) here, so we only // resolve dot-imported objects as needed. // A package scope may contain non-exported objects, // do not import them! if isExported(name) { // declare dot-imported object
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 14:10:44 UTC 2024 - 26.3K bytes - Viewed (0) -
src/go/types/resolver.go
} // merge imported scope with file scope for name, obj := range imp.scope.elems { // Note: Avoid eager resolve(name, obj) here, so we only // resolve dot-imported objects as needed. // A package scope may contain non-exported objects, // do not import them! if token.IsExported(name) { // declare dot-imported object
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 16:22:59 UTC 2024 - 26.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/facts/facts.go
// [GetPackageFunc] (if any) is also concurrency-safe. func (d *Decoder) Decode(read func(pkgPath string) ([]byte, error)) (*Set, error) { // Read facts from imported packages. // Facts may describe indirectly imported packages, or their objects. m := make(map[key]analysis.Fact) // one big bucket for _, imp := range d.pkg.Imports() { logf := func(format string, args ...interface{}) { if debug {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 12.1K bytes - Viewed (0) -
src/cmd/compile/internal/types2/object.go
return &PkgName{object{nil, pos, pkg, name, Typ[Invalid], 0, black, nopos}, imported, false} } // Imported returns the package that was imported. // It is distinct from Pkg(), which is the package containing the import statement. func (obj *PkgName) Imported() *Package { return obj.imported } // A Const represents a declared constant. type Const struct { object val constant.Value
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 20:08:23 UTC 2024 - 20.1K bytes - Viewed (0)