Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for timeEnd (0.16 sec)

  1. cmd/admin-handlers.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer nsLock.Unlock(lkctx)
    	timeEnd := time.Now()
    
    	atomic.SwapInt64(&globalLastClientPerfExtraTime, timeEnd.Sub(timeStart).Nanoseconds())
    
    	ctx, cancel := context.WithTimeout(ctx, madmin.MaxClientPerfTimeout)
    	defer cancel()
    	totalRx := int64(0)
    	connectTime := time.Now()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  2. src/cmd/vendor/golang.org/x/telemetry/package-lock.json

          },
          "funding": {
            "url": "https://github.com/sponsors/ljharb"
          }
        },
        "node_modules/string.prototype.trimend": {
          "version": "1.0.6",
          "resolved": "https://registry.npmjs.org/string.prototype.trimend/-/string.prototype.trimend-1.0.6.tgz",
          "integrity": "sha512-JySq+4mrPf9EsDBEDYMOb/lM7XQLulwg5R/m1r0PXEFqrV0qHvl58sdTilSXtKOflCsK2E8jxf+GKC0T07RWwQ==",
          "dev": true,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 17:57:25 UTC 2024
    - 156K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

                  ListenableFuture<String> a, ListenableFuture<String> b) {
                return successfulAsList(ImmutableSet.of(a, b));
              }
            };
      }
    
      /**
       * Very rough equivalent of a timed get, produced by calling the no-arg get method in another
       * thread and waiting a short time for it.
       *
       * <p>We need this to test the behavior of no-arg get methods without hanging the main test thread
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

                  ListenableFuture<String> a, ListenableFuture<String> b) {
                return successfulAsList(ImmutableSet.of(a, b));
              }
            };
      }
    
      /**
       * Very rough equivalent of a timed get, produced by calling the no-arg get method in another
       * thread and waiting a short time for it.
       *
       * <p>We need this to test the behavior of no-arg get methods without hanging the main test thread
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  5. src/cmd/vendor/rsc.io/markdown/entity.go

    	"&tilde;":                           "\u02dc",
    	"&times;":                           "\u00d7",
    	"&timesb;":                          "\u22a0",
    	"&timesbar;":                        "\u2a31",
    	"&timesd;":                          "\u2a30",
    	"&tint;":                            "\u222d",
    	"&toea;":                            "\u2928",
    	"&top;":                             "\u22a4",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 13:01:26 UTC 2024
    - 101K bytes
    - Viewed (0)
  6. src/net/http/serve_test.go

    		cst := newClientServerTest(t, mode, HandlerFunc(func(res ResponseWriter, req *Request) {
    			_, err := io.Copy(io.Discard, req.Body)
    			if !errors.Is(err, os.ErrDeadlineExceeded) {
    				t.Errorf("server timed out reading request body: got err %v; want os.ErrDeadlineExceeded", err)
    			}
    			res.Write([]byte(respBody))
    		}), func(ts *httptest.Server) {
    			ts.Config.ReadHeaderTimeout = -1 // don't time out while reading headers
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_node_status_test.go

    	done := make(chan struct{})
    	go func() {
    		kubelet.registerWithAPIServer()
    		done <- struct{}{}
    	}()
    	select {
    	case <-time.After(wait.ForeverTestTimeout):
    		assert.Fail(t, "timed out waiting for registration")
    	case <-done:
    		return
    	}
    }
    
    func TestTryRegisterWithApiServer(t *testing.T) {
    	alreadyExists := &apierrors.StatusError{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/CallTest.kt

        val startNanos = System.nanoTime()
        bodySource.use {
          assertFailsWith<IOException> {
            bodySource.readByte()
          }.also { expected ->
            // Timed out as expected.
            val elapsedNanos = System.nanoTime() - startNanos
            val elapsedMillis = TimeUnit.NANOSECONDS.toMillis(elapsedNanos)
            assertThat(elapsedMillis).isLessThan(500)
          }
        }
      }
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  9. src/net/http/server.go

    	return &timeoutHandler{
    		handler: h,
    		body:    msg,
    		dt:      dt,
    	}
    }
    
    // ErrHandlerTimeout is returned on [ResponseWriter] Write calls
    // in handlers which have timed out.
    var ErrHandlerTimeout = errors.New("http: Handler timeout")
    
    type timeoutHandler struct {
    	handler Handler
    	body    string
    	dt      time.Duration
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
Back to top