Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 406 for readLine (0.59 seconds)

  1. cmd/bucket-metadata_gen.go

    			z.EncryptionConfigUpdatedAt, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "EncryptionConfigUpdatedAt")
    				return
    			}
    		case "TaggingConfigUpdatedAt":
    			z.TaggingConfigUpdatedAt, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "TaggingConfigUpdatedAt")
    				return
    			}
    		case "QuotaConfigUpdatedAt":
    			z.QuotaConfigUpdatedAt, err = dc.ReadTime()
    			if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  2. cmd/callhome.go

    		}
    	}
    }
    
    func performCallhome(ctx context.Context) {
    	deadline := 10 * time.Second // Default deadline is 10secs for callhome
    	objectAPI := newObjectLayerFn()
    	if objectAPI == nil {
    		internalLogIf(ctx, errors.New("Callhome: object layer not ready"))
    		return
    	}
    
    	healthCtx, healthCancel := context.WithTimeout(ctx, deadline)
    	defer healthCancel()
    
    	healthInfoCh := make(chan madmin.HealthInfo)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  3. internal/config/certs.go

    // decrypted using the ENV_VAR: MINIO_CERT_PASSWD.
    func LoadX509KeyPair(certFile, keyFile string) (tls.Certificate, error) {
    	certPEMBlock, err := os.ReadFile(certFile)
    	if err != nil {
    		return tls.Certificate{}, ErrTLSReadError(nil).Msgf("Unable to read the public key: %s", err)
    	}
    	keyPEMBlock, err := os.ReadFile(keyFile)
    	if err != nil {
    		return tls.Certificate{}, ErrTLSReadError(nil).Msgf("Unable to read the private key: %s", err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Aug 14 17:11:51 GMT 2024
    - 3.8K bytes
    - Click Count (0)
  4. build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/tasks/FixProjectHealthTask.kt

            dependenciesToModify.forEach { (filePath, dependencies) ->
                val file = File(filePath)
                if (!file.exists()) return@forEach
    
                val lines = file.readLines().toMutableList()
                dependencies.forEach { dependency ->
                    val dependencyRegex = Regex("""(api|implementation)(\(projects\.[a-zA-Z]+\)) \(was (api|implementation)\)""")
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Mon Mar 03 06:57:08 GMT 2025
    - 6.2K bytes
    - Click Count (1)
  5. internal/ioutil/ioutil.go

    	return &WriteOnCloser{w, false}
    }
    
    type ioret[V any] struct {
    	val V
    	err error
    }
    
    // WithDeadline will execute a function with a deadline and return a value of a given type.
    // If the deadline/context passes before the function finishes executing,
    // the zero value and the context error is returned.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  6. src/bytes/reader_test.go

    		if _, _, err := reader.ReadRune(); err != nil {
    			// should not happen
    			t.Fatal(err)
    		}
    		tt.f(reader)
    		err := reader.UnreadRune()
    		if err == nil {
    			t.Errorf("Unreading after %s: expected error", tt.name)
    		}
    	}
    }
    
    func TestReaderDoubleUnreadRune(t *testing.T) {
    	buf := NewBuffer([]byte("groucho"))
    	if _, _, err := buf.ReadRune(); err != nil {
    		// should not happen
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  7. mvnw

        # readlink(1) is not available as standard on Solaris 10.
        readLink=$(which readlink)
        if [ ! "$(expr "$readLink" : '\([^ ]*\)')" = "no" ]; then
          if $darwin; then
            javaHome="$(dirname "$javaExecutable")"
            javaExecutable="$(cd "$javaHome" && pwd -P)/javac"
          else
            javaExecutable="$(readlink -f "$javaExecutable")"
          fi
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Oct 14 22:24:15 GMT 2024
    - 10.9K bytes
    - Click Count (0)
  8. internal/grid/muxclient.go

    		Payload:    req,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    	ch := make(chan Response, 1)
    	m.respMu.Lock()
    	if m.closed {
    		m.respMu.Unlock()
    		return nil, ErrDisconnected
    	}
    	m.respWait = ch
    	m.respMu.Unlock()
    	ctx := m.ctx
    
    	// Add deadline if none.
    	if msg.DeadlineMS == 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/ByteSource.java

       * than would be returned by reading all of the bytes (for example, some special files may return
       * a size of 0 despite actually having content when read).
       *
       * <p>In either case, for mutable sources such as files, a subsequent read may return a different
       * number of bytes if the contents are changed.
       *
       * @throws IOException if an I/O error occurs while reading the size of this source
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

       */
      @SuppressWarnings("removal") // b/260137033
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
        long timeoutSeconds = timeoutSeconds();
        long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds);
        do {
          System.runFinalization();
          if (future.isDone()) {
            return;
          }
          System.gc();
          try {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 11.5K bytes
    - Click Count (0)
Back to Top