- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 404 for Observer (0.04 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
) peer.sendFrame().headers(true, 2, expectedResponseHeaders) peer.sendFrame().data(true, 3, data(0), 0) peer.play() val observer = RecordingPushObserver() // Play it back. val connection = connect(peer, observer, Http2Connection.Listener.REFUSE_INCOMING_STREAMS) val client = connection.newStream(headerEntries("b", "banana"), false)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
doc/go_mem.html
If a synchronizing read-like memory operation <i>r</i> observes a synchronizing write-like memory operation <i>w</i> (that is, if <i>W</i>(<i>r</i>) = <i>w</i>), then <i>w</i> is synchronized before <i>r</i>. Informally, the synchronized before relation is a subset of the implied total order mentioned in the previous paragraph, limited to the information that <i>W</i> directly observes. </p> <p>
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Aug 05 15:41:37 UTC 2025 - 26.6K bytes - Viewed (0) -
src/test/java/jcifs/netbios/NbtAddressTest.java
void testFirstCalledName_RegularHostName() { // Test firstCalledName with a regular hostname mockName = new Name(mockConfig, "MYSERVER", 0x20, null); NbtAddress nbtAddress = new NbtAddress(mockName, testAddressInt, false, NbtAddress.H_NODE); assertEquals("MYSERVER", nbtAddress.firstCalledName()); } @Test void testFirstCalledName_IpAddress() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 20.4K bytes - Viewed (0) -
cmd/server-startup-msg.go
if globalIsDistErasure { logger.Startup(color.Bold(banner)) } logger.Startup(color.Bold(MinioBannerName)) if err != nil { if globalConsoleSys != nil { globalConsoleSys.Send(GlobalContext, fmt.Sprintf("Server startup failed with '%v', some features may be missing", err)) } } if !globalSubnetConfig.Registered() { var builder strings.Builder startupBanner(&builder) logger.Startup(builder.String()) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 6.2K bytes - Viewed (0) -
cmd/ftp-server-driver.go
"github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/credentials" "github.com/minio/minio/internal/auth" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/pkg/v3/mimedb" ftp "goftp.io/server/v2" ) var _ ftp.Driver = &ftpDriver{} // ftpDriver implements ftpDriver to store files in minio type ftpDriver struct { endpoint string } // NewFTPDriver implements ftp.Driver interface
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 14.3K bytes - Viewed (0) -
src/test/java/jcifs/NetbiosAddressTest.java
String smbServer = NbtAddress.SMBSERVER_NAME; assertNotNull(anyHosts); assertNotNull(masterBrowser); assertNotNull(smbServer); // Test that they have expected lengths assertEquals(16, anyHosts.length()); assertEquals(15, masterBrowser.length()); assertEquals(15, smbServer.length()); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMaker.java
* table is internally partitioned to try to permit the indicated number of concurrent updates * without contention. Because assignment of entries to these partitions is not necessarily * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to * accommodate as many threads as will ever concurrently modify the table. Using a significantly
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 12.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans2/Trans2SetFileInformation.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.3K bytes - Viewed (0) -
src/test/java/jcifs/SIDTest.java
SID sid = new SID(adminSidString); String server = "myserver"; sid.resolve(server, mockContext); ArgumentCaptor<jcifs.SID[]> sidArrayCaptor = ArgumentCaptor.forClass(jcifs.SID[].class); verify(mockResolver).resolveSids(eq(mockContext), eq(server), sidArrayCaptor.capture()); assertEquals(1, sidArrayCaptor.getValue().length);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13.5K bytes - Viewed (0) -
docs/en/docs/deployment/server-workers.md
# Server Workers - Uvicorn with Workers { #server-workers-uvicorn-with-workers } Let's check back those deployment concepts from before: * Security - HTTPS * Running on startup * Restarts * **Replication (the number of processes running)** * Memory * Previous steps before starting
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 8.3K bytes - Viewed (0)