Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 815 for fslock (0.15 sec)

  1. src/cmd/vet/testdata/print/print.go

    	var x float64
    	var p *int
    	var imap map[int]int
    	var fslice []float64
    	var c complex64
    	// Some good format/argtypes
    	fmt.Printf("")
    	fmt.Printf("%b %b %b", 3, i, x)
    	fmt.Printf("%c %c %c %c", 3, i, 'x', r)
    	fmt.Printf("%d %d %d", 3, i, imap)
    	fmt.Printf("%e %e %e %e", 3e9, x, fslice, c)
    	fmt.Printf("%E %E %E %E", 3e9, x, fslice, c)
    	fmt.Printf("%f %f %f %f", 3e9, x, fslice, c)
    	fmt.Printf("%F %F %F %F", 3e9, x, fslice, c)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 09 01:28:01 UTC 2023
    - 27.5K bytes
    - Viewed (0)
  2. internal/lock/lock_nix.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lock
    
    import (
    	"os"
    	"syscall"
    )
    
    // Internal function implements support for both
    // blocking and non blocking lock type.
    func lockedOpenFile(path string, flag int, perm os.FileMode, lockType int) (*LockedFile, error) {
    	switch flag {
    	case syscall.O_RDONLY:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  3. src/syscall/zerrors_aix_ppc64.go

    	F_SETLKW                      = 0xd
    	F_SETLKW64                    = 0xd
    	F_SETOWN                      = 0x9
    	F_TEST                        = 0x3
    	F_TLOCK                       = 0x2
    	F_TSTLK                       = 0xf
    	F_ULOCK                       = 0x0
    	F_UNLCK                       = 0x3
    	F_WRLCK                       = 0x2
    	HUPCL                         = 0x400
    	ICANON                        = 0x2
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 16:18:12 UTC 2019
    - 47.2K bytes
    - Viewed (0)
  4. pkg/util/iptables/iptables_linux.go

    			return false, nil
    		}
    		return true, nil
    	}); err != nil {
    		return nil, fmt.Errorf("failed to acquire old iptables lock: %v", err)
    	}
    
    	success = true
    	return l, nil
    }
    
    func grabIptablesFileLock(f *os.File) error {
    	return unix.Flock(int(f.Fd()), unix.LOCK_EX|unix.LOCK_NB)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  5. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ProducerGuard.java

            private final Striped<Lock> locks = Striped.lock(Runtime.getRuntime().availableProcessors() * 4);
    
            @Override
            public <V> V guardByKey(T key, Supplier<V> supplier) {
                Lock lock = locks.get(key);
                lock.lock();
                try {
                    return supplier.get();
                } finally {
                    lock.unlock();
                }
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 26 16:02:31 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  6. src/syscall/zerrors_linux_386.go

    	F_SETPIPE_SZ                     = 0x407
    	F_SETSIG                         = 0xa
    	F_SHLCK                          = 0x8
    	F_TEST                           = 0x3
    	F_TLOCK                          = 0x2
    	F_ULOCK                          = 0x0
    	F_UNLCK                          = 0x2
    	F_WRLCK                          = 0x1
    	ICMPV6_FILTER                    = 0x1
    	IFA_F_DADFAILED                  = 0x8
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 19 16:12:50 UTC 2022
    - 57.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/watch/mux.go

    // won't ever see that event, and will always see any event after they are
    // added.
    func (m *Broadcaster) blockQueue(f func()) {
    	m.incomingBlock.Lock()
    	defer m.incomingBlock.Unlock()
    	select {
    	case <-m.stopped:
    		return
    	default:
    	}
    	var wg sync.WaitGroup
    	wg.Add(1)
    	m.incoming <- Event{
    		Type: internalRunFunctionMarker,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 16 15:26:36 UTC 2022
    - 9.4K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    		if err != nil {
    			errResp(err)
    			return
    		}
    	}
    
    	nsLock := objectAPI.NewNSLock(minioMetaBucket, "health-check-in-progress")
    	lkctx, err := nsLock.GetLock(ctx, newDynamicTimeout(deadline, deadline))
    	if err != nil { // returns a locked lock
    		errResp(err)
    		return
    	}
    
    	defer nsLock.Unlock(lkctx)
    	healthCtx, healthCancel := context.WithTimeout(lkctx.Context(), deadline)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  9. cmd/bucket-object-lock.go

    					return ObjectLocked{}
    				}
    
    				if !ret.RetainUntilDate.Before(t) {
    					return ObjectLocked{}
    				}
    				return nil
    			}
    			// https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lock-overview.html#object-lock-retention-modes
    			// If you try to delete objects protected by governance mode and have s3:BypassGovernanceRetention, the operation will succeed.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  10. cmd/lock-rest-client.go

    		err = errLockNotInitialized
    	default:
    		err = errors.New(r.Err)
    	}
    	return ok, err
    }
    
    // RLock calls read lock REST API.
    func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRLock, &args)
    }
    
    // Lock calls lock REST API.
    func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCLock, &args)
    }
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Nov 24 17:07:14 UTC 2023
    - 3.3K bytes
    - Viewed (0)
Back to top