Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 797 for Blaser (0.19 sec)

  1. cmd/xl-storage_unix_test.go

    		expectedUmask int
    	}{
    		{"is-this-valid", getUmask()},
    	}
    	testCase := testCases[0]
    
    	// Initialize a new xlStorage layer.
    	disk, err := newLocalXLStorage(tmpPath)
    	if err != nil {
    		t.Fatalf("Initializing xlStorage failed with %s.", err)
    	}
    
    	// Attempt to create a volume to verify the permissions later.
    	// MakeVol creates 0777.
    	if err = disk.MakeVol(context.Background(), testCase.volName); err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jul 25 19:37:26 GMT 2022
    - 3.4K bytes
    - Viewed (0)
  2. internal/s3select/progress.go

    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    	}
    	pr.closed = true
    	if pr.closer != nil {
    		pr.closer.Close()
    	}
    	return pr.rc.Close()
    }
    
    func (pr *progressReader) Stats() (bytesScanned, bytesProcessed int64) {
    	if pr == nil {
    		return 0, 0
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Oct 18 15:44:36 GMT 2021
    - 4.2K bytes
    - Viewed (0)
  3. internal/ioutil/ioutil.go

    	w.hasWritten = true
    	return w.Writer.Write(p)
    }
    
    // Close closes the WriteOnCloser. It behaves like io.Closer.
    func (w *WriteOnCloser) Close() error {
    	if !w.hasWritten {
    		_, err := w.Write(nil)
    		if err != nil {
    			return err
    		}
    	}
    	if closer, ok := w.Writer.(io.Closer); ok {
    		return closer.Close()
    	}
    	return nil
    }
    
    // HasWritten returns true if at least one write operation was performed.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  4. cmd/metacache.go

    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    // but WITHOUT ANY WARRANTY; without even the implied warranty of
    // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
  5. cmd/bitrot-streaming.go

    func (b *streamingBitrotReader) Close() error {
    	if b.rc == nil {
    		return nil
    	}
    	if closer, ok := b.rc.(io.Closer); ok {
    		// drain the body for connection reuse at network layer.
    		xhttp.DrainBody(struct {
    			io.Reader
    			io.Closer
    		}{
    			Reader: b.rc,
    			Closer: closeWrapper(func() error { return nil }),
    		})
    		return closer.Close()
    	}
    	return nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  6. cmd/erasure.go

    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    // but WITHOUT ANY WARRANTY; without even the implied warranty of
    // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  7. cmd/bucket-policy-handlers_test.go

    		0, nil, "", "", nil)
    	if err != nil {
    		t.Errorf("MinIO %s: Failed to create HTTP request for testing the response when object Layer is set to `nil`.", instanceType)
    	}
    	// execute the object layer set to `nil` test.
    	// `ExecObjectLayerAPINilTest` manages the operation.
    	ExecObjectLayerAPINilTest(t, nilBucket, "", instanceType, apiRouter, nilReq)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 32.7K bytes
    - Viewed (0)
  8. cmd/callhome.go

    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    // but WITHOUT ANY WARRANTY; without even the implied warranty of
    // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.1K bytes
    - Viewed (1)
  9. cmd/admin-handlers_test.go

    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    // but WITHOUT ANY WARRANTY; without even the implied warranty of
    // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  10. cmd/object-api-interface.go

    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    // but WITHOUT ANY WARRANTY; without even the implied warranty of
    // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
Back to top