Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 35 for absorb (0.35 seconds)

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

  1. docker-buildx.sh

    	minisign -qQSm ./minio-${arch}.${release} -s "$CRED_DIR/minisign.key" <"$CRED_DIR/minisign-passphrase"
    
    	sha256sum_str=$(sha256sum <./minio-${arch}.${release})
    	rc=$?
    	if [ "$rc" -ne 0 ]; then
    		abort "unable to generate sha256sum for ${1}"
    	fi
    	echo "${sha256sum_str// -/minio.${release}}" >./minio-${arch}.${release}.sha256sum
    }
    
    function main() {
    	echo "Testing builds for OS/Arch: ${SUPPORTED_OSARCH}"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Oct 19 08:22:05 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

                            }
                        }
                    }
                }
            } catch (final CrawlerSystemException e) {
                httpGet.abort();
                throw e;
            } catch (final Exception e) {
                httpGet.abort();
                throw new CrawlingAccessException("Could not process " + robotTxtUrl + ". ", e);
            } finally {
                EntityUtils.consumeQuietly(httpEntity);
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Nov 23 12:19:14 GMT 2025
    - 53.7K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

        if (success && !entry.readable) {
          for (i in 0 until valueCount) {
            if (!editor.written!![i]) {
              editor.abort()
              throw IllegalStateException("Newly created entry didn't create value for index $i")
            }
            if (!fileSystem.exists(entry.dirtyFiles[i])) {
              editor.abort()
              return
            }
          }
        }
    
        for (i in 0 until valueCount) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

                super.close()
                editor.commit()
              }
            }
        }
    
        override fun abort() {
          synchronized(this@Cache) {
            if (done) return
            done = true
            writeAbortCount++
          }
          cacheOut.closeQuietly()
          try {
            editor.abort()
          } catch (_: IOException) {
          }
        }
    
        override fun body(): Sink = body
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Oct 03 17:41:45 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  5. ci/official/utilities/setup.sh

    # specifically. Use your best judgment to keep the scripts in this directory
    # lean and easy to follow. When in doubt, remember that for CI scripts, "keep it
    # simple" is MUCH more important than "don't repeat yourself."
    
    # -e: abort script if one command fails
    # -u: error if undefined variable used
    # -x: log all commands
    # -o pipefail: entire command fails if pipe fails. watch out for yes | ...
    # -o history: record shell history
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Thu Jan 09 18:37:25 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  6. docs/bigdata/README.md

    fs.s3a.secret.key=minio123
    fs.s3a.path.style.access=true
    fs.s3a.block.size=512M
    fs.s3a.buffer.dir=${hadoop.tmp.dir}/s3a
    fs.s3a.committer.magic.enabled=false
    fs.s3a.committer.name=directory
    fs.s3a.committer.staging.abort.pending.uploads=true
    fs.s3a.committer.staging.conflict-mode=append
    fs.s3a.committer.staging.tmp.path=/tmp/staging
    fs.s3a.committer.staging.unique-filenames=true
    fs.s3a.connection.establish.timeout=5000
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. internal/event/target/kafka.go

    func (target *KafkaTarget) Close() error {
    	close(target.quitCh)
    
    	if target.batch != nil {
    		target.batch.Close()
    	}
    
    	if target.producer != nil {
    		if target.store != nil {
    			// It is safe to abort the current transaction if
    			// queue_dir is configured
    			target.producer.AbortTxn()
    		} else {
    			target.producer.CommitTxn()
    		}
    		target.producer.Close()
    		return target.client.Close()
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  8. cmd/global-heal.go

    				bucket, humanize.Ordinal(er.setIndex+1))
    		}
    
    		disks, _, healing := er.getOnlineDisksWithHealingAndInfo(true)
    		if len(disks) == healing {
    			// All drives in this erasure set were reformatted for some reasons, abort healing and mark it as successful
    			healingLogIf(ctx, errors.New("all drives are in healing state, aborting.."))
    			return nil
    		}
    
    		disks = disks[:len(disks)-healing] // healing drives are always at the end of the list
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  9. src/cmd/asm/internal/asm/parse.go

    next:
    	// Skip newlines.
    	var tok lex.ScanToken
    	for {
    		tok = p.nextToken()
    		// We save the line number here so error messages from this instruction
    		// are labeled with this line. Otherwise we complain after we've absorbed
    		// the terminating newline and the line numbers are off by one in errors.
    		p.lineNum = p.lex.Line()
    		switch tok {
    		case '\n', ';':
    			continue
    		case scanner.EOF:
    			return "", "", nil, false
    		}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Nov 12 03:59:40 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  10. src/cmd/asm/internal/lex/input.go

    	}
    	in.Push(NewSlice(in.Base(), in.Line(), tokens))
    }
    
    // argsFor returns a map from formal name to actual value for this argumented macro invocation.
    // The opening parenthesis has been absorbed.
    func (in *Input) argsFor(macro *Macro) map[string][]Token {
    	var args [][]Token
    	// One macro argument per iteration. Collect them all and check counts afterwards.
    	for argNum := 0; ; argNum++ {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Nov 12 03:59:40 GMT 2025
    - 12.4K bytes
    - Click Count (0)
Back to Top