Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for _resume (0.04 sec)

  1. lib/wasm/wasm_exec.js

    							() => {
    								this._resume();
    								while (this._scheduledTimeouts.has(id)) {
    									// for some reason Go failed to register the timeout event, log and try again
    									// (temporary workaround for https://github.com/golang/go/issues/28975)
    									console.warn("scheduleTimeoutEvent: missed timeout event");
    									this._resume();
    								}
    							},
    							getInt64(sp + 8),
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Sun Dec 08 15:34:47 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

          return yieldUntil(strategy, condition)
        }
      }
    
      private enum class ResumePriority {
        /** Resumes as soon as the condition is satisfied. */
        BeforeOtherTasks,
    
        /** Resumes after the already-enqueued tasks. */
        AfterEnqueuedTasks,
    
        /** Resumes after all other tasks, including tasks enqueued while yielding. */
        AfterOtherTasks,
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/MultipartBodyTest.kt

          |Content-Type: application/pdf; charset=utf-8
          |
          |Jesse’s Resumé
          |--AaB03x--
          |
          """.trimMargin().replace("\n", "\r\n")
        val body =
          MultipartBody
            .Builder("AaB03x")
            .setType(MultipartBody.FORM)
            .addFormDataPart(
              "attachment",
              "resumé.pdf",
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  4. cmd/background-newdisks-heal-ops.go

    }
    
    func (h *healingTracker) isHealed(bucket string) bool {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    	return slices.Contains(h.HealedBuckets, bucket)
    }
    
    // resume will reset progress to the numbers at the start of the bucket.
    func (h *healingTracker) resume() {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.ItemsHealed = h.ResumeItemsHealed
    	h.ItemsFailed = h.ResumeItemsFailed
    	h.ItemsSkipped = h.ResumeItemsSkipped
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    		if tracker.isHealed(bucket) {
    			continue
    		}
    
    		var forwardTo string
    		// If we resume to the same bucket, forward to last known item.
    		b := tracker.getBucket()
    		if b == bucket {
    			forwardTo = tracker.getObject()
    		}
    		if b != "" {
    			// Reset to where last bucket ended if resuming.
    			tracker.resume()
    		}
    		tracker.setObject("")
    		tracker.setBucket(bucket)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbCopyUtil.java

            log.debug("Trying server side copy");
            SmbFileHandleImpl dfd = null;
            try {
                long size;
                byte[] resumeKey;
    
                // despite there being a resume key, we still need an open file descriptor?
                try (SmbFileHandleImpl sfd =
                        src.openUnshared(0, SmbConstants.O_RDONLY, SmbConstants.FILE_SHARE_READ, SmbConstants.ATTR_NORMAL, 0)) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 16.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/dcerpc/msrpc/srvsvc.java

             */
            public int prefmaxlen;
            /**
             * The total number of entries.
             */
            public int totalentries;
            /**
             * The resume handle for enumeration.
             */
            public int resume_handle;
    
            /**
             * Constructs a ShareEnumAll request.
             * @param servername the server name
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 26.3K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/google/UnmodifiableCollectionTests.java

       *   <li>All methods that return objects that can indirectly mutate the collection throw
       *       UnsupportedOperationException when those mutators are called.
       * </ol>
       *
       * @param collection the presumed-immutable collection
       * @param sampleElement an element of the same type as that contained by {@code collection}.
       *     {@code collection} may or may not have {@code sampleElement} as a member.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 14.8K bytes
    - Viewed (0)
  9. docs/es/docs/tutorial/schema-extra-example.md

    ### Resumen
    
    Solía decir que no me gustaba mucho la historia... y mírame ahora dando lecciones de "historia tecnológica". 😅
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-decom.go

    		if pool.Decommission == nil {
    			continue
    		}
    		if pool.Decommission.Complete || pool.Decommission.Canceled {
    			// Do not resume decommission upon startup for
    			// - decommission complete
    			// - decommission canceled
    			continue
    		} // In all other situations we need to resume
    		newPools = append(newPools, pool)
    	}
    	return newPools
    }
    
    func (p *poolMeta) DecommissionComplete(idx int) bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
Back to top