- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,081 for readArg (0.21 sec)
-
tensorflow/c/checkpoint_reader.cc
} else { reader_.reset(new TensorSliceReader(filename)); if (!reader_->status().ok()) { tsl::Set_TF_Status_from_Status(status, reader_->status()); return; } var_to_shape_map_.reset( new TensorSliceReader::VarToShapeMap(reader_->GetVariableToShapeMap())); var_to_data_type_map_.reset(new TensorSliceReader::VarToDataTypeMap( reader_->GetVariableToDataTypeMap())); } }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Aug 25 21:29:12 UTC 2023 - 5.5K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
fmt.Println(args...) } } // Inject random reader/writer sleeps. const maxSleep = int(1 * time.Millisecond) doSleep := !testing.Short() rb := New(4 << 10).SetBlocking(true) // Reader var readErr error var wg sync.WaitGroup wg.Add(1) go func() { readRng := rand.New(rand.NewSource(1)) defer wg.Done() defer rb.CloseWithError(readErr) buf := make([]byte, 1024) for { // Read
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/junit/result/TestOutputStoreBackedResultsProvider.java
Thread thread = Thread.currentThread(); TestOutputStore.Reader reader = readers.get(thread); if (reader == null) { reader = outputStore.reader(); readers.put(thread, reader); } return reader; } @Override public void close() throws IOException { CompositeStoppable.stoppable(readers.values()).stop(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 1.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/resolver/MavenChainedWorkspaceReader.java
protected List<WorkspaceReader> readers; protected WorkspaceRepository repository; /** * Creates a new workspace reader by chaining the specified readers. * * @param readers The readers to chain must not be {@code null}. */ public MavenChainedWorkspaceReader(WorkspaceReader... readers) { setReaders(Arrays.asList(readers)); } @Override
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 5.6K bytes - Viewed (0) -
src/mime/multipart/multipart.go
// For example, "foo-bar" changes case to "Foo-Bar" Header textproto.MIMEHeader mr *Reader disposition string dispositionParams map[string]string // r is either a reader directly reading from mr, or it's a // wrapper around such a reader, decoding the // Content-Transfer-Encoding r io.Reader n int // known data bytes waiting in mr.bufReader total int64 // total data bytes read already
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 14.1K bytes - Viewed (0) -
src/sync/rwmutex.go
w Mutex // held if there are pending writers writerSem uint32 // semaphore for writers to wait for completing readers readerSem uint32 // semaphore for readers to wait for completing writers readerCount atomic.Int32 // number of pending readers readerWait atomic.Int32 // number of departing readers } const rwmutexMaxReaders = 1 << 30 // Happens-before relationships are indicated to the race detector via:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/encoding/csv/reader.go
} // A Reader reads records from a CSV-encoded file. // // As returned by [NewReader], a Reader expects input conforming to RFC 4180. // The exported fields can be changed to customize the details before the // first call to [Reader.Read] or [Reader.ReadAll]. // // The Reader converts all \r\n sequences in its input to plain \n,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:32:28 UTC 2024 - 14.2K bytes - Viewed (0) -
src/image/gif/reader.go
func (b *blockReader) close() error { if b.err == io.EOF { // A clean block-sequence terminator was encountered while reading. return nil } else if b.err != nil { // Some other error was encountered while reading. return b.err } if b.i == b.j { // We reached the end of a sub block reading LZW data. We'll allow at // most one more sub block of data with a length of 1 byte. b.fill() if b.err == io.EOF {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 16:15:54 UTC 2024 - 17.5K bytes - Viewed (0) -
src/internal/trace/reader.go
"internal/trace/event/go122" "internal/trace/internal/oldtrace" "internal/trace/version" ) // Reader reads a byte stream, validates it, and produces trace events. type Reader struct { r *bufio.Reader lastTs Time gen *generation spill *spilledBatch spillErr error // error from reading spill frontier []*batchCursor cpuSamples []cpuSample order ordering emittedSync bool
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0) -
src/testing/iotest/reader.go
// Package iotest implements Readers and Writers useful mainly for testing. package iotest import ( "bytes" "errors" "fmt" "io" ) // OneByteReader returns a Reader that implements // each non-empty Read by reading one byte from r. func OneByteReader(r io.Reader) io.Reader { return &oneByteReader{r} } type oneByteReader struct { r io.Reader }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:47 UTC 2023 - 8K bytes - Viewed (0)