diff options
Diffstat (limited to 'newsort.go')
| -rw-r--r-- | newsort.go | 31 |
1 files changed, 21 insertions, 10 deletions
@@ -12,19 +12,30 @@ func (pb *Files) makeNewSortfile(pf *File) { header(f, pf) - for _, msg := range pf.MsgNames { - if msg.DoMutex { - msg.syncLock(f, msg.Lockname) - for _, key := range msg.Sort { - pf.iterTop(f, key) - pf.iterNext(f, key) + pf.syncLock(f) + if pf.Bases != nil { + log.Info("THIS IS WHAT BASES?", pf.Bases.Name, pf.Bases) + } + if pf.Base != nil { + log.Info("THIS IS WHAT BASE?", pf.Base.Name, pf.Base) + pf.Base.iterTop(f) + pf.Base.iterNext(f) + } + + /* + for _, msg := range pf.MsgNames { + if msg.DoMutex { + for _, key := range msg.Sort { + pf.iterTop(f, key) + pf.iterNext(f, key) + } + } else { + log.Info("Skipping syncLock() for", msg.Name, "DoMutex = false") } - } else { - log.Info("Skipping syncLock() for", msg.Name, "DoMutex = false") } - pf.appendUnique(f, msg, sortmap) // Append() enforce no unique keys - } + */ + // pf.appendUnique(f, msg, sortmap) // Append() enforce no unique keys return // iterSortAll(f, sortmap) |
