Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 276 for buf1 (0.09 sec)

  1. cmd/erasure-encode_test.go

    	"github.com/dustin/go-humanize"
    )
    
    type badDisk struct{ StorageAPI }
    
    func (a badDisk) String() string {
    	return "bad-disk"
    }
    
    func (a badDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	return errFaultyDisk
    }
    
    func (a badDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	return nil, errFaultyDisk
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/batch-expire.go

    	// immediately one last time before we exit this method.
    	xioutil.SafeClose(saverQuitCh)
    
    	// Notify expire jobs final status to the configured endpoint
    	buf, _ := json.Marshal(ri)
    	if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil {
    		batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err))
    	}
    
    	return nil
    }
    
    //msgp:ignore batchExpireJobError
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  3. internal/grid/grid_test.go

    	c := time.After(after)
    	cc := make(chan struct{})
    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api.h

    // If async mode is enabled, this call blocks till all currently pending ops are
    // done.
    TF_CAPI_EXPORT extern void TFE_ContextExportRunMetadata(TFE_Context* ctx,
                                                            TF_Buffer* buf,
                                                            TF_Status* status);
    
    // Some TF ops need a step container to be set to limit the lifetime of some
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 22.8K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    	// Initialize the header.
    	binary.LittleEndian.PutUint16(data[0:2], rebalMetaFmt)
    	binary.LittleEndian.PutUint16(data[2:4], rebalMetaVer)
    
    	buf, err := r.MarshalMsg(data)
    	if err != nil {
    		return err
    	}
    
    	return saveConfigWithOpts(ctx, store, rebalMetaName, buf, opts)
    }
    
    func (r *rebalanceMeta) save(ctx context.Context, store objectIO) error {
    	return r.saveWithOpts(ctx, store, ObjectOptions{})
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

                  sink.writeByte('x'.code)
                }
              } else {
                val buf = ByteArray(if (writeKind == WriteKind.SMALL_BUFFERS) 256 else 64 * 1024)
                Arrays.fill(buf, 'x'.code.toByte())
                var i = 0
                while (i < n) {
                  sink.write(buf, 0, Math.min(buf.size, n - i))
                  i += buf.size
                }
              }
            }
          }
        val response =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  7. cmd/site-replication.go

    	var ver struct {
    		Version int `json:"version"`
    	}
    	err = json.Unmarshal(buf, &ver)
    	if err != nil {
    		return err
    	}
    	if ver.Version != srStateFormatVersion1 {
    		return fmt.Errorf("Unexpected ClusterRepl state version: %d", ver.Version)
    	}
    
    	var sdata srStateData
    	err = json.Unmarshal(buf, &sdata)
    	if err != nil {
    		return err
    	}
    
    	c.Lock()
    	defer c.Unlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  8. internal/s3select/select_test.go

        <RequestProgress>
            <Enabled>FALSE</Enabled>
        </RequestProgress>
    </SelectObjectContentRequest>`),
    			withJSON: `
    {
      "name": "small_pdf1.pdf",
      "lume_id": "9507193e-572d-4f95-bcf1-e9226d96be65",
      "elements": [
        {
          "element_type": "__elem__image",
          "element_id": "859d09c4-7cf1-4a37-9674-3a7de8b56abc",
          "attributes": {
            "__attr__image_dpi": 300,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbTransportImpl.java

             * calls doRecv() after and no one else but the transport thread
             * should call doRecv(). Therefore it is ok to expect that the data
             * in sbuf will be preserved for copying into BUF in doRecv().
             */
    
            return (long) Encdec.dec_uint16le(this.sbuf, 34) & 0xFFFF;
        }
    
    
        @Override
        protected void doSend ( Request request ) throws IOException {
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  10. cmd/object-handlers_test.go

    	}
    
    	var buf bytes.Buffer
    	r, err := obj.GetObjectNInfo(context.Background(), bucketName, testObject, nil, nil, ObjectOptions{})
    	if err != nil {
    		t.Fatalf("Test %s: reading completed file failed: <ERROR> %v", instanceType, err)
    	}
    	if _, err = io.Copy(&buf, r); err != nil {
    		r.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
Back to top