- Sort Score
- Result 10 results
- Languages All
Results 941 - 950 of 1,423 for Func (0.02 sec)
-
misc/cgo/gmp/fib.go
// that pass integers back and forth. No actual // concurrency, just threads and synchronization // and foreign code on multiple pthreads. package main import ( big "." "runtime" ) func fibber(c chan *big.Int, out chan string, n int64) { // Keep the fibbers in dedicated operating system // threads, so that this program tests coordination // between pthreads and not just goroutines. runtime.LockOSThread()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Apr 10 22:32:35 UTC 2023 - 919 bytes - Viewed (0) -
cmd/batch-expire.go
) type objInfoCache map[string]*ObjectInfo func newObjInfoCache() objInfoCache { return objInfoCache(make(map[string]*ObjectInfo)) } func (oiCache objInfoCache) Add(toDel ObjectToDelete, oi *ObjectInfo) { oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)] = oi } func (oiCache objInfoCache) Get(toDel ObjectToDelete) (*ObjectInfo, bool) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 21.9K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
r *parquetgo.FileReader } // NewParquetReader creates a Reader2 from a io.ReadSeekCloser. func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) { fr, err := parquetgo.NewFileReader(rsc) if err != nil { return nil, errParquetParsingError(err) } return &Reader{Closer: rsc, r: fr}, nil } func (pr *Reader) Read(dst sql.Record) (rec sql.Record, rerr error) { nextRow, err := pr.r.NextRow()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/update-notifier.go
"github.com/cheggaaa/pb" humanize "github.com/dustin/go-humanize" "github.com/minio/minio/internal/color" ) // prepareUpdateMessage - prepares the update message, only if a // newer version is available. func prepareUpdateMessage(downloadURL string, older time.Duration) string { if downloadURL == "" || older <= 0 { return "" } // Compute friendly duration string to indicate time
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Mar 09 03:07:08 UTC 2024 - 3.6K bytes - Viewed (0) -
internal/bucket/object/lock/lock_test.go
package lock import ( "encoding/xml" "errors" "fmt" "net/http" "reflect" "strings" "testing" "time" xhttp "github.com/minio/minio/internal/http" ) func TestParseMode(t *testing.T) { testCases := []struct { value string expectedMode RetMode }{ { value: "governance", expectedMode: RetGovernance, }, {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 29 01:20:27 UTC 2024 - 17.1K bytes - Viewed (0) -
cmd/api-response_test.go
testCase := testCase t.Run("", func(t *testing.T) { gotLocation := getObjectLocation(testCase.request, testCase.domains, testCase.bucket, testCase.object) if testCase.expectedLocation != gotLocation { t.Errorf("expected %s, got %s", testCase.expectedLocation, gotLocation) } }) } } // Tests getURLScheme function behavior. func TestGetURLScheme(t *testing.T) { tls := false
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 3.5K bytes - Viewed (0) -
cmd/server-main_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "reflect" "testing" ) func TestServerConfigFile(t *testing.T) { for _, testcase := range []struct { config string expectedErr bool hash string }{ { config: "testdata/config/1.yaml", expectedErr: false,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Dec 07 09:33:56 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/metacache-manager.go
trash map[string]metacache // Recently deleted lists. } const metacacheMaxEntries = 5000 // initManager will start async saving the cache. func (m *metacacheManager) initManager() { // Add a transient bucket. // Start saver when object layer is ready. go func() { objAPI := newObjectLayerFn() for objAPI == nil { time.Sleep(time.Second) objAPI = newObjectLayerFn() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0) -
cmd/xl-storage-format-v1_gen.go
"github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BitrotAlgorithm) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint zb0001, err = dc.ReadUint() if err != nil { err = msgp.WrapError(err) return } (*z) = BitrotAlgorithm(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z BitrotAlgorithm) EncodeMsg(en *msgp.Writer) (err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 41.2K bytes - Viewed (0) -
api/next/66626.txt
pkg go/types, method (*Interface) EmbeddedTypes() iter.Seq[Type] #66626 pkg go/types, method (*Interface) ExplicitMethods() iter.Seq[*Func] #66626 pkg go/types, method (*Interface) Methods() iter.Seq[*Func] #66626 pkg go/types, method (*MethodSet) Methods() iter.Seq[*Selection] #66626 pkg go/types, method (*Named) Methods() iter.Seq[*Func] #66626 pkg go/types, method (*Scope) Children() iter.Seq[*Scope] #66626 pkg go/types, method (*Struct) Fields() iter.Seq[*Var] #66626
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Jul 31 22:54:09 UTC 2024 - 743 bytes - Viewed (0)