diff options
Diffstat (limited to 'newsort.go')
| -rw-r--r-- | newsort.go | 13 |
1 files changed, 8 insertions, 5 deletions
@@ -14,16 +14,19 @@ func (pb *Files) makeNewSortfile(pf *File) { for _, msg := range pf.MsgNames { if msg.DoMutex { - pf.syncLock(f, msg.Lockname) - pf.iterTop(f, msg.Name) + msg.syncLock(f, msg.Lockname) + for _, key := range msg.Sort { + pf.iterTop(f, key) + pf.iterNext(f, key) + } } else { log.Info("Skipping syncLock() for", msg.Name, "DoMutex = false") } + pf.appendUnique(f, msg, sortmap) // Append() enforce no unique keys } - iterNext(f, sortmap) - iterAppend(f, sortmap) // Append() enforce no unique keys - iterSortAll(f, sortmap) + return + // iterSortAll(f, sortmap) if argv.Append != "" { sortmap["append"] = string(argv.Append) |
