Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 2621 - 2630 of 4,269 for string (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

        pongQueue.add(payload)
        runWriter()
        return true
      }
    
      override fun close(
        code: Int,
        reason: String?,
      ): Boolean = close(code, reason, webSocketCloseTimeout)
    
      @Synchronized fun close(
        code: Int,
        reason: String?,
        cancelAfterCloseMillis: Long,
      ): Boolean {
        validateCloseCode(code)
    
        var reasonBytes: ByteString? = null
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  2. internal/event/target/nsq_test.go

    )
    
    func TestNSQArgs_Validate(t *testing.T) {
    	type fields struct {
    		Enable      bool
    		NSQDAddress xnet.Host
    		Topic       string
    		TLS         struct {
    			Enable     bool
    			SkipVerify bool
    		}
    	}
    	tests := []struct {
    		name    string
    		fields  fields
    		wantErr bool
    	}{
    		{
    			name: "test1_missing_topic",
    			fields: fields{
    				Enable: true,
    				NSQDAddress: xnet.Host{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 2.2K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

            throw new InterruptedException();
          }
          remainingNanos = endNanos - System.nanoTime();
        }
    
        String futureToString = toString();
        String unitString = unit.toString().toLowerCase(Locale.ROOT);
        String message = "Waited " + timeout + " " + unit.toString().toLowerCase(Locale.ROOT);
        // Only report scheduling delay if larger than our spin threshold - otherwise it's just noise
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  4. cmd/lceventsrc_string.go

    var _lcEventSrc_index = [...]uint8{0, 4, 8, 15, 20, 25, 37, 48, 61, 72, 84, 109}
    
    func (i lcEventSrc) String() string {
    	if i >= lcEventSrc(len(_lcEventSrc_index)-1) {
    		return "lcEventSrc(" + strconv.FormatInt(int64(i), 10) + ")"
    	}
    	return _lcEventSrc_name[_lcEventSrc_index[i]:_lcEventSrc_index[i+1]]
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Dec 01 15:56:24 GMT 2023
    - 1.1K bytes
    - Click Count (0)
  5. src/archive/zip/writer_test.go

    	}
    }
    
    // TestWriterComment is test for EOCD comment read/write.
    func TestWriterComment(t *testing.T) {
    	tests := []struct {
    		comment string
    		ok      bool
    	}{
    		{"hi, hello", true},
    		{"hi, こんにちわ", true},
    		{strings.Repeat("a", uint16max), true},
    		{strings.Repeat("a", uint16max+1), false},
    	}
    
    	for _, test := range tests {
    		// write a zip file
    		buf := new(bytes.Buffer)
    		w := NewWriter(buf)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  6. cmd/untar.go

    		f:      formatS2,
    	},
    	{
    		header: []byte{0x42, 0x5a, 'h'},
    		f:      formatBZ2,
    	},
    }
    
    type untarOptions struct {
    	ignoreDirs bool
    	ignoreErrs bool
    	prefixAll  string
    }
    
    // disconnectReader will ensure that no reads can take place on
    // the upstream reader after close has been called.
    type disconnectReader struct {
    	r  io.Reader
    	mu sync.Mutex
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (2)
  7. src/main/java/org/codelibs/fess/crawler/util/FessCrawlerConfig.java

         *
         * @return the queue index name
         */
        @Override
        public String getQueueIndex() {
            return ComponentUtil.getFessConfig().getIndexDocumentCrawlerIndex() + ".queue";
        }
    
        /**
         * Gets the name of the data index for the crawler.
         *
         * @return the data index name
         */
        @Override
        public String getDataIndex() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/core/exception/ConstructorNotFoundRuntimeException.java

                } else {
                    buf.append("null");
                }
                buf.append(", ");
            }
            buf.setLength(buf.length() - 2);
            return new String(buf);
        }
    
        private static String getSignature(final Class<?>... paramTypes) {
            if (paramTypes == null || paramTypes.length == 0) {
                return "";
            }
            final StringBuilder buf = new StringBuilder(100);
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat Jul 05 00:11:05 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  9. compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/DefaultProfileSelector.java

        @Override
        public List<Profile> getActiveProfiles(
                Collection<Profile> profiles, ProfileActivationContext context, ModelProblemCollector problems) {
            Collection<String> activatedIds = new HashSet<>(context.getActiveProfileIds());
            Collection<String> deactivatedIds = new HashSet<>(context.getInactiveProfileIds());
    
            List<Profile> activeProfiles = new ArrayList<>(profiles.size());
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/relatedcontent/EditForm.java

         */
        @Required
        @Size(max = 1000)
        public String id;
    
        /**
         * The username of the user who last updated this related content configuration.
         * Used for audit trail purposes to track who made changes.
         */
        @Size(max = 1000)
        public String updatedBy;
    
        /**
         * The timestamp when this related content configuration was last updated.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 2.4K bytes
    - Click Count (0)
Back to Top