Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 56 for Flush (0.15 sec)

  1. istioctl/pkg/admin/istiodconfig.go

    		_, _ = fmt.Fprintln(w, "ACTIVE SCOPE\tDESCRIPTION\tLOG LEVEL")
    		for _, sll := range resultScopeLogLevel {
    			_, _ = fmt.Fprintf(w, "%s\t%s\t%s\n", sll.ScopeName, sll.Description, sll.LogLevel)
    		}
    		return w.Flush()
    	case "json", "yaml":
    		outputBytes, err := json.MarshalIndent(&resultScopeLogLevel, "", "  ")
    		outputBytes = append(outputBytes, []byte("\n")...)
    		if err != nil {
    			return err
    		}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  2. maven-api-impl/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar

    final int _mask; private final Object[] _keys; private final Object[] _values; public void CachedMap(); public void CachedMap(int); public void CachedMap(int, java.util.Map); public int getCacheSize(); public java.util.Map getBackingMap(); public void flush(); public Object get(Object); private Object getCacheMissed(Object, int); public Object put(Object, Object); public Object remove(Object); public boolean containsKey(Object); public int size(); public boolean isEmpty(); public boolean containsValue(Object);...
    Archive
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu May 02 15:10:38 GMT 2024
    - 164.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/ImmutableMapTest.java

        Collection<Integer> values = map.values();
    
        ByteArrayOutputStream bytes = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(bytes);
        oos.writeObject(map);
        oos.flush();
    
        int mapSize = bytes.size();
        oos.writeObject(keySet);
        oos.writeObject(values);
        oos.close();
    
        int finalSize = bytes.size();
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Feb 27 13:27:08 GMT 2024
    - 41.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/io/CopyUtil.java

                int len;
                int amount = 0;
                while ((len = in.read(buf)) != -1) {
                    out.write(buf, 0, len);
                    amount += len;
                }
                out.flush();
                return amount;
            } catch (final IOException e) {
                throw new IORuntimeException(e);
            }
        }
    
        /**
         * ファイル入力ストリームの内容を出力ストリームにコピーします。
         * <p>
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 52.4K bytes
    - Viewed (0)
  5. istioctl/pkg/waypoint/waypoint.go

    				if allNamespaces {
    					_, _ = fmt.Fprintf(w, "%s\t%s\t%s\t%s\n", gw.Namespace, gw.Name, rev, programmed)
    				} else {
    					_, _ = fmt.Fprintf(w, "%s\t%s\t%s\n", gw.Name, rev, programmed)
    				}
    			}
    			return w.Flush()
    		},
    	}
    	waypointListCmd.PersistentFlags().BoolVarP(&allNamespaces, "all-namespaces", "A", false, "List all waypoints in all namespaces")
    
    	waypointCmd := &cobra.Command{
    		Use:   "waypoint",
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    	var buffer bytes.Buffer
    	encoder := msgp.NewWriter(&buffer)
    	for _, version := range versions {
    		version.EncodeMsg(encoder)
    	}
    	storageLogIf(ctx, encoder.Flush())
    
    	errs = make([]error, len(versions))
    
    	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
    	defer xhttp.DrainBody(respBody)
    	if err != nil {
    		if contextCanceled(ctx) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/CallTest.kt

              return null
            }
    
            override fun writeTo(sink: BufferedSink) {
              sink.writeUtf8("abc")
              sink.flush()
              makeFailingCall()
              sink.writeUtf8("def")
              sink.flush()
            }
          }
        val call =
          client.newCall(
            Request(
              url = server.url("/"),
              body = requestBody,
            ),
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  8. istioctl/pkg/tag/tag.go

    	fmt.Fprintln(w, "TAG\tREVISION\tNAMESPACES")
    	for _, t := range tags {
    		fmt.Fprintf(w, "%s\t%s\t%s\n", t.Tag, t.Revision, strings.Join(t.Namespaces, ","))
    	}
    
    	return w.Flush()
    }
    
    func PrintJSON(w io.Writer, res any) error {
    	out, err := json.MarshalIndent(res, "", "\t")
    	if err != nil {
    		return fmt.Errorf("error while marshaling to JSON: %v", err)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 16.3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/collect/ImmutableMapTest.java

        Collection<Integer> values = map.values();
    
        ByteArrayOutputStream bytes = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(bytes);
        oos.writeObject(map);
        oos.flush();
    
        int mapSize = bytes.size();
        oos.writeObject(keySet);
        oos.writeObject(values);
        oos.close();
    
        int finalSize = bytes.size();
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Apr 30 14:39:16 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  10. src/cmd/api/main_test.go

    		for cname := range cmap {
    			f2 := fmt.Sprintf("%s (%s)%s", f[:comma], cname, f[comma:])
    			features = append(features, f2)
    		}
    	}
    
    	bw := bufio.NewWriter(os.Stdout)
    	defer bw.Flush()
    
    	var required []string
    	for _, file := range checkFiles {
    		required = append(required, fileFeatures(file, needApproval(file))...)
    	}
    	for _, file := range nextFiles {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Apr 09 20:48:51 GMT 2024
    - 31.4K bytes
    - Viewed (0)
Back to top