Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 437 for readLine (0.07 sec)

  1. cmd/admin-handlers.go

    		healthInfo.Error = string(encodedErrorResponse)
    		adminLogIf(ctx, enc.Encode(healthInfo))
    	}
    
    	deadline := 10 * time.Second // Default deadline is 10secs for health diagnostics.
    	if dstr := query.Get("deadline"); dstr != "" {
    		var err error
    		deadline, err = time.ParseDuration(dstr)
    		if err != nil {
    			errResp(err)
    			return
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. cni/pkg/install/cniconfig.go

    			return "", fmt.Errorf("CNI config file %s removed during configuration", cniConfigFilepath)
    		}
    		// This section overwrites an existing plugins list entry for istio-cni
    		existingCNIConfig, err := os.ReadFile(cniConfigFilepath)
    		if err != nil {
    			return "", err
    		}
    		pluginConfig, err = insertCNIConfig(pluginConfig, existingCNIConfig)
    		if err != nil {
    			return "", err
    		}
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. common/scripts/setup_env.sh

    fi
    if [[ "${IMAGE_NAME:-}" == "" ]]; then
      IMAGE_NAME=build-tools
    fi
    
    DOCKER_GID="${DOCKER_GID:-$(grep '^docker:' /etc/group | cut -f3 -d:)}"
    
    TIMEZONE=$(readlink "$readlink_flags" /etc/localtime | sed -e 's/^.*zoneinfo\///')
    
    TARGET_OUT="${TARGET_OUT:-$(pwd)/out/${TARGET_OS}_${TARGET_ARCH}}"
    TARGET_OUT_LINUX="${TARGET_OUT_LINUX:-$(pwd)/out/linux_${TARGET_ARCH}}"
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 04:52:54 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

                        } else if (StringUtil.isBlank(reading) && StringUtil.isBlank(boost)) {
                            elevateWordBhv.delete(elevateWord);
                            final String id = elevateWord.getId();
                            elevateWordToLabelBhv.queryDelete(cb -> cb.query().setElevateWordId_Equal(id));
                        } else {
                            elevateWord.setReading(reading);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "ResetID")
    				return
    			}
    		case "StartTime":
    			z.StartTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "StartTime")
    				return
    			}
    		case "EndTime":
    			z.EndTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "EndTime")
    				return
    			}
    		case "ResyncStatus":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 61.1K bytes
    - Viewed (0)
  6. istioctl/pkg/proxyconfig/proxyconfig.go

    	debug, err := extractConfigDump(kubeClient, podName, podNamespace, includeEds)
    	if err != nil {
    		return nil, err
    	}
    	return setupConfigdumpEnvoyConfigWriter(debug, out)
    }
    
    func readFile(filename string) ([]byte, error) {
    	file := os.Stdin
    	if filename != "-" {
    		var err error
    		file, err = os.Open(filename)
    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  7. internal/grid/grid_test.go

    			Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    				started := time.Now()
    				dl, _ := ctx.Deadline()
    				if testing.Verbose() {
    					fmt.Println(GetCaller(ctx).Name, "Server deadline:", time.Until(dl))
    				}
    				<-ctx.Done()
    				serverCanceled <- time.Since(started)
    				if testing.Verbose() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/it/admin/dict/KuromojiTests.java

            final String keyProp = NAME_PREFIX + id;
            requestBody.put(KEY_PROPERTY, keyProp);
            requestBody.put("segmentation", "segment");
            requestBody.put("reading", "reading");
            requestBody.put("pos", "pos");
            return requestBody;
        }
    
        @Override
        protected Map<String, Object> getUpdateMap() {
            final Map<String, Object> updateMap = new HashMap<>();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  9. istioctl/pkg/describe/describe_test.go

    	wantException bool
    }
    
    // Tests Pilot /debug
    func TestDescribe(t *testing.T) {
    	productPageConfigPath := "testdata/describe/http_config.json"
    	config, err := os.ReadFile(productPageConfigPath)
    	if err != nil {
    		t.Fatalf("failed to read %s: %v", productPageConfigPath, err)
    	}
    	cases := []execAndK8sConfigTestCase{
    		{ // case 0
    			args:           []string{},
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/CharSourceTester.java

        } else {
          assertEquals(expectedLines.get(0), source.readFirstLine());
        }
      }
    
      public void testReadLines_toList() throws IOException {
        assertExpectedLines(source.readLines());
      }
    
      public void testIsEmpty() throws IOException {
        assertEquals(expected.isEmpty(), source.isEmpty());
      }
    
      public void testLength() throws IOException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 6.8K bytes
    - Viewed (0)
Back to top