chad - Code Search

internal/s3select/csv/reader.go

	input        chan *queueItem  // input for workers
	queue        chan *queueItem  // output from workers in order
	err          error            // global error state, only touched by Reader.Read
	bufferPool   sync.Pool        // pool of []byte objects for input
	csvDstPool   sync.Pool        // pool of [][]string used for output

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

- Last Modified: Thu Feb 22 06:26:06 UTC 2024

- 8.9K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java

   */
  @Override
  @CheckForNull
  protected final char[] escape(char c) {
    if (c < replacementsLength) {
      char[] chars = replacements[c];
      if (chars != null) {
        return chars;
      }
    }
    if (c >= safeMin && c <= safeMax) {
      return null;
    }
    return escapeUnsafe(c);
  }

  /**
   * Escapes a {@code char} value that has no direct explicit value in the replacement array and

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

- Last Modified: Tue Jan 18 20:55:09 UTC 2022

- 6.3K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/hash/HashTestUtils.java

        hashFunction.newHasher().putUnencodedChars(string).hash());
  }

  static char randomLowSurrogate(Random random) {
    return (char)
        (Character.MIN_LOW_SURROGATE
            + random.nextInt(Character.MAX_LOW_SURROGATE - Character.MIN_LOW_SURROGATE + 1));
  }

  static char randomHighSurrogate(Random random) {
    return (char)
        (Character.MIN_HIGH_SURROGATE

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

- Last Modified: Tue Jul 23 14:22:54 UTC 2024

- 25.5K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/drwmutex_test.go

func doTestParallelReaders(numReaders, gomaxprocs int) {
	runtime.GOMAXPROCS(gomaxprocs)
	m := NewDRWMutex(ds, "test-parallel")

	clocked := make(chan bool)
	cunlock := make(chan bool)
	cdone := make(chan bool)
	for i := 0; i < numReaders; i++ {
		go parallelReader(context.Background(), m, clocked, cunlock, cdone)
	}
	// Wait for all parallel RLock()s to succeed.
	for i := 0; i < numReaders; i++ {
		<-clocked
	}

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

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

- 9.7K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/net/PercentEscaperTest.java

    assertThat(expected).hasMessageThat().isEqualTo(msg);
  }

  public void testBadArguments_plusforspace() {
    // space can be a safe char if plusForSpace is false
    PercentEscaper unused = new PercentEscaper(" ", false);

    // space cannot be a safe char is plusForSpace is true
    String msg = "plusForSpace cannot be specified when space is a 'safe' character";
    IllegalArgumentException expected =

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

- Last Modified: Mon Oct 21 15:41:36 UTC 2024

- 5.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/dcerpc/UnicodeString.java

        }
    }


    @Override
    public String toString () {
        int len = this.length / 2 - ( this.zterm ? 1 : 0 );
        char[] ca = new char[len];
        for ( int i = 0; i < len; i++ ) {
            ca[ i ] = (char) this.buffer[ i ];
        }
        return new String(ca, 0, len);
    }

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Sun Jul 01 13:12:10 UTC 2018

- 2.5K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/c_api.cc

  if (status->status.ok()) {
    char* buf = new char[new_handle.size() + 1];
    memcpy(buf, new_handle.c_str(), new_handle.size() + 1);
    *handle = buf;
  }
}

void TF_PRun(TF_DeprecatedSession* s, const char* handle,
             // Input tensors
             const char** c_input_names, TF_Tensor** c_inputs, int ninputs,
             // Output tensors

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

- Last Modified: Sat Oct 12 16:27:48 UTC 2024

- 102.3K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/escape/UnicodeEscaper.java

   */
  private static char[] growBuffer(char[] dest, int index, int size) {
    if (size < 0) { // overflow - should be OutOfMemoryError but GWT/j2cl don't support it
      throw new AssertionError("Cannot increase internal buffer any further");
    }
    char[] copy = new char[size];
    if (index > 0) {
      System.arraycopy(dest, 0, copy, 0, index);
    }

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

- Last Modified: Tue Jan 18 20:55:09 UTC 2022

- 13.2K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial003.py

from fastapi import FastAPI, WebSocket, WebSocketDisconnect
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <h2>Your ID: <span id="ws-id"></span></h2>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>

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

- Last Modified: Sun Aug 09 13:52:19 UTC 2020

- 2.5K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/c_test_util.cc

                      nullptr);
}

TF_Tensor* Int8Tensor(const int64_t* dims, int num_dims, const char* values) {
  int64_t num_values = 1;
  for (int i = 0; i < num_dims; ++i) {
    num_values *= dims[i];
  }
  TF_Tensor* t =
      TF_AllocateTensor(TF_INT8, dims, num_dims, sizeof(char) * num_values);
  memcpy(TF_TensorData(t), values, sizeof(char) * num_values);
  return t;
}

TF_Tensor* Int32Tensor(const int64_t* dims, int num_dims,

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

- Last Modified: Fri Oct 15 03:16:52 UTC 2021

- 17.8K bytes

- Viewed (0)

Search Options