}
status = zchan->zio->read(zchan, data, datalen);
- if (zchan->fds[0]) {
+ if (zchan->fds[0] > -1) {
int dlen = (int) *datalen;
if (write(zchan->fds[0], data, dlen) != dlen) {
- snprintf(zchan->last_error, sizeof(zchan->last_error), "write error!");
+ snprintf(zchan->last_error, sizeof(zchan->last_error), "file write error!");
return ZAP_FAIL;
}
}
}
}
- if (zchan->fds[1]) {
+ if (zchan->fds[1] > -1) {
int dlen = (int) *datalen;
if ((write(zchan->fds[1], data, dlen)) != dlen) {
- snprintf(zchan->last_error, sizeof(zchan->last_error), "write error!");
+ snprintf(zchan->last_error, sizeof(zchan->last_error), "file write error!");
return ZAP_FAIL;
}
}