Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 502 for Mock (0.05 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

         * as well as to handle state changes in a thread-safe manner. The current state of the future
         * is held in the Sync state, and the lock is released whenever the state changes to {@link
         * #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED}
         *
         * <p>To avoid races between threads doing release and acquire, we transition to the final state
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. cmd/metrics-resource.go

    		}
    		sfx += v
    	}
    
    	return string(name) + "_" + sfx
    }
    
    func updateResourceMetrics(subSys MetricSubsystem, name MetricName, val float64, labels map[string]string, isCumulative bool) {
    	resourceMetricsMapMu.Lock()
    	defer resourceMetricsMapMu.Unlock()
    	subsysMetrics, found := resourceMetricsMap[subSys]
    	if !found {
    		subsysMetrics = ResourceMetrics{}
    	}
    
    	key := getResourceKey(name, labels)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  3. internal/s3select/progress.go

    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    	}
    	pr.closed = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

        private static final String RO = Config.getProperty( "jcifs.smb1.resolveOrder" );
    
        private static LogStream log = LogStream.getInstance();
    
        private final Object LOCK = new Object();
    
        private int lport, closeTimeout;
        private byte[] snd_buf, rcv_buf;
        private DatagramSocket socket;
        private DatagramPacket in, out;
        private HashMap responseTable = new HashMap();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 17.4K bytes
    - Viewed (0)
  5. internal/logger/targets.go

    func (tl *targetsList) get() []Target {
    	tl.mu.RLock()
    	defer tl.mu.RUnlock()
    
    	return tl.list
    }
    
    func (tl *targetsList) add(t Target) {
    	tl.mu.Lock()
    	defer tl.mu.Unlock()
    
    	tl.list = append(tl.list, t)
    }
    
    func (tl *targetsList) set(tgts []Target) {
    	tl.mu.Lock()
    	defer tl.mu.Unlock()
    
    	tl.list = tgts
    }
    
    var (
    
    	// systemTargets is the set of enabled loggers.
    	systemTargets = newTargetsList()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. cmd/metacache-set.go

    	"fmt"
    	"io"
    	"math/rand"
    	"strconv"
    	"strings"
    	"sync"
    	"time"
    
    	jsoniter "github.com/json-iterator/go"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/versioning"
    	"github.com/minio/minio/internal/color"
    	"github.com/minio/minio/internal/hash"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v3/console"
    )
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  7. cmd/bootstrap-messages.go

    type bootstrapTracer struct {
    	mu   sync.RWMutex
    	info []madmin.TraceInfo
    }
    
    var globalBootstrapTracer = &bootstrapTracer{}
    
    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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  8. doc/go_mem.html

    var a string
    
    func f() {
    	a = "hello, world"
    	l.Unlock()
    }
    
    func main() {
    	l.Lock()
    	go f()
    	l.Lock()
    	print(a)
    }
    </pre>
    
    <p>
    is guaranteed to print <code>"hello, world"</code>.
    The first call to <code>l.Unlock()</code> (in <code>f</code>) is synchronized
    before the second call to <code>l.Lock()</code> (in <code>main</code>) returns,
    which is sequenced before the <code>print</code>.
    </p>
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  9. .gitignore

    /src/main/webapp/jar/
    /dbflute_fess/extlib/*
    /dbflute_fess/log/*.log
    /dbflute_h2/log/*.log
    /dbflute_mysql/log/*.log
    /dbflute_oracle/log/*.log
    /src/main/webapp/WEB-INF/conf/*.properties
    /src/main/webapp/WEB-INF/db/*.lock.db
    /src/main/webapp/WEB-INF/logs/fess*
    /.settings/
    .project
    .classpath
    *.iml
    .idea
    .vscode
    .DS_Store
    /plugins/
    /modules/
    /tomcat.8080/
    dbflute_fess/output/doc/lastadoc-fess.html
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Oct 24 01:47:10 UTC 2024
    - 1023 bytes
    - Viewed (0)
  10. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    // Submitted by Zulfais <******@****.***>
    co.bn
    
    // Postman, Inc : https://postman.com
    // Submitted by Rahul Dhawan <******@****.***>
    postman-echo.com
    pstmn.io
    mock.pstmn.io
    httpbin.org
    
    //prequalifyme.today : https://prequalifyme.today
    //Submitted by DeepakTiwari ******@****.***
    prequalifyme.today
    
    // prgmr.com : https://prgmr.com/
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 240.3K bytes
    - Viewed (0)
Back to top