|
Lines 305-318
_server_read(eio_obj_t *obj, List objs)
Link Here
|
| 305 |
|
305 |
|
| 306 |
n = io_hdr_read_fd(obj->fd, &s->header); |
306 |
n = io_hdr_read_fd(obj->fd, &s->header); |
| 307 |
if (n <= 0) { /* got eof or error on socket read */ |
307 |
if (n <= 0) { /* got eof or error on socket read */ |
| 308 |
if (n < 0) { /* Error */ |
308 |
if (n < 0) { /* Error */ |
| 309 |
if (getenv("SLURM_PTY_PORT") == NULL) { |
309 |
if (obj->shutdown) { |
| 310 |
error("%s: fd %d error reading header: %m", |
310 |
verbose("%s: Dropped pending I/O for terminated task", |
| 311 |
__func__, obj->fd); |
311 |
__func__); |
| 312 |
} |
312 |
} else { |
| 313 |
if (s->cio->sls) { |
313 |
if (getenv("SLURM_PTY_PORT") == NULL) { |
| 314 |
step_launch_notify_io_failure( |
314 |
error("%s: fd %d error reading header: %m", |
| 315 |
s->cio->sls, s->node_id); |
315 |
__func__, obj->fd); |
|
|
316 |
} |
| 317 |
if (s->cio->sls) { |
| 318 |
step_launch_notify_io_failure( |
| 319 |
s->cio->sls, |
| 320 |
s->node_id); |
| 321 |
} |
| 316 |
} |
322 |
} |
| 317 |
} |
323 |
} |
| 318 |
close(obj->fd); |
324 |
close(obj->fd); |
