- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 492 for isopen (0.18 sec)
-
src/cmd/cgo/internal/swig/testdata/stdio/main.swig
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri May 12 12:00:07 GMT 2023 - 563 bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
count: Long, ) { val latch = CountDownLatch(1) val startNanos = AtomicLong() newWebSocket( "/runCase?case=$number&agent=okhttp", object : WebSocketListener() { override fun onOpen( webSocket: WebSocket, response: Response, ) { println("Executing test case $number/$count") startNanos.set(System.nanoTime()) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/PathModularizationCache.java
import org.apache.maven.api.JavaPathType; import org.apache.maven.api.PathType; /** * Cache of {@link PathModularization} instances computed for given {@link Path} elements. * The cache is used for avoiding the need to reopen the same files many times when the * same dependency is used for different scope. For example a path used for compilation * is typically also used for tests. */ class PathModularizationCache { /**
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 5.2K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
func unstructureIstioType(spec any) (map[string]any, error) { b, err := yaml.Marshal(spec) if err != nil { return nil, err } iSpec := map[string]any{} err = yaml.Unmarshal(b, &iSpec) if err != nil { return nil, err } return iSpec, nil } func convertToUnsignedInt32Map(s []string) map[string]uint32 { out := make(map[string]uint32, len(s)) for _, l := range s {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
""" |data: hey | | """.trimMargin(), ).setHeader("content-type", "text/event-stream") .build(), ) listener.enqueueCancel() // Will cancel in onOpen(). newEventSource() listener.assertOpen() listener.assertFailure("canceled") } @Test fun badContentType() { server.enqueue( MockResponse.Builder() .body(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/info/Smb2QueryDirectoryRequest.java
public static final byte SMB2_RETURN_SINGLE_ENTRY = 0x2; /** * */ public static final byte SMB2_INDEX_SPECIFIED = 0x4; /** * */ public static final byte SMB2_REOPEN = 0x10; private byte fileInformationClass = FILE_BOTH_DIRECTORY_INFO; private byte queryFlags; private int fileIndex; private byte[] fileId; private int outputBufferLength;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Nov 14 10:41:31 GMT 2021 - 6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
.pingInterval(Duration.ofMillis(500)) .build() // Stall in onOpen to prevent pongs from being sent. val latch = CountDownLatch(1) webServer.enqueue( MockResponse.Builder() .webSocketUpgrade( object : WebSocketListener() { override fun onOpen( webSocket: WebSocket, response: Response, ) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
tensorflow/c/experimental/filesystem/plugins/gcs/cleanup.h
// capturing the return value in an 'auto' local variable. Most users will not // need more sophisticated syntax than that. // // Example: // void func() { // FILE* fp = fopen("data.txt", "r"); // if (fp == nullptr) return; // auto fp_cleaner = gtl::MakeCleanup([fp] { fclose(fp); }); // // No matter what, fclose(fp) will happen. // DataObject d;
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 09 11:16:00 GMT 2020 - 3.4K bytes - Viewed (0) -
cmd/tier-journal.go
// Rotate active journal to perform pending deletes. return os.Rename(jPath, jroPath) } // Open opens a new active journal. Note: calling Open on an opened journal is a // no-op. func (jd *tierDiskJournal) Open() error { jd.Lock() defer jd.Unlock() if jd.file != nil { // already open return nil } var err error
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
fastapi/security/open_id_connect_url.py
Aleksei Kotenko <******@****.***> 1712026131 +0100
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 2.7K bytes - Viewed (0)