Reader-地鼠文档

本文整理汇总了Golang中bufio.Reader类的典型用法代码### 示例。如果您正苦于以下问题：Golang Reader类的具体用法？Golang Reader怎么用？Golang Reader使用的例子？那么恭喜您, 这里精选的类代码### 示例或许可以为您提供帮助。

在下文中一共展示了Reader类的20个代码### 示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码### 示例。

示例1: readline

func readline(reader *bufio.Reader, buffer *bytes.Buffer) (line string, size int, err error) {
    var (
        segment []byte
    )

    for {
        if segment, err = reader.ReadBytes('\n'); err != nil {
            if err != io.EOF {
                log.Errorf("read line failed: %s", err)
            }
            return
        }

        if _, err = buffer.Write(segment); err != nil {
            log.Errorf("write buffer failed: %s", err)
            return
        }

        if isPartialLine(segment) {
            time.Sleep(1 * time.Second)
        } else {
            size = buffer.Len()
            line = buffer.String()
            buffer.Reset()
            line = strings.TrimRight(line, "\r\n")
            return
        }
    }

    return
}

开发者ID:vaderyang，项目名称:gogstash，代码行数:31，代码来源:inputfile.go

示例2: IsXM

func IsXM(reader *bufio.Reader) bool {
    header, e := reader.Peek(17)
    if e != nil {
        return false
    }
    return bytes.Equal(header[0:17], xmHeader)
}

开发者ID:vova616，项目名称:ibxmgo，代码行数:7，代码来源:module.go

示例3: nextLine

func nextLine(reader *bufio.Reader) []byte {
    line, _, err := reader.ReadLine()

    handleError(err)

    return line
}

开发者ID:peterhellberg，项目名称:hackerrank，代码行数:7，代码来源:saveprincess2.go

示例4: readTrimmedLine

func readTrimmedLine(r *bufio.Reader) ([]byte, error) {
    if line, err := r.ReadBytes('\n'); err != nil {
        return nil, err
    } else {
        return bytes.TrimRight(line, "\r\n"), nil
    }
}

开发者ID:strider-，项目名称:go-usenet，代码行数:7，代码来源:yenc.go

示例5: readError

func readError(r *bufio.Reader) (*Message, error) {
    b, err := r.ReadBytes(delimEnd)
    if err != nil {
        return nil, err
    }
    return &Message{Type: Err, val: b[1 : len(b)-2], raw: b}, nil
}

开发者ID:qinguoan，项目名称:rambo_golang，代码行数:7，代码来源:resp.go

示例6: ReadTillEOL

func ReadTillEOL(reader *bufio.Reader, buf []byte) int {
    i := 0
    for {
        ch, err := reader.ReadByte()
        if err != nil {
            return -1
        }
        if i >= len(buf) {
            return i
        }

        if ch == '\r' {
            ch, err := reader.ReadByte()
            if err != nil {
                return -1
            }
            if ch == '\n' {
                return i
            } else {
                buf[i] = '\r'
                buf[i+1] = ch
                i += 1
            }
        } else {
            buf[i] = ch
        }
        i += 1
    }
    return i
}

开发者ID:pratyakshs，项目名称:cs733，代码行数:30，代码来源:cmd.go

示例7: escapeKey

// translate EscX to Meta+X
func escapeKey(r rune, reader *bufio.Reader) rune {
    switch r {
    case 'b':
        r = MetaBackward
    case 'f':
        r = MetaForward
    case 'd':
        r = MetaDelete
    case CharTranspose:
        r = MetaTranspose
    case CharBackspace:
        r = MetaBackspace
    case 'O':
        d, _, _ := reader.ReadRune()
        switch d {
        case 'H':
            r = CharLineStart
        case 'F':
            r = CharLineEnd
        default:
            reader.UnreadRune()
        }
    case CharEsc:

    }
    return r
}

开发者ID:mhahn，项目名称:empire，代码行数:28，代码来源:utils.go

示例8: parseStatsSettingsResponse

func parseStatsSettingsResponse(r *bufio.Reader, stats *SettingsStats) error {
    pattern := "STAT %s %s\r\n"
    var (
        key   string
        value []byte
    )
    for {
        line, err := r.ReadSlice('\n')
        if err != nil {
            return err
        }
        if bytes.Equal(line, resultEnd) {
            return nil
        }

        n, err := fmt.Sscanf(string(line), pattern, &key, &value)
        if err != nil || n != 2 {
            return fmt.Errorf("memcache: unexpected line in stats response: %q", line)
        }
        err = stats.Set(key, value)
        if err != nil && err != ErrInvalidStatsKey {
            return err
        }
    }
    panic("unreached")
}

