Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 801 for send (0.03 sec)

  1. guava/src/com/google/common/util/concurrent/RateLimiter.java

     *
     * <pre>{@code
     * final RateLimiter rateLimiter = RateLimiter.create(5000.0); // rate = 5000 permits per second
     * void submitPacket(byte[] packet) {
     *   rateLimiter.acquire(packet.length);
     *   networkService.send(packet);
     * }
     * }</pre>
     *
     * <p>It is important to note that the number of permits requested <i>never</i> affects the
     * throttling of the request itself (an invocation to {@code acquire(1)} and an invocation to {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/ntlmssp/Type3Message.java

                List<AvPair> avPairs = ntlmClientChallengeInfo != null ? AvPairs.decode(ntlmClientChallengeInfo) : null;
    
                // if targetInfo has an MsvAvTimestamp
                // client should not send LmChallengeResponse
                boolean haveTimestamp = AvPairs.contains(avPairs, AvPair.MsvAvTimestamp);
                if ( !haveTimestamp ) {
                    byte[] lmClientChallenge = new byte[8];
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 12:07:20 UTC 2020
    - 30.6K bytes
    - Viewed (0)
  3. cni/pkg/iptables/iptables.go

    	)
    
    	if redirectDNS {
    		// CLI: -A ISTIO_OUTPUT ! -o lo -p udp -m udp --dport 53 -j REDIRECT --to-port 15053
    		//
    		// DESC: If this is a UDP DNS request to a non-localhost resolver, send it to ztunnel DNS proxy port
    		iptablesBuilder.AppendRule(
    			iptableslog.UndefinedCommand, ChainInpodOutput, iptablesconstants.NAT,
    			"!", "-o", "lo",
    			"-p", "udp",
    			"-m", "mark", "!",
    			"--mark", inpodMark,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    			// itself will not leak.
    			<-h.traverseAndHealDoneCh
    		}()
    	}
    }
    
    func (h *healSequence) queueHealTask(source healSource, healType madmin.HealItemType) error {
    	// Send heal request
    	task := healTask{
    		bucket:    source.bucket,
    		object:    source.object,
    		versionID: source.versionID,
    		opts:      h.settings,
    	}
    	if source.opts != nil {
    		task.opts = *source.opts
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  5. cmd/post-policy_test.go

    	var buf bytes.Buffer
    	w := multipart.NewWriter(&buf)
    
    	// Set the normal formData
    	for k, v := range formData {
    		w.WriteField(k, v)
    	}
    	// Set the File formData but don't if we want send an incomplete multipart request
    	if !corruptedMultipart {
    		var writer io.Writer
    		var err error
    		if noFilename {
    			writer, err = w.CreateFormField("file")
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. fastapi/applications.py

                self.add_route(self.redoc_url, redoc_html, include_in_schema=False)
    
        async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
            if self.root_path:
                scope["root_path"] = self.root_path
            await super().__call__(scope, receive, send)
    
        def add_api_route(
            self,
            path: str,
            endpoint: Callable[..., Any],
            *,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:52:31 UTC 2024
    - 172.2K bytes
    - Viewed (0)
  7. istioctl/pkg/workload/workload.go

    		Long: `Creates a WorkloadGroup resource that provides a template for associated WorkloadEntries.
    The default output is serialized YAML, which can be piped into 'kubectl apply -f -' to send the artifact to the API Server.`,
    		Example: "  istioctl x workload group create --name foo --namespace bar --labels app=foo,bar=baz " +
    			"--ports grpc=3550,http=8080 --annotations annotation=foobar --serviceAccount sa",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    				return nil
    			}
    			volsInfo, err := storageDisks[index].ListVols(ctx)
    			if err != nil {
    				return err
    			}
    			for _, volInfo := range volsInfo {
    				// StorageAPI can send volume names which are
    				// incompatible with buckets - these are
    				// skipped, like the meta-bucket.
    				if isReservedOrInvalidBucket(volInfo.Name, false) {
    					continue
    				}
    				mu.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  9. cmd/api-response.go

    	}
    
    	var toRemove []string
    	for k := range cleanMinioInternalMetadataKeys(m) {
    		if stringsHasPrefixFold(k, ReservedMetadataPrefixLower) {
    			// Do not need to send any internal metadata
    			// values to client.
    			toRemove = append(toRemove, k)
    			continue
    		}
    
    		// https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  10. docs/en/docs/async.md

    This is the case for most of the web applications.
    
    Many, many users, but your server is waiting πŸ•™ for their not-so-good connection to send their requests.
    
    And then waiting πŸ•™ again for the responses to come back.
    
    This "waiting" πŸ•™ is measured in microseconds, but still, summing it all, it's a lot of waiting in the end.
    
    That's why it makes a lot of sense to use asynchronous βΈπŸ”€β― code for web APIs.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
Back to top