return ErrAsyncWriterFull if async channel is full

README.md

@@ -13,7 +13,7 @@
     - `IOWriter`, *io.Writer wrapper*
     - `ConsoleWriter`, *colorful & formatting*
     - `FileWriter`, *rotating & effective*
-    - `Async File Writer`, *asynchronously & performant*
+    - `AsyncWriter`, *asynchronously & performant*
     - `MultiLevelWriter`, *multiple level dispatch*
     - `SyslogWriter`, *memory efficient syslog*
    file  - `JournalWriter`, *linux systemd logging*

async.go

@@ -65,7 +65,7 @@ func (w *AsyncWriter) WriteEntry(e *Entry) (int, error) {
 		case w.ch <- entry:
 			return len(entry.buf), nil
 		default:
-			return 0, nil
+			return 0, ErrAsyncWriterFull
 		}
 	} else {
 		w.ch <- entry

async_linux.go

@@ -41,9 +41,7 @@ func (w *AsyncWriter) vwriter() {
 		}
 		// writev
 		_, err = w.file.WriteV(iovs[:n])
-		// if err != nil {
-		// 	quit = true
-		// }
+		// quic = err != nil
 		// return entries to pool
 		for i := 0; i < n; i++ {
 			epool.Put(es[i])

async_test.go

@@ -50,31 +50,11 @@ func BenchmarkSyncFileWriter(b *testing.B) {
 }
 
 func BenchmarkAsyncFileWriter(b *testing.B) {
-	logger := Logger{
-		Writer: &AsyncWriter{
-			ChannelSize:    4096,
-			WritevDisabled: true,
-			Writer: &FileWriter{
-				Filename: "async_file_test.log",
-			},
-		},
-	}
-	defer logger.Writer.(io.Closer).Close()
-
-	b.ReportAllocs()
-	b.ResetTimer()
-	b.RunParallel(func(b *testing.PB) {
-		for b.Next() {
-			logger.Info().Msg("hello file writer")
-		}
-	})
-}
-
-func BenchmarkAsyncFileWriterWriteV(b *testing.B) {
 	logger := Logger{
 		Writer: &AsyncWriter{
 			ChannelSize:    4096,
 			WritevDisabled: false,
+			DiscardOnFull:  false,
 			Writer: &FileWriter{
 				Filename: "async_file_test2.log",
 			},