Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 245 for flush (0.03 sec)

  1. internal/s3select/csv/record.go

    	w.Comma = opts.FieldDelimiter
    	w.AlwaysQuote = opts.AlwaysQuote
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(r.csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	var kvs jstream.KVS = make([]jstream.KV, 0, len(r.columnNames))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

                builder.startObject();
                response.toXContent(builder, ToXContent.EMPTY_PARAMS);
                builder.endObject();
                builder.flush();
                try (OutputStream out = builder.getOutputStream()) {
                    stats = ((ByteArrayOutputStream) out).toString(Constants.UTF_8);
                }
            } catch (final Exception e) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/web/admin/upgrade/AdminUpgradeAction.java

                    if (response.getHttpStatusCode() == 200) {
                        logger.info("Flushed config files.");
                    } else {
                        logger.warn("Failed to flush config files.");
                    }
                } catch (final Exception e) {
                    logger.warn("Failed to flush config files.", e);
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 54K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      fun awaitPong() {
        this.withLock {
          while (awaitPongsReceived < awaitPingsSent) {
            condition.await()
          }
        }
      }
    
      @Throws(IOException::class)
      fun flush() {
        writer.flush()
      }
    
      /**
       * Degrades this connection such that new streams can neither be created locally, nor accepted
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/service/BadWordService.java

                            list.add(StringUtil.EMPTY);
                        } else {
                            list.add(value.toString());
                        }
                    }
                });
    
                csvWriter.flush();
            } catch (final IOException e) {
                logger.warn("Failed to write a sugget bad word.", e);
            }
        }
    
        private static String getValue(final List<String> list, final int index) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. cmd/metacache-stream.go

    				if err == nil && cerr != nil {
    					err = cerr
    				}
    			}()
    			if w.streamErr != nil {
    				return w.streamErr
    			}
    			if err = w.mw.WriteBool(false); err != nil {
    				return err
    			}
    			return w.mw.Flush()
    		}
    		return nil
    	}
    	return &w
    }
    
    // write one or more objects to the stream in order.
    // It is favorable to send as many objects as possible in a single write,
    // but no more than math.MaxUint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/clusters/clusters.go

    		} else {
    			endpoint = ce.address
    		}
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", endpoint, core.HealthStatus_name[int32(ce.status)], printFailedOutlierCheck(ce.failedOutlierCheck), ce.cluster)
    	}
    
    	return w.Flush()
    }
    
    // PrintEndpoints prints the endpoints config to the ConfigWriter stdout
    func (c *ConfigWriter) PrintEndpoints(filter EndpointFilter, outputFormat string) error {
    	if c.clusters == nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    					} else {
    						write([]byte{0})
    					}
    					return
    				default:
    				}
    
    				// Response not ready, write a filler byte.
    				write([]byte{32})
    				if canWrite {
    					w.(http.Flusher).Flush()
    				}
    			case err := <-doneCh:
    				if err != nil {
    					write([]byte{1})
    					write([]byte(err.Error()))
    				} else {
    					write([]byte{0})
    				}
    				return
    			}
    		}
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/endpoint.go

    				}
    				fmt.Fprintf(w, "%v\t%v\t%v\t%v\n",
    					addr,
    					ep.GetHealthStatus().String(),
    					util.LocalityToString(llb.Locality),
    					eds.ClusterName,
    				)
    			}
    		}
    	}
    
    	return w.Flush()
    }
    
    func (c *ConfigWriter) retrieveSortedEndpointsSlice(filter EndpointFilter) ([]*endpoint.ClusterLoadAssignment, error) {
    	if c.configDump == nil {
    		return nil, fmt.Errorf("config writer has not been primed")
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 09:57:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
             * predictable what work might be done. (e.g., close a file and flush buffers to disk). To
             * protect ourselves from this, we park ourselves and tell our interrupter that we did so.
             */
            if (state == PARKED || compareAndSet(state, PARKED)) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top