initial - Code Search

internal/lsync/lrwmutex_test.go

	ctx := context.Background()
	lrwm := NewLRWMutex()

	// fmt.Println("Getting initial write lock")
	if !lrwm.GetLock(ctx, "", "", time.Second) {
		panic("Failed to acquire initial write lock")
	}

	go func() {
		time.Sleep(2 * time.Second)
		lrwm.Unlock()
		// fmt.Println("Initial write lock released, waiting...")
	}()

	// fmt.Println("Trying to acquire 2nd write lock, waiting...")

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Sun Mar 05 04:57:35 GMT 2023

- 7.9K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/collect/AbstractIndexedListIterator.java

  @ParametricNullness
  protected abstract E get(int index);

  /**
   * Constructs an iterator across a sequence of the given size whose initial position is 0. That
   * is, the first call to {@link #next()} will return the first element (or throw {@link
   * NoSuchElementException} if {@code size} is zero).
   *

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Fri Jul 09 17:31:04 GMT 2021

- 3.2K bytes

- Viewed (0)

github.com/google/guava

guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

  /**
   * Creates a {@code MonitorBasedPriorityBlockingQueue} with the default initial capacity (11) that
   * orders its elements according to their {@linkplain Comparable natural ordering}.
   */
  public MonitorBasedPriorityBlockingQueue() {
    q = new PriorityQueue<E>();
  }

  /**
   * Creates a {@code MonitorBasedPriorityBlockingQueue} with the specified initial capacity that

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Wed Apr 19 19:24:36 GMT 2023

- 19.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt

import okio.ByteString.Companion.encodeUtf8

object Http2 {
  @JvmField
  val CONNECTION_PREFACE = "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n".encodeUtf8()

  /** The initial max frame size, applied independently writing to, or reading from the peer. */
  const val INITIAL_MAX_FRAME_SIZE = 0x4000 // 16384

  const val TYPE_DATA = 0x0
  const val TYPE_HEADERS = 0x1
  const val TYPE_PRIORITY = 0x2
  const val TYPE_RST_STREAM = 0x3

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 5.7K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/drwmutex_test.go

	// fmt.Println("Getting initial write lock")
	ctx1, cancel1 := context.WithCancel(context.Background())
	if !drwm1.GetLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) {
		panic("Failed to acquire initial write lock")
	}

	go func() {
		time.Sleep(3 * testDrwMutexAcquireTimeout)
		drwm1.Unlock(context.Background())
		// fmt.Println("Initial write lock released, waiting...")
	}()

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Sat Dec 24 03:49:07 GMT 2022

- 9.7K bytes

- Viewed (0)

github.com/istio/istio

licenses/github.com/hashicorp/errwrap/LICENSE

1.4. “Covered Software”

     means Source Code Form to which the initial Contributor has attached the
     notice in Exhibit A, the Executable Form of such Source Code Form, and
     Modifications of such Source Code Form, in each case including portions
     thereof.

1.5. “Incompatible With Secondary Licenses”
     means

     a. that the initial Contributor has attached the notice described in

Plain Text

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Sat Oct 26 02:47:39 GMT 2019

- 15.6K bytes

- Viewed (0)

github.com/istio/istio

licenses/github.com/hashicorp/hcl/LICENSE

1.4. “Covered Software”

     means Source Code Form to which the initial Contributor has attached the
     notice in Exhibit A, the Executable Form of such Source Code Form, and
     Modifications of such Source Code Form, in each case including portions
     thereof.

1.5. “Incompatible With Secondary Licenses”
     means

     a. that the initial Contributor has attached the notice described in

Plain Text

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Sat Oct 26 02:47:39 GMT 2019

- 15.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/DfsImpl.java

                DfsReferralData initial = null;
                @SuppressWarnings ( "resource" )
                SmbTransportInternal trans = dc != null ? dc.unwrap(SmbTransportInternal.class) : null;
                if ( trans != null ) {
                    // get domain referral

Java

- Registered: Sun Apr 28 00:10:09 GMT 2024

- Last Modified: Thu Jan 05 13:07:29 GMT 2023

- 29.1K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/io/ByteProcessor.java

   * should process the bytes from {@code buf[off]} through {@code buf[off + len - 1]} (inclusive).
   *
   * @param buf the byte array containing the data to process
   * @param off the initial offset into the array
   * @param len the length of data to be processed
   * @return true to continue processing, false to stop
   */
  @CanIgnoreReturnValue // some uses know that their processor never returns false

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed May 17 14:35:11 GMT 2023

- 2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/help.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>
<link href="${fe:url('/css/bootstrap.min.css')}" rel="stylesheet"
	type="text/css" />

Others

- Registered: Mon Apr 29 08:04:11 GMT 2024

- Last Modified: Fri Feb 17 12:13:41 GMT 2023

- 1.4K bytes

- Viewed (0)

Search Options