Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 350 for Reactor (0.41 seconds)

  1. src/main/java/jcifs/spnego/NegTokenInit.java

                if (mechs != null) {
                    final ASN1EncodableVector vector = new ASN1EncodableVector();
                    for (final ASN1ObjectIdentifier mech : mechs) {
                        vector.add(mech);
                    }
                    fields.add(new DERTaggedObject(true, 0, new DERSequence(vector)));
                }
                final int ctxFlags = getContextFlags();
                if (ctxFlags != 0) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  2. cmd/data-scanner.go

    	}
    }
    
    // Sleep sleeps the specified time multiplied by the sleep factor.
    // If the factor is updated the sleep will be done again with the new factor.
    func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) {
    	for {
    		// Grab current values
    		d.mu.RLock()
    		minWait, maxWait := d.minSleep, d.maxSleep
    		factor := d.factor
    		cycle := d.cycle
    		d.mu.RUnlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  3. guava/src/com/google/common/base/SmallCharMatcher.java

       * can hold setSize elements with the desired load factor.
       */
      @VisibleForTesting
      static int chooseTableSize(int setSize) {
        if (setSize == 1) {
          return 2;
        }
        // Correct the size for open addressing to match desired load factor.
        // Round up to the next highest power of 2.
        int tableSize = Integer.highestOneBit(setSize - 1) << 1;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 12 03:49:18 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  4. .teamcity/src/main/kotlin/model/FunctionalTestBucketGenerator.kt

                splitIntoBuckets(
                    LinkedList(subProjectTestClassTimes),
                    SubprojectTestClassTime::totalTime,
                    { largeElement, factor ->
                        List(factor) { SmallSubprojectBucket(largeElement.subProject, parallelization(factor)) }
                    },
                    { list ->
                        SmallSubprojectBucket(list.map { it.subProject }, parallelization(1))
                    },
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Apr 10 15:09:32 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  5. .github/workflows/labeler.yml

        permissions:
          pull-requests: read
        runs-on: ubuntu-latest
        steps:
          - uses: docker://agilepathway/pull-request-label-checker:latest
            with:
              one_of: breaking,security,feature,bug,refactor,upgrade,docs,lang-all,internal
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Sep 09 09:11:44 GMT 2025
    - 828 bytes
    - Click Count (1)
  6. src/test/java/jcifs/smb/NtlmUtilTest.java

            }
            return out;
        }
    
        @Test
        @DisplayName("getNTHash: known vector for 'password'")
        void testGetNTHash_knownVector() {
            // Arrange
            String password = "password";
            // Known NT hash for "password" (UTF-16LE MD4)
            // This is a well-known test vector: password -> 8846F7EAEE8FB117AD06BDD830B7586C
            byte[] expected = hex("8846F7EAEE8FB117AD06BDD830B7586C");
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 12K bytes
    - Click Count (1)
  7. tensorflow/c/eager/gradients.h

    // gradient registerer to instantiate a GradientFunction.
    struct ForwardOperation {
     public:
      string op_name;
      std::vector<AbstractTensorHandle*> inputs;
      std::vector<AbstractTensorHandle*> outputs;
      std::vector<int64_t> skip_input_indices;
      AttrBuilder attrs;
    };
    
    using GradientFunctionFactory =
        std::function<GradientFunction*(const ForwardOperation& op)>;
    
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Oct 12 05:11:17 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  8. docs/en/docs/management-tasks.md

        * For translations use the `🌐` emoji ("globe with meridians").
    * Start the title with a verb. For example `Add`, `Refactor`, `Fix`, etc. This way the title will say the action that the PR does. Like `Add support for teleporting`, instead of `Teleporting wasn't working, so this PR fixes it`.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Mar 23 13:59:26 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  9. samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java

                sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i)));
              }
              sink.close();
            } catch (IOException | InterruptedException e) {
              e.printStackTrace();
            }
          }
    
          private String factor(int n) {
            for (int i = 2; i < n; i++) {
              int x = n / i;
              if (x * i == n) return factor(x) + " × " + i;
            }
            return Integer.toString(n);
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jul 06 03:18:15 GMT 2018
    - 3.1K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb1/smb1/Trans2QueryFSInformationResponseTest.java

            writeInt8(1000, buffer, 8); // free allocation units
            writeInt4(8, buffer, 16); // sectors per allocation unit
            writeInt4(4096, buffer, 20); // bytes per sector
    
            int bytesRead = response.readDataWireFormat(buffer, 0, buffer.length);
    
            assertEquals(24, bytesRead, "Should read 24 bytes");
            assertNotNull(response.info, "Info object should not be null");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.6K bytes
    - Click Count (0)
Back to Top