Scaled - Code Search

internal/grid/connection.go

	c.writeStream(ctx, conn, cancel)
}

// readStream handles the read side of the connection.
// It will read messages and send them to c.handleMsg.
// If an error occurs the cancel function will be called and conn be closed.
// The function will block until the connection is closed or an error occurs.
func (c *Connection) readStream(ctx context.Context, conn net.Conn, cancel context.CancelCauseFunc) {
	defer func() {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Jul 29 18:10:04 UTC 2024

- 46.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/js/clipboard.min.js

ault:t}}var l=function(t){function o(t,e){!function(t,e){if(!(t instanceof e))throw new TypeError("Cannot call a class as a function")}(this,o);var n=function(t,e){if(!t)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return!e||"object"!=typeof e&&"function"!=typeof e?t:e}(this,(o.__proto__||Object.getPrototypeOf(o)).call(this));return n.resolveOptions(e),n.listenClick(t),n}return function(t,e){if("function"!=typeof e&&null!==e)throw new TypeError("Super expression...

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Sat May 28 04:16:16 UTC 2022

- 10.5K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/base/Equivalence.java

    }
    return doHash(t);
  }

  /**
   * Implemented by the user to return a hash code for {@code t}, subject to the requirements
   * specified in {@link #hash}.
   *
   * <p>This method should not be called except by {@link #hash}. When {@link #hash} calls this
   * method, {@code t} is guaranteed to be non-null.
   *
   * @since 10.0 (previously, subclasses would override hash())
   */
  @ForOverride

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Thu May 16 14:34:47 UTC 2024

- 13.8K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            + (throwable == null ? null : Throwables.getStackTraceAsString(throwable)),
        throwableFromOtherThread.get());
  }

  /**
   * Test for a bug where threads weren't getting signaled when shutdown was called, only when tasks
   * completed.
   */
  public void testDirectExecutorService_awaitTermination_missedSignal() {
    final ExecutorService service = newDirectExecutorService();
    Thread waiter =

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 18 22:10:29 UTC 2024

- 28.1K bytes

- Viewed (0)

github.com/minio/minio

internal/grid/types.go

func (j *Array[T]) Value() []T {
	if j.val == nil {
		j.val = j.p.newA(10)
	}
	return j.val
}

// Append a value to the underlying array.
// The returned Array is always the same as the one called.
func (j *Array[T]) Append(v ...T) *Array[T] {
	if j.val == nil {
		j.val = j.p.newA(uint32(len(v)))
	}
	j.val = append(j.val, v...)
	return j
}

// Set the underlying value.

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Wed Aug 14 17:11:51 UTC 2024

- 15.5K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/parallel_device/parallel_device_lib.cc

  //
  // `cancellation_manager` must live until after `Join` finishes and pending
  // `is_async` operations finish. In addition to allowing the caller to cancel
  // the operation, its `StartCancel` method will be called if op execution
  // fails on any device in order to cancel the others.
  void StartExecute(TFE_Context* context, const char* operation_name,
                    std::vector<TFE_TensorHandle*> inputs,

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Mon Oct 21 04:14:14 UTC 2024

- 25.9K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

 * number types; reasonable default instance for other stateless types. For mutable types, a fresh
 * instance is created each time {@code get()} is called.
 *
 * @author Kevin Bourrillion
 * @author Ben Yu
 * @since 12.0
 */
@GwtIncompatible
@J2ktIncompatible
@ElementTypesAreNonnullByDefault
public final class ArbitraryInstances {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Oct 19 00:26:48 UTC 2024

- 21.2K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/data/external_links.yml

s-request title: How to profile a FastAPI asynchronous request - author: Stephen Siegert - Neon link: https://neon.tech/blog/deploy-a-serverless-fastapi-app-with-neon-postgres-and-aws-app-runner-at-any-scale title: Deploy a Serverless FastAPI App with Neon Postgres and AWS App Runner at any scale - author: Kurtis Pykes - NVIDIA link: https://developer.nvidia.com/blog/building-a-machine-learning-microservice-with-fastapi/ title: Building a Machine Learning Microservice with FastAPI - author: Ravgeet...

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Thu Oct 24 18:39:34 UTC 2024

- 22.8K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/docs/tutorial/sql-databases.md

/// tip

You could use any other SQL or NoSQL database library you want (in some cases called <abbr title="Object Relational Mapper, a fancy term for a library where some classes represent SQL tables and instances represent rows in those tables">"ORMs"</abbr>), FastAPI doesn't force you to use anything. 😎

///

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Wed Oct 09 19:44:42 UTC 2024

- 14.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/advance.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
<html>
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<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.search_title" /></title>
<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml" href="${fe:url('/osdd')}"

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Sat Oct 26 01:07:52 UTC 2024

- 14.9K bytes

- Viewed (0)

Search Options