1*0Sstevel@tonic-gate /* crypto/bio/bss_rtcp.c */
2*0Sstevel@tonic-gate /* Copyright (C) 1995-1998 Eric Young (eay@cryptsoft.com)
3*0Sstevel@tonic-gate * All rights reserved.
4*0Sstevel@tonic-gate *
5*0Sstevel@tonic-gate * This package is an SSL implementation written
6*0Sstevel@tonic-gate * by Eric Young (eay@cryptsoft.com).
7*0Sstevel@tonic-gate * The implementation was written so as to conform with Netscapes SSL.
8*0Sstevel@tonic-gate *
9*0Sstevel@tonic-gate * This library is free for commercial and non-commercial use as long as
10*0Sstevel@tonic-gate * the following conditions are aheared to. The following conditions
11*0Sstevel@tonic-gate * apply to all code found in this distribution, be it the RC4, RSA,
12*0Sstevel@tonic-gate * lhash, DES, etc., code; not just the SSL code. The SSL documentation
13*0Sstevel@tonic-gate * included with this distribution is covered by the same copyright terms
14*0Sstevel@tonic-gate * except that the holder is Tim Hudson (tjh@cryptsoft.com).
15*0Sstevel@tonic-gate *
16*0Sstevel@tonic-gate * Copyright remains Eric Young's, and as such any Copyright notices in
17*0Sstevel@tonic-gate * the code are not to be removed.
18*0Sstevel@tonic-gate * If this package is used in a product, Eric Young should be given attribution
19*0Sstevel@tonic-gate * as the author of the parts of the library used.
20*0Sstevel@tonic-gate * This can be in the form of a textual message at program startup or
21*0Sstevel@tonic-gate * in documentation (online or textual) provided with the package.
22*0Sstevel@tonic-gate *
23*0Sstevel@tonic-gate * Redistribution and use in source and binary forms, with or without
24*0Sstevel@tonic-gate * modification, are permitted provided that the following conditions
25*0Sstevel@tonic-gate * are met:
26*0Sstevel@tonic-gate * 1. Redistributions of source code must retain the copyright
27*0Sstevel@tonic-gate * notice, this list of conditions and the following disclaimer.
28*0Sstevel@tonic-gate * 2. Redistributions in binary form must reproduce the above copyright
29*0Sstevel@tonic-gate * notice, this list of conditions and the following disclaimer in the
30*0Sstevel@tonic-gate * documentation and/or other materials provided with the distribution.
31*0Sstevel@tonic-gate * 3. All advertising materials mentioning features or use of this software
32*0Sstevel@tonic-gate * must display the following acknowledgement:
33*0Sstevel@tonic-gate * "This product includes cryptographic software written by
34*0Sstevel@tonic-gate * Eric Young (eay@cryptsoft.com)"
35*0Sstevel@tonic-gate * The word 'cryptographic' can be left out if the rouines from the library
36*0Sstevel@tonic-gate * being used are not cryptographic related :-).
37*0Sstevel@tonic-gate * 4. If you include any Windows specific code (or a derivative thereof) from
38*0Sstevel@tonic-gate * the apps directory (application code) you must include an acknowledgement:
39*0Sstevel@tonic-gate * "This product includes software written by Tim Hudson (tjh@cryptsoft.com)"
40*0Sstevel@tonic-gate *
41*0Sstevel@tonic-gate * THIS SOFTWARE IS PROVIDED BY ERIC YOUNG ``AS IS'' AND
42*0Sstevel@tonic-gate * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
43*0Sstevel@tonic-gate * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
44*0Sstevel@tonic-gate * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
45*0Sstevel@tonic-gate * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
46*0Sstevel@tonic-gate * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
47*0Sstevel@tonic-gate * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
48*0Sstevel@tonic-gate * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
49*0Sstevel@tonic-gate * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
50*0Sstevel@tonic-gate * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
51*0Sstevel@tonic-gate * SUCH DAMAGE.
52*0Sstevel@tonic-gate *
53*0Sstevel@tonic-gate * The licence and distribution terms for any publically available version or
54*0Sstevel@tonic-gate * derivative of this code cannot be changed. i.e. this code cannot simply be
55*0Sstevel@tonic-gate * copied and put under another distribution licence
56*0Sstevel@tonic-gate * [including the GNU Public Licence.]
57*0Sstevel@tonic-gate */
58*0Sstevel@tonic-gate
59*0Sstevel@tonic-gate /* Written by David L. Jones <jonesd@kcgl1.eng.ohio-state.edu>
60*0Sstevel@tonic-gate * Date: 22-JUL-1996
61*0Sstevel@tonic-gate * Revised: 25-SEP-1997 Update for 0.8.1, BIO_CTRL_SET -> BIO_C_SET_FD
62*0Sstevel@tonic-gate */
63*0Sstevel@tonic-gate /* VMS */
64*0Sstevel@tonic-gate #include <stdio.h>
65*0Sstevel@tonic-gate #include <stdlib.h>
66*0Sstevel@tonic-gate #include <string.h>
67*0Sstevel@tonic-gate #include <errno.h>
68*0Sstevel@tonic-gate #include "cryptlib.h"
69*0Sstevel@tonic-gate #include <openssl/bio.h>
70*0Sstevel@tonic-gate
71*0Sstevel@tonic-gate #include <iodef.h> /* VMS IO$_ definitions */
72*0Sstevel@tonic-gate #include <starlet.h>
73*0Sstevel@tonic-gate
74*0Sstevel@tonic-gate typedef unsigned short io_channel;
75*0Sstevel@tonic-gate /*************************************************************************/
76*0Sstevel@tonic-gate struct io_status { short status, count; long flags; };
77*0Sstevel@tonic-gate
78*0Sstevel@tonic-gate struct rpc_msg { /* Should have member alignment inhibited */
79*0Sstevel@tonic-gate char channel; /* 'A'-app data. 'R'-remote client 'G'-global */
80*0Sstevel@tonic-gate char function; /* 'G'-get, 'P'-put, 'C'-confirm, 'X'-close */
81*0Sstevel@tonic-gate unsigned short int length; /* Amount of data returned or max to return */
82*0Sstevel@tonic-gate char data[4092]; /* variable data */
83*0Sstevel@tonic-gate };
84*0Sstevel@tonic-gate #define RPC_HDR_SIZE (sizeof(struct rpc_msg) - 4092)
85*0Sstevel@tonic-gate
86*0Sstevel@tonic-gate struct rpc_ctx {
87*0Sstevel@tonic-gate int filled, pos;
88*0Sstevel@tonic-gate struct rpc_msg msg;
89*0Sstevel@tonic-gate };
90*0Sstevel@tonic-gate
91*0Sstevel@tonic-gate static int rtcp_write(BIO *h,const char *buf,int num);
92*0Sstevel@tonic-gate static int rtcp_read(BIO *h,char *buf,int size);
93*0Sstevel@tonic-gate static int rtcp_puts(BIO *h,const char *str);
94*0Sstevel@tonic-gate static int rtcp_gets(BIO *h,char *str,int size);
95*0Sstevel@tonic-gate static long rtcp_ctrl(BIO *h,int cmd,long arg1,void *arg2);
96*0Sstevel@tonic-gate static int rtcp_new(BIO *h);
97*0Sstevel@tonic-gate static int rtcp_free(BIO *data);
98*0Sstevel@tonic-gate
99*0Sstevel@tonic-gate static BIO_METHOD rtcp_method=
100*0Sstevel@tonic-gate {
101*0Sstevel@tonic-gate BIO_TYPE_FD,
102*0Sstevel@tonic-gate "RTCP",
103*0Sstevel@tonic-gate rtcp_write,
104*0Sstevel@tonic-gate rtcp_read,
105*0Sstevel@tonic-gate rtcp_puts,
106*0Sstevel@tonic-gate rtcp_gets,
107*0Sstevel@tonic-gate rtcp_ctrl,
108*0Sstevel@tonic-gate rtcp_new,
109*0Sstevel@tonic-gate rtcp_free,
110*0Sstevel@tonic-gate NULL,
111*0Sstevel@tonic-gate };
112*0Sstevel@tonic-gate
BIO_s_rtcp(void)113*0Sstevel@tonic-gate BIO_METHOD *BIO_s_rtcp(void)
114*0Sstevel@tonic-gate {
115*0Sstevel@tonic-gate return(&rtcp_method);
116*0Sstevel@tonic-gate }
117*0Sstevel@tonic-gate /*****************************************************************************/
118*0Sstevel@tonic-gate /* Decnet I/O routines.
119*0Sstevel@tonic-gate */
120*0Sstevel@tonic-gate
121*0Sstevel@tonic-gate #ifdef __DECC
122*0Sstevel@tonic-gate #pragma message save
123*0Sstevel@tonic-gate #pragma message disable DOLLARID
124*0Sstevel@tonic-gate #endif
125*0Sstevel@tonic-gate
get(io_channel chan,char * buffer,int maxlen,int * length)126*0Sstevel@tonic-gate static int get ( io_channel chan, char *buffer, int maxlen, int *length )
127*0Sstevel@tonic-gate {
128*0Sstevel@tonic-gate int status;
129*0Sstevel@tonic-gate struct io_status iosb;
130*0Sstevel@tonic-gate status = sys$qiow ( 0, chan, IO$_READVBLK, &iosb, 0, 0,
131*0Sstevel@tonic-gate buffer, maxlen, 0, 0, 0, 0 );
132*0Sstevel@tonic-gate if ( (status&1) == 1 ) status = iosb.status;
133*0Sstevel@tonic-gate if ( (status&1) == 1 ) *length = iosb.count;
134*0Sstevel@tonic-gate return status;
135*0Sstevel@tonic-gate }
136*0Sstevel@tonic-gate
put(io_channel chan,char * buffer,int length)137*0Sstevel@tonic-gate static int put ( io_channel chan, char *buffer, int length )
138*0Sstevel@tonic-gate {
139*0Sstevel@tonic-gate int status;
140*0Sstevel@tonic-gate struct io_status iosb;
141*0Sstevel@tonic-gate status = sys$qiow ( 0, chan, IO$_WRITEVBLK, &iosb, 0, 0,
142*0Sstevel@tonic-gate buffer, length, 0, 0, 0, 0 );
143*0Sstevel@tonic-gate if ( (status&1) == 1 ) status = iosb.status;
144*0Sstevel@tonic-gate return status;
145*0Sstevel@tonic-gate }
146*0Sstevel@tonic-gate
147*0Sstevel@tonic-gate #ifdef __DECC
148*0Sstevel@tonic-gate #pragma message restore
149*0Sstevel@tonic-gate #endif
150*0Sstevel@tonic-gate
151*0Sstevel@tonic-gate /***************************************************************************/
152*0Sstevel@tonic-gate
rtcp_new(BIO * bi)153*0Sstevel@tonic-gate static int rtcp_new(BIO *bi)
154*0Sstevel@tonic-gate {
155*0Sstevel@tonic-gate struct rpc_ctx *ctx;
156*0Sstevel@tonic-gate bi->init=1;
157*0Sstevel@tonic-gate bi->num=0;
158*0Sstevel@tonic-gate bi->flags = 0;
159*0Sstevel@tonic-gate bi->ptr=OPENSSL_malloc(sizeof(struct rpc_ctx));
160*0Sstevel@tonic-gate ctx = (struct rpc_ctx *) bi->ptr;
161*0Sstevel@tonic-gate ctx->filled = 0;
162*0Sstevel@tonic-gate ctx->pos = 0;
163*0Sstevel@tonic-gate return(1);
164*0Sstevel@tonic-gate }
165*0Sstevel@tonic-gate
rtcp_free(BIO * a)166*0Sstevel@tonic-gate static int rtcp_free(BIO *a)
167*0Sstevel@tonic-gate {
168*0Sstevel@tonic-gate if (a == NULL) return(0);
169*0Sstevel@tonic-gate if ( a->ptr ) OPENSSL_free ( a->ptr );
170*0Sstevel@tonic-gate a->ptr = NULL;
171*0Sstevel@tonic-gate return(1);
172*0Sstevel@tonic-gate }
173*0Sstevel@tonic-gate
rtcp_read(BIO * b,char * out,int outl)174*0Sstevel@tonic-gate static int rtcp_read(BIO *b, char *out, int outl)
175*0Sstevel@tonic-gate {
176*0Sstevel@tonic-gate int status, length;
177*0Sstevel@tonic-gate struct rpc_ctx *ctx;
178*0Sstevel@tonic-gate /*
179*0Sstevel@tonic-gate * read data, return existing.
180*0Sstevel@tonic-gate */
181*0Sstevel@tonic-gate ctx = (struct rpc_ctx *) b->ptr;
182*0Sstevel@tonic-gate if ( ctx->pos < ctx->filled ) {
183*0Sstevel@tonic-gate length = ctx->filled - ctx->pos;
184*0Sstevel@tonic-gate if ( length > outl ) length = outl;
185*0Sstevel@tonic-gate memmove ( out, &ctx->msg.data[ctx->pos], length );
186*0Sstevel@tonic-gate ctx->pos += length;
187*0Sstevel@tonic-gate return length;
188*0Sstevel@tonic-gate }
189*0Sstevel@tonic-gate /*
190*0Sstevel@tonic-gate * Requst more data from R channel.
191*0Sstevel@tonic-gate */
192*0Sstevel@tonic-gate ctx->msg.channel = 'R';
193*0Sstevel@tonic-gate ctx->msg.function = 'G';
194*0Sstevel@tonic-gate ctx->msg.length = sizeof(ctx->msg.data);
195*0Sstevel@tonic-gate status = put ( b->num, (char *) &ctx->msg, RPC_HDR_SIZE );
196*0Sstevel@tonic-gate if ( (status&1) == 0 ) {
197*0Sstevel@tonic-gate return -1;
198*0Sstevel@tonic-gate }
199*0Sstevel@tonic-gate /*
200*0Sstevel@tonic-gate * Read.
201*0Sstevel@tonic-gate */
202*0Sstevel@tonic-gate ctx->pos = ctx->filled = 0;
203*0Sstevel@tonic-gate status = get ( b->num, (char *) &ctx->msg, sizeof(ctx->msg), &length );
204*0Sstevel@tonic-gate if ( (status&1) == 0 ) length = -1;
205*0Sstevel@tonic-gate if ( ctx->msg.channel != 'R' || ctx->msg.function != 'C' ) {
206*0Sstevel@tonic-gate length = -1;
207*0Sstevel@tonic-gate }
208*0Sstevel@tonic-gate ctx->filled = length - RPC_HDR_SIZE;
209*0Sstevel@tonic-gate
210*0Sstevel@tonic-gate if ( ctx->pos < ctx->filled ) {
211*0Sstevel@tonic-gate length = ctx->filled - ctx->pos;
212*0Sstevel@tonic-gate if ( length > outl ) length = outl;
213*0Sstevel@tonic-gate memmove ( out, ctx->msg.data, length );
214*0Sstevel@tonic-gate ctx->pos += length;
215*0Sstevel@tonic-gate return length;
216*0Sstevel@tonic-gate }
217*0Sstevel@tonic-gate
218*0Sstevel@tonic-gate return length;
219*0Sstevel@tonic-gate }
220*0Sstevel@tonic-gate
rtcp_write(BIO * b,const char * in,int inl)221*0Sstevel@tonic-gate static int rtcp_write(BIO *b, const char *in, int inl)
222*0Sstevel@tonic-gate {
223*0Sstevel@tonic-gate int status, i, segment, length;
224*0Sstevel@tonic-gate struct rpc_ctx *ctx;
225*0Sstevel@tonic-gate /*
226*0Sstevel@tonic-gate * Output data, send in chunks no larger that sizeof(ctx->msg.data).
227*0Sstevel@tonic-gate */
228*0Sstevel@tonic-gate ctx = (struct rpc_ctx *) b->ptr;
229*0Sstevel@tonic-gate for ( i = 0; i < inl; i += segment ) {
230*0Sstevel@tonic-gate segment = inl - i;
231*0Sstevel@tonic-gate if ( segment > sizeof(ctx->msg.data) ) segment = sizeof(ctx->msg.data);
232*0Sstevel@tonic-gate ctx->msg.channel = 'R';
233*0Sstevel@tonic-gate ctx->msg.function = 'P';
234*0Sstevel@tonic-gate ctx->msg.length = segment;
235*0Sstevel@tonic-gate memmove ( ctx->msg.data, &in[i], segment );
236*0Sstevel@tonic-gate status = put ( b->num, (char *) &ctx->msg, segment + RPC_HDR_SIZE );
237*0Sstevel@tonic-gate if ((status&1) == 0 ) { i = -1; break; }
238*0Sstevel@tonic-gate
239*0Sstevel@tonic-gate status = get ( b->num, (char *) &ctx->msg, sizeof(ctx->msg), &length );
240*0Sstevel@tonic-gate if ( ((status&1) == 0) || (length < RPC_HDR_SIZE) ) { i = -1; break; }
241*0Sstevel@tonic-gate if ( (ctx->msg.channel != 'R') || (ctx->msg.function != 'C') ) {
242*0Sstevel@tonic-gate printf("unexpected response when confirming put %c %c\n",
243*0Sstevel@tonic-gate ctx->msg.channel, ctx->msg.function );
244*0Sstevel@tonic-gate
245*0Sstevel@tonic-gate }
246*0Sstevel@tonic-gate }
247*0Sstevel@tonic-gate return(i);
248*0Sstevel@tonic-gate }
249*0Sstevel@tonic-gate
rtcp_ctrl(BIO * b,int cmd,long num,void * ptr)250*0Sstevel@tonic-gate static long rtcp_ctrl(BIO *b, int cmd, long num, void *ptr)
251*0Sstevel@tonic-gate {
252*0Sstevel@tonic-gate long ret=1;
253*0Sstevel@tonic-gate
254*0Sstevel@tonic-gate switch (cmd)
255*0Sstevel@tonic-gate {
256*0Sstevel@tonic-gate case BIO_CTRL_RESET:
257*0Sstevel@tonic-gate case BIO_CTRL_EOF:
258*0Sstevel@tonic-gate ret = 1;
259*0Sstevel@tonic-gate break;
260*0Sstevel@tonic-gate case BIO_C_SET_FD:
261*0Sstevel@tonic-gate b->num = num;
262*0Sstevel@tonic-gate ret = 1;
263*0Sstevel@tonic-gate break;
264*0Sstevel@tonic-gate case BIO_CTRL_SET_CLOSE:
265*0Sstevel@tonic-gate case BIO_CTRL_FLUSH:
266*0Sstevel@tonic-gate case BIO_CTRL_DUP:
267*0Sstevel@tonic-gate ret=1;
268*0Sstevel@tonic-gate break;
269*0Sstevel@tonic-gate case BIO_CTRL_GET_CLOSE:
270*0Sstevel@tonic-gate case BIO_CTRL_INFO:
271*0Sstevel@tonic-gate case BIO_CTRL_GET:
272*0Sstevel@tonic-gate case BIO_CTRL_PENDING:
273*0Sstevel@tonic-gate case BIO_CTRL_WPENDING:
274*0Sstevel@tonic-gate default:
275*0Sstevel@tonic-gate ret=0;
276*0Sstevel@tonic-gate break;
277*0Sstevel@tonic-gate }
278*0Sstevel@tonic-gate return(ret);
279*0Sstevel@tonic-gate }
280*0Sstevel@tonic-gate
rtcp_gets(BIO * bp,char * buf,int size)281*0Sstevel@tonic-gate static int rtcp_gets(BIO *bp, char *buf, int size)
282*0Sstevel@tonic-gate {
283*0Sstevel@tonic-gate return(0);
284*0Sstevel@tonic-gate }
285*0Sstevel@tonic-gate
rtcp_puts(BIO * bp,const char * str)286*0Sstevel@tonic-gate static int rtcp_puts(BIO *bp, const char *str)
287*0Sstevel@tonic-gate {
288*0Sstevel@tonic-gate int length;
289*0Sstevel@tonic-gate if (str == NULL) return(0);
290*0Sstevel@tonic-gate length = strlen ( str );
291*0Sstevel@tonic-gate if ( length == 0 ) return (0);
292*0Sstevel@tonic-gate return rtcp_write ( bp,str, length );
293*0Sstevel@tonic-gate }
294*0Sstevel@tonic-gate
295