Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 143 for write_bytes (0.27 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

            indexFile.deleteOnExit();
            FileUtil.writeBytes(indexFile.getAbsolutePath(), content.getBytes("UTF-8"));
    
            for (int i = 1; i <= 10; i++) {
                final File file = new File(dir, "file" + count + "-" + i + ".html");
                file.deleteOnExit();
                FileUtil.writeBytes(file.getAbsolutePath(), content.getBytes("UTF-8"));
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. clause/where.go

    						builder.WriteByte('(')
    					}
    				}
    
    				c.Build(builder)
    
    				if wrapInParentheses {
    					builder.WriteByte(')')
    				}
    			}
    		}
    
    		if len(not.Exprs) > 1 {
    			builder.WriteByte(')')
    		}
    	} else {
    		builder.WriteString("NOT ")
    		if len(not.Exprs) > 1 {
    			builder.WriteByte('(')
    		}
    
    		for idx, c := range not.Exprs {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Apr 25 12:22:53 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

        val dataSize = messageBuffer.size
        sinkBuffer.writeByte(b0)
    
        var b1 = 0
        if (isClient) {
          b1 = b1 or B1_FLAG_MASK
        }
        when {
          dataSize <= PAYLOAD_BYTE_MAX -> {
            b1 = b1 or dataSize.toInt()
            sinkBuffer.writeByte(b1)
          }
          dataSize <= PAYLOAD_SHORT_MAX -> {
            b1 = b1 or PAYLOAD_SHORT
            sinkBuffer.writeByte(b1)
            sinkBuffer.writeShort(dataSize.toInt())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. internal/store/queuestore.go

    	// Marshalls the item.
    	eventData, err := json.Marshal(item)
    	if err != nil {
    		return err
    	}
    	return store.writeBytes(key, eventData)
    }
    
    // writeBytes - writes bytes to the directory.
    func (store *QueueStore[I]) writeBytes(key Key, b []byte) (err error) {
    	path := filepath.Join(store.directory, key.String())
    
    	if key.Compress {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. clause/expression.go

    			if inName {
    				if nv, ok := namedMap[string(name)]; ok {
    					builder.AddVar(builder, nv)
    				} else {
    					builder.WriteByte('@')
    					builder.WriteString(string(name))
    				}
    				inName = false
    			}
    
    			afterParenthesis = false
    			builder.WriteByte(v)
    		} else if v == '?' && len(expr.Vars) > idx {
    			if afterParenthesis {
    				if _, ok := expr.Vars[idx].(driver.Valuer); ok {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Oct 10 06:45:48 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt

          val byte0 = tagClass or constructedBit or tag.toInt()
          sink.writeByte(byte0)
        } else {
          val byte0 = tagClass or constructedBit or 0b0001_1111
          sink.writeByte(byte0)
          writeVariableLengthLong(tag)
        }
    
        // Write the length. This takes 1 byte if length is less than 128.
        val length = content.size
        if (length < 128) {
          sink.writeByte(length.toInt())
        } else {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        val headerBytes = literalHeaders(sentHeaders)
        writeMedium(frame, (headerBytes.size + 5).toInt())
        frame.writeByte(Http2.TYPE_HEADERS)
        frame.writeByte(FLAG_END_HEADERS or FLAG_PRIORITY)
        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.writeInt(0) // Independent stream.
        frame.writeByte(255) // Heaviest weight, zero-indexed.
        frame.writeAll(headerBytes)
        reader.nextFrame(
          requireSettings = false,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. internal/kms/context.go

    	for k := range c {
    		sortedKeys = append(sortedKeys, k)
    	}
    	sort.Strings(sortedKeys)
    
    	b.WriteByte('{')
    	for i, k := range sortedKeys {
    		b.WriteByte('"')
    		escapeStringJSON(b, k)
    		b.WriteString(`":"`)
    		escapeStringJSON(b, c[k])
    		b.WriteByte('"')
    		if i < len(sortedKeys)-1 {
    			b.WriteByte(',')
    		}
    	}
    	b.WriteByte('}')
    	return b.Bytes(), nil
    }
    
    // Adapted from Go stdlib.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 6K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

            indexFile.deleteOnExit();
            FileUtil.writeBytes(indexFile.getAbsolutePath(), content.getBytes("UTF-8"));
    
            for (int i = 1; i <= 10; i++) {
                final File file = new File(dir, "file" + count + "-" + i + ".html");
                file.deleteOnExit();
                FileUtil.writeBytes(file.getAbsolutePath(), content.getBytes("UTF-8"));
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. clause/on_conflict.go

    	if onConflict.OnConstraint != "" {
    		builder.WriteString("ON CONSTRAINT ")
    		builder.WriteString(onConflict.OnConstraint)
    		builder.WriteByte(' ')
    	} else {
    		if len(onConflict.Columns) > 0 {
    			builder.WriteByte('(')
    			for idx, column := range onConflict.Columns {
    				if idx > 0 {
    					builder.WriteByte(',')
    				}
    				builder.WriteQuoted(column)
    			}
    			builder.WriteString(`) `)
    		}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Oct 07 05:46:20 UTC 2022
    - 1.3K bytes
    - Viewed (0)
Back to top