sctp: Switch to buffered writes faster

On a very fast feed, writes may otherwise fail before the
switch happens.
This commit is contained in:
Heikki Hannikainen 2022-10-24 00:59:01 +03:00
parent 986c74545f
commit 8a6c464cc0
2 changed files with 9 additions and 1 deletions

View File

@ -287,8 +287,14 @@ int sctp_client_write(struct worker_t *self, struct client_t *c, char *p, int le
if (client_buffer_outgoing_data(self, c, p, len) == -12)
return -12;
clientaccount_add( c, IPPROTO_SCTP, 0, 0, len, 0, 0, 0);
if (c->obuf_writes > obuf_writes_threshold) {
// Lots and lots of writes, switch to buffering...
if (c->obuf_flushsize == 0) {
c->obuf_flushsize = c->obuf_size / 2;
}
}
}
/* Is it over the flush size ? */
if (c->obuf_end > c->obuf_flushsize || ((len == 0) && (c->obuf_end > c->obuf_start))) {
int to_send = c->obuf_end - c->obuf_start;

View File

@ -508,6 +508,8 @@ extern void workers_start(void);
extern int keepalive_interval;
extern int fileno_limit;
extern int obuf_writes_threshold;
extern struct client_udp_t *udpclients;
extern struct client_udp_t *udppeers;
extern void client_udp_free(struct client_udp_t *u);