Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 118 for write_bytes (0.14 sec)

  1. src/test/java/org/codelibs/fess/exec/CrawlerTest.java

                    return 60000;
                }
            };
            ComponentUtil.register(fessConfig, "fessConfig");
    
            File propFile = File.createTempFile("test", ".properties");
            FileUtil.writeBytes(propFile.getAbsolutePath(), new byte[0]);
            propFile.deleteOnExit();
            systemProperties = new DynamicProperties(propFile);
            ComponentUtil.register(systemProperties, "systemProperties");
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 30.5K bytes
    - Viewed (0)
  2. clause/update.go

    func (update Update) Name() string {
    	return "UPDATE"
    }
    
    // Build build update clause
    func (update Update) Build(builder Builder) {
    	if update.Modifier != "" {
    		builder.WriteString(update.Modifier)
    		builder.WriteByte(' ')
    	}
    
    	if update.Table.Name == "" {
    		builder.WriteQuoted(currentTable)
    	} else {
    		builder.WriteQuoted(update.Table)
    	}
    }
    
    // MergeClause merge update clause
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Mar 09 09:07:00 UTC 2020
    - 737 bytes
    - Viewed (0)
  3. clause/group_by.go

    func (groupBy GroupBy) Name() string {
    	return "GROUP BY"
    }
    
    // Build build group by clause
    func (groupBy GroupBy) Build(builder Builder) {
    	for idx, column := range groupBy.Columns {
    		if idx > 0 {
    			builder.WriteByte(',')
    		}
    
    		builder.WriteQuoted(column)
    	}
    
    	if len(groupBy.Having) > 0 {
    		builder.WriteString(" HAVING ")
    		Where{Exprs: groupBy.Having}.Build(builder)
    	}
    }
    
    // MergeClause merge group by clause
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Mar 30 10:28:09 UTC 2021
    - 1K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/helper/SambaHelperTest.java

            super.setUp();
    
            // Setup system properties for DI container
            File file = File.createTempFile("test", ".properties");
            file.deleteOnExit();
            FileUtil.writeBytes(file.getAbsolutePath(), "test.property=test".getBytes("UTF-8"));
            DynamicProperties systemProps = new DynamicProperties(file);
            ComponentUtil.register(systemProps, "systemProperties");
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  5. src/bytes/buffer.go

    	}
    	// Buffer is now empty; reset.
    	b.Reset()
    	return n, nil
    }
    
    // WriteByte appends the byte c to the buffer, growing the buffer as needed.
    // The returned error is always nil, but is included to match [bufio.Writer]'s
    // WriteByte. If the buffer becomes too large, WriteByte will panic with
    // [ErrTooLarge].
    func (b *Buffer) WriteByte(c byte) error {
    	b.lastRead = opInvalid
    	m, ok := b.tryGrowByReslice(1)
    	if !ok {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 19 17:38:56 UTC 2025
    - 16K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

        require(streamId and 0x80000000.toInt() == 0) { "reserved bit set: $streamId" }
        sink.writeMedium(length)
        sink.writeByte(type and 0xff)
        sink.writeByte(flags and 0xff)
        sink.writeInt(streamId and 0x7fffffff)
      }
    
      @Throws(IOException::class)
      override fun close() {
        withLock {
          closed = true
          sink.close()
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketWriterTest.kt

      @Test fun serverMessageLengthShort() {
        // Create a payload which will overflow the normal payload byte size.
        val payload = Buffer()
        while (payload.completeSegmentByteCount() <= PAYLOAD_BYTE_MAX) {
          payload.writeByte('0'.code)
        }
        serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot())
    
        // Write directly to the unbuffered sink. This ensures it will become single frame.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  8. docs/sts/web-identity.go

    	}
    	if len(c.Scopes) > 0 {
    		v.Set("scope", strings.Join(c.Scopes, " "))
    	}
    	v.Set("state", state)
    	v.Set("nonce", state)
    	if strings.Contains(c.Endpoint.AuthURL, "?") {
    		buf.WriteByte('&')
    	} else {
    		buf.WriteByte('?')
    	}
    	buf.WriteString(v.Encode())
    	return buf.String()
    }
    
    func main() {
    	flag.Parse()
    	if clientID == "" {
    		flag.PrintDefaults()
    		return
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  9. cmd/signature-v4.go

    		vals[k] = vv
    	}
    	sort.Strings(headers)
    
    	var buf bytes.Buffer
    	for _, k := range headers {
    		buf.WriteString(k)
    		buf.WriteByte(':')
    		for idx, v := range vals[k] {
    			if idx > 0 {
    				buf.WriteByte(',')
    			}
    			buf.WriteString(signV4TrimAll(v))
    		}
    		buf.WriteByte('\n')
    	}
    	return buf.String()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Dec 13 22:19:12 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageDeflater.kt

          deflatedBytes.readAndWriteUnsafe().use { cursor ->
            cursor.resizeBuffer(newSize)
          }
        } else {
          // Same as adding EMPTY_DEFLATE_BLOCK and then removing 4 bytes.
          deflatedBytes.writeByte(0x00)
        }
    
        buffer.write(deflatedBytes, deflatedBytes.size)
      }
    
      @Throws(IOException::class)
      override fun close() = deflaterSink.close()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.1K bytes
    - Viewed (0)
Back to top