- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for mask (0.84 sec)
-
internal/pubsub/mask.go
"math" "math/bits" ) // Mask allows filtering by a bitset mask. type Mask uint64 const ( // MaskAll is the mask for all entries. MaskAll Mask = math.MaxUint64 ) // MaskFromMaskable extracts mask from an interface. func MaskFromMaskable(m Maskable) Mask { return Mask(m.Mask()) } // Contains returns whether *all* flags in other is present in t. func (t Mask) Contains(other Mask) bool { return t&other == other
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jul 05 21:45:49 GMT 2022 - 1.3K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
} pattern := event.NewPattern(prefix, suffix) var eventNames []event.Name var mask pubsub.Mask for _, s := range values[peerRESTListenEvents] { eventName, err := event.ParseName(s) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } mask.MergeMaskable(eventName) eventNames = append(eventNames, eventName) } if bucketName != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/xl-storage_unix_test.go
"path" "syscall" "testing" ) // Based on `man getumask` a vaporware GNU extension to glibc. // returns file mode creation mask. func getUmask() int { mask := syscall.Umask(0) syscall.Umask(mask) return mask } // Tests if the directory and file creations happen with proper umask. func TestIsValidUmaskVol(t *testing.T) { tmpPath := t.TempDir() testCases := []struct { volName string expectedUmask int
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 3.4K bytes - Viewed (0) -
internal/event/event.go
S3 Metadata `json:"s3"` Source Source `json:"source"` Type madmin.TraceType `json:"-"` } // Mask returns the type as mask. func (e Event) Mask() uint64 { return e.EventName.Mask() } // Log represents event information for some event targets. type Log struct { EventName Name Key string Records []Event
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 3.4K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
ch3 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh) // Mask matches maskString, should get result if err := ps.Subscribe(Mask(1), ch1, doneCh, func(entry Maskable) bool { return true }); err != nil { t.Fatalf("unexpected error: %v", err) } // Mask matches maskString, should get result if err := ps.Subscribe(Mask(1|2), ch2, doneCh, func(entry Maskable) bool { return true }); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/pubsub/pubsub.go
sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter} ps.subs = append(ps.subs, sub) // We hold a lock, so we are safe to update combined := Mask(atomic.LoadUint64(&ps.types)) combined.Merge(Mask(mask.Mask())) atomic.StoreUint64(&ps.types, uint64(combined)) go func() { <-doneCh ps.Lock() defer ps.Unlock() var remainTypes Mask for i, s := range ps.subs { if s == sub {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
internal/once/init.go
return l.do(f) } return nil } func (l *Init) do(f func() error) error { l.m.Lock() defer l.m.Unlock() if atomic.LoadUint32(&l.done) == 0 { if err := f(); err != nil { return err } // Mark as done only when f() is successful atomic.StoreUint32(&l.done, 1) } return nil } // DoWithContext is similar to Do except that it accepts a context as an argument to be passed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 04:20:31 GMT 2023 - 2.1K bytes - Viewed (0) -
cmd/peer-rest-common.go
peerRESTReleaseInfo = "releaseinfo" peerRESTListenBucket = "bucket" peerRESTListenPrefix = "prefix" peerRESTListenSuffix = "suffix" peerRESTListenEvents = "events" peerRESTLogMask = "log-mask"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 2.7K bytes - Viewed (0) -
docs/ftp/README.md
| append | no | | rename | no | MinIO supports following FTP/SFTP based protocols to access and manage data. - Secure File Transfer Protocol (SFTP) – Defined by the Internet Engineering Task Force (IETF) as an extended version of SSH 2.0, allowing file transfer over SSH and for use with Transport Layer Security (TLS) and VPN applications.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:15:45 GMT 2024 - 7.1K bytes - Viewed (0) -
cmd/os_unix.go
// Forked from Golang but chooses to avoid performing lookup // // osMkdirAll creates a directory named path, // along with any necessary parents, and returns nil, // or else returns an error. // The permission bits perm (before umask) are used for all // directories that MkdirAll creates. // If path is already a directory, MkdirAll does nothing // and returns nil. func osMkdirAll(dirPath string, perm os.FileMode, baseDir string) error { if baseDir != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0)