scaler - Code Search

internal/config/storageclass/storage-class.go

//
// -- if input is RRS but RRS is not configured/initialized '-1' parity
//
//	for RRS is assumed, the caller is expected to choose the right parity
//	at that point.
//
// -- if input is STANDARD but STANDARD is not configured/initialized '-1' parity
//
//	is returned, the caller is expected to choose the right parity
//	at that point.
func (sCfg *Config) GetParityForSC(sc string) (parity int) {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 12.3K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-compat/src/main/java/org/apache/maven/ProjectDependenciesResolver.java

     * from any repository but are present among the set of specified projects will not cause an exception. Instead,
     * those unresolved artifacts will be returned in the result set, allowing the caller to take special care of
     * artifacts that haven't been build yet.
     *
     * @param projects The projects whose dependencies should be resolved, may be {@code null}.

Created: Sun Dec 28 03:35:09 GMT 2025

- Last Modified: Fri Oct 25 12:31:46 GMT 2024

- 5.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/os_windows.go

			typ = fi.Mode()
		case data.FileAttributes&syscall.FILE_ATTRIBUTE_DIRECTORY != 0:
			typ = os.ModeDir
		}

		if err = filter(name, typ); err == errDoneForNow {
			// filtering requested to return by caller.
			return nil
		}
	}

	return nil
}

// Return N entries at the directory dirPath.
func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Feb 18 16:25:55 GMT 2025

- 5K bytes

- Click Count (0)

github.com/minio/minio

internal/dsync/drwmutex.go

				noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum)
				if err == nil && noQuorum {
					// Clean the lock locally and in remote nodes
					forceUnlock(ctx, dm.clnt, id)
					// Execute the caller lock loss callback
					if lockLossCallback != nil {
						lockLossCallback()
					}
					return
				}

				refreshTimer.Reset(dm.refreshInterval)
			}
		}
	}()
}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 20.3K bytes

- Click Count (0)

github.com/tensorflow/tensorflow

tensorflow/c/checkpoint_reader.cc

    string key(v2_reader_->key());
    (*var_to_shape_map)[key] = TensorShape(entry.shape());
    (*var_to_data_type_map)[key] = DataType(entry.dtype());
  }
  // The returned pointers are owned by the caller.
  return std::make_pair(std::move(var_to_shape_map),
                        std::move(var_to_data_type_map));
}

}  // namespace checkpoint

Created: Tue Dec 30 12:39:10 GMT 2025

- Last Modified: Sat Nov 08 06:24:11 GMT 2025

- 5.4K bytes

- Click Count (0)

github.com/minio/minio

internal/lsync/lrwmutex.go

	r := rand.New(rand.NewSource(time.Now().UnixNano()))

	retryCtx, cancel := context.WithTimeout(ctx, timeout)
	defer cancel()

	for {
		select {
		case <-retryCtx.Done():
			// Caller context canceled or we timedout,
			// return false anyways for both situations.
			return false
		default:
			if lm.lock(id, source, isWriteLock) {
				return true
			}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Jan 02 17:15:06 GMT 2022

- 4.8K bytes

- Click Count (0)

github.com/apache/maven

api/maven-api-core/src/main/java/org/apache/maven/api/PathType.java

 *
 * @since 4.0.0
 */
@Experimental
public interface PathType {
    /**
     * The type for all paths that could not be placed in any of the types requested by a caller.
     * This type can appear in the return value of a call to
     * {@link Session#resolveDependencies resolveDependencies(...)} when at least one dependency

Created: Sun Dec 28 03:35:09 GMT 2025

- Last Modified: Tue Jan 07 12:02:00 GMT 2025

- 5K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportWorkAction.kt

       <link xmlns:xslthl="http://xslthl.sf.net" rel="stylesheet" href="https://fonts.googleapis.com/css?family=Lato:400,400i,700">
       <meta xmlns:xslthl="http://xslthl.sf.net" content="width=device-width, initial-scale=1" name="viewport">
       <link xmlns:xslthl="http://xslthl.sf.net" type="text/css" rel="stylesheet" href="https://docs.gradle.org/current/userguide/base.css">

    </head>
    <body>

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Mon Jun 02 09:57:54 GMT 2025

- 14.1K bytes

- Click Count (0)

github.com/minio/minio

cmd/global-heal.go

		// in the beginning of erasure set healing
		if err := bgSeq.healBucket(objAPI, bucket, true); err != nil {
			// Set this such that when we return this function
			// we let the caller retry this disk again for the
			// buckets that failed healing.
			retErr = err
			healingLogIf(ctx, err)
			continue
		}

		var (
			vc   *versioning.Versioning
			lc   *lifecycle.Lifecycle

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Apr 04 13:49:12 GMT 2025

- 16.2K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/smb1/Trans2QueryFSInformationResponseTest.java

        byte[] buffer = new byte[32];
        // Mock data for FsFullSizeInformation
        writeInt8(3000, buffer, 0); // total allocation units
        writeInt8(1500, buffer, 8); // caller available allocation units
        writeInt8(1500, buffer, 16); // actual free units (skipped)
        writeInt4(4, buffer, 24); // sectors per allocation unit
        writeInt4(8192, buffer, 28); // bytes per sector

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 8.6K bytes

- Click Count (0)

Search Options