Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 401 - 410 of 536 for Absent (0.04 seconds)

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

  1. internal/store/queuestore.go

    	"github.com/valyala/bytebufferpool"
    )
    
    const (
    	defaultLimit = 100000 // Default store limit.
    	defaultExt   = ".unknown"
    	compressExt  = ".snappy"
    )
    
    // errLimitExceeded error is sent when the maximum limit is reached.
    var errLimitExceeded = errors.New("the maximum store limit reached")
    
    // QueueStore - Filestore for persisting items.
    type QueueStore[_ any] struct {
    	sync.RWMutex
    	entryLimit uint64
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  2. docs/fr/docs/tutorial/dependencies/dependencies-with-yield.md

            end
            handler -->> client: HTTP error response
        end
    
        operation ->> client: Return response to client
        Note over client,operation: Response is already sent, can't change it anymore
        opt Tasks
            operation -->> tasks: Send background tasks
        end
        opt Raise other exception
            tasks -->> tasks: Handle exceptions in the background task code
        end
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 13.9K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

            // CRITICAL: Set the binding flag per MS-SMB2
            request.setSessionBinding(true);
    
            // The actual transport send would need proper integration
            // This would be sent on the NEW channel's transport, not the existing one
    
            log.debug("Channel binding prepared for channel {} with session 0x{}", channel.getChannelId(), Long.toHexString(getSessionId()));
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 20K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/base/Ascii.java

      /**
       * Cancel: A control character used to indicate that the data with which it is sent is in error or
       * is to be disregarded.
       *
       * @since 8.0
       */
      public static final byte CAN = 24;
    
      /**
       * End of Medium: A control character associated with the sent data which may be used to identify
       * the physical end of the medium, or the end of the used, or wanted, portion of information
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  5. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

            }
    
            if (tlsVersions.contains(TLS_1_3)) {
              println("TLSv1.3 requires an external command run before first traffic is sent")
              println("Follow instructions at https://github.com/neykov/extract-tls-secrets for TLSv1.3")
              println("Pid: ${ProcessHandle.current().pid()}")
    
              Thread.sleep(10000)
            }
          }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/smb1/AndXServerMessageBlock.java

             * the 'received' member of the response object will not
             * be set to true indicating the send and sendTransaction
             * methods that the next part should be sent. This is a
             * very indirect and simple batching control mechanism.
             */
    
            if (andx == null || !USE_BATCHING || batchLevel >= getBatchLimit(andx.command)) {
                andxCommand = (byte) 0xFF;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  7. docs/multi-user/README.md

    - `aws:PrincipalType` - This value indicates whether the principal is an account (Root credential), user (MinIO user), or assumed role (STS)
    - `aws:SecureTransport` - This is a Boolean value that represents whether the request was sent over TLS.
    - `aws:SourceIp` - This is the requester's IP address, for use with IP address conditions. If running behind Nginx like proxies, MinIO preserve's the source IP.
    
    ```
    {
      "Version": "2012-10-17",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                  workerRunningState = IDLE;
                  return;
                }
              }
              // Remove the interrupt bit before each task. The interrupt is for the "current task" when
              // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
              // by a previous one in the queue being interrupted.
              interruptedDuringTask |= Thread.interrupted();
              try {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  9. src/main/java/jcifs/internal/smb2/rdma/SmbDirectNegotiateResponse.java

     */
    package jcifs.internal.smb2.rdma;
    
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB Direct Negotiate Response message.
     *
     * As per MS-SMBD 2.2.2 - SMB_DIRECT_NEGOTIATE_RESPONSE
     * This message is sent in response to negotiate SMB Direct protocol parameters.
     */
    public class SmbDirectNegotiateResponse {
    
        // Protocol constants
        /** SMB Direct negotiate response message type */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  10. docs/en/docs/advanced/stream-data.md

    {* ../../docs_src/stream_data/tutorial001_py310.py ln[32:35] hl[33] *}
    
    This also means that with `StreamingResponse` you have the **freedom** and **responsibility** to produce and encode the data bytes exactly as you need them to be sent, independent of the type annotations. 🤓
    
    ### Stream Bytes { #stream-bytes }
    
    One of the main use cases would be to stream `bytes` instead of strings, you can of course do it.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 5.4K bytes
    - Click Count (0)
Back to Top