- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 262 for writeTo (0.19 sec)
-
internal/http/server.go
for { select { case <-shutdownTimer.C: if atomic.LoadInt32(&srv.requestCount) <= 0 { return nil } // Write all running goroutines. tmp, err := os.CreateTemp("", "minio-goroutines-*.txt") if err == nil { _ = pprof.Lookup("goroutine").WriteTo(tmp, 1) tmp.Close() return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } var s strings.Builder for _, subSysConfig := range subSysConfigs { subSysConfig.WriteTo(&s, false) } password := cred.SecretKey econfigData, err := madmin.EncryptData(password, []byte(s.String())) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
internal/grid/connection.go
} mid.respMu.Lock() resp(mid.closed) mid.respMu.Unlock() } } // wsWriter writes websocket messages. type wsWriter struct { tmp [ws.MaxHeaderSize]byte } // writeMessage writes a message to w without allocations. func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error { const fin = true var frame ws.Frame if s.ClientSide() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/s3select/message.go
} result := writer.write(newRecordsMessage(writer.payloadBuffer[0:writer.payloadBufferIndex])) if result { atomic.AddInt64(&writer.bytesReturned, int64(writer.payloadBufferIndex)) writer.payloadBufferIndex = 0 } return result } // Finish is the last call to the message writer - it sends any // remaining record payload, then sends statistics and finally the end // message.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/erasure-object.go
inlineBuffers[i] = bytes.NewBuffer(buf[:0]) defer grid.PutByteBuffer(buf) writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize()) } } n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum) closeBitrotWriters(writers) if erasureErr != nil { return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-heal_test.go
writers := make([]io.Writer, len(disks)) for i, disk := range disks { writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize()) } _, err = erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1) closeBitrotWriters(writers) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/s3select/simdj/record.go
return sql.SelectFmtSIMDJSON, r.object } // WriteJSON - encodes to JSON data. func (r *Record) WriteJSON(writer io.Writer) error { o := r.object elems, err := o.Parse(nil) if err != nil { return err } b, err := elems.MarshalJSON() if err != nil { return err } n, err := writer.Write(b) if err != nil { return err } if n != len(b) { return io.ErrShortWrite } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 5.4K bytes - Viewed (0) -
internal/grid/msg_gen.go
} // EncodeMsg implements msgp.Encodable func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "ID" err = en.Append(0x82, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteBytes((z.ID)[:]) if err != nil { err = msgp.WrapError(err, "ID") return } // write "Host" err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74) if err != nil { return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 18.8K bytes - Viewed (0) -
cmd/batch-job-common-types_gen.go
return } // EncodeMsg implements msgp.Encodable func (z BatchJobKV) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "Key" err = en.Append(0x82, 0xa3, 0x4b, 0x65, 0x79) if err != nil { return } err = en.WriteString(z.Key) if err != nil { err = msgp.WrapError(err, "Key") return } // write "Value" err = en.Append(0xa5, 0x56, 0x61, 0x6c, 0x75, 0x65) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 21.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2_gen.go
return } if (zb0001Mask & 0x1) == 0 { // if not omitted // write "V2Obj" err = en.Append(0xa5, 0x56, 0x32, 0x4f, 0x62, 0x6a) if err != nil { return } if z.ObjectV2 == nil { err = en.WriteNil() if err != nil { return } } else { // map header, size 1 // write "DDir" err = en.Append(0x81, 0xa4, 0x44, 0x44, 0x69, 0x72) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 53.8K bytes - Viewed (0)