Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 404 for Observer (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/main/java/jcifs/internal/smb1/trans2/Trans2SetFileInformation.java

            final int start = dstIndex;
            dstIndex += this.info.encode(dst, dstIndex);
    
            /* 6 zeros observed with NT */
            SMBUtil.writeInt8(0L, dst, dstIndex);
            dstIndex += 6;
    
            /*
             * Also observed 4 byte alignment but we stick
             * with the default for jCIFS which is 2
             */
    
            return dstIndex - start;
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top