- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 544 for Oplock (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/ioutil/ioutil.go
"github.com/minio/minio/internal/bpool" "github.com/minio/minio/internal/disk" ) // Block sizes constant. const ( SmallBlock = 32 * humanize.KiByte // Default r/w block size for smaller objects. MediumBlock = 128 * humanize.KiByte // Default r/w block size for medium sized objects. LargeBlock = 1 * humanize.MiByte // Default r/w block size for normal objects. ) // AlignedBytePool is a pool of fixed size aligned blocks
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 11.1K bytes - Click Count (0) -
cmd/metacache-server-pool.go
defer func() { funcReturnedMu.Lock() funcReturned = true funcReturnedMu.Unlock() }() // Write listing to results and saver. go func() { var returned bool for entry := range inCh { if o.shouldSkip(ctx, entry) { continue } if !returned { funcReturnedMu.Lock() returned = funcReturned funcReturnedMu.Unlock() outCh <- entry if returned {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (0) -
src/archive/tar/writer.go
sa.IsExtended()[0] = 1 } return sp } sp2 := formatSPD(spd, blk.GNU().Sparse()) for len(sp2) > 0 { var spHdr block sp2 = formatSPD(sp2, spHdr.Sparse()) spb = append(spb, spHdr[:]...) } // Update size fields in the header block. realSize := hdr.Size hdr.Size = 0 // Encoded size; does not account for encoded sparse map for _, s := range spd { hdr.Size += s.Length
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Feb 03 16:38:43 GMT 2025 - 19.7K bytes - Click Count (0) -
internal/disk/stat_linux.go
// e.g. if the mount is based on /dev/nvme0n1p1, let's calculate the // real device name (nvme0n1) to get its sysfs information parentDevPath, e := os.Readlink("/sys/class/block/" + devName) if e == nil { parentDev := filepath.Base(filepath.Dir(parentDevPath)) qst, err = bfs.SysBlockDeviceQueueStats(parentDev) } } if err == nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHook.java
processDBFluteSystem(); } protected void processDBFluteSystem() { DBFluteSystem.unlock(); DBFluteSystem.setFinalTimeZoneProvider(createFinalTimeZoneProvider()); DBFluteSystem.lock(); } protected DfFinalTimeZoneProvider createFinalTimeZoneProvider() { return new DfFinalTimeZoneProvider() {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 1.9K bytes - Click Count (0) -
cmd/bootstrap-messages.go
func (bs *bootstrapTracer) Record(info madmin.TraceInfo) { bs.mu.Lock() defer bs.mu.Unlock() if len(bs.info) > bootstrapTraceLimit { return } bs.info = append(bs.info, info) } func (bs *bootstrapTracer) Events() []madmin.TraceInfo { traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit) bs.mu.RLock() traceInfo = append(traceInfo, bs.info...) bs.mu.RUnlock() return traceInfo
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 1.7K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
cacheStmt := &Stmt{ Transaction: isTransaction, prepared: make(chan struct{}), } // Cache the Stmt object with the associated key. s.Set(key, cacheStmt) // Unlock after completing initialization to prevent deadlocks. locker.Unlock() // Ensure the prepared channel is closed after the function execution completes. defer close(cacheStmt.prepared) // Prepare the SQL statement using the provided connection.Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 6.1K bytes - Click Count (0) -
internal/config/lambda/target/lazyinit.go
} func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f) } return nil } func (l *lazyInit) doSlow(f func() error) error { l.m.Lock() defer l.m.Unlock() if atomic.LoadUint32(&l.done) == 0 { if err := f(); err != nil { return err } // Mark as done only when f() is successful atomic.StoreUint32(&l.done, 1) } return nil
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.3K bytes - Click Count (0) -
src/main/webapp/WEB-INF/view/common/admin/footer.jsp
<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%> <footer class="main-footer"> <div class="float-right d-none d-sm-inline-block"></div> <la:message key="labels.footer.copyright" />
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Feb 12 20:25:27 GMT 2020 - 213 bytes - Click Count (0) -
.github/workflows/ci.yml
- name: 'Set up JDKs' uses: actions/setup-java@be666c2fcd27ec809703dec50e508c2fdc7f6654 # v5.2.0 with: # For discussion, see the first setup-java block. # The publish-snapshot workflow doesn't run tests, so we don't have to care which version Maven would select for that step. java-version: 25 distribution: 'temurin' cache: 'maven'
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 22:02:44 GMT 2026 - 4.6K bytes - Click Count (0)