- Sort Score
- Result 10 results
- Languages All
Results 1121 - 1130 of 1,605 for var1 (0.06 sec)
-
cmd/xl-storage_noatime_supported.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "os" "syscall" ) var ( // Disallow updating access times // Add non-block to avoid syscall to attempt to set epoll on files. readMode = os.O_RDONLY | 0x40000 | syscall.O_NONBLOCK // O_NOATIME
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 16:36:24 UTC 2024 - 1.1K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/backup/admin_backup.jsp
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Wed Feb 12 20:25:27 UTC 2020 - 5.1K bytes - Viewed (0) -
internal/kms/secret-key_test.go
t.Fatalf("Test %d: failed to decrypt key: %v", i, err) } if !bytes.Equal(plaintext, dataKey) { t.Fatalf("Test %d: decrypted key does not generated one: got %x - want %x", i, plaintext, dataKey) } } } var decryptKeyTests = []struct { KeyID string Plaintext string Ciphertext string Context Context }{ { KeyID: "my-key", Plaintext: "zmS7NrG765UZ0ZN85oPjybelxqVvpz01vxsSpOISy2M=",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/config/identity/ldap/ldap.go
// of the configured LDAP base DNs. func (l *Config) GetValidatedGroupDN(conn *ldap.Conn, groupDN string) (*xldap.DNSearchResult, bool, error) { if conn == nil { var err error conn, err = l.LDAP.Connect() if err != nil { return nil, false, err } defer conn.Close() // Bind to the lookup user account if err = l.LDAP.LookupBind(conn); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 01:04:53 UTC 2024 - 12.4K bytes - Viewed (0) -
docs/logging/README.md
"Accept-Ranges": "bytes", "Content-Length": "0", "ETag": "9fe7a344ef4227d3e53751e9d88ce41e", "Server": "MinIO", "Strict-Transport-Security": "max-age=31536000; includeSubDomains", "Vary": "Origin,Accept-Encoding", "X-Amz-Id-2": "dd9025bab4ad464b049177c95eb6ebf374d3b3fd1af9251148b658df7ac2e3e8", "X-Amz-Request-Id": "17CDC1F4D7E69123", "X-Content-Type-Options": "nosniff",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 09 17:15:03 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/metacache-manager.go
) // localMetacacheMgr is the *local* manager for this peer. // It should never be used directly since buckets are // distributed deterministically. // Therefore no cluster locks are required. var localMetacacheMgr = &metacacheManager{ buckets: make(map[string]*bucketMetacache), trash: make(map[string]metacache), } type metacacheManager struct { mu sync.RWMutex init sync.Once
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0) -
internal/disk/stat_linux_32bit.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package disk import ( "errors" "fmt" "strconv" "syscall" ) // fsType2StringMap - list of filesystems supported on linux var fsType2StringMap = map[string]string{ "1021994": "TMPFS", "137d": "EXT", "4244": "HFS", "4d44": "MSDOS", "52654973": "REISERFS", "5346544e": "NTFS", "58465342": "XFS", "61756673": "AUFS",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 2.6K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
} func newScanner(r io.Reader) *scanner { sr := &scanner{ end: maxInt, fillReq: make(chan struct{}), fillReady: make(chan int64), } go func() { var rpos int64 // total bytes read into buffer defer func() { atomic.StoreInt64(&sr.end, rpos) close(sr.fillReady) }() for range sr.fillReq { scan: n, err := r.Read(sr.nbuf[:])
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
) : RealWebSocket.Streams(client, sourcePipe.source.buffer(), sinkPipe.sink.buffer()) { private val name = if (client) "client" else "server" val listener = WebSocketRecorder(name) var webSocket: RealWebSocket? = null var closed = false var canceled = false fun initWebSocket( random: Random?, pingIntervalMillis: Int = 0, responseHeaders: Headers? = headersOf(),
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
cmd/peer-s3-client.go
"fmt" "sort" "strconv" "sync/atomic" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/grid" "github.com/minio/pkg/v3/sync/errgroup" "golang.org/x/exp/slices" ) var errPeerOffline = errors.New("peer is offline") type peerS3Client interface { ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 15.4K bytes - Viewed (0)