Skip to content

Commit

Permalink
Fix typo and godoc
Browse files Browse the repository at this point in the history
  • Loading branch information
blushi committed May 18, 2022
1 parent 1972888 commit 70f11f4
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion store/streaming/file/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ func NewStreamingService(writeDir, filePrefix string, storeKeys []types.StoreKey
for _, key := range storeKeys {
listeners[key] = append(listeners[key], listener)
}
// check that the writeDir exists and is writeable so that we can catch the error here at initialization if it is not
// check that the writeDir exists and is writable so that we can catch the error here at initialization if it is not
// we don't open a dstFile until we receive our first ABCI message
if err := isDirWriteable(writeDir); err != nil {
return nil, err
Expand Down
4 changes: 2 additions & 2 deletions store/streaming/file/service_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -372,7 +372,7 @@ func readInFile(name string) ([]byte, error) {
return ioutil.ReadFile(path)
}

// Returns all of the protobuf messages contained in the byte array as an array of byte arrays
// segmentBytes returns all of the protobuf messages contained in the byte array as an array of byte arrays
// The messages have their length prefix removed
func segmentBytes(bz []byte) ([][]byte, error) {
var err error
Expand All @@ -388,7 +388,7 @@ func segmentBytes(bz []byte) ([][]byte, error) {
return segments, nil
}

// Returns the bytes for the leading protobuf object in the byte array (removing the length prefix) and returns the remainder of the byte array
// getHeadSegment returns the bytes for the leading protobuf object in the byte array (removing the length prefix) and returns the remainder of the byte array
func getHeadSegment(bz []byte) ([]byte, []byte, error) {
size, prefixSize := binary.Uvarint(bz)
if prefixSize < 0 {
Expand Down

0 comments on commit 70f11f4

Please sign in to comment.