- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 337 for Mack (0.14 sec)
-
internal/grid/muxserver.go
} // Acknowledge Mux created. // Send async. var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() var ack message ack.Op = OpAckMux ack.Flags = m.BaseFlags ack.MuxID = m.ID m.send(ack) if debugPrint { fmt.Println("connected stream mux:", ack.MuxID) } }() // Data inbound to the handler var handlerIn chan []byte if inboundCap > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/RangeGwtSerializationDependencies.java
/** * A dummy superclass to support GWT serialization of the element type of a {@link Range}. The GWT * supersource for this class contains a field of type {@code C}. * * <p>For details about this hack, see {@code GwtSerializationDependencies}, which takes the same * approach but with a subclass rather than a superclass. * * <p>TODO(cpovirk): Consider applying this subclass approach to our other types. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 1.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api_unified_experimental_graph.cc
std::vector<PartialTensorShape> shapes; shapes.reserve(num_values); for (int i = 0; i < num_values; ++i) { if (num_dims[i] < 0) { shapes.emplace_back(); } else { shapes.emplace_back(ArraySlice<int64_t>( reinterpret_cast<const int64_t*>(dims[i]), num_dims[i])); } } op_->node_builder.Attr(attr_name, shapes); return absl::OkStatus(); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Mar 12 20:00:09 GMT 2024 - 15.4K bytes - Viewed (1) -
internal/handlers/proxy.go
// these quotes. addr = strings.Trim(match[1], `"`) } } return addr } // GetSourceIPRaw retrieves the IP from the request headers // and falls back to r.RemoteAddr when necessary. // however returns without bracketing. func GetSourceIPRaw(r *http.Request) string { addr := GetSourceIPFromHeaders(r) if addr == "" { addr = r.RemoteAddr }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 5.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
type: Int, flags: Int, ): String { if (flags == 0) return "" when (type) { // Special case types that have 0 or 1 flag. TYPE_SETTINGS, TYPE_PING -> return if (flags == FLAG_ACK) "ACK" else BINARY[flags] TYPE_PRIORITY, TYPE_RST_STREAM, TYPE_GOAWAY, TYPE_WINDOW_UPDATE -> return BINARY[flags] } val result = if (flags < FLAGS.size) FLAGS[flags]!! else BINARY[flags]
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) -
doc/next/6-stdlib/1-time.md
When Go 1.23 builds older programs, the old behaviors remain in effect. The new [GODEBUG setting](/doc/godebug) [`asynctimerchan=1`](/pkg/time/#NewTimer) can be used to revert back to asynchronous channel behaviors
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Fri Apr 12 20:57:18 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
if (streamId != 0) throw IOException("TYPE_PING streamId != 0") val payload1 = source.readInt() val payload2 = source.readInt() val ack = flags and FLAG_ACK != 0 handler.ping(ack, payload1, payload2) } @Throws(IOException::class) private fun readGoAway( handler: Handler, length: Int, flags: Int, streamId: Int, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
deploy_website.sh
REPO="******@****.***:square/okhttp.git" DIR=temp-clone # Delete any existing temporary website clone rm -rf $DIR # Clone the current repo into temp folder git clone $REPO $DIR # Replace `git clone` with these lines to hack on the website locally # cp -a . "../okhttp-website" # mv "../okhttp-website" "$DIR" # Move working directory into temp folder cd $DIR # Generate the API docs ./gradlew dokkaHtmlMultiModule
Shell Script - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Nov 20 15:26:12 GMT 2023 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/escape/Platform.java
return requireNonNull(DEST_TL.get()); } /** * A thread-local destination buffer to keep us from creating new buffers. The starting size is * 1024 characters. If we grow past this we don't put it back in the threadlocal, we just keep * going and grow as needed. */ private static final ThreadLocal<char[]> DEST_TL = new ThreadLocal<char[]>() { @Override protected char[] initialValue() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 1.6K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
return } listObjectVersions := objectAPI.ListObjectVersions // Initiate a list object versions operation based on the input params. // On success would return back ListObjectsInfo object to be // marshaled into S3 compatible XML header. listObjectVersionsInfo, err := listObjectVersions(ctx, bucket, prefix, marker, versionIDMarker, delimiter, maxkeys) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 11.4K bytes - Viewed (0)