- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,728 for write (0.2 sec)
-
src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java
throw new DictionaryException("Failed to write: " + oldItem + " -> " + item, e); } } public void write(final String line) { try { writer.write(line); writer.write(Constants.LINE_SEPARATOR); } catch (final IOException e) { throw new DictionaryException("Failed to write: " + line, e); } }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 10.6K bytes - Viewed (0) -
src/main/java/jcifs/SmbConstants.java
static final int FILE_WRITE_ATTRIBUTES = 0x00000100; // 9 static final int DELETE = 0x00010000; // 16 static final int READ_CONTROL = 0x00020000; // 17 static final int WRITE_DAC = 0x00040000; // 18 static final int WRITE_OWNER = 0x00080000; // 19 static final int SYNCHRONIZE = 0x00100000; // 20 static final int GENERIC_ALL = 0x10000000; // 28
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 8.9K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
func (c *DeadlineConn) Read(b []byte) (n int, err error) { c.setReadDeadline() n, err = c.Conn.Read(b) return n, err } // Write - writes data to the connection. func (c *DeadlineConn) Write(b []byte) (n int, err error) { c.setWriteDeadline() n, err = c.Conn.Write(b) return n, err } // WithReadDeadline sets a new read side net.Conn deadline.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/s3select/genmessage.go
prelude := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude)) buf.Write(header) message := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(message)) fmt.Println(buf.Bytes()) } func genProgressHeader() { buf := new(bytes.Buffer) buf.WriteByte(13) buf.WriteString(":message-type") buf.WriteByte(7)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Viewed (0) -
cmd/erasure-encode.go
package cmd import ( "context" "fmt" "io" "sync" ) // Writes in parallel to writers type parallelWriter struct { writers []io.Writer writeQuorum int errs []error } // Write writes data to writers in parallel. func (p *parallelWriter) Write(ctx context.Context, blocks [][]byte) error { var wg sync.WaitGroup for i := range p.writers {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
lrwm := NewLRWMutex() // fmt.Println("Getting initial write lock") if !lrwm.GetLock(ctx, "", "", time.Second) { panic("Failed to acquire initial write lock") } go func() { time.Sleep(2 * time.Second) lrwm.Unlock() // fmt.Println("Initial write lock released, waiting...") }() // fmt.Println("Trying to acquire 2nd write lock, waiting...") locked = lrwm.GetLock(ctx, "", "", duration)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 10.9K bytes - Viewed (0) -
statement.go
// QuoteTo write quoted value to writer func (stmt *Statement) QuoteTo(writer clause.Writer, field interface{}) { write := func(raw bool, str string) { if raw { writer.WriteString(str) } else { stmt.DB.Dialector.QuoteTo(writer, str) } } switch v := field.(type) { case clause.Table: if v.Name == clause.CurrentTable { if stmt.TableExpr != nil { stmt.TableExpr.Build(stmt) } else {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 19.8K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LittleEndianDataOutputStream.java
} /** * Writes an {@code int} as specified by {@link DataOutputStream#writeInt(int)}, except using * little-endian byte order. * * @throws IOException if an I/O error occurs */ @Override public void writeInt(int v) throws IOException { out.write(0xFF & v); out.write(0xFF & (v >> 8)); out.write(0xFF & (v >> 16)); out.write(0xFF & (v >> 24)); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
var b1 = length if (isClient) { b1 = b1 or B1_FLAG_MASK sinkBuffer.writeByte(b1) random.nextBytes(maskKey!!) sinkBuffer.write(maskKey) if (length > 0) { val payloadStart = sinkBuffer.size sinkBuffer.write(payload) sinkBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(payloadStart) toggleMask(maskCursor, maskKey)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0)