Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,266 for write1 (2.39 sec)

  1. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. src/compress/flate/huffman_bit_writer.go

    }
    
    // The odd order in which the codegen code sizes are written.
    var codegenOrder = []uint32{16, 17, 18, 0, 8, 7, 9, 6, 10, 5, 11, 4, 12, 3, 13, 2, 14, 1, 15}
    
    type huffmanBitWriter struct {
    	// writer is the underlying writer.
    	// Do not use it directly; use the write method, which ensures
    	// that Write errors are sticky.
    	writer io.Writer
    
    	// Data waiting to be written is bytes[0:nbytes]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 29 22:59:14 UTC 2022
    - 18.4K bytes
    - Viewed (0)
  3. src/net/tcpsock_test.go

    				if err != nil {
    					t.Error(err)
    					return
    				}
    				buf := make([]byte, x)
    				var n int
    				if writev {
    					var n64 int64
    					n64, err = (&Buffers{buf}).WriteTo(c)
    					n = int(n64)
    				} else {
    					n, err = c.Write(buf)
    				}
    				if n != len(buf) || err != nil {
    					t.Errorf("Write(buf) = %d, %v, want %d, nil", n, err, x)
    				}
    				c.Close()
    			}()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  4. src/log/log.go

    }
    
    // SetPrefix sets the output prefix for the standard logger.
    func SetPrefix(prefix string) {
    	std.SetPrefix(prefix)
    }
    
    // Writer returns the output destination for the standard logger.
    func Writer() io.Writer {
    	return std.Writer()
    }
    
    // These functions write to the standard logger.
    
    // Print calls Output to print to the standard logger.
    // Arguments are handled in the manner of [fmt.Print].
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Oct 23 22:56:07 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/protobuf/protobuf.go

    }
    
    // EncodeWithAllocator writes an object to the provided writer.
    // In addition, it allows for providing a memory allocator for efficient memory usage during object serialization.
    func (s *Serializer) EncodeWithAllocator(obj runtime.Object, w io.Writer, memAlloc runtime.MemoryAllocator) error {
    	return s.encode(obj, w, memAlloc)
    }
    
    // Encode serializes the provided object to the given writer.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 23 13:38:23 UTC 2022
    - 17.8K bytes
    - Viewed (0)
  6. src/strings/replace.go

    		r.root.add(oldnew[i], oldnew[i+1], len(oldnew)-i, r)
    	}
    	return r
    }
    
    type appendSliceWriter []byte
    
    // Write writes to the buffer to satisfy io.Writer.
    func (w *appendSliceWriter) Write(p []byte) (int, error) {
    	*w = append(*w, p...)
    	return len(p), nil
    }
    
    // WriteString writes to the buffer without string->[]byte->string allocations.
    func (w *appendSliceWriter) WriteString(s string) (int, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Oct 13 17:10:31 UTC 2023
    - 14.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/io/CharStreams.java

        }
      }
    
      /**
       * Returns a Writer that sends all output to the given {@link Appendable} target. Closing the
       * writer will close the target if it is {@link Closeable}, and flushing the writer will flush the
       * target if it is {@link java.io.Flushable}.
       *
       * @param target the object to which output will be sent
       * @return a new Writer object, unless target is a Writer, in which case the target is returned
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  8. src/compress/flate/deflate_test.go

    	}
    
    	if err := zw.Close(); err != nil {
    		t.Fatalf("Close: %v", err)
    	}
    
    	afterClose := b.Len()
    
    	if c, err := zw.Write([]byte("Test")); err == nil || c != 0 {
    		t.Fatalf("Write to closed writer: %v, %d", err, c)
    	}
    
    	if err := zw.Flush(); err == nil {
    		t.Fatalf("Flush to closed writer: %s", err)
    	}
    
    	if err := zw.Close(); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/io/CharStreams.java

        }
      }
    
      /**
       * Returns a Writer that sends all output to the given {@link Appendable} target. Closing the
       * writer will close the target if it is {@link Closeable}, and flushing the writer will flush the
       * target if it is {@link java.io.Flushable}.
       *
       * @param target the object to which output will be sent
       * @return a new Writer object, unless target is a Writer, in which case the target is returned
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  10. internal/ioutil/ioutil.go

    			// we have written the entire stream, return right here.
    			return written, nil
    		}
    
    		if eof {
    			// We reached EOF prematurely but we did not write everything
    			// that we promised that we would write.
    			if totalSize > 0 && written != totalSize {
    				return written, io.ErrUnexpectedEOF
    			}
    			return written, nil
    		}
    	}
    }
    
    // SafeClose safely closes any channel of any type
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top