Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 377 for sharding (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. docs/es/docs/deployment/server-workers.md

    <div class="termy">
    
    ```console
    $ <font color="#4E9A06">fastapi</font> run --workers 4 <u style="text-decoration-style:solid">main.py</u>
    
      <span style="background-color:#009485"><font color="#D3D7CF"> FastAPI </font></span>  Starting production server 🚀
    
                 Searching for package file structure from directories with
                 <font color="#3465A4">__init__.py</font> files
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 16 16:33:45 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  2. src/builtin/builtin.go

    //     backed by this underlying array.
    //   - Map: An empty map is allocated with enough space to hold the
    //     specified number of elements. The size may be omitted, in which case
    //     a small starting size is allocated.
    //   - Channel: The channel's buffer is initialized with the specified
    //     buffer capacity. If zero, or the size is omitted, the channel is
    //     unbuffered.
    func make(t Type, size ...IntegerType) Type
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 30 23:59:23 GMT 2024
    - 12.8K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

         *
         * @param url the SMB URL of the file to access
         * @param mode the access mode ("r" for read-only, "rw" for read-write)
         * @param shareAccess the share access flags for file sharing
         * @throws SmbException if an SMB error occurs
         * @throws MalformedURLException if the URL is malformed
         * @throws UnknownHostException if the host cannot be resolved
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/ShareEnumIteratorTest.java

            List<FileEntry> entries = Arrays.asList(entry("keep1", SmbConstants.TYPE_SHARE), entry("skip1", SmbConstants.TYPE_SHARE),
                    entry("keep2", SmbConstants.TYPE_SHARE));
    
            // Filter accepts names starting with "keep"
            when(filter.accept(any())).thenAnswer(inv -> {
                SmbResource res = inv.getArgument(0);
                return res.getName().startsWith("keep");
            });
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb2/rdma/SmbDirectNegotiateResponse.java

            this.maxFragmentedSize = RdmaCapabilities.DEFAULT_MAX_FRAGMENTED_SIZE;
        }
    
        /**
         * Decode from byte array
         *
         * @param data source data
         * @param offset starting offset
         * @return decoded response
         */
        public static SmbDirectNegotiateResponse decode(byte[] data, int offset) {
            if (data.length - offset < 32) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/EmlExtractor.java

            }
            return null;
        }
    
        /**
         * Extracts a date string from the received header text.
         *
         * @param text the received header text
         * @return the date string starting from the day of week, or null if not found
         */
        private static String getDateString(final String text) {
            for (final String dow : DAY_OF_WEEK) {
                final int i = text.lastIndexOf(dow);
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  7. cmd/utils_test.go

    			}
    			if objectName != testCase.object {
    				t.Errorf("failed expected bucket name \"%s\", got \"%s\"", testCase.object, objectName)
    			}
    		})
    	}
    }
    
    // Add tests for starting and stopping different profilers.
    func TestStartProfiler(t *testing.T) {
    	_, err := startProfiler("")
    	if err == nil {
    		t.Fatal("Expected a non nil error, but nil error returned for invalid profiler.")
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb2/io/Smb2FlushResponseTest.java

                assertEquals("Expected structureSize = 4", exception.getMessage());
            }
    
            @Test
            @DisplayName("Should correctly calculate bytes read from different starting positions")
            void testReadBytesWireFormatDifferentStartPositions() throws SMBProtocolDecodingException {
                // Given
                byte[] buffer = new byte[20];
    
                // Test at different positions
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  9. src/main/java/jcifs/SmbConstants.java

         * this file is open. This constant may be logically OR'd with other share
         * access flags.
         */
        int FILE_SHARE_DELETE = 0x04;
        /**
         * Default sharing mode for files
         */
        int DEFAULT_SHARING = FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE;
    
        /**
         * Returned by {@link jcifs.SmbResource#getType()} if the resource this <code>SmbFile</code>
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 24 00:49:49 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        return UnknownLengthSource(url)
      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 17.5K bytes
    - Click Count (7)
Back to Top