Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 286 for unlocks (0.07 sec)

  1. tensorflow/c/c_api.cc

          // it.
          status->status = graph::ValidateGraphHasNoCycle(session->graph->graph);
          if (!status->status.ok()) {
            session->graph->mu.unlock();
            return false;
          }
    
          GraphDef graph_def;
          *graph_def.mutable_versions() = graph.versions();
          // Fill graph_def with nodes with ids in the range
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  2. cmd/erasure-coding.go

    		return nil, err
    	}
    	if err = e.encoder().Encode(encoded); err != nil {
    		return nil, err
    	}
    	return encoded, nil
    }
    
    // DecodeDataBlocks decodes the given erasure-coded data.
    // It only decodes the data blocks but does not verify them.
    // It returns an error if the decoding failed.
    func (e *Erasure) DecodeDataBlocks(data [][]byte) error {
    	isZero := 0
    	for _, b := range data {
    		if len(b) == 0 {
    			isZero++
    			break
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

    import java.util.concurrent.Future;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/util/MD4.java

    // This file is currently unlocked (change this line if you lock the file)
    //
    // $Log: MD4.java,v $
    // Revision 1.2  1998/01/05 03:41:19  iang
    // Added references only.
    //
    // Revision 1.1.1.1  1997/11/03 22:36:56  hopwood
    // + Imported to CVS (tagged as 'start').
    //
    // Revision 0.1.0.0  1997/07/14  R. Naffah
    // + original version
    //
    // $Endlog$
    /*
     * Copyright (c) 1997 Systemics Ltd
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9.3K bytes
    - Viewed (0)
  5. cmd/bucket-policy-handlers_test.go

    				if _, ok := err.(BucketExists); !ok {
    					t.Logf("unexpected error: %T: %v", err, err)
    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    	close(start)
    	wg.Wait()
    	if ok != 1 {
    		t.Fatalf("want 1 ok, got %d", ok)
    	}
    	if errs != n-1 {
    		t.Fatalf("want %d errors, got %d", n-1, errs)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    		copy(disks, newDisks)
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    	}
    	getDisk := func(n int) StorageAPI {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		disk := disks[n]
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    		return disk
    	}
    
    	// Remove 4 disks.
    	setDisks(nil, nil, nil, nil)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbFileInputStream.java

         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public int read () throws IOException {
            // need oplocks to cache otherwise use BufferedInputStream
            if ( read(this.tmp, 0, 1) == -1 ) {
                return -1;
            }
            return this.tmp[ 0 ] & 0xFF;
        }
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 08:55:14 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

    import java.util.concurrent.TimeUnit
    import java.util.concurrent.locks.Condition
    import java.util.concurrent.locks.ReentrantLock
    import okhttp3.internal.EMPTY_BYTE_ARRAY
    import okhttp3.internal.EMPTY_HEADERS
    import okhttp3.internal.assertThreadDoesntHoldLock
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.http2.ErrorCode.REFUSED_STREAM
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  9. cmd/utils.go

    // Returns current profile data, returns error if there is no active
    // profiling in progress. Stops an active profile.
    func getProfileData() (map[string][]byte, error) {
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if len(globalProfiler) == 0 {
    		return nil, errors.New("profiler not enabled")
    	}
    
    	dst := make(map[string][]byte, len(globalProfiler))
    	for typ, prof := range globalProfiler {
    		// Stop the profiler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  10. cmd/batch-rotate.go

    	lock := api.NewNSLock(r.Bucket, objInfo.Name)
    	lkctx, err := lock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		return err
    	}
    	ctx = lkctx.Context()
    	defer lock.Unlock(lkctx)
    
    	opts := ObjectOptions{
    		VersionID:        objInfo.VersionID,
    		Versioned:        versioned,
    		VersionSuspended: versionSuspended,
    		NoLock:           true,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top