- Sort Score
- Result 10 results
- Languages All
Results 611 - 620 of 1,425 for Func (0.02 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)