Search Options

Results per page
Sort
Preferred Languages
Advance

Results 771 - 780 of 1,024 for Start (0.04 sec)

  1. guava/src/com/google/common/io/ReaderInputStream.java

      private static int availableCapacity(Buffer buffer) {
        return buffer.capacity() - buffer.limit();
      }
    
      /**
       * Flips the buffer output buffer so we can start reading bytes from it. If we are starting to
       * drain because there was overflow, and there aren't actually any characters to drain, then the
       * overflow must be due to a small output buffer.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  2. cmd/batch-expire.go

    					time.Sleep(delay)
    				}
    			}
    		}(toExpire)
    	}
    }
    
    type expireObjInfo struct {
    	ObjectInfo
    	ExpireAll bool
    }
    
    // Start the batch expiration job, resumes if there was a pending job via "job.ID"
    func (r *BatchJobExpire) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    		StartTime: job.Started,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

      private @Nullable Throwable uncaughtThrowable = null;
    
      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)
  4. guava/src/com/google/common/hash/BloomFilterStrategies.java

         * this operation is executing, not all of those new 1's may be set in the final state of this
         * LockFreeBitArray. The ONLY guarantee provided is that all the bits that were set in the other
         * LockFreeBitArray at the start of this method will be set in this LockFreeBitArray at the end
         * of this method.
         */
        void putAll(LockFreeBitArray other) {
          checkArgument(
              data.length() == other.data.length(),
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 10.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/dcerpc/DcerpcHandle.java

                    msg.flags &= ~DCERPC_FIRST_FRAG;
                }
    
                if ( ( msg.flags & ( DCERPC_FIRST_FRAG | DCERPC_LAST_FRAG ) ) != ( DCERPC_FIRST_FRAG | DCERPC_LAST_FRAG ) ) {
                    buf.start = off;
                    buf.reset();
                    msg.encode_header(buf);
                    buf.enc_ndr_long(msg.alloc_hint);
                    buf.enc_ndr_short(0); /* context id */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jun 30 10:11:57 UTC 2019
    - 12.9K bytes
    - Viewed (0)
  6. docs/site-replication/run-multi-site-oidc.sh

    	exit_1
    fi
    
    # force a resync after removing all site replication
    ./mc admin replicate rm --all --force minio1
    ./mc rb minio2 --force --dangerous
    ./mc admin replicate add minio1 minio2
    ./mc admin replicate resync start minio1 minio2
    sleep 30
    
    ./mc ls -r --versions minio1/newbucket >/tmp/minio1.txt
    ./mc ls -r --versions minio2/newbucket >/tmp/minio2.txt
    
    out=$(diff -qpruN /tmp/minio1.txt /tmp/minio2.txt)
    ret=$?
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/net_test.go

    	netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, NewPodNetnsProcFinder(fakeFs()))
    
    	netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error {
    		return toRun()
    	}
    	netServer.Start(ctx)
    	return netTestFixture{
    		netServer:            netServer,
    		podNsMap:             podNsMap,
    		ztunnelServer:        ztunnelServer,
    		iptablesConfigurator: iptablesConfigurator,
    		nlDeps:               nlDeps,
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/core/v1/generated.proto

      // If this value is in the future, no logs will be returned.
      // Only one of sinceSeconds or sinceTime may be specified.
      // +optional
      optional int64 sinceSeconds = 4;
    
      // An RFC3339 timestamp from which to show logs. If this value
      // precedes the time a pod was started, only logs since the pod start will be returned.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 255.8K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.3.md

    ## Changes since v1.3.0-beta.1
    
    ### Experimental Features
    
    * Init containers enable pod authors to perform tasks before their normal containers start. Each init container is started in order, and failing containers will prevent the application from starting. ([#23666](https://github.com/kubernetes/kubernetes/pull/23666), [@smarterclayton](https://github.com/smarterclayton))
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 84K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

            return 0
          }
        }
    
        return references.size
      }
    
      /**
       * Adds or replaces the policy for [address].
       * This will trigger a background task to start creating connections as needed.
       */
      fun setPolicy(
        address: Address,
        policy: ConnectionPool.AddressPolicy,
      ) {
        val state = AddressState(address, taskRunner.newQueue(), policy)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
Back to top