84 	uint16_t o_stream;  member
181 		channel->o_stream = 0;  in init_peer_connection()
226 find_channel_by_o_stream(struct peer_connection *pc, uint16_t o_stream)  in find_channel_by_o_stream()  argument
228 	if (o_stream < NUMBER_OF_STREAMS) {  in find_channel_by_o_stream()
229 		return (pc->o_stream_channel[o_stream]);  in find_channel_by_o_stream()
293 		    (pc->channels[i].o_stream == 0)) {  in request_more_o_streams()
318 send_open_request_message(struct socket *sock, uint16_t o_stream, uint8_t unordered, uint16_t pr_po…  in send_open_request_message()  argument
348 	sndinfo.snd_sid = o_stream;  in send_open_request_message()
364 send_open_response_message(struct socket *sock, uint16_t o_stream, uint16_t i_stream)  in send_open_response_message()  argument
376 	sndinfo.snd_sid = o_stream;  in send_open_response_message()
392 send_open_ack_message(struct socket *sock, uint16_t o_stream)  in send_open_ack_message()  argument
401 	sndinfo.snd_sid = o_stream;  in send_open_ack_message()
425 …if (send_open_request_message(pc->sock, channel->o_stream, channel->unordered, channel->pr_policy,…  in send_deferred_messages()
434 			if (send_open_response_message(pc->sock, channel->o_stream, channel->i_stream)) {  in send_deferred_messages()
443 			if (send_open_ack_message(pc->sock, channel->o_stream)) {  in send_deferred_messages()
459 	uint16_t o_stream;  in open_channel()  local
475 	o_stream = find_free_o_stream(pc);  in open_channel()
480 	channel->o_stream = o_stream;  in open_channel()
482 	if (o_stream == 0) {  in open_channel()
485 		if (send_open_request_message(pc->sock, o_stream, unordered, pr_policy, pr_value)) {  in open_channel()
486 			pc->o_stream_channel[o_stream] = channel;  in open_channel()
489 				pc->o_stream_channel[o_stream] = channel;  in open_channel()
496 				channel->o_stream = 0;  in open_channel()
520 	spa.sendv_sndinfo.snd_sid = channel->o_stream;  in send_user_message()
548 reset_outgoing_stream(struct peer_connection *pc, uint16_t o_stream)  in reset_outgoing_stream()  argument
553 		if (pc->o_stream_buffer[i] == o_stream) {  in reset_outgoing_stream()
557 	pc->o_stream_buffer[pc->o_stream_buffer_counter++] = o_stream;  in reset_outgoing_stream()
603 	reset_outgoing_stream(pc, channel->o_stream);  in close_channel()
618 	uint16_t o_stream;  in handle_open_request_message()  local
660 	o_stream = find_free_o_stream(pc);  in handle_open_request_message()
666 	channel->o_stream = o_stream;  in handle_open_request_message()
669 	if (o_stream == 0) {  in handle_open_request_message()
672 		if (send_open_response_message(pc->sock, o_stream, i_stream)) {  in handle_open_request_message()
673 			pc->o_stream_channel[o_stream] = channel;  in handle_open_request_message()
677 				pc->o_stream_channel[o_stream] = channel;  in handle_open_request_message()
686 				channel->o_stream = 0;  in handle_open_request_message()
698 	uint16_t o_stream;  in handle_open_response_message()  local
701 	o_stream = ntohs(rsp->reverse_stream);  in handle_open_response_message()
702 	channel = find_channel_by_o_stream(pc, o_stream);  in handle_open_response_message()
705 		printf("handle_open_response_message: Can't find channel for outgoing steam %d.\n", o_stream);  in handle_open_response_message()
710 …hannel with id %u for outgoing steam %u is in state %u.\n", channel->id, o_stream, channel->state);  in handle_open_response_message()
715 …lision for channel with id %u and streams (in/out) = (%u/%u).\n", channel->id, i_stream, o_stream);  in handle_open_response_message()
721 	if (send_open_ack_message(pc->sock, o_stream)) {  in handle_open_response_message()
1018 					if (channel->o_stream == 0) {
1026 							reset_outgoing_stream(pc, channel->o_stream);
1037 					pc->o_stream_channel[channel->o_stream] = NULL;
1038 					channel->o_stream = 0;
1056 	uint16_t o_stream;  local
1065 		    (channel->o_stream == 0)) {
1076 				channel->o_stream = 0;
1080 				o_stream = find_free_o_stream(pc);
1081 				if (o_stream != 0) {
1082 					channel->o_stream = o_stream;
1083 					pc->o_stream_channel[o_stream] = channel;
1267 		       channel->o_stream);