Skip to content

Commit

Permalink
remove dead function (#17)
Browse files Browse the repository at this point in the history
  • Loading branch information
Preetam authored Oct 8, 2016
1 parent c1b0c8e commit bab6b72
Showing 1 changed file with 3 additions and 40 deletions.
43 changes: 3 additions & 40 deletions lm2.go
Original file line number Diff line number Diff line change
Expand Up @@ -304,44 +304,7 @@ func (c *Collection) nextRecord(rec *record) *record {
return nextRec
}

func (c *Collection) writeRecord(rec *record) (int64, error) {
offset, err := c.f.Seek(0, 2)
if err != nil {
return 0, err
}

rec.KeyLen = uint16(len(rec.Key))
rec.ValLen = uint32(len(rec.Value))

buf := bytes.NewBuffer(nil)

err = binary.Write(buf, binary.LittleEndian, rec.recordHeader)
if err != nil {
return 0, err
}

_, err = buf.WriteString(rec.Key)
if err != nil {
return 0, err
}
_, err = buf.WriteString(rec.Value)
if err != nil {
return 0, err
}

n, err := c.f.Write(buf.Bytes())
if err != nil {
return 0, fmt.Errorf("lm2: error writing record: %v", err)
}
if n != buf.Len() {
return 0, errors.New("lm2: partial write")
}

rec.Offset = offset
return offset, nil
}

func writeRecord2(rec *record, currentOffset int64, buf *bytes.Buffer) error {
func writeRecord(rec *record, currentOffset int64, buf *bytes.Buffer) error {
rec.KeyLen = uint16(len(rec.Key))
rec.ValLen = uint32(len(rec.Value))

Expand Down Expand Up @@ -546,7 +509,7 @@ func (c *Collection) Update(wb *WriteBatch) (int64, error) {
Value: value,
}
newRecordOffset := currentOffset + int64(appendBuf.Len())
err = writeRecord2(rec, newRecordOffset, appendBuf)
err = writeRecord(rec, newRecordOffset, appendBuf)
if err != nil {
return 0, err
}
Expand Down Expand Up @@ -582,7 +545,7 @@ func (c *Collection) Update(wb *WriteBatch) (int64, error) {
Value: value,
}
newRecordOffset := currentOffset + int64(appendBuf.Len())
err = writeRecord2(rec, newRecordOffset, appendBuf)
err = writeRecord(rec, newRecordOffset, appendBuf)
if err != nil {
return 0, err
}
Expand Down

0 comments on commit bab6b72

Please sign in to comment.