Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for xbufio (0.05 sec)

  1. cmd/storage-rest-client.go

    	"github.com/minio/minio/internal/grid"
    	xhttp "github.com/minio/minio/internal/http"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/rest"
    	xnet "github.com/minio/pkg/v3/net"
    	xbufio "github.com/philhofer/fwd"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func isNetworkError(err error) bool {
    	if err == nil {
    		return false
    	}
    
    	if nerr, ok := err.(*rest.NetworkError); ok {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  2. internal/s3select/jstream/scanner_test.go

    		}
    	})
    	b.Run("large", func(b *testing.B) {
    		for b.Loop() {
    			benchmarkBufioScanner(largeInput)
    		}
    	})
    }
    
    func benchmarkBufioScanner(b []byte) {
    	s := bufio.NewScanner(bytes.NewReader(b))
    	s.Split(bufio.ScanBytes)
    	for s.Scan() {
    		s.Bytes()
    	}
    }
    
    func BenchmarkBufioReader(b *testing.B) {
    	b.Run("small", func(b *testing.B) {
    		for b.Loop() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  3. cmd/streaming-signature-v4_test.go

    	}
    	testCases := []testCase{
    		// Test - 1 - small bufio reader.
    		{
    			bufio.NewReaderSize(readers[0], 16),
    			errLineTooLong,
    			nil,
    			nil,
    		},
    		// Test - 2 - unexpected end of the reader.
    		{
    			bufio.NewReader(readers[1]),
    			io.ErrUnexpectedEOF,
    			nil,
    			nil,
    		},
    		// Test - 3 - line too long bigger than 4k+1
    		{
    			bufio.NewReader(readers[2]),
    			errLineTooLong,
    			nil,
    			nil,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  4. cmd/streaming-signature-v4.go

    // The returned bytes are owned by the bufio.Reader
    // so they are only valid until the next bufio read.
    func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) {
    	buf, err := b.ReadSlice('\n')
    	if err != nil {
    		// We always know when EOF is coming.
    		// If the caller asked for a line, there should be a line.
    		switch err {
    		case io.EOF:
    			err = io.ErrUnexpectedEOF
    		case bufio.ErrBufferFull:
    			err = errLineTooLong
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  5. internal/disk/stat_linux.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package disk
    
    import (
    	"bufio"
    	"errors"
    	"fmt"
    	"io"
    	"os"
    	"path/filepath"
    	"strconv"
    	"strings"
    	"syscall"
    
    	"github.com/prometheus/procfs/blockdevice"
    	"golang.org/x/sys/unix"
    )
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  6. cmd/common-main.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bufio"
    	"bytes"
    	"context"
    	"crypto/x509"
    	"encoding/gob"
    	"errors"
    	"fmt"
    	"net"
    	"net/url"
    	"os"
    	"path"
    	"path/filepath"
    	"runtime"
    	"sort"
    	"strconv"
    	"strings"
    	"syscall"
    	"time"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  7. cmd/update.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bufio"
    	"crypto"
    	"crypto/tls"
    	"encoding/hex"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    	"net/url"
    	"os"
    	"path"
    	"path/filepath"
    	"runtime"
    	"strings"
    	"sync/atomic"
    	"time"
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  8. internal/config/config.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package config
    
    import (
    	"bufio"
    	"fmt"
    	"io"
    	"maps"
    	"regexp"
    	"slices"
    	"sort"
    	"strings"
    	"sync"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/auth"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 37.7K bytes
    - Viewed (0)
  9. cmd/encryption-v1.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bufio"
    	"bytes"
    	"context"
    	"crypto/hmac"
    	"crypto/rand"
    	"crypto/subtle"
    	"encoding/binary"
    	"encoding/hex"
    	"errors"
    	"fmt"
    	"io"
    	"maps"
    	"net/http"
    	"path"
    	"strconv"
    	"strings"
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 38K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bufio"
    	"bytes"
    	"compress/gzip"
    	"encoding/base64"
    	"encoding/binary"
    	"encoding/json"
    	"fmt"
    	"io"
    	"math/rand"
    	"os"
    	"reflect"
    	"sort"
    	"testing"
    	"time"
    
    	"github.com/google/uuid"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
Back to top