Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 377 for goexit (0.11 sec)

  1. common/config/.golangci.yml

            # - name: confusing-naming
            # - name: unexported-naming
            # - name: early-return
            # - name: unused-parameter
            # - name: unnecessary-stmt
            # - name: deep-exit
            # - name: import-shadowing
            # - name: modifies-value-receiver
            # - name: unused-receiver
            # - name: bare-return
            # - name: flag-parameter
            # - name: unhandled-error
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  2. cmd/metacache-walk.go

    		}
    	}
    	send := func(entry metaCacheEntry) error {
    		objReturned(entry.metadata)
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		case out <- entry:
    		}
    		return nil
    	}
    
    	// Fast exit track to check if we are listing an object with
    	// a trailing slash, this will avoid to list the object content.
    	if HasSuffix(opts.BaseDir, SlashSeparator) {
    		metadata, err := s.readMetadata(ctx, pathJoin(volumeDir,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. internal/ioutil/ioutil.go

    // Run runs the given function, passing it a stopper channel. If the deadline passes before
    // the function finishes executing, Run returns context.DeadlineExceeded to the caller.
    // channel so that the work function can attempt to exit gracefully.
    // Multiple calls to Run will run independently of each other.
    func (d *DeadlineWorker) Run(work func() error) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/asm/asm.go

    		Ctxt: p.ctxt,
    		As:   obj.AFUNCDATA,
    		Pos:  p.pos(),
    		From: valueAddr,
    		To:   nameAddr,
    	}
    	p.append(prog, "", true)
    }
    
    // asmJump assembles a jump instruction.
    // JMP	R1
    // JMP	exit
    // JMP	3(PC)
    func (p *Parser) asmJump(op obj.As, cond string, a []obj.Addr) {
    	var target *obj.Addr
    	prog := &obj.Prog{
    		Ctxt: p.ctxt,
    		Pos:  p.pos(),
    		As:   op,
    	}
    	targetAddr := &prog.To
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 21 14:11:44 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/base/Ascii.java

       *
       * @since 16.0
       */
      public static boolean equalsIgnoreCase(CharSequence s1, CharSequence s2) {
        // Calling length() is the null pointer check (so do it before we can exit early).
        int length = s1.length();
        if (s1 == s2) {
          return true;
        }
        if (length != s2.length()) {
          return false;
        }
        for (int i = 0; i < length; i++) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  6. docs/site-replication/run-replication-with-checksum-header.sh

    #!/usr/bin/env bash
    
    # shellcheck disable=SC2120
    exit_1() {
    	cleanup
    
    	echo "minio1 ============"
    	cat /tmp/minio1_1.log
    	echo "minio2 ============"
    	cat /tmp/minio2_1.log
    
    	exit 1
    }
    
    cleanup() {
    	echo -n "Cleaning up instances of MinIO ..."
    	pkill -9 minio || sudo pkill -9 minio
    	rm -rf /tmp/minio{1,2}
    	echo "done"
    }
    
    # Function to convert number to corresponding alphabet
    num_to_alpha() {
    	local num=$1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 08:02:16 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  7. docs/site-replication/run-sse-kms-object-replication.sh

    	echo "minio1 ============"
    	cat /tmp/minio1_1.log
    	echo "minio2 ============"
    	cat /tmp/minio2_1.log
    	echo "minio3 ============"
    	cat /tmp/minio3_1.log
    	echo "minio4 ============"
    	cat /tmp/minio4_1.log
    	exit 1
    }
    
    cleanup() {
    	echo -n "Cleaning up instances of MinIO ..."
    	pkill -9 minio || sudo pkill -9 minio
    	pkill -9 kes || sudo pkill -9 kes
    	rm -rf ${PWD}/keys
    	rm -rf /tmp/minio{1,2,3,4}
    	echo "done"
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  8. cmd/metacache-server-pool.go

    		o.ID = ""
    		o.Transient = true
    		return entries, errDiskFull
    	}
    	o.set = z.serverPools[o.pool].getHashedSetIndex(o.ID)
    	saver := z.serverPools[o.pool].sets[o.set]
    
    	// Disconnect from call above, but cancel on exit.
    	listCtx, cancel := context.WithCancel(GlobalContext)
    	saveCh := make(chan metaCacheEntry, metacacheBlockSize)
    	inCh := make(chan metaCacheEntry, metacacheBlockSize)
    	outCh := make(chan metaCacheEntry, o.Limit)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/lex/input.go

    func (in *Input) Error(args ...interface{}) {
    	if panicOnError {
    		panic(fmt.Errorf("%s:%d: %s", in.File(), in.Line(), fmt.Sprintln(args...)))
    	}
    	fmt.Fprintf(os.Stderr, "%s:%d: %s", in.File(), in.Line(), fmt.Sprintln(args...))
    	os.Exit(1)
    }
    
    // expectText is like Error but adds "got XXX" where XXX is a quoted representation of the most recent token.
    func (in *Input) expectText(args ...interface{}) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/exec/Crawler.java

                    hotThreadMonitorTask.cancel();
                }
                destroyContainer();
            }
    
            if (exitCode != Constants.EXIT_OK) {
                System.exit(exitCode);
            }
        }
    
        private static void destroyContainer() {
            if (running.getAndSet(false)) {
                TimeoutManager.getInstance().stop();
                if (logger.isDebugEnabled()) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
Back to top