开发者ID:qmdx，项目名称:gomemcache，代码行数:26，代码来源:memcache.go

示例9: parseStatsItemsResponse

func parseStatsItemsResponse(r *bufio.Reader, slabMap map[int]*ItemStats) error {
    pattern := "STAT items:%d:%s %s\r\n"
    var (
        slabIndex int
        key       string
        value     []byte
    )
    for {
        line, err := r.ReadSlice('\n')
        if err != nil {
            return err
        }
        if bytes.Equal(line, resultEnd) {
            return nil
        }

        n, err := fmt.Sscanf(string(line), pattern, &slabIndex, &key, &value)
        if err != nil || n != 3 {
            return fmt.Errorf("memcache: unexpected line in stats items response: %q", line)
        }

        _, ok := slabMap[slabIndex]
        if !ok {
            slabMap[slabIndex] = new(ItemStats)
        }
        err = slabMap[slabIndex].Set(key, value)
        if err != nil && err != ErrInvalidStatsKey {
            return err
        }
    }
    panic("unreached")
}

开发者ID:qmdx，项目名称:gomemcache，代码行数:32，代码来源:memcache.go

示例10: readBulkData

func readBulkData(conn *bufio.Reader, len int64) ([]byte, os.Error) {
    buff := make([]byte, len)

    _, e := io.ReadFull(conn, buff)
    if e != nil {
        return nil, NewErrorWithCause(SYSTEM_ERR, "Error while attempting read of bulkdata", e)
    }
    //  fmt.Println ("Read ", n, " bytes.  data: ", buff);

    crb, e1 := conn.ReadByte()
    if e1 != nil {
        return nil, os.NewError("Error while attempting read of bulkdata terminal CR:" + e1.String())
    }
    if crb != CR_BYTE {
        return nil, os.NewError("<BUG> bulkdata terminal was not CR as expected")
    }
    lfb, e2 := conn.ReadByte()
    if e2 != nil {
        return nil, os.NewError("Error while attempting read of bulkdata terminal LF:" + e2.String())
    }
    if lfb != LF_BYTE {
        return nil, os.NewError("<BUG> bulkdata terminal was not LF as expected.")
    }

    return buff, nil
}

开发者ID:chronicaww，项目名称:Go-Redis，代码行数:26，代码来源:protocol.go

示例11: parseGetResponse

// parseGetResponse reads a GET response from r and calls cb for each
// read and allocated Item
func parseGetResponse(r *bufio.Reader, cb func(*Item)) error {
    for {
        line, err := r.ReadSlice('\n')
        if err != nil {
            return err
        }
        if bytes.Equal(line, resultEnd) {
            return nil
        }
        it := new(Item)
        size, err := scanGetResponseLine(line, it)
        if err != nil {
            return err
        }
        it.Value, err = ioutil.ReadAll(io.LimitReader(r, int64(size)+2))
        if err != nil {
            return err
        }
        if !bytes.HasSuffix(it.Value, crlf) {
            return fmt.Errorf("memcache: corrupt get result read")
        }
        it.Value = it.Value[:size]
        cb(it)
    }
    panic("unreached")
}

开发者ID:qmdx，项目名称:gomemcache，代码行数:28，代码来源:memcache.go

示例12: parseGetResponse

// parseGetResponse reads a GET response from r and calls cb for each
// read and allocated Item
func parseGetResponse(r *bufio.Reader, cb func(*Item)) error {
    for {
        line, err := r.ReadSlice('\n')
        if err != nil {
            return err
        }
        if bytes.Equal(line, resultEnd) {
            return nil
        }
        it := new(Item)
        var size int
        n, err := fmt.Sscanf(string(line), "VALUE %s %d %d %d\r\n",
            &it.Key, &it.Flags, &size, &it.casid)
        if err != nil {
            return err
        }
        if n != 4 {
            return fmt.Errorf("memcache: unexpected line in get response: %q", string(line))
        }
        it.Value, err = ioutil.ReadAll(io.LimitReader(r, int64(size)+2))
        if err != nil {
            return err
        }
        if !bytes.HasSuffix(it.Value, crlf) {
            return fmt.Errorf("memcache: corrupt get result read")
        }
        it.Value = it.Value[:size]
        cb(it)
    }
    panic("unreached")
}

开发者ID:npe9，项目名称:gomemcache，代码行数:33，代码来源:memcache.go

示例13: readBulkString

