This commit is contained in:
PolynomialDivision 2018-02-11 22:34:18 +01:00
parent 856176a460
commit 6fa7f62576

View file

@ -34,7 +34,7 @@ struct client {
int ctr; int ctr;
int counter; int counter;
}; };
/*
static void client_close(struct ustream *s) { static void client_close(struct ustream *s) {
struct client *cl = container_of(s, struct client *cl = container_of(s,
struct client, s.stream); struct client, s.stream);
@ -49,7 +49,7 @@ static void client_close(struct ustream *s) {
pthread_mutex_unlock(&tcp_array_mutex); pthread_mutex_unlock(&tcp_array_mutex);
free(cl); free(cl);
}*/ }
static void client_notify_write(struct ustream *s, int bytes) { static void client_notify_write(struct ustream *s, int bytes) {
return; return;
@ -65,8 +65,8 @@ static void client_notify_state(struct ustream *s) {
fprintf(stderr, "eof!, pending: %d, total: %d\n", s->w.data_bytes, cl->ctr); fprintf(stderr, "eof!, pending: %d, total: %d\n", s->w.data_bytes, cl->ctr);
// TODO: REMOVE CLIENT FROM LIST! OR NOT? // TODO: REMOVE CLIENT FROM LIST! OR NOT?
//if (!s->w.data_bytes) if (!s->w.data_bytes)
// return client_close(s); return client_close(s);
} }