- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for ts (0.04 sec)
-
src/net/http/serve_test.go
io.WriteString(w, r.RemoteAddr) }), func(ts *httptest.Server) { ts.Config.ReadHeaderTimeout = readHeaderTimeout ts.Config.IdleTimeout = 2 * readHeaderTimeout }) defer cst.close() ts := cst.ts t.Logf("ReadHeaderTimeout = %v", ts.Config.ReadHeaderTimeout) t.Logf("IdleTimeout = %v", ts.Config.IdleTimeout) c := ts.Client() get := func() (string, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/net/http/transport_test.go
ts := newClientServerTest(t, mode, h).ts go proxy(t) c := ts.Client() c.Transport.(*Transport).Proxy = ProxyURL(pu) r, err := c.Head(ts.URL) if err != nil { t.Fatal(err) } if r.Header.Get(sentinelHeader) != sentinelValue { t.Errorf("Failed to retrieve sentinel value") } got := <-ch ts.Close() tsu, err := url.Parse(ts.URL)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
} } func (ts *telemetryStore) add(cfg config.Config) { ts.data = append(ts.data, struct { typ config.GroupVersionKind ns string cfg config.Config }{ typ: cfg.GroupVersionKind, ns: cfg.Namespace, cfg: cfg, }) } func (ts *telemetryStore) Schemas() collection.Schemas { return collection.SchemasFor() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
pkg/test/framework/test.go
requireLocalIstiod bool requireSingleNetwork bool minIstioVersion string minKubernetesMinorVersion uint topLevel bool ctx *testContext tc context2.Context ts traceapi.Span } // NewTest returns a new test wrapper for running a single test. func NewTest(t *testing.T) Test { rtMu.Lock() defer rtMu.Unlock() if rt == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 10.3K bytes - Viewed (0) -
cmd/object-api-datatypes.go
cinfo.UserDefined[k] = v } return cinfo } func (o ObjectInfo) tierStats() tierStats { ts := tierStats{ TotalSize: uint64(o.Size), NumVersions: 1, } // the current version of an object is accounted towards objects count if o.IsLatest { ts.NumObjects = 1 } return ts } // ToObjectInfo converts a replication object info to a partial ObjectInfo
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} } } else { ts := tierStats{ TotalSize: uint64(task.objInfo.Size), NumVersions: 1, } if task.objInfo.IsLatest { ts.NumObjects = 1 } t.addLastDayStats(task.event.StorageClass, ts) } t.activeTasks.Add(-1) } } } func (t *transitionState) addLastDayStats(tier string, ts tierStats) { t.lastDayMu.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheSupportedTypesIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 26.1K bytes - Viewed (0) -
src/os/exec/exec_test.go
ts := httptest.NewUnstartedServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {})) // quiet expected TLS handshake error "remote error: bad certificate" ts.Config.ErrorLog = log.New(io.Discard, "", 0) ts.StartTLS() defer ts.Close() _, err = http.Get(ts.URL) if err == nil { t.Errorf("success trying to fetch %s; want an error", ts.URL) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K bytes - Viewed (0) -
common/Makefile.common.mk
lint-sass: @${FINDFILES} -name '*.scss' -print0 | ${XARGS} sass-lint -c common/config/sass-lint.yml --verbose lint-typescript: @${FINDFILES} -name '*.ts' -print0 | ${XARGS} tslint -c common/config/tslint.json lint-licenses: @if test -d licenses; then license-lint --config common/config/license-lint.yml; fi
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 14:37:27 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/bucket-replication.go
func (s *replicationResyncer) incStats(ts TargetReplicationResyncStatus, opts resyncOpts) { s.Lock() defer s.Unlock() m := s.statusMap[opts.bucket] st := m.TargetsMap[opts.arn] st.Object = ts.Object st.ReplicatedCount += ts.ReplicatedCount st.FailedCount += ts.FailedCount st.ReplicatedSize += ts.ReplicatedSize st.FailedSize += ts.FailedSize m.TargetsMap[opts.arn] = st
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0)