Commit b5782e0d authored by Niels Möller's avatar Niels Möller
Browse files

* src/channel.c (make_channel_table): Initialize

active_global_requests and pending_global_requests.
* src/channel.c, src/channel.h: object_queues should be declared
as structs.

Rev: src/channel.c:1.40
Rev: src/channel.h:1.34
parent 738a3691
......@@ -169,6 +169,9 @@ struct channel_table *make_channel_table(void)
table->max_channels = MAX_CHANNELS;
table->pending_close = 0;
object_queue_init(&table->active_global_requests);
object_queue_init(&table->pending_global_requests);
return table;
};
......@@ -342,7 +345,7 @@ do_global_request_response(struct global_request_callback *c,
int success)
{
CAST(global_request_response, self, c);
struct object_queue *q = self->super.connection->channels->active_global_requests;
struct object_queue *q = &self->super.connection->channels->active_global_requests;
int res = 0;
......@@ -414,7 +417,7 @@ static int do_global_request(struct packet_handler *c,
{
struct global_request_status *a = make_global_request_status();
object_queue_add_tail(connection->channels->active_global_requests,
object_queue_add_tail(&connection->channels->active_global_requests,
&a->super);
c = make_global_request_response(connection, a);
......
......@@ -163,10 +163,10 @@
; Global requests that we have received, and should reply to
; in the right order
(active_global_requests object object_queue)
(active_global_requests struct object_queue)
; Queue of global requests that we expect replies on.
(pending_global_requests object object_queue)
(pending_global_requests struct object_queue)
; If non-zero, close connection after all active channels have
; died.
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment