Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 529 for writers (0.09 sec)

  1. cmd/naughty-disk_test.go

    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.DeleteVol(ctx, volume, forceDelete)
    }
    
    func (d *naughtyDisk) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.WalkDir(ctx, opts, wr)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. cmd/notification.go

    // DownloadProfilingData - download profiling data from all remote peers.
    func (sys *NotificationSys) DownloadProfilingData(ctx context.Context, writer io.Writer) (profilingDataFound bool) {
    	// Initialize a zip writer which will provide a zipped content
    	// of profiling data of all nodes
    	zipWriter := zip.NewWriter(writer)
    	defer zipWriter.Close()
    
    	// Start by embedding cluster info.
    	if b := getClusterMetaInfo(ctx); len(b) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. cmd/data-usage-cache_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *dataUsageCache) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Info"
    	err = en.Append(0x82, 0xa4, 0x49, 0x6e, 0x66, 0x6f)
    	if err != nil {
    		return
    	}
    	err = z.Info.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "Info")
    		return
    	}
    	// write "Cache"
    	err = en.Append(0xa5, 0x43, 0x61, 0x63, 0x68, 0x65)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
        // synchronized block, so we can iterate the list without the lock held here.
        RunnableExecutorPair reversedList = null;
        while (list != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. docs/de/docs/advanced/middleware.md

    * <a href="https://github.com/florimondmanca/msgpack-asgi" class="external-link" target="_blank">MessagePack</a>
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.io.OutputStream;
    import java.io.PrintStream;
    import java.io.PrintWriter;
    import java.io.Reader;
    import java.io.Serializable;
    import java.io.StringReader;
    import java.io.StringWriter;
    import java.io.Writer;
    import java.lang.reflect.AnnotatedElement;
    import java.lang.reflect.Array;
    import java.lang.reflect.Constructor;
    import java.lang.reflect.Field;
    import java.lang.reflect.GenericDeclaration;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  7. docs/de/docs/advanced/templates.md

    {!../../docs_src/templates/static/styles.css!}
    ```
    
    Und da Sie `StaticFiles` verwenden, wird diese CSS-Datei automatisch von Ihrer **FastAPI**-Anwendung unter der URL `/static/styles.css` bereitgestellt.
    
    ## Mehr Details
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    				// concurrently, check for it before we
    				// write the filler byte.
    				select {
    				case err := <-doneCh:
    					if err != nil {
    						write([]byte{1})
    						write([]byte(err.Error()))
    					} else {
    						write([]byte{0})
    					}
    					return
    				default:
    				}
    
    				// Response not ready, write a filler byte.
    				write([]byte{32})
    				if canWrite {
    					w.(http.Flusher).Flush()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  9. api/go1.12.txt

    pkg go/token, method (*File) LineStart(int) Pos
    pkg io, type StringWriter interface { WriteString }
    pkg io, type StringWriter interface, WriteString(string) (int, error)
    pkg log, method (*Logger) Writer() io.Writer
    pkg math/bits, func Add(uint, uint, uint) (uint, uint)
    pkg math/bits, func Add32(uint32, uint32, uint32) (uint32, uint32)
    pkg math/bits, func Add64(uint64, uint64, uint64) (uint64, uint64)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jan 02 21:21:53 UTC 2019
    - 13.5K bytes
    - Viewed (0)
  10. internal/kms/context.go

    // provided when decrypting an encrypted DEK.
    type Context map[string]string
    
    // MarshalText returns a canonical text representation of
    // the Context.
    
    // MarshalText sorts the context keys and writes the sorted
    // key-value pairs as canonical JSON object. The sort order
    // is based on the un-escaped keys. It never returns an error.
    func (c Context) MarshalText() ([]byte, error) {
    	if len(c) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 6K bytes
    - Viewed (0)
Back to top