Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,042 for bread (0.77 sec)

  1. guava/src/com/google/common/hash/HashingInputStream.java

        if (b != -1) {
          hasher.putByte((byte) b);
        }
        return b;
      }
    
      /**
       * Reads the specified bytes of data from the underlying input stream and updates the hasher with
       * the bytes read.
       */
      @Override
      @CanIgnoreReturnValue
      public int read(byte[] bytes, int off, int len) throws IOException {
        int numOfBytesRead = in.read(bytes, off, len);
        if (numOfBytesRead != -1) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. src/main/java/jcifs/pac/kerberos/KerberosApRequest.java

                    }
                    break;
                case 1:
                    ASN1Integer msgType = ASN1Util.as(ASN1Integer.class, tagged);
                    if (!msgType.getValue().equals(new BigInteger(KerberosConstants.KERBEROS_AP_REQ))) {
                        throw new PACDecodingException("Invalid kerberos request");
                    }
                    break;
                case 2:
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

                        }
                    } catch (final Exception e) {
                        logger.warn("Failed to read a sugget elevate word: {}", list, e);
                    }
                }
                elevateWordBhv.refresh();
            } catch (final IOException e) {
                logger.warn("Failed to read a sugget elevate word.", e);
            }
        }
    
        /**
         * Exports elevate words to a CSV file.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

      /**
       * Duplex calls that have follow-ups are weird. By the time we know there's a follow-up we've
       * already split off another thread to stream the request body. Because we permit at most one
       * exchange at a time we break the request stream out from under that writer.
       */
      @Test
      fun duplexWithRedirect() {
        enableProtocol(Protocol.HTTP_2)
        val duplexResponseSent = CountDownLatch(1)
        listener =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  5. src/test/java/jcifs/netbios/SessionServicePacketTest.java

        }
    
        @Test
        @DisplayName("readn should handle multiple read calls")
        void testReadnMultipleCalls() throws IOException {
            when(mockInputStream.read(any(byte[].class), anyInt(), anyInt())).thenReturn(2) // First read returns 2 bytes
                    .thenReturn(2) // Second read returns 2 bytes
                    .thenReturn(1); // Third read returns 1 byte
    
            byte[] buffer = new byte[10];
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/query/BooleanQueryCommand.java

                        boolQuery.must(queryBuilder);
                        break;
                    case SHOULD:
                        boolQuery.should(queryBuilder);
                        break;
                    case MUST_NOT:
                        boolQuery.mustNot(queryBuilder);
                        break;
                    default:
                        break;
                    }
                }
            }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

          // The removed stream may be blocked on a connection-wide window update.
          notifyAll()
    
          return stream
        }
      }
    
      internal fun updateConnectionFlowControl(read: Long) {
        withLock {
          readBytes.update(total = read)
          val readBytesToAcknowledge = readBytes.unacknowledged
          if (readBytesToAcknowledge >= okHttpSettings.initialWindowSize / 2) {
            writeWindowUpdateLater(0, readBytesToAcknowledge)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache2/FileOperatorTest.kt

        val buffer = Buffer()
        operator.read(6, buffer, 21)
        operator.read(36, buffer, 1)
        operator.read(5, buffer, 5)
        operator.read(28, buffer, 8)
        operator.read(17, buffer, 10)
        operator.read(36, buffer, 2)
        operator.read(2, buffer, 4)
        operator.write(0, buffer, buffer.size)
        operator.read(0, buffer, 12)
        operator.read(47, buffer, 3)
        operator.read(45, buffer, 2)
        operator.read(47, buffer, 3)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/xml/DomUtil.java

                case '<':
                    buf.append("&lt;");
                    break;
                case '>':
                    buf.append("&gt;");
                    break;
                case '&':
                    buf.append("&amp;");
                    break;
                case '"':
                    buf.append("&quot;");
                    break;
                default:
                    buf.append(element);
                }
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  10. src/main/webapp/js/admin/plugins/form-validator/html5.js

    b=[],e=a(this),f=e.attr("required"),h={};switch(f&&b.push("required"),(e.attr("type")||"").toLowerCase()){case"time":b.push("time"),a.formUtils.validators.validate_date||d||(d=!0,a.formUtils.loadModules("date"));break;case"url":b.push("url");break;case"email":b.push("email");break;case"date":b.push("date");break;case"number":b.push("number");var i=e.attr("max"),j=e.attr("min"),k=e.attr("step");j||i?(j||(j="0"),i||(i="9007199254740992"),k||(k="1"),h["data-validation-allowing"]="range["+j+";"+i+"]",0!==j.index...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 2.6K bytes
    - Viewed (0)
Back to top