Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 245 for flush (0.02 sec)

  1. src/cmd/asm/internal/asm/endtoend_test.go

    	pList := new(obj.Plist)
    	var ok bool
    	testOut = new(strings.Builder) // The assembler writes test output to this buffer.
    	ctxt.Bso = bufio.NewWriter(os.Stdout)
    	ctxt.IsAsm = true
    	defer ctxt.Bso.Flush()
    	failed := false
    	ctxt.DiagFunc = func(format string, args ...interface{}) {
    		failed = true
    		t.Errorf(format, args...)
    	}
    	pList.Firstpc, ok = parser.Parse()
    	if !ok || failed {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Dec 07 18:42:59 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/listener.go

    			matches := newMatcher(fc, l)
    			destination := getFilterType(fc.GetFilters())
    			for _, match := range matches {
    				fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", lname, name, match, destination)
    			}
    		}
    	}
    	return w.Flush()
    }
    
    func newMatcher(fc *listener.FilterChain, l *listener.Listener) []string {
    	if l.FilterChainMatcher == nil {
    		return []string{getMatches(fc.GetFilterChainMatch())}
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  3. internal/s3select/json/record.go

    	w.Comma = opts.FieldDelimiter
    	w.Quote = opts.Quote
    	w.AlwaysQuote = opts.AlwaysQuote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    }
    
    // Raw - returns the underlying representation.
    func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) {
    	return r.SelectFormat, r.KVS
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  4. internal/s3select/simdj/record.go

    	w.Comma = opts.FieldDelimiter
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	w.AlwaysQuote = opts.AlwaysQuote
    	if err := w.Write(csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    }
    
    // Raw - returns the underlying representation.
    func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) {
    	return sql.SelectFmtSIMDJSON, r.object
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java

                            0, thumbnailWidth, thumbnailHeight, null);
                    ImageIO.write(thumbnail, fessConfig.getThumbnailHtmlImageFormat(), outputFile);
                    image.flush();
                    return Result.OK;
                } finally {
                    reader.dispose();
                }
            }
            return Result.FAILED;
        }
    
        protected enum Result {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java

                    }
                }
                return null;
            }
    
            @Override
            public void close() {
                try {
                    writer.flush();
                } catch (final IOException e) {
                    // ignore
                }
                CloseableUtil.closeQuietly(writer);
    
                if (isCommit) {
                    try {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

            }
            try {
                final OutputStream out = jobProcess.getProcess().getOutputStream();
                IOUtils.write(command + "\n", out, Constants.CHARSET_UTF_8);
                out.flush();
            } catch (final IOException e) {
                throw new JobProcessingException(e);
            }
        }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java

          throws IOException {
        if (singleByte) {
          for (int i = off; i < off + len; i++) {
            out.write(b[i]);
          }
        } else {
          out.write(b, off, len);
        }
        out.flush(); // for coverage
      }
    
      // TODO(chrisn): only works if we ensure we have crossed file threshold
    
      public void testWriteErrorAfterClose() throws Exception {
        byte[] data = newPreFilledByteArray(100);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. docs/hotfixes.md

    Author: Klaus Post <******@****.***>
    Date:   Mon Nov 8 08:41:27 2021 -0800
    
        Close stream on panic (#13605)
    
        Always close streamHTTPResponse on panic on main thread to avoid
        write/flush after response handler has returned.
    ```
    
    ```
    λ git cherry-pick 4f3317effea38c203c358af9cb5ce3c0e4173976
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 14 21:36:02 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/envoy/configdump/route.go

    							describeRouteDomains(vhosts.GetDomains()),
    							"/*",
    							"404")
    					}
    				}
    			} else {
    				fmt.Fprintf(w, "%v\t%v\n", route.Name, len(route.GetVirtualHosts()))
    			}
    		}
    	}
    	return w.Flush()
    }
    
    func describeRouteDomains(domains []string) string {
    	if len(domains) == 0 {
    		return ""
    	}
    	if len(domains) == 1 {
    		return domains[0]
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 08 20:44:50 UTC 2024
    - 7.2K bytes
    - Viewed (0)
Back to top