Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 640 for Oplock (0.27 seconds)

  1. scripts/tests/test_translation_fixer/test_complex_doc/data/translated_doc_expected.md

    Инструмент исправления не будет сохранять комментарии в этих блоках.
    
    ```json
    {
        # This is a sample JSON code block
        "greeting": "Hello, world!" # Print greeting
    }
    ```
    
    ```console
    # This is a sample console code block
    $ echo "Hello, world!"  # Print greeting
    ```
    
    ```toml
    // This is a sample TOML code block
    title = "TOML Example"  // Title of the document
    ```
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 08:08:04 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  2. docs/debugging/inspect/utils.go

    import (
    	"crypto/rsa"
    	"crypto/x509"
    	"encoding/base64"
    	"encoding/pem"
    	"log"
    )
    
    func bytesToPrivateKey(priv []byte) (*rsa.PrivateKey, error) {
    	// Try PEM
    	if block, _ := pem.Decode(priv); block != nil {
    		return x509.ParsePKCS1PrivateKey(block.Bytes)
    	}
    	// Try base 64
    	dst := make([]byte, base64.StdEncoding.DecodedLen(len(priv)))
    	if n, err := base64.StdEncoding.Decode(dst, priv); err == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Nov 02 20:36:38 GMT 2022
    - 1.4K bytes
    - Click Count (0)
  3. cmd/perf-tests.go

    	activeConnections uint64
    	sync.RWMutex
    }
    
    func (n *netPerfRX) Connect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections++
    	atomic.StoreUint64(&n.RX, 0)
    	n.lastToConnect = time.Now()
    }
    
    func (n *netPerfRX) Disconnect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections--
    	if n.firstToDisconnect.IsZero() {
    		n.RXSample = atomic.LoadUint64(&n.RX)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  4. docs/en/docs/css/termynal.css

        text-align: center;
    }
    
    a[data-terminal-control] {
        text-align: right;
        display: block;
        color: #aebbff;
    }
    
    [data-ty] {
        display: block;
        line-height: 2;
    }
    
    [data-ty]:before {
        /* Set up defaults and ensure empty lines are displayed. */
        content: '';
        display: inline-block;
        vertical-align: middle;
    }
    
    [data-ty="input"]:before,
    [data-ty-prompt]:before {
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Nov 23 09:27:40 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  5. scripts/tests/test_translation_fixer/test_code_blocks/test_code_blocks_lines_number_mismatch.py

        )
    
        assert fixed_content == expected_content  # Translated doc remains unchanged
        assert "Error processing docs/lang/docs/doc.md" in result.output
        assert (
            "Code block (lines 14-18) has different number of lines than the original block (5 vs 4)"
        ) in result.output
    
    
    @pytest.mark.parametrize(
        "copy_test_files",
        [(f"{data_path}/en_doc.md", f"{data_path}/translated_doc_lines_number_lt.md")],
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Jan 10 22:43:44 GMT 2026
    - 1.9K bytes
    - Click Count (0)
  6. scripts/tests/test_translation_fixer/test_code_blocks/test_code_blocks_wrong_lang_code.py

        )
    
        assert fixed_content == expected_content  # Translated doc remains unchanged
        assert "Error processing docs/lang/docs/doc.md" in result.output
        assert (
            "Code block (lines 16-19) has different language than the original block ('yaml' vs 'toml')"
        ) in result.output
    
    
    @pytest.mark.parametrize(
        "copy_test_files",
        [(f"{data_path}/en_doc.md", f"{data_path}/translated_doc_wrong_lang_code_2.md")],
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Jan 10 22:43:44 GMT 2026
    - 1.9K bytes
    - Click Count (0)
  7. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt

      fun write(
        name: String,
        tagClass: Int,
        tag: Long,
        block: (BufferedSink) -> Unit,
      ) {
        val constructedBit: Int
        val content = Buffer()
    
        stack.add(content)
        constructed = false // The enclosed object written in block() is not constructed.
        path += name
        try {
          block(content)
          constructedBit = if (constructed) 0b0010_0000 else 0
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  8. internal/logger/logonce.go

    	if err == nil {
    		return
    	}
    
    	nerr := unwrapErrs(err)
    	l.Lock()
    	shouldLog := true
    	prev, ok := l.IDMap[id]
    	if !ok {
    		l.IDMap[id] = onceErr{
    			Err:   nerr,
    			Count: 1,
    		}
    	} else if prev.Err.Error() == nerr.Error() {
    		// if errors are equal do not log.
    		prev.Count++
    		l.IDMap[id] = prev
    		shouldLog = false
    	}
    	l.Unlock()
    
    	if shouldLog {
    		consoleLogIf(ctx, subsystem, err, errKind...)
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  9. cmd/namespace-lock_test.go

    			nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond)
    		}()
    		time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2
    
    		// Unlock the 1st lock; ref=1 after this line
    		nsLk.unlock("volume", "path", false)
    
    		// Taking another lockMapMutex here allows queuing up additional lockers. This should
    		// not be required but makes reproduction much easier.
    		nsLk.lockMapMutex.Lock()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  10. cmd/admin-heal-ops.go

    func (ahs *allHealState) setDiskHealingStatus(ep Endpoint, healing bool) {
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	ahs.healLocalDisks[ep] = healing
    }
    
    func (ahs *allHealState) pushHealLocalDisks(healLocalDisks ...Endpoint) {
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	for _, ep := range healLocalDisks {
    		ahs.healLocalDisks[ep] = false
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
Back to Top