Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 462 for slop (0.03 sec)

  1. internal/cachevalue/cache_test.go

    package cachevalue
    
    import (
    	"context"
    	"errors"
    	"testing"
    	"time"
    )
    
    func slowCaller(ctx context.Context) error {
    	sl := time.NewTimer(time.Second)
    	defer sl.Stop()
    
    	select {
    	case <-sl.C:
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    
    	return nil
    }
    
    func TestCacheCtx(t *testing.T) {
    	cache := New[time.Time]()
    	t.Parallel()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. internal/store/batch.go

    		limit:  config.Limit,
    		store:  config.Store,
    		quitCh: quitCh,
    	}
    	if batch.store != nil {
    		go func() {
    			commitTicker := time.NewTicker(config.CommitTimeout)
    			defer commitTicker.Stop()
    			for {
    				select {
    				case <-commitTicker.C:
    				case <-batch.quitCh:
    					return
    				}
    				batch.Lock()
    				err := batch.commit()
    				batch.Unlock()
    				if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. internal/s3select/message.go

    			if !writer.write(newProgressMessage(bytesScanned, bytesProcessed, bytesReturned)) {
    				quitFlag = true
    			}
    		}
    	}
    	close(writer.doneCh)
    
    	recordStagingTicker.Stop()
    	keepAliveTicker.Stop()
    	if progressTicker != nil {
    		progressTicker.Stop()
    	}
    
    	// Whatever drain the payloadCh to prevent from memory leaking.
    	for len(writer.payloadCh) > 0 {
    		payload := <-writer.payloadCh
    		bufPool.Put(payload)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        }
    
        @Override
        public void run() {
          while (true) {
            try {
              Thread.sleep(everyMillis);
            } catch (InterruptedException e) {
              // ok. just stop sleeping.
            }
            if (shouldStop) {
              break;
            }
            interruptee.interrupt();
          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  5. src/test/java/jcifs/tests/FileOperationsTest.java

            long length = 4096 * 16 * 1024;
            try ( SmbFile f = createTestFile();
                  SmbTreeHandle treeHandle = f.getTreeHandle() ) {
                // this is tremendously slow on SMB1
                try {
                    Assume.assumeTrue("Not SMB2", treeHandle.isSMB2());
    
                    try ( SmbFile d1 = createTestDirectory();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:17:59 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

      public TestThread(L lockLikeObject, String threadName) {
        super(threadName);
        this.lockLikeObject = checkNotNull(lockLikeObject);
        start();
      }
    
      // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  7. src/packaging/common/scripts/postinst

            systemctl daemon-reload
            systemctl restart fess.service || true
    
        elif [ -x /etc/init.d/fess ]; then
            if command -v invoke-rc.d >/dev/null; then
                invoke-rc.d fess stop || true
                invoke-rc.d fess start || true
            else
                /etc/init.d/fess restart || true
            fi
    
        # older suse linux distributions do not ship with systemd
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Dec 10 01:24:02 UTC 2015
    - 3.1K bytes
    - Viewed (0)
  8. buildscripts/minio-upgrade.sh

    	verify_checksum_mc ./minio minio/minio-test/to-read/minio
    
    	curl -s http://127.0.0.1:9000/minio-test/to-read/hosts | sha256sum
    
    	MINIO_VERSION=dev /tmp/gopath/bin/docker-compose -f "buildscripts/upgrade-tests/compose.yml" stop
    }
    
    main() {
    	MINIO_VERSION=dev /tmp/gopath/bin/docker-compose -f "buildscripts/upgrade-tests/compose.yml" up -d --build
    
    	add_alias
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 05:08:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/collect/testing/OpenJdk6MapTests.java

         * changes: https://mail.openjdk.org/pipermail/core-libs-dev/2013-May/thread.html#17367
         *
         * TODO(cpovirk): decide what the best long-term action here is: force users
         * to suppress (as we do now), stop testing entrySet().add() at all, make
         * entrySet().add() tests tolerant of either behavior, introduce a map
         * feature for entrySet() that supports add(), or something else
         */
        return asList(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        }
    
        @Override
        public void run() {
          while (true) {
            try {
              Thread.sleep(everyMillis);
            } catch (InterruptedException e) {
              // ok. just stop sleeping.
            }
            if (shouldStop) {
              break;
            }
            interruptee.interrupt();
          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
Back to top