}
ret = 1;
out:
- if (ret > 0)
+ if (ret > 0) {
+ wng->eof = &sit.eof;
return wng;
+ }
free(wng);
return NULL;
}
PARA_INFO_LOG("task %p, ret: %d\n", t, t->ret);
if (t->ret < 0)
PARA_ERROR_LOG("%s\n", PARA_STRERROR(-t->ret));
- wng->eof = 1;
}
int main(int argc, char *argv[])