Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 1,425 for Func (0.02 sec)

  1. cmd/os_other.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"io"
    	"os"
    	"syscall"
    )
    
    func access(name string) error {
    	_, err := os.Lstat(name)
    	return err
    }
    
    func osMkdirAll(dirPath string, perm os.FileMode, _ string) error {
    	// baseDir is not honored in plan9 and solaris platforms.
    	return os.MkdirAll(dirPath, perm)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 13 15:14:36 UTC 2023
    - 4K bytes
    - Viewed (0)
  2. internal/disk/directio_unix.go

    const ODirectPlatform = true
    
    // OpenFileDirectIO - bypass kernel cache.
    func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) {
    	return directio.OpenFile(filePath, flag, perm)
    }
    
    // DisableDirectIO - disables directio mode.
    func DisableDirectIO(f *os.File) error {
    	fd := f.Fd()
    	flag, err := unix.FcntlInt(fd, unix.F_GETFL, 0)
    	if err != nil {
    		return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 17 14:31:36 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  3. istioctl/pkg/analyze/analyze_test.go

    import (
    	"strings"
    	"testing"
    
    	. "github.com/onsi/gomega"
    
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/istioctl/pkg/util/testutil"
    	"istio.io/istio/pkg/config/analysis/diag"
    )
    
    func TestErrorOnIssuesFound(t *testing.T) {
    	g := NewWithT(t)
    
    	msgs := []diag.Message{
    		diag.NewMessage(
    			diag.NewMessageType(diag.Error, "B1", "Template: %q"),
    			nil,
    			"",
    		),
    		diag.NewMessage(
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  4. cmd/http-stats.go

    }
    
    // Increase internode total input bytes
    func (s *connStats) incInternodeInputBytes(n int64) {
    	atomic.AddUint64(&s.internodeInputBytes, uint64(n))
    }
    
    // Increase internode total output bytes
    func (s *connStats) incInternodeOutputBytes(n int64) {
    	atomic.AddUint64(&s.internodeOutputBytes, uint64(n))
    }
    
    // Return internode total input bytes
    func (s *connStats) getInternodeInputBytes() uint64 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. tests/transaction_test.go

    		t.Fatalf("Transaction should get error when using cancelled context")
    	}
    }
    
    func TestTransactionWithBlock(t *testing.T) {
    	assertPanic := func(f func()) {
    		defer func() {
    			if r := recover(); r == nil {
    				t.Fatalf("The code did not panic")
    			}
    		}()
    		f()
    	}
    
    	// rollback
    	err := DB.Transaction(func(tx *gorm.DB) error {
    		user := *GetUser("transaction-block", Config{})
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. cmd/batch-replicate.go

    // Validate validates if the replicate resource type is recognized and supported
    func (t BatchJobReplicateResourceType) Validate() error {
    	switch t {
    	case BatchJobReplicateResourceMinIO:
    	case BatchJobReplicateResourceS3:
    	default:
    		return errInvalidArgument
    	}
    	return nil
    }
    
    func (t BatchJobReplicateResourceType) isMinio() bool {
    	return t == BatchJobReplicateResourceMinIO
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. internal/ringbuffer/ring_buffer_benchmark_test.go

    	buf := make([]byte, 512)
    
    	go func() {
    		for {
    			rb.Read(buf)
    		}
    	}()
    
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		rb.Write(data)
    	}
    }
    
    func BenchmarkRingBuffer_AsyncReadBlocking(b *testing.B) {
    	const sz = 512
    	const buffers = 10
    	rb := New(sz * buffers)
    	rb.SetBlocking(true)
    	data := []byte(strings.Repeat("a", sz))
    	buf := make([]byte, sz)
    
    	go func() {
    		for {
    			rb.Read(buf)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2_gen.go

    func (z ErasureAlgo) Msgsize() (s int) {
    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *VersionType) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = VersionType(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  9. internal/s3select/sql/errors.go

    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errInvalidDataType(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  10. cmd/erasure-decode.go

    		stashBuffer:   b,
    	}
    }
    
    // Done will release any resources used by the parallelReader.
    func (p *parallelReader) Done() {
    	if p.stashBuffer != nil {
    		globalBytePoolCap.Load().Put(p.stashBuffer)
    		p.stashBuffer = nil
    	}
    }
    
    // preferReaders can mark readers as preferred.
    // These will be chosen before others.
    func (p *parallelReader) preferReaders(prefer []bool) {
    	if len(prefer) != len(p.orgReaders) {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
Back to top