Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 1,066 for readOp (0.14 sec)

  1. src/main/java/org/codelibs/fess/dict/stopwords/StopwordsFile.java

            final List<StopwordsItem> itemList = new ArrayList<>();
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {
                long id = 0;
                String line = null;
                while ((line = reader.readLine()) != null) {
                    if (line.length() == 0 || line.charAt(0) == '#') {
                        if (updater != null) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  2. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/upgrades/UpgradedProperties.java

            File file = new File(path);
            if (!file.exists()) {
                return Collections.emptyList();
            }
            try (FileReader reader = new FileReader(file)) {
                List<UpgradedProperty> upgradedProperties = new Gson().fromJson(reader, new TypeToken<List<UpgradedProperty>>() {}.getType());
                // FIXME There should be no duplicates, yet there are some
                return upgradedProperties.stream()
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Wed Oct 02 14:20:08 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. cmd/healthcheck-handler.go

    		w.Header().Set(xhttp.MinIOServerStatus, "iam-offline")
    		writeResponse(w, http.StatusServiceUnavailable, nil, mimeNone)
    		return nil
    	}
    
    	return objLayer
    }
    
    // ClusterCheckHandler returns if the server is ready for requests.
    func ClusterCheckHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "ClusterCheckHandler")
    
    	objLayer := checkHealth(w)
    	if objLayer == nil {
    		return
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. buildscripts/rewrite-old-new.sh

    	# remove mc source.
    	purge "${MC_BUILD_DIR}"
    
    	"${MINIO_OLD[@]}" --address ":$start_port" "${WORK_DIR}/xl{1...16}" >"${WORK_DIR}/server1.log" 2>&1 &
    	pid=$!
    	disown $pid
    
    	"${WORK_DIR}/mc" ready minio/
    
    	if ! ps -p ${pid} 1>&2 >/dev/null; then
    		echo "server1 log:"
    		cat "${WORK_DIR}/server1.log"
    		echo "FAILED"
    		purge "$WORK_DIR"
    		exit 1
    	fi
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/testdata/routes/empty-gateway/output.txt

    NAME     VHOST NAME     DOMAINS     MATCH                  VIRTUAL SERVICE
             backend        *           /healthz/ready*        
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 190 bytes
    - Viewed (0)
  6. internal/s3select/parquet/args.go

    package parquet
    
    import "encoding/xml"
    
    // ReaderArgs - represents elements inside <InputSerialization><Parquet/> in request XML.
    type ReaderArgs struct {
    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  7. fastapi/routing.py

                    WebSocket.
    
                    Read more about it in the
                    [FastAPI docs for WebSockets](https://fastapi.tiangolo.com/advanced/websockets/).
                    """
                ),
            ] = None,
        ) -> Callable[[DecoratedCallable], DecoratedCallable]:
            """
            Decorate a WebSocket function.
    
            Read more about it in the
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:44:57 UTC 2024
    - 172.1K bytes
    - Viewed (0)
  8. cmd/bucket-encryption.go

    	return sseCfg, err
    }
    
    // validateBucketSSEConfig parses bucket encryption configuration and validates if it is supported by MinIO.
    func validateBucketSSEConfig(r io.Reader) (*sse.BucketSSEConfig, error) {
    	encConfig, err := sse.ParseBucketSSEConfig(r)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(encConfig.Rules) == 1 {
    		return encConfig, nil
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  9. docs/distributed/decom-compressed-sse-s3.sh

    export MC_HOST_myminio="http://minioadmin:minioadmin@localhost:9000/"
    
    (minio server http://localhost:9000/tmp/xl/{1...10}/disk{0...1} 2>&1 >/dev/null) &
    pid=$!
    
    ./mc ready myminio
    
    ./mc admin user add myminio/ minio123 minio123
    ./mc admin user add myminio/ minio12345 minio12345
    
    ./mc admin policy create myminio/ rw ./docs/distributed/rw.json
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  10. internal/s3select/jstream/decoder_test.go

    package jstream
    
    import (
    	"bytes"
    	"testing"
    )
    
    func mkReader(s string) *bytes.Reader { return bytes.NewReader([]byte(s)) }
    
    func TestDecoderSimple(t *testing.T) {
    	var (
    		counter int
    		mv      *MetaValue
    		body    = `[{"bio":"bada bing bada boom","id":1,"name":"Charles","falseVal":false}]`
    	)
    
    	decoder := NewDecoder(mkReader(body), 1)
    
    	for mv = range decoder.Stream() {
    		counter++
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top