Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,848 for Pwrite (0.17 sec)

  1. api/go1.16.txt

    pkg log/syslog (darwin-arm64), method (*Writer) Emerg(string) error
    pkg log/syslog (darwin-arm64), method (*Writer) Err(string) error
    pkg log/syslog (darwin-arm64), method (*Writer) Info(string) error
    pkg log/syslog (darwin-arm64), method (*Writer) Notice(string) error
    pkg log/syslog (darwin-arm64), method (*Writer) Warning(string) error
    pkg log/syslog (darwin-arm64), method (*Writer) Write([]uint8) (int, error)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Dec 02 16:30:41 UTC 2022
    - 479.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java

                    try {
                        writer.write(s);
                        writer.write('\n');
                    } catch (final IOException e) {
                        throw new IORuntimeException(e);
                    }
                });
            } catch (final Exception e) {
                logger.warn("Failed to write thread dump: file={}", file, e);
            }
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  3. internal/ringbuffer/README.md

    Regular Reads will block until data is available, but not wait for a full buffer. 
    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()`
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SmbCopyUtilTest.java

                // Act: submit a write
                w.write(payload, 3, out);
            }
    
            // Assert: verify the underlying stream was called
            verify(out, timeout(1000)).write(payload, 0, 3);
    
            // Stop the thread by sending n = -1
            synchronized (w) {
                w.write(new byte[0], -1, out);
            }
    
            w.join(2000);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer.go

    	r.isFull = false
    	return b, r.readErr(true)
    }
    
    // Write writes len(p) bytes from p to the underlying buf.
    // It returns the number of bytes written from p (0 <= n <= len(p))
    // and any error encountered that caused the write to stop early.
    // If blocking n < len(p) will be returned only if an error occurred.
    // Write returns a non-nil error if it returns n < len(p).
    // Write will not modify the slice data, even temporarily.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  6. internal/s3select/message.go

    				if !writer.write(newStatsMessage(writer.finBytesScanned, writer.finBytesProcessed, bytesReturned)) {
    					break
    				}
    				writer.write(endMessage)
    			} else {
    				for payload.Len() > 0 {
    					copiedLen := copy(writer.payloadBuffer[writer.payloadBufferIndex:], payload.Bytes())
    					writer.payloadBufferIndex += copiedLen
    					payload.Next(copiedLen)
    
    					// If buffer is filled, flush it now!
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/CharSink.java

       * @since 15.0 (in 14.0 with return type {@link BufferedWriter})
       */
      public Writer openBufferedStream() throws IOException {
        Writer writer = openStream();
        return (writer instanceof BufferedWriter)
            ? (BufferedWriter) writer
            : new BufferedWriter(writer);
      }
    
      /**
       * Writes the given character sequence to this sink.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 16:07:06 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  8. src/archive/zip/zip_test.go

    	}
    	for i := 0; i < chunks; i++ {
    		_, err := f.Write(chunk)
    		if err != nil {
    			t.Fatal("write chunk:", err)
    		}
    	}
    	if frag := int(size % chunkSize); frag > 0 {
    		_, err := f.Write(chunk[:frag])
    		if err != nil {
    			t.Fatal("write chunk:", err)
    		}
    	}
    	end := []byte("END\n")
    	_, err = f.Write(end)
    	if err != nil {
    		t.Fatal("write end:", err)
    	}
    	if err := w.Close(); err != nil {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  9. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/ToolchainsWriter.java

     */
    @Deprecated(since = "4.0.0")
    public interface ToolchainsWriter {
    
        /**
         * Writes the supplied toolchains to the specified character writer. The writer will be automatically closed before
         * the method returns.
         *
         * @param output The writer to serialize the toolchains to, must not be {@code null}.
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Mar 05 09:37:42 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  10. cmd/local-locker.go

    		return true, nil
    	}
    	if isWriteLock(lri) {
    		// A write-lock is held, cannot release a read lock
    		return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", resource)
    	}
    	l.removeEntry(resource, args, &lri)
    	return reply, nil
    }
    
    type lockStats struct {
    	Total          int
    	Writes         int
    	Reads          int
    	LockQueue      int
    	LocksAbandoned int
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12K bytes
    - Viewed (0)
Back to top