closer - Code Search

cmd/grid.go

var globalLockGrid atomic.Pointer[grid.Manager]

// globalGridStart is a channel that will block startup of grid connections until closed.
var globalGridStart = make(chan struct{})

// globalLockGridStart is a channel that will block startup of lock grid connections until closed.
var globalLockGridStart = make(chan struct{})

func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {

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

- Last Modified: Fri May 16 14:27:42 GMT 2025

- 3.7K bytes

- Click Count (0)

github.com/tiangolo/fastapi

.github/workflows/notify-translations.yml

name: Notify Translations

on:
  pull_request_target:
    types:
      - labeled
      - closed
  workflow_dispatch:
    inputs:
      number:
        description: PR number
        required: true
      debug_enabled:
        description: 'Run the build with tmate debugging enabled (https://github.com/marketplace/actions/debugging-with-tmate)'
        required: false
        default: 'false'

env:
  UV_SYSTEM_PYTHON: 1

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Fri Nov 21 13:03:21 GMT 2025

- 1.7K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic-commons/code-quality-rules/src/main/resources/classycle/classycle_report_resources.zip

+ "</td>"; } text += "</tr>"; } } text += "</table>"; } showText(text); } function showText(text) { list = window.open("", "list", "dependent=yes,location=no,menubar=yes,resizable=yes,toolbar=no,scrollbars=yes,width=500,height=400"); list.document.close(); list.document.open(); list.document.write("<html><head><style type=\"text/css\">"); list.document.write("body { font-family:Helvetica,Arial,sans-serif; } "); list.document.write(".link { cursor:pointer;text-decoration:underline; } "); list.document.writeln("th...

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

- Last Modified: Wed Dec 09 08:14:05 GMT 2020

- 23.4K bytes

- Click Count (0)

github.com/square/okhttp

mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

    stream.writeHeaders(
      responseHeaders = responseHeaders,
      outFinished = false,
      flushHeaders = false,
    )
    val out = stream.sink.buffer()
    out.writeUtf8("Not found: $path")
    out.close()
  }

  private fun serveDirectory(
    stream: Http2Stream,
    files: Array<File>,
  ) {
    val responseHeaders =
      listOf(
        Header(":status", "200"),

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Thu Jul 31 04:18:40 GMT 2025

- 6.4K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_http_connection_injection.py

@app.websocket("/ws")
async def get_value_by_ws(
    websocket: WebSocket, value: int = Depends(extract_value_from_http_connection)
):
    await websocket.accept()
    await websocket.send_json(value)
    await websocket.close()


client = TestClient(app)


def test_value_extracting_by_http():
    response = client.get("/http")
    assert response.status_code == 200
    assert response.json() == 42

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sun Aug 09 13:56:41 GMT 2020

- 972 bytes

- Click Count (0)

github.com/golang/go

src/Make.dist

# The -v causes dist to print the name of each directory as it runs.
# The -vv causes dist to print each build command as it runs.
# go tool dist clean cleans all directories, not just this one,
# but it's as close as we can get.

# Default target (first).
install:
	go tool dist install -v

verbose:
	go tool dist install -vv

clean:

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Wed Feb 08 20:26:47 GMT 2012

- 553 bytes

- Click Count (0)

github.com/minio/minio

internal/event/target/elasticsearch.go

			return store.ErrNotConnected
		}
		return err
	}

	// Delete the event from store.
	return target.store.Del(key)
}

// Close - does nothing and available for interface compatibility.
func (target *ElasticsearchTarget) Close() error {
	close(target.quitCh)
	if target.client != nil {
		// Stops the background processes that the client is running.
		target.client.stop()
	}
	return nil
}

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

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

- 15K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/io/SourceSinkFactories.java

      checkNotNull(bytes);
      File file = createFile();
      OutputStream out = new FileOutputStream(file);
      try {
        out.write(bytes);
      } finally {
        out.close();
      }
      return Files.asByteSource(file);
    }

    @Override
    public byte[] getExpected(byte[] bytes) {
      return checkNotNull(bytes);
    }
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Wed Jul 16 17:42:14 GMT 2025

- 17.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

 */
class AddressPolicy(
  /**
   * How many concurrent calls should be possible to make at any time.
   * The pool will routinely try to pre-emptively open connections to satisfy this minimum.
   * Connections will still be closed if they idle beyond the keep-alive but will be replaced.
   */
  @JvmField val minimumConcurrentCalls: Int = 0,
  /** How long to wait to retry pre-emptive connection attempts that fail. */

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Tue Jun 03 17:10:08 GMT 2025

- 1.3K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/collect/PowerSetBenchmark.java

@NullUnmarked
public class PowerSetBenchmark {
  @Param({"2", "4", "8", "16"})
  int elements;

  Set<Set<Integer>> powerSet;

  @BeforeExperiment
  void setUp() {
    Set<Integer> set = ContiguousSet.create(Range.closed(1, elements), integers());
    powerSet = Sets.powerSet(set);
  }

  @Benchmark
  int iteration(int reps) {
    int sum = 0;
    for (int i = 0; i < reps; i++) {
      for (Set<Integer> subset : powerSet) {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 19 18:03:30 GMT 2024

- 1.5K bytes

- Click Count (0)

Search Options