Fix SyscallVectorisedWriter

Author: nekohasekai

common/bufio/vectorised_unix.go

@@ -25,6 +25,9 @@ func (w *SyscallVectorisedWriter) WriteVectorised(buffers []*buf.Buffer) error {
 	defer buf.ReleaseMulti(buffers)
 	iovecList := w.iovecList
 	for _, buffer := range buffers {
+		if buffer.IsEmpty() {
+			continue
+		}
 		iovecList = append(iovecList, buffer.Iovec(buffer.Len()))
 	}
 	if cap(iovecList) > cap(w.iovecList) {
@@ -36,17 +39,14 @@ func (w *SyscallVectorisedWriter) WriteVectorised(buffers []*buf.Buffer) error {
 		for {
 			var r0 uintptr
 			//nolint:staticcheck
-			r0, _, innerErr = unix.RawSyscall(unix.SYS_WRITEV, fd, uintptr(unsafe.Pointer(&writeIovecList[0])), uintptr(len(writeIovecList)))
-			writeN := int(r0)
-			for writeN > 0 {
-				if buffers[0].Len() > writeN {
-					buffers[0].Advance(writeN)
-					writeIovecList[0] = buffers[0].Iovec(buffers[0].Len())
+			r0, _, innerErr = unix.RawSyscall(unix.SYS_WRITEV, fd, uintptr(unsafe.Pointer(unsafe.SliceData(writeIovecList))), uintptr(len(writeIovecList)))
+			writeN := uint64(r0)
+			for writeN > 0 && len(writeIovecList) > 0 {
+				if writeIovecList[0].Len > writeN {
+					writeIovecList[0].Base = (*byte)(unsafe.Add(unsafe.Pointer(writeIovecList[0].Base), writeN))
 					break
 				} else {
-					writeN -= buffers[0].Len()
-					buffers[0].Release()
-					buffers = buffers[1:]
+					writeN -= writeIovecList[0].Len
 					writeIovecList = writeIovecList[1:]
 				}
 			}
@@ -69,6 +69,9 @@ func (w *SyscallVectorisedPacketWriter) WriteVectorisedPacket(buffers []*buf.Buf
 	defer buf.ReleaseMulti(buffers)
 	iovecList := w.iovecList
 	for _, buffer := range buffers {
+		if buffer.IsEmpty() {
+			continue
+		}
 		iovecList = append(iovecList, buffer.Iovec(buffer.Len()))
 	}
 	if cap(iovecList) > cap(w.iovecList) {

common/bufio/vectorised_windows.go

@@ -45,6 +45,9 @@ func (w *SyscallVectorisedPacketWriter) WriteVectorisedPacket(buffers []*buf.Buf
 	defer buf.ReleaseMulti(buffers)
 	iovecList := w.iovecList
 	for _, buffer := range buffers {
+		if buffer.IsEmpty() {
+			continue
+		}
 		iovecList = append(iovecList, buffer.Iovec(buffer.Len()))
 	}
 	var n uint32