Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,609 for writeLn (0.07 sec)

  1. android/guava/src/com/google/common/io/ByteArrayDataOutput.java

      @Override
      void write(int b);
    
      @Override
      void write(byte b[]);
    
      @Override
      void write(byte b[], int off, int len);
    
      @Override
      void writeBoolean(boolean v);
    
      @Override
      void writeByte(int v);
    
      @Override
      void writeShort(int v);
    
      @Override
      void writeChar(int v);
    
      @Override
      void writeInt(int v);
    
      @Override
      void writeLong(long v);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. 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
    }
    
    func (l *localLocker) stats() lockStats {
    	l.mutex.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          writerToClose = this.writer
          this.writer = null
    
          streamsToClose =
            when {
              writerToClose != null && reader == null -> this.streams
              else -> null
            }
    
          if (!isWriter && writerToClose != null) {
            // If the caller isn't the writer thread, get that thread to close the writer.
            taskQueue.execute("$name writer close", cancelable = false) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

      fun fromDer(byteString: ByteString): T {
        val buffer = Buffer().write(byteString)
        val reader = DerReader(buffer)
        return fromDer(reader)
      }
    
      /**
       * Writes [value] to this adapter, unless it is the default value and can be safely omitted.
       *
       * If this does write a value, it will write a tag and a length and a full value.
       */
      fun toDer(
        writer: DerWriter,
        value: T,
      )
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. internal/lsync/lrwmutex_test.go

    	lrwm := NewLRWMutex()
    
    	// fmt.Println("Getting initial write lock")
    	if !lrwm.GetLock(ctx, "", "", time.Second) {
    		panic("Failed to acquire initial write lock")
    	}
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.Unlock()
    		// fmt.Println("Initial write lock released, waiting...")
    	}()
    
    	// fmt.Println("Trying to acquire 2nd write lock, waiting...")
    	locked = lrwm.GetLock(ctx, "", "", duration)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  6. 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 Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  7. doc/go_mem.html

    <p>
    Note that if there are no read-write or write-write data races on memory location <i>x</i>,
    then any read <i>r</i> on <i>x</i> has only one possible <i>W</i>(<i>r</i>):
    the single <i>w</i> that immediately precedes it in the happens before order.
    </p>
    
    <p>
    More generally, it can be shown that any Go program that is data-race-free,
    meaning it has no program executions with read-write or write-write data races,
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  8. src/archive/tar/testdata/writer-big-long.tar

    Joe Tsai <******@****.***> 1503105518 -0700
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 23 22:38:45 UTC 2017
    - 1.5K bytes
    - Viewed (0)
  9. src/archive/zip/writer_test.go

    	dw, err := w.Create("dir/")
    	if err != nil {
    		t.Fatal(err)
    	}
    	if _, err := dw.Write(nil); err != nil {
    		t.Errorf("Write(nil) to directory: got %v, want nil", err)
    	}
    	if _, err := dw.Write([]byte("hello")); err == nil {
    		t.Error(`Write("hello") to directory: got nil error, want non-nil`)
    	}
    }
    
    func TestWriterDirAttributes(t *testing.T) {
    	var buf bytes.Buffer
    	w := NewWriter(&buf)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top