Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 1,066 for readOp (0.23 sec)

  1. istioctl/pkg/describe/describe.go

    		if !containerStatus.Ready {
    			fmt.Fprintf(writer, "WARNING: Pod %s Container %s NOT READY\n", kname(pod.ObjectMeta), containerStatus.Name)
    		}
    	}
    	for _, containerStatus := range pod.Status.InitContainerStatuses {
    		if !containerStatus.Ready {
    			fmt.Fprintf(writer, "WARNING: Pod %s Init Container %s NOT READY\n", kname(pod.ObjectMeta), containerStatus.Name)
    		}
    	}
    
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  2. docs/metrics/prometheus/list.md

    | `minio_node_drive_reads_per_sec`     | Reads per second on a drive.                             |
    | `minio_node_drive_reads_kb_per_sec`  | Kilobytes read per second on a drive.                    |
    | `minio_node_drive_reads_await`       | Average time for read requests to be served on a drive.  |
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
  3. cmd/xl-storage_test.go

    	w := newStreamingBitrotWriter(storage, "", volName, fileName, size, algo, shardSize)
    	reader := bytes.NewReader(data)
    	for {
    		// Using io.Copy instead of this loop will not work for us as io.Copy
    		// will use bytes.Reader.WriteTo() which will not do shardSize'ed writes
    		// causing error.
    		n, err := reader.Read(shard)
    		w.Write(shard[:n])
    		if err == nil {
    			continue
    		}
    		if err == io.EOF {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  4. common-protos/k8s.io/api/discovery/v1/generated.proto

      // Service has set the publishNotReadyAddresses flag.
      // +optional
      optional bool ready = 1;
    
      // serving is identical to ready except that it is set regardless of the
      // terminating state of endpoints. This condition should be set to true for
      // a ready endpoint that is terminating. If nil, consumers should defer to
      // the ready condition.
      // +optional
      optional bool serving = 2;
    
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/badword/AdminBadwordAction.java

            verifyToken(this::asUploadHtml);
            CommonPoolUtil.execute(() -> {
                try (Reader reader = new BufferedReader(new InputStreamReader(form.badWordFile.getInputStream(), getCsvEncoding()))) {
                    badWordService.importCsv(reader);
                    suggestHelper.storeAllBadWords(false);
                } catch (final Exception e) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. tensorflow/c/eager/c_api_remote_function_test.cc

                                        /*remote_func_outputs=*/true);
    }
    TEST(CAPI, RemoteExecuteSilentCopiesLocalAsyncFuncOrdering) {
      // A remote input may be not ready when we start running a function. Test that
      // the function execution should wait until the remote input is ready.
      TestRemoteExecuteSilentCopiesFunc(/*async=*/true, /*remote=*/false,
                                        /*heavy_load_on_streaming_rpc=*/true);
    }
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 3.6K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    	}
    	err = enc.Close()
    	if err != nil {
    		return err
    	}
    	return nil
    }
    
    // deserialize the supplied byte slice into the cache.
    func (d *dataUsageCache) deserialize(r io.Reader) error {
    	var b [1]byte
    	n, _ := r.Read(b[:])
    	if n != 1 {
    		return io.ErrUnexpectedEOF
    	}
    	ver := int(b[0])
    	switch ver {
    	case dataUsageCacheVerV1:
    		return errors.New("cache version deprecated (will autoupdate)")
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  8. internal/hash/errors.go

    }
    
    // SizeTooSmall reader size too small
    type SizeTooSmall struct {
    	Want int64
    	Got  int64
    }
    
    func (e SizeTooSmall) Error() string {
    	return fmt.Sprintf("Size small: got %d, want %d", e.Got, e.Want)
    }
    
    // SizeTooLarge reader size too large
    type SizeTooLarge struct {
    	Want int64
    	Got  int64
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon May 15 21:08:54 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  9. buildscripts/verify-build.sh

    	"${MINIO[@]}" server "${WORK_DIR}/fs-disk" >"$WORK_DIR/fs-minio.log" 2>&1 &
    
    	"${WORK_DIR}/mc" ready verify
    }
    
    function start_minio_erasure() {
    	"${MINIO[@]}" server "${WORK_DIR}/erasure-disk1" "${WORK_DIR}/erasure-disk2" "${WORK_DIR}/erasure-disk3" "${WORK_DIR}/erasure-disk4" >"$WORK_DIR/erasure-minio.log" 2>&1 &
    
    	"${WORK_DIR}/mc" ready verify
    }
    
    function start_minio_erasure_sets() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 19:28:51 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  10. istioctl/pkg/analyze/analyze.go

    			if isatty.IsTerminal(os.Stdin.Fd()) && !isJSONorYAMLOutputFormat() {
    				fmt.Fprint(cmd.OutOrStdout(), "Reading from stdin:\n")
    			}
    			r = os.Stdin
    			readers = append(readers, local.ReaderSource{Name: f, Reader: r})
    			continue
    		}
    
    		fi, err := os.Stat(f)
    		if err != nil {
    			return nil, err
    		}
    
    		if fi.IsDir() {
    			dirReaders, err := gatherFilesInDirectory(cmd, f)
    			if err != nil {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Fri Oct 25 03:42:48 UTC 2024
    - 17.4K bytes
    - Viewed (0)
Back to top