job.linux.go

// +build linux

package elio

//import (
//	"golang.org/x/sys/unix"
//)

// // Work work
// func (j *WriteJob) Work() error {

// 	var err error
// 	var out []byte
// 	var written int

// 	outs := j.session.outQueue.Fetch()

// 	for _, o := range outs {
// 		out = append(out, o.(*ByteBuffer).Bytes()...)
// 		PutByteBuffer(o.(*ByteBuffer))
// 	}

// 	l := len(out)
// 	for written < l {
// 		var w int
// 		w, err = j.session.service.io.Write(j.session, out[written:])
// 		if 0 < w {
// 			written += w

// 		} else {
// 			if (unix.EAGAIN == err) || (unix.EWOULDBLOCK == err) {
// 				if written < l {
// 					b := GetByteBuffer()
// 					b.Write(out[written:])
// 					j.session.outQueue.Prepend(b)

// 					w := &WriteJob{session: j.session}
// 					j.session.service.io.Trigger(w)
// 				}

// 			} else {
// 				//AppgError().Str(LogObject, j.String()).Str(LogSession, j.session.String()).
// 				AppError().Str(LogSession, j.session.String()).
// 					Err(err).Msgf("writing failed with fd:%v written:%d w:%d count.outqueue:%d", j.session.fd, written, w, l)
// 			}

// 			break
// 		}
// 	}

// 	return err
// }