- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 65 for writelns (0.39 sec)
-
src/runtime/tracetype.go
// Insert the pointer to the type itself. id, _ := t.tab.put(noescape(unsafe.Pointer(&typ)), goarch.PtrSize) return id } // dump writes all previously cached types to trace buffers and // releases all memory and resets state. It must only be called once the caller // can guarantee that there are no more writers to the table. func (t *traceTypeTable) dump(gen uintptr) { w := unsafeTraceExpWriter(gen, nil, traceExperimentAllocFree)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:31:27 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/volume/util/atomic_writer.go
// by the caller. // // The visible files in this volume are symlinks to files in the writer's data // directory. Actual files are stored in a hidden timestamped directory which // is symlinked to by the data directory. The timestamped directory and // data directory symlink are created in the writer's target dir. This scheme // allows the files to be atomically updated by changing the target of the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/metrics-resource.go
rdAwait = float64(diffStats.ReadTicks) / float64(diffStats.ReadIOs) } updateResourceMetrics(driveSubsystem, readsAwait, rdAwait, labels, false) wrAwait := 0.0 if diffStats.WriteIOs > 0 { wrAwait = float64(diffStats.WriteTicks) / float64(diffStats.WriteIOs) } updateResourceMetrics(driveSubsystem, writesAwait, wrAwait, labels, false)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 17 15:15:13 UTC 2024 - 17.2K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
} // write "ra" err = en.Append(0xa2, 0x72, 0x61) if err != nil { return } err = en.WriteInt(z.RetryAttempts) if err != nil { err = msgp.WrapError(err, "RetryAttempts") return } // write "at" err = en.Append(0xa2, 0x61, 0x74) if err != nil { return } err = en.WriteInt(z.Attempts) if err != nil { err = msgp.WrapError(err, "Attempts") return } // write "cmp"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 18.6K bytes - Viewed (0) -
cmd/erasure-object.go
inlineBuffers[i] = bytes.NewBuffer(buf[:0]) defer grid.PutByteBuffer(buf) writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize()) } } n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum) closeBitrotWriters(writers) if erasureErr != nil { return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/IsolatedCodecs.kt
return StringValueSnapshot(value) } } object IntegerValueSnapshotCodec : Codec<IntegerValueSnapshot> { override suspend fun WriteContext.encode(value: IntegerValueSnapshot) { writeInt(value.value) } override suspend fun ReadContext.decode(): IntegerValueSnapshot { val value = readInt() return IntegerValueSnapshot(value) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 23:09:56 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/kube-proxy/app/conntrack.go
// errReadOnlySysFS differently. writable, err := rct.isSysFSWritable(ctx) if err != nil { return err } if !writable { return errReadOnlySysFS } // TODO: generify this and sysctl to a new sysfs.WriteInt() logger.Info("Setting conntrack hashsize", "conntrackHashsize", max/4) return writeIntStringFile("/sys/module/nf_conntrack/parameters/hashsize", max/4) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 5.6K bytes - Viewed (0) -
internal/logger/logrotate.go
opts Options // f is the currently open file used for appends. // Writes to f are only synchronized once Close() is called, // or when files are being rotated. f *os.File pw *xioutil.PipeWriter pr *xioutil.PipeReader } // Write writes p into the current file, rotating if necessary. // Write is non-blocking, if the writer's queue is not full. // Write is blocking otherwise.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/IsolatableSerializerRegistryTest.groovy
and: Isolatable<?>[] newIsolatables = deserialize() then: newIsolatables[0].isolate() == list } def serialize(Isolatable<?>... isolatables) { encoder.writeInt(isolatables.size()) isolatables.each { serializer.writeIsolatable(encoder, it) } encoder.flush() } Isolatable<?>[] deserialize() { def isolatables = []
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 08 14:30:36 UTC 2024 - 11.5K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/TaskNodeCodec.kt
val projectPath = task.project.path val taskName = task.name writeClass(taskType) writeString(projectPath) writeString(taskName) writeLong(task.taskIdentity.uniqueId) writeNullableString(task.reasonTaskIsIncompatibleWithConfigurationCache.orElse(null)) withDebugFrame({ taskType.name }) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 17.2K bytes - Viewed (0)