Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 1,756 for writeFn (0.04 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

         */
        Waiter(boolean unused) {}
    
        Waiter() {
          // avoid volatile write, write is made visible by subsequent CAS on waitersField field
          putThread(this, Thread.currentThread());
        }
    
        // non-volatile write to the next field. Should be made visible by a subsequent CAS on
        // waitersField.
        void setNext(@Nullable Waiter next) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  2. src/cmd/cgo/doc.go

    	-debug-gcc
    		Debugging option. Trace C compiler execution and output.
    	-dynimport file
    		Write list of symbols imported by file. Write to
    		-dynout argument or to standard output. Used by go
    		build when building a cgo package.
    	-dynlinker
    		Write dynamic linker as part of -dynimport output.
    	-dynout file
    		Write -dynimport output to file.
    	-dynpackage package
    		Set Go package for -dynimport output.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Dec 11 23:57:34 UTC 2024
    - 44K bytes
    - Viewed (0)
  3. src/archive/tar/tar_test.go

    	return n, nil
    }
    
    func (f *testFile) Write(b []byte) (int, error) {
    	if len(b) == 0 {
    		return 0, nil
    	}
    	if len(f.ops) == 0 {
    		return 0, errors.New("unexpected Write operation")
    	}
    	s, ok := f.ops[0].(string)
    	if !ok {
    		return 0, errors.New("unexpected Write operation")
    	}
    
    	if !strings.HasPrefix(s, string(b)) {
    		return 0, testError{fmt.Errorf("got Write(%q), want Write(%q)", b, s)}
    	}
    	if len(s) > len(b) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    // tests are adjusted to use GetObjectNInfo this function can be removed.
    func GetObject(ctx context.Context, api ObjectLayer, bucket, object string, startOffset int64, length int64, writer io.Writer, etag string, opts ObjectOptions) (err error) {
    	var header http.Header
    	if etag != "" {
    		header.Set("ETag", etag)
    	}
    	Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/api/admin/elevateword/ApiAdminElevatewordAction.java

                try {
                    try (Writer writer = new BufferedWriter(new OutputStreamWriter(Files.newOutputStream(tempFile), getCsvEncoding()))) {
                        elevateWordService.exportCsv(writer);
                    } catch (final Exception e) {
                        logger.warn("Failed to process a request.", e);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/BaseEncodingTest.java

          throws IOException {
        StringWriter writer = new StringWriter();
        try (OutputStream encodingStream = encoding.encodingStream(writer)) {
          encodingStream.write(decoded.getBytes(UTF_8));
        }
        assertThat(writer.toString()).isEqualTo(encoded);
      }
    
      @GwtIncompatible // Reader
      private static void testStreamingDecodes(BaseEncoding encoding, String encoded, String decoded)
          throws IOException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 24.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt

        delegate: Sink,
        /** The exact number of bytes to be written, or -1L if that is unknown. */
        private val contentLength: Long,
      ) : ForwardingSink(delegate) {
        private var completed = false
        private var bytesReceived = 0L
        private var closed = false
    
        @Throws(IOException::class)
        override fun write(
          source: Buffer,
          byteCount: Long,
        ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb2/info/Smb2QueryInfoRequestTest.java

                byte[] actualFileId = new byte[16];
                System.arraycopy(buffer, 88, actualFileId, 0, 16);
                assertArrayEquals(testFileId, actualFileId);
    
                // Verify total bytes written
                assertEquals(40, bytesWritten);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 22.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/lock/Smb2LeaseBreakNotification.java

            return shareAccessHint;
        }
    
        @Override
        protected int writeBytesWireFormat(byte[] dst, int dstIndex) {
            // Lease break notifications are sent by the server, not written by client
            return 0;
        }
    
        @Override
        protected int readBytesWireFormat(byte[] buffer, int bufferIndex) throws SMBProtocolDecodingException {
            int start = bufferIndex;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  10. docs/en/docs/benchmarks.md

        * So, by using FastAPI you are saving development time, bugs, lines of code, and you would probably get the same performance (or better) you would if you didn't use it (as you would have to implement it all in your code)....
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 3.5K bytes
    - Viewed (0)
Back to top