Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,595 for fwrite (2.48 sec)

  1. cmd/site-replication-metrics_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z RStat) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Count"
    	err = en.Append(0x82, 0xa5, 0x43, 0x6f, 0x75, 0x6e, 0x74)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt64(z.Count)
    	if err != nil {
    		err = msgp.WrapError(err, "Count")
    		return
    	}
    	// write "Bytes"
    	err = en.Append(0xa5, 0x42, 0x79, 0x74, 0x65, 0x73)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

        set("b", "b", "b")
    
        // Create an entry that fails to write to the journal during commit.
        val editor = cache.edit("c")!!
        editor.setString(0, "c")
        editor.setString(1, "c")
        filesystem.setFaultyWrite(journalFile, true)
        editor.commit()
    
        // Once the journal has a failure, subsequent writes aren't permitted.
        filesystem.setFaultyWrite(journalFile, false)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 75.7K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/dict/mapping/CharMappingFileTest.java

        }
    
        // Helper method to write content to test file
        private void writeTestFile(String content) throws IOException {
            Writer writer = null;
            try {
                writer = new OutputStreamWriter(new FileOutputStream(testFile), Constants.UTF_8);
                writer.write(content);
                writer.flush();
            } finally {
                CloseableUtil.closeQuietly(writer);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 18.5K bytes
    - Viewed (0)
  4. cmd/last-minute_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z AccElem) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 3
    	// write "Total"
    	err = en.Append(0x83, 0xa5, 0x54, 0x6f, 0x74, 0x61, 0x6c)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt64(z.Total)
    	if err != nil {
    		err = msgp.WrapError(err, "Total")
    		return
    	}
    	// write "Size"
    	err = en.Append(0xa4, 0x53, 0x69, 0x7a, 0x65)
    	if err != nil {
    		return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 17.2K bytes
    - Viewed (0)
  5. api/go1.25.txt

    pkg testing, method (*B) Output() io.Writer #59928
    pkg testing, method (*F) Attr(string, string) #43936
    pkg testing, method (*F) Output() io.Writer #59928
    pkg testing, method (*T) Attr(string, string) #43936
    pkg testing, method (*T) Output() io.Writer #59928
    pkg testing, type TB interface, Attr(string, string) #43936
    pkg testing, type TB interface, Output() io.Writer #59928
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Jun 02 16:09:57 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

        var b1 = length
        if (isClient) {
          b1 = b1 or B1_FLAG_MASK
          sinkBuffer.writeByte(b1)
    
          random.nextBytes(maskKey!!)
          sinkBuffer.write(maskKey)
    
          if (length > 0) {
            val payloadStart = sinkBuffer.size
            sinkBuffer.write(payload)
    
            sinkBuffer.readAndWriteUnsafe(maskCursor!!)
            maskCursor.seek(payloadStart)
            toggleMask(maskCursor, maskKey)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/CharSource.java

        }
    
        @Override
        public long copyTo(CharSink sink) throws IOException {
          checkNotNull(sink);
          Closer closer = Closer.create();
          try {
            Writer writer = closer.register(sink.openStream());
            writer.write((String) seq);
            return seq.length();
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.7K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/CharSource.java

        }
    
        @Override
        public long copyTo(CharSink sink) throws IOException {
          checkNotNull(sink);
          Closer closer = Closer.create();
          try {
            Writer writer = closer.register(sink.openStream());
            writer.write((String) seq);
            return seq.length();
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       *
       * 1. visibility of the writes to these fields to Fire.run:
       *
       * The initial write to delegateRef is made definitely visible via the semantics of
       * addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed,
       * however that is fine since the correctness is based on the atomic state in our base class. The
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

         * Pipe instance although this is not a requirement (e.g. a
         * read-only named pipe would write data to this stream on
         * connection). Reading from this stream may block. Therefore it
         * may be necessary that an addition thread be used to read and
         * write to a Named Pipe.
         * @return the input stream for reading from this pipe
         * @throws IOException if an I/O error occurs
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 8.5K bytes
    - Viewed (0)
Back to top