func readBulkString(r *bufio.Reader) (interface{}, error) {
    _, err := r.ReadByte()
    if err != nil {
        return EMPTY_STRING, err
    }
    countAsStr, err := ReadLine(r)
    if err != nil {
        return EMPTY_STRING, err
    }
    count, err := strconv.Atoi(countAsStr)
    if err != nil {
        return EMPTY_STRING, err
    }
    if count == -1 {
        return countAsStr, nil
    }
    line, err := ReadLine(r)
    if err != nil {
        return EMPTY_STRING, err
    }

    if len(line) != count {
        return EMPTY_STRING, errors.New("Expected " + countAsStr + " characters in string and got " + line)
    }
    return line, nil
}

开发者ID:ashaniray，项目名称:go4redis，代码行数:26，代码来源:read_utils.go

示例14: readArray

func readArray(r *bufio.Reader) (interface{}, error) {
    _, err := r.ReadByte()
    if err != nil {
        return EMPTY_STRING, err
    }
    countAsStr, err := ReadLine(r)
    if err != nil {
        return EMPTY_STRING, err
    }

    arrLen, err := strconv.Atoi(countAsStr)
    if err != nil {
        return EMPTY_STRING, err
    }

    l := list.New()
    for i := 0; i < arrLen; i++ {
        val, err := readType(r)
        if err != nil {
            return EMPTY_STRING, err
        }
        l.PushBack(val)
    }
    return l, nil
}

开发者ID:ashaniray，项目名称:go4redis，代码行数:25，代码来源:read_utils.go

示例15: Decode

func (c *ListCommand) Decode(r *bufio.Reader) error {
    started := false
    for {
        resp, err := r.ReadString('\n')
        if err != nil {
            return err
        }

        // Handle the start condition
        if !started {
            if resp != "START\n" {
                return fmt.Errorf("expect list start block")
            }
            started = true
            continue
        }

        // Check for the end
        if resp == "END\n" {
            c.done = true
            return nil
        }

        // Store the line
        c.lines = append(c.lines, resp)
    }
    return nil
}

开发者ID:armon，项目名称:go-hlld，代码行数:28，代码来源:commands.go

示例16: readError

// reades errors like -ERR not working :D\r\n
func readError(reader *bufio.Reader) (*Reply, error) {
    raw_response, err := reader.ReadBytes('\n')
    if err != nil {
        return nil, err
    }
    return nil, errors.New(string(raw_response[0 : len(raw_response)-2]))
}

开发者ID:JakubOboza，项目名称:reddan，代码行数:8，代码来源:client.go

示例17: readSimpleString

// parses Simple string response like +OK\r\n
func readSimpleString(reader *bufio.Reader) (*Reply, error) {
    raw_response, err := reader.ReadBytes('\n')
    if err != nil {
        return nil, err
    }
    return &Reply{Response: raw_response[0 : len(raw_response)-2], Rtype: RString}, nil
}

开发者ID:JakubOboza，项目名称:reddan，代码行数:8，代码来源:client.go

示例18: escapeExKey

// translate Esc[X
func escapeExKey(r rune, reader *bufio.Reader) rune {
    switch r {
    case 'D':
        r = CharBackward
    case 'C':
        r = CharForward
    case 'A':
        r = CharPrev
    case 'B':
        r = CharNext
    case 'H':
        r = CharLineStart
    case 'F':
        r = CharLineEnd
    default:
        if r == '3' && reader != nil {
            d, _, _ := reader.ReadRune()
            if d == '~' {
                r = CharDelete
            } else {
                reader.UnreadRune()
            }
        }
    }
    return r
}

开发者ID:mhahn，项目名称:empire，代码行数:27，代码来源:utils.go

示例19: readInteger

func readInteger(reader *bufio.Reader) (*Reply, error) {
    raw_response, err := reader.ReadBytes('\n')
    if err != nil {
        return nil, err
    }
    return &Reply{Response: raw_response[0 : len(raw_response)-2], Rtype: RInt}, nil
}

开发者ID:JakubOboza，项目名称:reddan，代码行数:7，代码来源:client.go

示例20: PSyncPipeCopy

func (cmd *cmdSync) PSyncPipeCopy(c net.Conn, br *bufio.Reader, bw *bufio.Writer, offset int64, copyto io.Writer) (int64, error) {
    defer c.Close()
    var nread atomic2.Int64
    go func() {
        defer c.Close()
        for {
            time.Sleep(time.Second * 5)
            if err := sendPSyncAck(bw, offset+nread.Get()); err != nil {
                return
            }
        }
    }()

    var p = make([]byte, 8192)
    for {
        n, err := br.Read(p)
        if err != nil {
            return nread.Get(), nil
        }
        if _, err := copyto.Write(p[:n]); err != nil {
            return nread.Get(), err
        }
        nread.Add(int64(n))
    }
}

开发者ID:morya，项目名称:redis-port，代码行数:25，代码来源:sync.go

最后编辑: goerone 文档更新时间: 2021-08-23 19:14 作者：goerone