|
|
@ -470,9 +470,12 @@ func (s *Store) Load(r io.Reader, sz int) (int64, error) {
|
|
|
|
cmd == "COMMIT" {
|
|
|
|
cmd == "COMMIT" {
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if cmd == "" && err == io.EOF {
|
|
|
|
if cmd == "" {
|
|
|
|
|
|
|
|
if err == io.EOF {
|
|
|
|
break
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
continue
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
queries = append(queries, cmd)
|
|
|
|
queries = append(queries, cmd)
|
|
|
|
if len(queries) == sz {
|
|
|
|
if len(queries) == sz {
|
|
|
|