Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 639 for records (0.1 sec)

  1. .github/CODEOWNERS

    gradle/shared-with-buildSrc/                @gradle/bt-developer-productivity
    platforms/build-infrastructure/             @gradle/bt-developer-productivity
    subprojects/internal-build-reports/         @gradle/bt-developer-productivity
    testing/internal-architecture-testing/      @gradle/bt-developer-productivity
    testing/internal-integ-testing/             @gradle/bt-developer-productivity
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Oct 24 14:46:27 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. cni/pkg/cmd/root.go

    			log.Errorf("Failed to start up UDS Log Server: %v", err)
    			return
    		}
    
    		// Creates a basic health endpoint server that reports health status
    		// based on atomic flag, as set by installer
    		// TODO nodeagent watch server should affect this too, and drop atomic flag
    		installDaemonReady, watchServerReady := nodeagent.StartHealthServer()
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. cmd/prepare-storage.go

    		return nil, nil, errInvalidArgument
    	}
    
    	// prepare getElapsedTime() to calculate elapsed time since we started trying formatting disks.
    	// All times are rounded to avoid showing milli, micro and nano seconds
    	formatStartTime := time.Now().Round(time.Second)
    	getElapsedTime := func() string {
    		return time.Now().Round(time.Second).Sub(formatStartTime).String()
    	}
    
    	var (
    		tries   int
    		verbose bool
    	)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  4. okhttp/src/test/java/okhttp3/EventListenerTest.kt

          "ResponseBodyEnd", "ConnectionReleased", "CallEnd",
        )
      }
    
      @Test
      fun failedCallEventSequence() {
        server.enqueue(
          MockResponse.Builder()
            .headersDelay(2, TimeUnit.SECONDS)
            .build(),
        )
        client =
          client.newBuilder()
            .readTimeout(Duration.ofMillis(250))
            .build()
        val call =
          client.newCall(
            Request.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  5. common-protos/k8s.io/api/batch/v1/generated.proto

      // reason UnknownTimeZone.
      // More information can be found in https://kubernetes.io/docs/concepts/workloads/controllers/cron-jobs/#time-zones
      // +optional
      optional string timeZone = 8;
    
      // Optional deadline in seconds for starting the job if it misses scheduled
      // time for any reason.  Missed jobs executions will be counted as failed ones.
      // +optional
      optional int64 startingDeadlineSeconds = 2;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Cache.java

       * created using {@link CacheBuilder} only does so if the {@link CacheBuilder#recordStats} method
       * was called. If statistics are not being recorded, a {@code CacheStats} instance with zero for
       * all values is returned.
       *
       */
      CacheStats stats();
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Aug 07 02:38:22 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  7. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt

        assertThat(Adapters.parseGeneralizedTime("19920622123421Z"))
          .isEqualTo(date("1992-06-22T12:34:21.000+0000").time)
      }
    
      @Disabled("fractional seconds are not implemented")
      @Test
      fun `parse generalized time with fractional seconds`() {
        assertThat(Adapters.parseGeneralizedTime("19920722132100.3Z"))
          .isEqualTo(date("1992-07-22T13:21:00.300+0000").time)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  8. cmd/iam.go

    }
    
    // LoadUser - reloads a specific user from backend disks or etcd.
    func (sys *IAMSys) LoadUser(ctx context.Context, objAPI ObjectLayer, accessKey string, userType IAMUserType) error {
    	if !sys.Initialized() {
    		return errServerNotInitialized
    	}
    
    	return sys.store.UserNotificationHandler(ctx, accessKey, userType)
    }
    
    // LoadServiceAccount - reloads a specific service account from backend disks or etcd.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/ByteSourceTest.java

        // Open a stream to the slice.
        InputStream in = slice.openStream();
    
        // Append 10 more bytes to the source.
        source.append(newPreFilledByteArray(5, 10));
    
        // The stream reports no bytes... importantly, it doesn't read the byte at index 5 when it
        // should be reading the byte at index 10.
        // We could use a custom InputStream instead to make the read start at index 10, but since this
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. cmd/bucket-stats.go

    	min := time.Now().Unix() / 60
    	l.forwardTo(min)
    	winIdx := min % 60
    	l.Totals[winIdx].merge(AccElem{Total: min, Size: sz, N: 1})
    	l.LastMin = min
    }
    
    // Merge all recorded counts of last hour into one
    func (l *ReplicationLastHour) getTotal() AccElem {
    	var res AccElem
    	min := time.Now().Unix() / 60
    	l.forwardTo(min)
    	for _, elem := range l.Totals[:] {
    		res.merge(elem)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top