scaler - Code Search

cmd/storage-errors.go

// errLessData - returned when less data available than what was requested.
var errLessData = StorageErr("less data available than what was requested")

// errMoreData = returned when more data was sent by the caller than what it was supposed to.
var errMoreData = StorageErr("more data was sent than what was advertised")

// indicates readDirFn to return without further applying the fn()
var errDoneForNow = errors.New("done for now")

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 6.4K 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: Sun Apr 05 00:10:12 GMT 2026

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

- 8.6K bytes

- Click Count (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/testing/GcFinalization.java

@NullMarked
public final class GcFinalization {
  private GcFinalization() {}

  /**
   * 10 seconds ought to be long enough for any object to be GC'ed and finalized. Unless we have a
   * gigantic heap, in which case we scale by heap size.
   */
  private static long timeoutSeconds() {
    // This class can make no hard guarantees.  The methods in this class are inherently flaky, but

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Mar 12 20:19:19 GMT 2026

- 12.3K bytes

- Click Count (0)

github.com/minio/minio

internal/config/dns/operator_dns.go

		Endpoint: endpoint,
	}
	for _, setter := range setters {
		setter(args)
	}
	args.httpClient = &http.Client{
		Transport: &http.Transport{
			Proxy: http.ProxyFromEnvironment,
			DialContext: (&net.Dialer{
				Timeout:   3 * time.Second,
				KeepAlive: 5 * time.Second,
			}).DialContext,
			ResponseHeaderTimeout: 3 * time.Second,
			TLSHandshakeTimeout:   3 * time.Second,
			ExpectContinueTimeout: 3 * time.Second,

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Mon Nov 11 14:51:43 GMT 2024

- 6.6K bytes

- Click Count (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/c_api.h

typedef struct TFE_TensorHandle TFE_TensorHandle;

TF_CAPI_EXPORT extern TFE_TensorHandle* TFE_NewTensorHandle(const TF_Tensor* t,
                                                            TF_Status* status);
// Indicates that the caller will not be using `h` any more.
TF_CAPI_EXPORT extern void TFE_DeleteTensorHandle(TFE_TensorHandle* h);
TF_CAPI_EXPORT extern TF_DataType TFE_TensorHandleDataType(TFE_TensorHandle* h);

Created: Tue Apr 07 12:39:13 GMT 2026

- Last Modified: Thu Apr 27 21:07:00 GMT 2023

- 22.8K bytes

- Click Count (0)

github.com/minio/minio

cmd/iam-store.go

// Assumes that c.Lock is held by caller.
func (c *iamCache) buildUserGroupMemberships() {
	for group, gi := range c.iamGroupsMap {
		c.updateGroupMembershipsMap(group, &gi)
	}
}

// updateGroupMembershipsMap - updates the memberships map for a
// group. IMPORTANT: Assumes c.Lock() is held by caller.
func (c *iamCache) updateGroupMembershipsMap(group string, gi *GroupInfo) {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 87.1K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/chat/chat.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.chat_title" /></title>
<link href="${fe:url('/css/bootstrap.min.css')}" rel="stylesheet" type="text/css" />
<link href="${fe:url('/css/style.css')}" rel="stylesheet" type="text/css" />

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Mar 19 01:36:02 GMT 2026

- 10.8K bytes

- Click Count (0)

github.com/minio/minio

internal/deadlineconn/deadlineconn.go

	readSetAt               time.Time
	writeDeadline           time.Duration // sets the write deadline on a connection.
	writeSetAt              time.Time
	abortReads, abortWrites atomic.Bool // A deadline was set to indicate caller wanted the conn to time out.
	infReads, infWrites     atomic.Bool
	mu                      sync.Mutex
}

// Unwrap will unwrap the connection and remove the deadline if applied.

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Mon Dec 02 13:21:17 GMT 2024

- 5.1K bytes

- Click Count (0)

github.com/google/guava

README.md

    otherwise. Do not persist these and assume they can be read by a future
    version of the library.

5.  Our classes are not designed to protect against a malicious caller. You
    should not use them for communication between trusted and untrusted code.

6.  For the mainline flavor, we test the libraries using OpenJDK 8, 11, and 17

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Sep 16 22:01:32 GMT 2025

- 6.2K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/MutableClassToInstanceMap.java

    return new MutableClassToInstanceMap<>(new HashMap<Class<? extends @NonNull B>, B>());
  }

  /**
   * Returns a new {@code MutableClassToInstanceMap} instance backed by a given empty {@code
   * backingMap}. The caller surrenders control of the backing map, and thus should not allow any
   * direct references to it to remain accessible.
   */
  public static <B extends @Nullable Object> MutableClassToInstanceMap<B> create(

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sun Mar 08 16:16:42 GMT 2026

- 7.1K bytes

- Click Count (0)

Search Options