Search Options

Results per page
Sort
Preferred Languages
Advance

Results 641 - 650 of 808 for oper (0.05 sec)

  1. internal/s3select/message.go

    	headerLength := len(recordsHeader)
    	payloadLength := messageLength - 4 - 4 - 4 - headerLength - 4
    	return payloadLength
    }
    
    // continuationMessage - S3 periodically sends this message to keep the TCP connection open.
    // These messages appear in responses at random. The client must detect the message type and process accordingly.
    //
    // Header specification:
    // Continuation messages contain two headers, as follows:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  2. .bazelrc

    # errors.
    # There is ongoing work on Bazel team's side to provide support for transitive
    # shared libraries. As part of migrating to transitive shared libraries, we
    # hope to provide a better mechanism for control over symbol exporting, and
    # then tackle this issue again.
    #
    # TODO: Remove the following two lines once TF doesn't depend on Bazel wrapping
    # all library archives in -whole_archive -no_whole_archive.
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Oct 28 22:02:31 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

            if (list.isEmpty()) {
                return null;
            }
            if (list.size() >= 2) {
                String msg = "The size of selected list is over 1: " + list.size();
                throw new FetchingOverSafetySizeException(msg, 1); // immediately caught by caller and translated
            }
            return list.get(0);
        }
    
        @Override
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java

            if (list.isEmpty()) {
                return null;
            }
            if (list.size() >= 2) {
                String msg = "The size of selected list is over 1: " + list.size();
                throw new FetchingOverSafetySizeException(msg, 1); // immediately caught by caller and translated
            }
            return list.get(0);
        }
    
        @Override
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/ztunnelserver.go

    }
    
    func (z *ztunnelServer) Close() error {
    	return z.listener.Close()
    }
    
    func (z *ztunnelServer) Run(ctx context.Context) {
    	context.AfterFunc(ctx, func() { _ = z.Close() })
    
    	// Allow at most 5 requests per second. This is still a ridiculous amount; at most we should have 2 ztunnels on our node,
    	// and they will only connect once and persist.
    	// However, if they do get in a state where they call us in a loop, we will quickly OOM
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  6. helm-releases/minio-2.0.1.tgz

    resources: requests: storage: {{ $psize }} {{- end }} {{- end }} {{- end }} minio/.helmignore # Patterns to ignore when building packages. # This supports shell glob matching, relative path matching, and # negation (prefixed with !). Only one pattern per line. .DS_Store # Common VCS dirs .git/ .gitignore .bzr/ .bzrignore .hg/ .hgignore .svn/ # Common backup files *.swp *.bak *.tmp *~ # Various IDEs .project .idea/ *.tmproj # OWNERS file for Kubernetes OWNERS minio/README.md # MinIO Helm Chart [![Sl...
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 31 09:09:09 UTC 2021
    - 13.6K bytes
    - Viewed (0)
  7. docs/bucket/replication/README.md

    Also note that `mc` version `RELEASE.2021-09-02T09-21-27Z` or older supports only a single remote target per bucket. To take advantage of multiple destination replication, use the latest version of `mc`
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jan 24 23:46:33 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  8. istioctl/pkg/waypoint/waypoint.go

    			// choose to do so.
    			//
    			// NOTE: This is a warning and not an error because the user may not intend to label their namespace as ambient.
    			//
    			// e.g. Users are handling ambient redirection per workload rather than at the namespace level.
    			hasWaypoint, err := namespaceHasLabel(kubeClient, ns, label.IoIstioUseWaypoint.Name)
    			if err != nil {
    				return err
    			}
    			if enrollNamespace {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  9. cmd/data-scanner.go

    	if err != nil {
    		internalLogIf(ctx, err)
    	}
    }
    
    // runDataScanner will start a data scanner.
    // The function will block until the context is canceled.
    // There should only ever be one scanner running per cluster.
    func runDataScanner(ctx context.Context, objAPI ObjectLayer) {
    	ctx, cancel := globalLeaderLock.GetLock(ctx)
    	defer cancel()
    
    	// Load current bloom cycle
    	var cycleInfo currentScannerCycle
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  10. cmd/notification.go

    }
    
    // WithNPeersThrottled returns a new NotificationGroup with length of errs slice upto nerrs,
    // upon Wait() errors are returned collected from all tasks, optionally allows for X workers
    // only "per" parallel task.
    func WithNPeersThrottled(nerrs, wks int) *NotificationGroup {
    	if nerrs <= 0 {
    		nerrs = 1
    	}
    	if wks > nerrs {
    		wks = nerrs
    	}
    	wk, _ := workers.New(wks)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
Back to top