- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 50 for spent (0.1 sec)
-
src/main/java/org/codelibs/fess/mylasta/action/FessMessages.java
/** The key of the message: Uploaded Mapping file. */ public static final String SUCCESS_upload_mapping_file = "{success.upload_mapping_file}"; /** The key of the message: Sent the test mail. */ public static final String SUCCESS_send_testmail = "{success.send_testmail}"; /** The key of the message: Deleted job logs. */
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 119.9K bytes - Viewed (0) -
src/database/sql/sql.go
db.openNewConnection(ctx) } } } // Open one new connection func (db *DB) openNewConnection(ctx context.Context) { // maybeOpenNewConnections has already executed db.numOpen++ before it sent // on db.openerCh. This function must execute db.numOpen-- if the // connection fails or is closed before returning. ci, err := db.connector.Connect(ctx) db.mu.Lock() defer db.mu.Unlock() if db.closed {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
src/reflect/value.go
v.mustBe(Chan) v.mustBeExported() return v.recv(true) } // TrySend attempts to send x on the channel v but will not block. // It panics if v's Kind is not [Chan]. // It reports whether the value was sent. // As in Go, x's value must be assignable to the channel's element type. func (v Value) TrySend(x Value) bool { v.mustBe(Chan) v.mustBeExported() return v.send(x, true) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 119.9K bytes - Viewed (0) -
src/cmd/go/alldocs.go
// See also -skip. // // -short // Tell long-running tests to shorten their run time. // It is off by default but set during all.bash so that installing // the Go tree can run a sanity check but not spend time running // exhaustive tests. // // -shuffle off,on,N // Randomize the execution order of tests and benchmarks. // It is off by default. If -shuffle is set to on, then it will seed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:54:28 UTC 2024 - 142.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
manager.podStoreSynced = alwaysReady manager.jobStoreSynced = alwaysReady var testJob batch.Job received := make(chan struct{}) // The update sent through the fakeWatcher should make its way into the workqueue, // and eventually into the syncHandler. manager.syncHandler = func(ctx context.Context, key string) error { defer close(received)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
.filter { event: CallEvent? -> event is ConnectStart } .count() assertThat(connectCount).isEqualTo(1) } } /** Test which headers are sent unencrypted to the HTTP proxy. */ @Test fun proxyConnectOmitsApplicationHeaders() { server.useHttps(handshakeCertificates.sslSocketFactory()) server.enqueue( MockResponse(inTunnel = true),
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal_test.go
timeoutTime := time.Now().Add(2 * time.Second) for now := time.Now(); timeoutTime.After(now); now = time.Now() { sleepUntil := timeoutTime.Sub(now) select { case <-tc.processed: // drain the chan of any sent events to keep it from filling before the timeout case <-time.After(sleepUntil): // timeout reached, ready to verifyResults } } } else { // Wait for HPA to be processed. <-tc.processed }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 199.3K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
file.ServeHTTP(w, req) })) } else { kl.logServer = http.StripPrefix("/logs/", file) } } if kl.kubeClient == nil { klog.InfoS("No API server defined - no node status update will be sent") } // Start the cloud provider sync manager if kl.cloudResourceSyncManager != nil { go kl.cloudResourceSyncManager.Run(wait.NeverStop) } if err := kl.initializeModules(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
cmd/object-handlers_test.go
mustGetPutObjReader(t, strings.NewReader(part.inputReaderData), part.inputDataSize, part.inputMd5, ""), opts) if err != nil { t.Fatalf("%s : %s", instanceType, err) } } // Parts to be sent as input for CompleteMultipartUpload. inputParts := []struct { parts []CompletePart }{ // inputParts - 0. // Case for replicating ETag mismatch. { []CompletePart{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0)