mirrors
/
kore
mirror of https://git.kore.io/kore.git
1
0
Fork 1
Code Issues Projects Releases Wiki Activity

Unbreak the sse example.

This commit is contained in:
Joris Vink 2015-08-06 08:21:28 +02:00
parent 7b3224ad30
commit 63dc498807
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
examples/sse/src/sse.c
View File

@ -29,10 +29,10 @@
#include "assets.h"
void sse_ping(void *, u_int64_t);
int page(struct http_request *);
int subscribe(struct http_request *);
void sse_disconnect(struct connection *);
void sse_ping(void *, u_int64_t, u_int64_t);
void sse_send(struct connection *, void *, size_t);
void sse_broadcast(struct connection *, void *, size_t);
void sse_spdy_stream_closed(struct connection *, struct spdy_stream *);
@ -135,7 +135,7 @@ sse_broadcast(struct connection *src, void *data, size_t len)
struct connection *c;
/* Broadcast the message to all other clients. */
TAILQ_FOREACH(c, &worker_clients, list) {
TAILQ_FOREACH(c, &connections, list) {
if (c == src)
continue;
sse_send(c, data, len);
@ -174,7 +174,7 @@ sse_send(struct connection *c, void *data, size_t len)
}
void
sse_ping(void *arg, u_int64_t now, u_int64_t delta)
sse_ping(void *arg, u_int64_t now)
{
struct connection *c = arg;
char *ping = "event:ping\ndata:\n\n";