- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 66 for Breiding (0.28 sec)
-
docs/sts/ldap.go
if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file: %v", sessionPolicyFile, err) } else { bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } ldapOpts = append(ldapOpts, cr.LDAPIdentityPolicyOpt(policy)) } if expiryDuration != 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 4K bytes - Viewed (0) -
cmd/dummy-data-generator_test.go
n2, e2 := io.ReadFull(r2, b2) if n1 != n2 { return false, fmt.Sprintf("Read %d != %d bytes from the readers", n1, n2) } if !bytes.Equal(b1[:n1], b2[:n2]) { return false, fmt.Sprintf("After reading %d equal buffers (32Kib each), we got the following two strings:\n%v\n%v\n", i, b1, b2) } // Check if stream has ended if (e1 == io.ErrUnexpectedEOF && e2 == io.ErrUnexpectedEOF) || (e1 == io.EOF && e2 == io.EOF) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/logger/target/http/http.go
status int32 // Worker control workers int64 maxWorkers int64 // workerStartMu sync.Mutex lastStarted time.Time wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/s3select/json/preader.go
if cap(dst) < skip { dst = make([]byte, 0, skip+1024) } dst = dst[:skip] if skip > 0 { n, err := io.ReadFull(r.buf, dst) if err != nil && err != io.ErrUnexpectedEOF { // If an EOF happens after reading some but not all the bytes, // ReadFull returns ErrUnexpectedEOF. return dst[:n], err } dst = dst[:n] if err == io.ErrUnexpectedEOF { return dst, io.EOF } } // Read until next line.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
internal/auth/credentials.go
Name string `xml:"-" json:"name,omitempty"` Description string `xml:"-" json:"description,omitempty"` // Deprecated: In favor of Description - when reading credentials from // storage the value of this field is placed in the Description field above // if the existing Description from storage is empty. Comment string `xml:"-" json:"comment,omitempty"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 12:41:13 GMT 2024 - 11.7K bytes - Viewed (0) -
cmd/utils.go
if err != nil { return "", fmt.Errorf("request err: %v", err) } // { // bodyBuf, err := io.ReadAll(resp.Body) // if err != nil { // return "", fmt.Errorf("Error reading body: %v", err) // } // fmt.Printf("bodyBuf (for LDAP login page): %s\n", string(bodyBuf)) // } // Fill the login form with our test creds: // fmt.Printf("login form url: %s\n", lastReq.URL.String())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/xl-storage_test.go
// Buffer size greater than object size. - 6 { volume, "myobject", 0, 16, []byte("hello, world"), io.ErrUnexpectedEOF, }, // Reading from an offset success. - 7 { volume, "myobject", 7, 5, []byte("world"), nil, }, // Reading from an object but buffer size greater. - 8 { volume, "myobject", 7, 8, []byte("world"), io.ErrUnexpectedEOF, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 66.7K bytes - Viewed (0) -
cmd/erasure-decode.go
readerIndex := 0 var wg sync.WaitGroup // if readTrigger is true, it implies next disk.ReadAt() should be tried // if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need // to try reading the next disk. for readTrigger := range readTriggerCh { newBufLK.RLock() canDecode := p.canDecode(newBuf) newBufLK.RUnlock() if canDecode { break } if readerIndex == len(p.readers) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
package deadlineconn import ( "bufio" "io" "net" "sync" "testing" "time" ) // Test deadlineconn handles read timeout properly by reading two messages beyond deadline. func TestBuffConnReadTimeout(t *testing.T) { l, err := net.Listen("tcp", "localhost:0") if err != nil { t.Fatalf("unable to create listener. %v", err) } defer l.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
internal/http/dial_linux.go
// https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/ // This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can // affect clients reading data with a very slow pace (disappropriate with socket buffer sizes) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, opts.UserTimeout) if opts.Interface != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 4.3K bytes - Viewed (3)