Commit62a3bb5

committed

Correctly handle error of output socket in sockhub

1 parent2ec3827 commit62a3bb5Copy full SHA for 62a3bb5

File tree

-2

lines changed

-2

lines changed

Lines changed: 6 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -335,10 +335,14 @@ void ShubLoop(Shub* shub)`
`335`	`335`	`for (j=0;j<n;j++) {`
`336`	`336`	`i=events[j].data.fd;`
`337`	`337`	`if (events[j].events&EPOLLERR) {`
`338`		`-if (i!=shub->input&&i!=shub->output) {`
	`338`	`+if (i==shub->input) {`
	`339`	`+shub->params->error_handler("Input socket error",SHUB_FATAL_ERROR);`
	`340`	`+ }elseif (i==shub->output) {`
	`341`	`+reconnect(shub);`
	`342`	`+ }else {`
`339`	`343`	`notify_disconnect(shub,i);`
	`344`	`+close_socket(shub,i);`
`340`	`345`	`}`
`341`		`-close_socket(shub,i);`
`342`	`346`	`}elseif (events[j].events&EPOLLIN) {`
`343`	`347`	`#else`
`344`	`348`	`for (i=0;i <=max_fd;i++) {`

Comments

(0)