- Sort Score
- Num 10 results
- Language All
Results 221 - 230 of 1,653 for make (0.02 seconds)
-
cmd/data-scanner-metric.go
m.CollectedAt = time.Now() m.ActivePaths = p.getCurrentPaths() m.LifeTimeOps = make(map[string]uint64, scannerMetricLast) for i := range scannerMetricLast { if n := atomic.LoadUint64(&p.operations[i]); n > 0 { m.LifeTimeOps[i.String()] = n } } if len(m.LifeTimeOps) == 0 { m.LifeTimeOps = nil } m.LastMinute.Actions = make(map[string]madmin.TimedAction, scannerMetricLastRealtime)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Oct 01 06:06:01 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/s3select/jstream/scanner.go
fillReq chan struct{} fillReady chan int64 readerErr error // underlying reader error, if any } 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) }()Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 2.5K bytes - Click Count (0) -
docs/en/docs/how-to/conditional-openapi.md
Hiding the documentation just makes it more difficult to understand how to interact with your API, and could make it more difficult for you to debug it in production. It could be considered simply a form of [Security through obscurity](https://en.wikipedia.org/wiki/Security_through_obscurity). If you want to secure your API, there are several better things you can do, for example:
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 2.4K bytes - Click Count (0) -
internal/dsync/drwmutex_test.go
} // Borrowed from rwmutex_test.go func doTestParallelReaders(numReaders, gomaxprocs int) { runtime.GOMAXPROCS(gomaxprocs) m := NewDRWMutex(ds, "test-parallel") clocked := make(chan bool) cunlock := make(chan bool) cdone := make(chan bool) for range numReaders { go parallelReader(context.Background(), m, clocked, cunlock, cdone) } // Wait for all parallel RLock()s to succeed. for range numReaders {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.4K bytes - Click Count (0) -
.junit.run/Not Slow.run.xml
<option name="TEST_SEARCH_SCOPE"> <value defaultName="wholeProject" /> </option> <tag value="!Slow & !Slowish & !Remote & !Android" /> <method v="2"> <option name="Make" enabled="true" /> </method> </configuration>
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Nov 21 13:28:45 GMT 2020 - 730 bytes - Click Count (0) -
src/bytes/bytes_js_wasm_test.go
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Wed Jul 17 07:00:20 GMT 2024 - 417 bytes - Click Count (0) -
internal/event/target/amqp.go
target.connMutex.Lock() defer target.connMutex.Unlock() if target.conn != nil { ch, err = target.conn.Channel() if err == nil { if target.args.PublisherConfirms { confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1)) if err := ch.Confirm(false); err != nil { ch.Close() return nil, nil, err } return ch, confirms, nil } return ch, nil, nil }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
internal/http/dial_dnscache.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "context" "net" "time" ) // LookupHost is a function to make custom lookupHost for optional cached DNS requests type LookupHost func(ctx context.Context, host string) (addrs []string, err error) // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.6K bytes - Click Count (0) -
cmd/bucket-policy.go
} // NewPolicySys - creates new policy system. func NewPolicySys() *PolicySys { return &PolicySys{} } func getSTSConditionValues(r *http.Request, lc string, cred auth.Credentials) map[string][]string { m := make(map[string][]string) if d := r.Form.Get("DurationSeconds"); d != "" { m["DurationSeconds"] = []string{d} } return m }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.9K bytes - Click Count (0) -
cmd/handler-utils.go
if contentEncoding != "" { // Make sure to trim and save the content-encoding // parameter for a streaming signature which is set // to a custom value for example: "aws-chunked,gzip". metadata[strings.ToLower(xhttp.ContentEncoding)] = contentEncoding } else { // Trimmed content encoding is empty when the header // value is set to "aws-chunked" only. // Make sure to delete the content-encoding parameterCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.4K bytes - Click Count (1)