Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 561 for sesd (0.03 sec)

  1. internal/event/targetlist.go

    	CurrentSendCalls int64 // CurrentSendCalls is the number of concurrent async Send calls to all targets
    	CurrentQueue     int   // Populated if target has a store.
    	TotalEvents      int64
    	FailedEvents     int64 // Number of failed events per target
    }
    
    // TargetList - holds list of targets indexed by target ID.
    type TargetList struct {
    	// The number of concurrent async Send calls to all targets
    	currentSendCalls  atomic.Int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbTreeConnection.java

        <T extends CommonServerMessageBlockResponse> T send ( SmbResourceLocatorImpl loc, CommonServerMessageBlockRequest request, T response,
                RequestParam... params ) throws CIFSException {
            return send(loc, request, response, params.length == 0 ? EnumSet.noneOf(RequestParam.class) : EnumSet.copyOf(Arrays.asList(params)));
        }
    
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:50:16 UTC 2020
    - 31K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        /**
         * Apply inbound settings and send an acknowledgement to the peer that provided them.
         *
         * We need to apply the settings and ack them atomically. This is because some HTTP/2
         * implementations (nghttp2) forbid peers from taking advantage of settings before they have
         * acknowledged! In particular, we shouldn't send frames that assume a new `initialWindowSize`
         * until we send the frame that acknowledges this new size.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  4. docs/en/docs/tutorial/header-param-models.md

    ///
    
    ```Python hl_lines="10"
    {!> ../../docs_src/header_param_models/tutorial002.py!}
    ```
    
    ////
    
    If a client tries to send some **extra headers**, they will receive an **error** response.
    
    For example, if the client tries to send a `tool` header with a value of `plumbus`, they will receive an **error** response telling them that the header parameter `tool` is not allowed:
    
    ```json
    {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/hash/Murmur3Hash32Test.java

      }
    
      public void testParanoidHashBytes() {
        HashFn hf =
            new HashFn() {
              @Override
              public byte[] hash(byte[] input, int seed) {
                return murmur3_32(seed).hashBytes(input).asBytes();
              }
            };
        // Murmur3A, MurmurHash3 for x86, 32-bit (MurmurHash3_x86_32)
        // https://github.com/aappleby/smhasher/blob/master/src/main.cpp
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:29:46 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. cmd/global-heal.go

    							bucket, version.Name, err))
    					}
    				}
    
    				if !send(result) {
    					return
    				}
    			}
    
    			// All versions resulted in 'ObjectNotFound/VersionNotFound'
    			if versionNotFound == len(fivs.Versions) {
    				return
    			}
    
    			send(healEntryDone(entry.name))
    
    			// Wait and proceed if there are active requests
    			waitForLowHTTPReq()
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  7. cmd/metacache-walk.go

    				}
    				if err := send(meta); err != nil {
    					return err
    				}
    			case osIsNotExist(err), isSysErrIsDir(err):
    				if legacy {
    					meta.metadata, err = xioutil.ReadFile(pathJoinBuf(sb, volumeDir, meta.name, xlStorageFormatFileV1))
    					diskHealthCheckOK(ctx, err)
    					if err == nil {
    						// It was an object
    						if err := send(meta); err != nil {
    							return err
    						}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. src/main/resources/fess_env.properties

    # ----------------------------------------------------------
    #                                                      Mail
    #                                                     ------
    # Does it send mock mail? (true: no send actually, logging only)
    mail.send.mock = true
    
    # SMTP server settings for main: host:port
    mail.smtp.server.main.host.and.port = localhost:25
    
    # The prefix of subject to show test environment or not
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Aug 07 04:53:24 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  9. docs/en/docs/reference/websockets.md

    # WebSockets
    
    When defining WebSockets, you normally declare a parameter of type `WebSocket` and with it you can read data from the client and send data to it.
    
    It is provided directly by Starlette, but you can import it from `fastapi`:
    
    ```python
    from fastapi import WebSocket
    ```
    
    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  10. internal/store/store.go

    	retryTicker := time.NewTicker(retryInterval)
    	defer retryTicker.Stop()
    
    	send := func(key Key) bool {
    		for {
    			err := target.SendFromStore(key)
    			if err == nil {
    				break
    			}
    
    			logger(
    				context.Background(),
    				fmt.Errorf("unable to send log entry to '%s' err '%w'", target.Name(), err),
    				target.Name(),
    			)
    
    			select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top