tagstruct_putu32(t, l);
pstream_send_tagstruct(s->connection->pstream, t);
- fprintf(stderr, "Requesting %u bytes\n", l);
+/* fprintf(stderr, "Requesting %u bytes\n", l);*/
}
/*** sinkinput callbacks ***/
assert(stream->sink_input);
sink_notify(stream->sink_input->sink);
- fprintf(stderr, "Recieved %u bytes.\n", chunk->length);
+ /*fprintf(stderr, "Recieved %u bytes.\n", chunk->length);*/
return 0;
}
p->server = server;
p->core = core;
p->connections = idxset_new(NULL, NULL);
+ assert(p->connections);
socket_server_set_callback(p->server, on_connection, p);