- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 69 for buffer_end (0.28 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
limitations under the License. */ package buffered import ( "fmt" "sync" "time" "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/wait" auditinternal "k8s.io/apiserver/pkg/apis/audit" "k8s.io/apiserver/pkg/audit" "k8s.io/client-go/util/flowcontrol" ) // PluginName is the name reported in error metrics. const PluginName = "buffered"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
src/os/user/cgo_lookup_unix.go
g := &Group{ Gid: strconv.Itoa(int(_C_gr_gid(grp))), Name: _C_GoString(_C_gr_name(grp)), } return g } type bufferKind _C_int var ( userBuffer = bufferKind(_C__SC_GETPW_R_SIZE_MAX) groupBuffer = bufferKind(_C__SC_GETGR_R_SIZE_MAX) ) func (k bufferKind) initialSize() _C_size_t { sz := _C_sysconf(_C_int(k)) if sz == -1 { // DragonFly and FreeBSD do not have _SC_GETPW_R_SIZE_MAX.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:08:14 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-execution/build-cache/src/jmh/java/org/gradle/caching/internal/tasks/TaskOutputPackagingBufferBenchmark.java
public class TaskOutputPackagingBufferBenchmark extends AbstractTaskOutputPackagingBenchmark { @Param({"tar.snappy.small", "tar.snappy.large"}) String packer; @Param({"direct", "buffered.small", "buffered.large"}) String accessor; @Override protected String getPackerName() { return packer; } @Override protected String getAccessorName() { return accessor;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:43:12 UTC 2023 - 1.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/audit_test.go
return o }, expected: "union[buffered<log>,ignoreErrors<webhook>]", }, { name: "default webhook with truncating", options: func() *AuditOptions { o := NewAuditOptions() o.WebhookOptions.ConfigFile = webhookConfig o.WebhookOptions.TruncateOptions.Enabled = true o.PolicyFile = policy return o }, expected: "truncate<buffered<webhook>>", }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 27 14:57:26 UTC 2022 - 7.8K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
// Package deadlineconn implements net.Conn wrapper with configured deadlines. package deadlineconn import ( "net" "time" ) // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. writeDeadline time.Duration // sets the write deadline on a connection. }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/core-execution/build-cache/src/jmh/java/org/gradle/caching/internal/tasks/AbstractTaskOutputPackagingBenchmark.java
.put("direct", new DirectFileFileAccessor(DIRECTORY_PROVIDER)) .put("buffered", new BufferedFileAccessor(8, DIRECTORY_PROVIDER)) .put("buffered.small", new BufferedFileAccessor(2, DIRECTORY_PROVIDER)) .put("buffered.large", new BufferedFileAccessor(64, DIRECTORY_PROVIDER)) .put("in-memory", new InMemoryDataAccessor()) .build();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:43:12 UTC 2023 - 7.2K bytes - Viewed (0) -
src/encoding/csv/writer.go
// // [Writer.Comma] is the field delimiter. // // If [Writer.UseCRLF] is true, // the Writer ends each output line with \r\n instead of \n. // // The writes of individual records are buffered. // After all data has been written, the client should call the // [Writer.Flush] method to guarantee all data has been forwarded to // the underlying [io.Writer]. Any errors that occurred should
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 4.8K bytes - Viewed (0) -
platforms/core-execution/build-cache/src/jmh/java/org/gradle/caching/internal/tasks/TaskOutputPackagingTarBenchmark.java
import org.openjdk.jmh.annotations.Param; public class TaskOutputPackagingTarBenchmark extends AbstractTaskOutputPackagingBenchmark { @Param({"tar", "tar.commons", "tar.jtar"}) String packer; @Param({"direct", "buffered"}) String accessor; @Override protected String getPackerName() { return packer; } @Override protected String getAccessorName() { return accessor; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:43:12 UTC 2023 - 1.1K bytes - Viewed (0) -
src/net/http/responsecontroller.go
func NewResponseController(rw ResponseWriter) *ResponseController { return &ResponseController{rw} } type rwUnwrapper interface { Unwrap() ResponseWriter } // Flush flushes buffered data to the client. func (c *ResponseController) Flush() error { rw := c.rw for { switch t := rw.(type) { case interface{ FlushError() error }: return t.FlushError() case Flusher: t.Flush()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/testing/http.go
h.t.Logf("Failed to flush pending writes to client, host=%s: %v", req.Host, err) return } if _, err := io.Copy(sconn, io.LimitReader(brw, int64(brw.Reader.Buffered()))); err != nil { h.t.Logf("Failed to flush buffered reads to server, host=%s: %v", req.Host, err) return } var wg sync.WaitGroup wg.Add(2) go func() { defer wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 20 14:58:46 UTC 2023 - 3.8K bytes - Viewed (0)