Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 682 for Mlock (0.02 sec)

  1. src/bytes/buffer_test.go

    			b.Write(buf[:1])
    		}
    	}
    }
    
    func BenchmarkBufferWriteBlock(b *testing.B) {
    	block := make([]byte, 1024)
    	for _, n := range []int{1 << 12, 1 << 16, 1 << 20} {
    		b.Run(fmt.Sprintf("N%d", n), func(b *testing.B) {
    			b.ReportAllocs()
    			for i := 0; i < b.N; i++ {
    				var bb Buffer
    				for bb.Len() < n {
    					bb.Write(block)
    				}
    			}
    		})
    	}
    }
    
    func BenchmarkBufferAppendNoCopy(b *testing.B) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

          // a test timeout failure.
          val waitTime = (entryTime + 1_000_000_000L - System.nanoTime())
          if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) {
            TaskRunner.INSTANCE.lock.withLock {
              TaskRunner.INSTANCE.cancelAll()
            }
            fail<Unit>("Queue still active after 1000 ms")
          }
        }
      }
    
      override fun beforeEach(context: ExtensionContext) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         *
         * <ol>
         *   <li>Update the {@link #servicesByState()}
         *   <li>Update the {@link #startupTimers}
         *   <li>Based on the new state queue listeners to run
         *   <li>Run the listeners (outside of the lock)
         * </ol>
         */
        void transitionService(final Service service, State from, State to) {
          checkNotNull(service);
          checkArgument(from != to);
          monitor.enter();
          try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ServiceManager.java

         *
         * <ol>
         *   <li>Update the {@link #servicesByState()}
         *   <li>Update the {@link #startupTimers}
         *   <li>Based on the new state queue listeners to run
         *   <li>Run the listeners (outside of the lock)
         * </ol>
         */
        void transitionService(final Service service, State from, State to) {
          checkNotNull(service);
          checkArgument(from != to);
          monitor.enter();
          try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/testing/GcFinalization.java

        // we try hard to make them robust in practice.  We could additionally try to add in a system
        // load timeout multiplier.  Or we could try to use a CPU time bound instead of wall clock time
        // bound.  But these ideas are harder to implement.  We do not try to detect or handle a
        // user-specified -XX:+DisableExplicitGC.
        //
        // TODO(user): Consider using
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. architecture/environments/operator.md

    ### K8s settings
    
    Rather than defining selective mappings from parameters to fields in K8s resources, the `IstioOperatorSpec` API
    contains a consistent K8s block for each Istio component. The available K8s settings are defined in
    [KubernetesResourcesSpec](https://github.com/istio/api/blob/7791470ecc4c5e123589ff2b781f47b1bcae6ddd/mesh/v1alpha1/component.proto#L103):
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 21:11:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  7. cmd/encryption-v1.go

    	SSECustomerKeySize = 32
    
    	// SSEIVSize is the size of the IV data
    	SSEIVSize = 32 // 32 bytes
    
    	// SSEDAREPackageBlockSize - SSE dare package block size.
    	SSEDAREPackageBlockSize = 64 * 1024 // 64KiB bytes
    
    	// SSEDAREPackageMetaSize - SSE dare package meta padding bytes.
    	SSEDAREPackageMetaSize = 32 // 32 bytes
    
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/plugins/form-validator/jquery.form-validator.min.js

    reference "+f.id),g=a(f),i();else if("function"==typeof d.inlineErrorMessageCallback){if(g=d.inlineErrorMessageCallback(b,c,d),!g)return;i()}else{var j=this.getParentContainer(b);e=j.find("."+d.errorMessageClass+".help-block"),0===e.length&&(e=a("<span></span>").addClass("help-block").addClass(d.errorMessageClass),e.appendTo(j)),h(e)}},setMessageInTopOfForm:function(b,c,d,e){var f='<div class="{errorMessageClass} alert alert-danger"><strong>{errorTitle}</strong><ul>{fields}</ul></div>',g=!1;if("function"!=typeof...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 32.8K bytes
    - Viewed (0)
  9. src/main/webapp/js/admin/adminlte.min.js

    ),o=a&&(e.hasClass(L)||e.hasClass(D));a||o?this.show(a):i&&this.collapse()},t._init=function(){var e=this,t=n.default("body");t.hasClass(L)||t.hasClass(D)?(n.default(k).not(this._config.target).hide(),n.default(this._config.target).css("display","block")):n.default(k).hide(),this._fixHeight(),this._fixScrollHeight(),n.default(window).resize((function(){e._fixHeight(),e._fixScrollHeight()})),n.default(window).scroll((function(){var t=n.default("body");(t.hasClass(L)||t.hasClass(D))&&e._fixScrollH...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 45.3K bytes
    - Viewed (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/event/ExecutionEventLogger.java

            long finish = System.currentTimeMillis();
    
            long time = finish - session.getRequest().getStartTime().getTime();
    
            String wallClock = session.getRequest().getDegreeOfConcurrency() > 1 ? " (Wall Clock)" : "";
    
            logger.info("Total time:  {}{}", formatDuration(time), wallClock);
    
            logger.info("Finished at: {}", formatTimestamp(finish));
        }
    
        @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 17.2K bytes
    - Viewed (0)
Back to top