write.go

func (self *Morass) write(writing sortable) (err os.Error) {
        defer func() {
                self.error <- err
                self.done <- writing[:0]
        }()

        select {
        case <-self.error:
        default:
        }

        sort.Sort(&writing)

        var tf *os.File
        if tf, err = ioutil.TempFile(self.dir, self.prefix); err != nil {
                return
        }

        enc := gob.NewEncoder(tf)
        dec := gob.NewDecoder(tf)
        f := &file{head: nil, file: tf, encoder: enc, decoder: dec}
        self.files = append(self.files, f)

        for _, e := range writing {
                if err = enc.Encode(&e); err != nil {
                        return
                }
        }

        err = tf.Sync()

        return
}