nsq_to_file: s/atomicRename/exclusiveRename

apps/nsq_to_file/file_logger.go

@@ -172,7 +172,7 @@ func (f *FileLogger) Close() {
 
 		// Optimistic rename
 		log.Printf("INFO: moving finished file %s to %s", src, dst)
-		err := atomicRename(src, dst)
+		err := exclusiveRename(src, dst)
 		if err == nil {
 			return
 		} else if !os.IsExist(err) {
@@ -189,7 +189,7 @@ func (f *FileLogger) Close() {
 		for i := f.rev + 1; ; i++ {
 			log.Printf("INFO: destination file already exists: %s", dst)
 			dst := strings.Replace(dstTmpl, "<REV>", fmt.Sprintf("-%06d", i), -1)
-			err := atomicRename(src, dst)
+			err := exclusiveRename(src, dst)
 			if err != nil {
 				if os.IsExist(err) {
 					continue // next rev
@@ -346,7 +346,7 @@ func makeOutputDir(path string) {
 	}
 }
 
-func atomicRename(src, dst string) error {
+func exclusiveRename(src, dst string) error {
 	err := os.Link(src, dst)
 	if err != nil {
 		return err