- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 168 for getSink (0.12 sec)
-
apache-maven/src/assembly/maven/conf/settings.xml
| NOTE: This location can be overridden with the CLI option: | | -is /path/to/installation/settings.xml | | The sections in this sample file are intended to give you a running start at | getting the most out of your Maven installation. Where appropriate, the default | values (values used when the setting is not specified) are provided. | |--> <settings xmlns="http://maven.apache.org/SETTINGS/2.0.0"
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Wed Jan 22 07:44:50 UTC 2025 - 11.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
// Do blocking calls to plan a route for a new connection. val connect = planConnect() // Now that we have a set of IP addresses, make another attempt at getting a connection from // the pool. We have a better chance of matching thanks to connection coalescing. val pooled2 = planReusePooledConnection(connect, connect.routes) if (pooled2 != null) return pooled2
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 12K bytes - Viewed (0) -
cmd/handler-api.go
if contextCanceled(ctx) { w.WriteHeader(499) return } f.ServeHTTP(w, r) case <-r.Context().Done(): globalHTTPStats.addRequestsInQueue(-1) // When the client disconnects before getting the S3 handler // status code response, set the status code to 499 so this request // will be properly audited and traced. w.WriteHeader(499) default: globalHTTPStats.addRequestsInQueue(-1)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 10.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/srvsvc.java
} totalentries = _src.dec_ndr_long(); resume_handle = _src.dec_ndr_long(); retval = _src.dec_ndr_long(); } } /** * RPC message for getting information about a specific share. */ public static class ShareGetInfo extends DcerpcMessage { @Override public int getOpnum() { return 0x10; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 26.3K bytes - Viewed (0) -
cmd/encryption-v1_test.go
} if err == nil { if etag != test.ETag { t.Fatalf("Test %d: ETag mismatch: got %s - want %s", i, etag, test.ETag) } } } } // Tests for issue reproduced when getting the right encrypted // offset of the object. func TestGetDecryptedRange_Issue50(t *testing.T) { rs, err := parseRequestRangeSpec("bytes=594870256-594870263") if err != nil { t.Fatal(err) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 19.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/http/NtlmHttpURLConnection.java
*/ public class NtlmHttpURLConnection extends HttpURLConnection { private static final int MAX_REDIRECTS = Integer.getInteger("http.maxRedirects", 20); private static final int LM_COMPATIBILITY = Config.getInt("jcifs.smb1.smb.lmCompatibility", 0); private static final String DEFAULT_DOMAIN; private HttpURLConnection connection; private final Map requestProperties; private Map headerFields;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Murmur3_32HashFunction.java
@Override public Hasher putBytes(ByteBuffer buffer) { ByteOrder bo = buffer.order(); buffer.order(ByteOrder.LITTLE_ENDIAN); while (buffer.remaining() >= 4) { putInt(buffer.getInt()); } while (buffer.hasRemaining()) { putByte(buffer.get()); } buffer.order(bo); return this; } @CanIgnoreReturnValue @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 16:36:11 UTC 2025 - 11.8K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableList.java
/** * Views the array as an immutable list. The array must have only {@code E} elements. * * <p>The array must be internally created. */ @SuppressWarnings("unchecked") // caller is reponsible for getting this right static <E> ImmutableList<E> asImmutableList(Object[] elements) { return unsafeDelegateList((List) Arrays.asList(elements)); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Aug 06 18:32:41 UTC 2025 - 11.1K bytes - Viewed (0) -
docs/en/docs/tutorial/handling-errors.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 9.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/dict/stopwords/StopwordsFileTest.java
// With offset 3 and total 5 items, we should get 2 items assertEquals(2, result.size()); assertEquals(1, result.getCurrentPageNumber()); // First page since we're getting actual results assertEquals(10, result.getPageSize()); assertEquals(5, result.getAllRecordCount()); } public void test_selectList_withNullList() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 17.6K bytes - Viewed (0)