- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 71 for Justen (0.27 sec)
-
internal/http/check_port_others.go
// Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{} ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/install/install_test.go
} // Copy a valid config file into tempDir if err := file.AtomicCopy(filepath.Join("testdata", c.validConfigFilename), tempDir, c.cniConfigFilename); err != nil { t.Fatal(err) } // Listen for isReady to be set to true ticker := time.NewTicker(500 * time.Millisecond) defer ticker.Stop() readyChan := make(chan bool) go func(ctx context.Context, tick <-chan time.Time) { for {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
cmd/perf-tests.go
package cmd import ( "context" "encoding/gob" "errors" "fmt" "io" "math/rand" "net/http" "net/url" "sync" "sync/atomic" "time" "github.com/dustin/go-humanize" "github.com/minio/madmin-go/v3" "github.com/minio/minio-go/v7" xhttp "github.com/minio/minio/internal/http" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/pkg/v2/randreader" )
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/server-main.go
}) } // Return the list of address that MinIO server needs to listen on: // - Returning 127.0.0.1 is necessary so Console will be able to send // requests to the local S3 API. // - The returned List needs to be deduplicated as well. func getServerListenAddrs() []string { // Use a string set to avoid duplication addrs := set.NewStringSet() // Listen on local interface to receive requests from Console
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1) -
cmd/erasure-metadata_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "strconv" "testing" "time" "github.com/dustin/go-humanize" ) const ActualSize = 1000 // Test FileInfo.AddObjectPart() func TestAddObjectPart(t *testing.T) { testCases := []struct { partNum int expectedIndex int }{ {1, 0},
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/batch-job-common-types.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "strings" "time" "github.com/dustin/go-humanize" "github.com/minio/pkg/v2/wildcard" "gopkg.in/yaml.v3" ) //go:generate msgp -file $GOFILE //msgp:ignore BatchJobYamlErr // BatchJobYamlErr can be used to return yaml validation errors with line,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 01 21:53:26 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/generic-handlers.go
package cmd import ( "fmt" "net" "net/http" "path" "path/filepath" "runtime/debug" "strings" "sync/atomic" "time" "github.com/dustin/go-humanize" "github.com/minio/minio-go/v7/pkg/s3utils" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/grid" xnet "github.com/minio/pkg/v2/net" "golang.org/x/exp/maps"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
internal/ioutil/ioutil.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
cmd/global-heal.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "math/rand" "runtime" "sort" "time" "github.com/dustin/go-humanize" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/bucket/lifecycle" objectlock "github.com/minio/minio/internal/bucket/object/lock" "github.com/minio/minio/internal/bucket/replication"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
internal/deadlineconn/deadlineconn_test.go
"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() serverAddr := l.Addr().String() tcpListener, ok := l.(*net.TCPListener) if !ok {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0)