Commit597e2ee

committed

Increase socket buffer size

1 parentae0efde commit597e2eeCopy full SHA for 597e2ee

File tree

+11

-0

lines changed

+11

-0

lines changed

Lines changed: 1 addition & 0 deletions

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -81,6 +81,10 @@ static int create_listening_socket(const char *host, int port) {`
`81`	`81`	`intoptval=1;`
`82`	`82`	`setsockopt(s,IPPROTO_TCP,TCP_NODELAY, (charconst*)&optval,sizeof(optval));`
`83`	`83`	`setsockopt(s,SOL_SOCKET,SO_REUSEADDR, (charconst*)&optval,sizeof(optval));`
	`84`	`+optval=SOCKET_BUFFER_SIZE;`
	`85`	`+setsockopt(s,SOL_SOCKET,SO_SNDBUF, (constchar*)&optval,sizeof(int));`
	`86`	`+optval=SOCKET_BUFFER_SIZE;`
	`87`	`+setsockopt(s,SOL_SOCKET,SO_RCVBUF, (constchar*)&optval,sizeof(int));`
`84`	`88`
`85`	`89`	`structsockaddr_inaddr;`
`86`	`90`	`addr.sin_family=AF_INET;`

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,8 @@`
`19`	`19`
`20`	`20`	`#include"sockhub.h"`
`21`	`21`
	`22`	`+constsize_tSOCKHUB_BUFFER_SIZE (1610241024)`
	`23`	`+`
`22`	`24`	`voidShubAddSocket(Shub*shub,intfd);`
`23`	`25`
`24`	`26`	`inlinevoidShubAddSocket(Shub*shub,intfd)`
`@@ -189,6 +191,10 @@ static void reconnect(Shub* shub)`
`189`	`191`	`}else {`
`190`	`192`	`intoptval=1;`
`191`	`193`	`setsockopt(shub->output,IPPROTO_TCP,TCP_NODELAY, (charconst*)&optval,sizeof(optval));`
	`194`	`+optval=SOCKHUB_BUFFER_SIZE;`
	`195`	`+setsockopt(shub->output,SOL_SOCKET,SO_SNDBUF, (constchar*)&optval,sizeof(int));`
	`196`	`+optval=SOCKHUB_BUFFER_SIZE;`
	`197`	`+setsockopt(shub->output,SOL_SOCKET,SO_RCVBUF, (constchar*)&optval,sizeof(int));`
`192`	`198`
`193`	`199`	`ShubAddSocket(shub,shub->output);`
`194`	`200`	`if (sep!=NULL) {`

Comments

(0)