be28472d346b35ff51ccb8890353b128a40518c9
[openssl.git] / crypto / bio / bss_bio.c
1 /* crypto/bio/bss_bio.c  -*- Mode: C; c-file-style: "eay" -*- */
2
3 /* Special method for a BIO where the other endpoint is also a BIO
4  * of this kind, handled by the same thread (i.e. the "peer" is actually
5  * ourselves, wearing a different hat).
6  * Such "BIO pairs" are mainly for using the SSL library with I/O interfaces
7  * for which no specific BIO method is available.
8  * See ssl/ssltest.c for some hints on how this can be used. */
9
10 #ifndef BIO_PAIR_DEBUG
11 # undef NDEBUG /* avoid conflicting definitions */
12 # define NDEBUG
13 #endif
14
15 #include <assert.h>
16 #include <limits.h>
17 #include <stdlib.h>
18 #include <string.h>
19
20 #include <openssl/bio.h>
21 #include <openssl/err.h>
22 #include <openssl/crypto.h>
23
24 static int bio_new(BIO *bio);
25 static int bio_free(BIO *bio);
26 static int bio_read(BIO *bio, char *buf, int size);
27 static int bio_write(BIO *bio, char *buf, int num);
28 static long bio_ctrl(BIO *bio, int cmd, long num, void *ptr);
29 static int bio_puts(BIO *bio, char *str);
30
31 static int bio_make_pair(BIO *bio1, BIO *bio2);
32 static void bio_destroy_pair(BIO *bio);
33
34 static BIO_METHOD methods_biop =
35 {
36         BIO_TYPE_BIO,
37         "BIO pair",
38         bio_write,
39         bio_read,
40         bio_puts,
41         NULL /* no bio_gets */,
42         bio_ctrl,
43         bio_new,
44         bio_free
45 };
46
47 BIO_METHOD *BIO_s_bio(void)
48         {
49         return &methods_biop;
50         }
51
52 struct bio_bio_st
53 {
54         BIO *peer;     /* NULL if buf == NULL.
55                         * If peer != NULL, then peer->ptr is also a bio_bio_st,
56                         * and its "peer" member points back to us.
57                         * peer != NULL iff init != 0 in the BIO. */
58         
59         /* This is for what we write (i.e. reading uses peer's struct): */
60         int closed;     /* valid iff peer != NULL */
61         size_t len;     /* valid iff buf != NULL; 0 if peer == NULL */
62         size_t offset;  /* valid iff buf != NULL; 0 if len == 0 */
63         size_t size;
64         char *buf;      /* "size" elements (if != NULL) */
65
66         size_t request; /* valid iff peer != NULL; 0 if len != 0,
67                          * otherwise set by peer to number of bytes
68                          * it (unsuccesfully) tried to read,
69                          * never more than buffer space (size-len) warrants. */
70 };
71
72 static int bio_new(BIO *bio)
73         {
74         struct bio_bio_st *b;
75         
76         b = Malloc(sizeof *b);
77         if (b == NULL)
78                 return 0;
79
80         b->peer = NULL;
81         b->size = 17*1024; /* enough for one TLS record (just a default) */
82         b->buf = NULL;
83
84         bio->ptr = b;
85         return 1;
86         }
87
88
89 static int bio_free(BIO *bio)
90         {
91         struct bio_bio_st *b;
92
93         if (bio == NULL)
94                 return 0;
95         b = bio->ptr;
96
97         assert(b != NULL);
98
99         if (b->peer)
100                 bio_destroy_pair(bio);
101         
102         if (b->buf != NULL)
103                 {
104                 Free(b->buf);
105                 }
106
107         Free(b);
108
109         return 1;
110         }
111
112
113
114 static int bio_read(BIO *bio, char *buf, int size_)
115         {
116         size_t size = size_;
117         size_t rest;
118         struct bio_bio_st *b, *peer_b;
119
120         BIO_clear_retry_flags(bio);
121
122         if (!bio->init)
123                 return 0;
124
125         b = bio->ptr;
126         assert(b != NULL);
127         assert(b->peer != NULL);
128         peer_b = b->peer->ptr;
129         assert(peer_b != NULL);
130         assert(peer_b->buf != NULL);
131
132         peer_b->request = 0; /* will be set in "retry_read" situation */
133
134         if (buf == NULL || size == 0)
135                 return 0;
136
137         if (peer_b->len == 0)
138                 {
139                 if (peer_b->closed)
140                         return 0; /* writer has closed, and no data is left */
141                 else
142                         {
143                         BIO_set_retry_read(bio); /* buffer is empty */
144                         if (size <= peer_b->size)
145                                 peer_b->request = size;
146                         else
147                                 /* don't ask for more than the peer can
148                                  * deliver in one write */
149                                 peer_b->request = peer_b->size;
150                         return -1;
151                         }
152                 }
153
154         /* we can read */
155         if (peer_b->len < size)
156                 size = peer_b->len;
157
158         /* now read "size" bytes */
159         
160         rest = size;
161         
162         assert(rest > 0);
163         do /* one or two iterations */
164                 {
165                 size_t chunk;
166                 
167                 assert(rest <= peer_b->len);
168                 if (peer_b->offset + rest <= peer_b->size)
169                         chunk = rest;
170                 else
171                         /* wrap around ring buffer */
172                         chunk = peer_b->size - peer_b->offset;
173                 assert(peer_b->offset + chunk <= peer_b->size);
174                 
175                 memcpy(buf, peer_b->buf + peer_b->offset, chunk);
176                 
177                 peer_b->len -= chunk;
178                 if (peer_b->len)
179                         {
180                         peer_b->offset += chunk;
181                         assert(peer_b->offset <= peer_b->size);
182                         if (peer_b->offset == peer_b->size)
183                                 peer_b->offset = 0;
184                         buf += chunk;
185                         }
186                 else
187                         {
188                         /* buffer now empty, no need to advance "buf" */
189                         assert(chunk == rest);
190                         peer_b->offset = 0;
191                         }
192                 rest -= chunk;
193                 }
194         while (rest);
195         
196         return size;
197         }
198
199 /* non-copying interface: provide pointer to available data in buffer
200  *    bio_nread0:  return number of available bytes
201  *    bio_nread:   also advance index
202  * (example usage:  bio_nread0(), read from buffer, bio_nread()
203  *  or just         bio_nread(), read from buffer)
204  */
205 /* WARNING: The non-copying interface is largely untested as of yet
206  * and may contain bugs. */
207 static size_t bio_nread0(BIO *bio, char **buf)
208         {
209         struct bio_bio_st *b, *peer_b;
210         size_t num;
211         
212         BIO_clear_retry_flags(bio);
213
214         if (!bio->init)
215                 return 0;
216         
217         b = bio->ptr;
218         assert(b != NULL);
219         assert(b->peer != NULL);
220         peer_b = b->peer->ptr;
221         assert(peer_b != NULL);
222         assert(peer_b->buf != NULL);
223         
224         peer_b->request = 0;
225         
226         if (peer_b->len == 0)
227                 {
228                 char dummy;
229                 
230                 /* avoid code duplication -- nothing available for reading */
231                 return bio_read(bio, &dummy, 1); /* returns 0 or -1 */
232                 }
233
234         num = peer_b->len;
235         if (peer_b->size < peer_b->offset + num)
236                 /* no ring buffer wrap-around for non-copying interface */
237                 num = peer_b->size - peer_b->offset;
238         assert(num > 0);
239
240         if (buf != NULL)
241                 *buf = peer_b->buf + peer_b->offset;
242         return num;
243         }
244
245 static size_t bio_nread(BIO *bio, char **buf, size_t num)
246         {
247         struct bio_bio_st *b, *peer_b;
248         size_t available;
249
250         available = bio_nread0(bio, buf);
251         if (num > available)
252                 num = available;
253         if (num <= 0)
254                 return num;
255
256         b = bio->ptr;
257         peer_b = b->peer->ptr;
258
259         peer_b->len -= num;
260         if (peer_b->len) 
261                 {
262                 peer_b->offset += num;
263                 assert(peer_b->offset <= peer_b->size);
264                 if (peer_b->offset == peer_b->size)
265                         peer_b->offset = 0;
266                 }
267         else
268                 peer_b->offset = 0;
269
270         return num;
271         }
272
273
274 static int bio_write(BIO *bio, char *buf, int num_)
275         {
276         size_t num = num_;
277         size_t rest;
278         struct bio_bio_st *b;
279
280         BIO_clear_retry_flags(bio);
281
282         if (!bio->init || buf == NULL || num == 0)
283                 return 0;
284
285         b = bio->ptr;           
286         assert(b != NULL);
287         assert(b->peer != NULL);
288         assert(b->buf != NULL);
289
290         b->request = 0;
291         if (b->closed)
292                 {
293                 /* we already closed */
294                 BIOerr(BIO_F_BIO_WRITE, BIO_R_BROKEN_PIPE);
295                 return -1;
296                 }
297
298         assert(b->len <= b->size);
299
300         if (b->len == b->size)
301                 {
302                 BIO_set_retry_write(bio); /* buffer is full */
303                 return -1;
304                 }
305
306         /* we can write */
307         if (num > b->size - b->len)
308                 num = b->size - b->len;
309         
310         /* now write "num" bytes */
311
312         rest = num;
313         
314         assert(rest > 0);
315         do /* one or two iterations */
316                 {
317                 size_t write_offset;
318                 size_t chunk;
319
320                 assert(b->len + rest <= b->size);
321
322                 write_offset = b->offset + b->len;
323                 if (write_offset >= b->size)
324                         write_offset -= b->size;
325                 /* b->buf[write_offset] is the first byte we can write to. */
326
327                 if (write_offset + rest <= b->size)
328                         chunk = rest;
329                 else
330                         /* wrap around ring buffer */
331                         chunk = b->size - write_offset;
332                 
333                 memcpy(b->buf + write_offset, buf, chunk);
334                 
335                 b->len += chunk;
336
337                 assert(b->len <= b->size);
338                 
339                 rest -= chunk;
340                 buf += chunk;
341                 }
342         while (rest);
343
344         return num;
345         }
346
347 /* non-copying interface: provide pointer to region to write to
348  *   bio_nwrite0:  check how much space is available
349  *   bio_nwrite:   also increase length
350  * (example usage:  bio_nwrite0(), write to buffer, bio_nwrite()
351  *  or just         bio_nwrite(), write to buffer)
352  */
353 static size_t bio_nwrite0(BIO *bio, char **buf)
354         {
355         struct bio_bio_st *b;
356         size_t num;
357         size_t write_offset;
358
359         BIO_clear_retry_flags(bio);
360
361         if (!bio->init)
362                 return 0;
363
364         b = bio->ptr;           
365         assert(b != NULL);
366         assert(b->peer != NULL);
367         assert(b->buf != NULL);
368
369         b->request = 0;
370         if (b->closed)
371                 {
372                 BIOerr(BIO_F_BIO_NWRITE0, BIO_R_BROKEN_PIPE);
373                 return -1;
374                 }
375
376         assert(b->len <= b->size);
377
378         if (b->len == b->size)
379                 {
380                 BIO_set_retry_write(bio);
381                 return -1;
382                 }
383
384         num = b->size - b->len;
385         write_offset = b->offset + b->len;
386         if (write_offset >= b->size)
387                 write_offset -= b->size;
388         if (write_offset + num > b->size)
389                 /* no ring buffer wrap-around for non-copying interface
390                  * (to fulfil the promise by BIO_ctrl_get_write_guarantee,
391                  * BIO_nwrite may have to be called twice) */
392                 num = b->size - write_offset;
393
394         if (buf != NULL)
395                 *buf = b->buf + write_offset;
396         assert(write_offset + num <= b->size);
397
398         return num;
399         }
400
401 static size_t bio_nwrite(BIO *bio, char **buf, size_t num)
402         {
403         struct bio_bio_st *b=bio->ptr;
404         size_t space;
405
406         space = bio_nwrite0(bio, buf);
407         if (num > space)
408                 num = space;
409         if (num <= 0)
410                 return num;
411         b->len += num;
412         assert(b->len <= b->size);
413
414         return num;
415         }
416
417
418 static long bio_ctrl(BIO *bio, int cmd, long num, void *ptr)
419         {
420         long ret;
421         struct bio_bio_st *b = bio->ptr;
422         
423         assert(b != NULL);
424
425         switch (cmd)
426                 {
427         /* specific CTRL codes */
428
429         case BIO_C_SET_WRITE_BUF_SIZE:
430                 if (b->peer)
431                         {
432                         BIOerr(BIO_F_BIO_CTRL, BIO_R_IN_USE);
433                         ret = 0;
434                         }
435                 else if (num == 0)
436                         {
437                         BIOerr(BIO_F_BIO_CTRL, BIO_R_INVALID_ARGUMENT);
438                         ret = 0;
439                         }
440                 else
441                         {
442                         size_t new_size = num;
443
444                         if (b->size != new_size)
445                                 {
446                                 if (b->buf) 
447                                         {
448                                         Free(b->buf);
449                                         b->buf = NULL;
450                                         }
451                                 b->size = new_size;
452                                 }
453                         ret = 1;
454                         }
455                 break;
456
457         case BIO_C_GET_WRITE_BUF_SIZE:
458                 num = (long) b->size;
459
460         case BIO_C_MAKE_BIO_PAIR:
461                 {
462                 BIO *other_bio = ptr;
463                 
464                 if (bio_make_pair(bio, other_bio))
465                         ret = 1;
466                 else
467                         ret = 0;
468                 }
469                 break;
470                 
471         case BIO_C_DESTROY_BIO_PAIR:
472                 /* Effects both BIOs in the pair -- call just once!
473                  * Or let BIO_free(bio1); BIO_free(bio2); do the job. */
474                 bio_destroy_pair(bio);
475                 ret = 1;
476                 break;
477
478         case BIO_C_GET_WRITE_GUARANTEE:
479                 /* How many bytes can the caller feed to the next write
480                  * withouth having to keep any? */
481                 if (b->peer == NULL || b->closed)
482                         ret = 0;
483                 else
484                         ret = (long) b->size - b->len;
485                 break;
486
487         case BIO_C_GET_READ_REQUEST:
488                 /* If the peer unsuccesfully tried to read, how many bytes
489                  * were requested?  (As with BIO_CTRL_PENDING, that number
490                  * can usually be treated as boolean.) */
491                 ret = (long) b->request;
492                 break;
493
494         case BIO_C_SHUTDOWN_WR:
495                 /* similar to shutdown(..., SHUT_WR) */
496                 b->closed = 1;
497                 ret = 1;
498                 break;
499
500         case BIO_C_NREAD:
501                 /* non-copying read */
502                 ret = (long) bio_nread(bio, ptr, (size_t) num);
503                 break;
504                 
505         case BIO_C_NWRITE0:
506                 /* prepare for non-copying write */
507                 ret = (long) bio_nwrite0(bio, ptr);
508                 break;
509
510         case BIO_C_NWRITE:
511                 /* non-copying write */
512                 ret = (long) bio_nwrite(bio, ptr, (size_t) num);
513                 break;
514                 
515
516         /* standard CTRL codes follow */
517
518         case BIO_CTRL_RESET:
519                 if (b->buf != NULL)
520                         {
521                         b->len = 0;
522                         b->offset = 0;
523                         }
524                 ret = 0;
525                 break;          
526
527         case BIO_CTRL_GET_CLOSE:
528                 ret = bio->shutdown;
529                 break;
530
531         case BIO_CTRL_SET_CLOSE:
532                 bio->shutdown = (int) num;
533                 ret = 1;
534                 break;
535
536         case BIO_CTRL_PENDING:
537                 if (b->peer != NULL)
538                         {
539                         struct bio_bio_st *peer_b = b->peer->ptr;
540                         
541                         ret = (long) peer_b->len;
542                         }
543                 else
544                         ret = 0;
545                 break;
546
547         case BIO_CTRL_WPENDING:
548                 if (b->buf != NULL)
549                         ret = (long) b->len;
550                 else
551                         ret = 0;
552                 break;
553
554         case BIO_CTRL_DUP:
555                 /* See BIO_dup_chain for circumstances we have to expect. */
556                 {
557                 BIO *other_bio = ptr;
558                 struct bio_bio_st *other_b;
559                 
560                 assert(other_bio != NULL);
561                 other_b = other_bio->ptr;
562                 assert(other_b != NULL);
563                 
564                 assert(other_b->buf == NULL); /* other_bio is always fresh */
565
566                 other_b->size = b->size;
567                 }
568
569                 ret = 1;
570                 break;
571
572         case BIO_CTRL_FLUSH:
573                 ret = 1;
574                 break;
575
576         case BIO_CTRL_EOF:
577                 {
578                 BIO *other_bio = ptr;
579                 
580                 if (other_bio)
581                         {
582                         struct bio_bio_st *other_b = other_bio->ptr;
583                         
584                         assert(other_b != NULL);
585                         ret = other_b->len == 0 && other_b->closed;
586                         }
587                 else
588                         ret = 1;
589                 }
590                 break;
591
592         default:
593                 ret = 0;
594                 }
595         return ret;
596         }
597
598 static int bio_puts(BIO *bio, char *str)
599         {
600         return bio_write(bio, str, strlen(str));
601         }
602
603
604 static int bio_make_pair(BIO *bio1, BIO *bio2)
605         {
606         struct bio_bio_st *b1, *b2;
607
608         assert(bio1 != NULL);
609         assert(bio2 != NULL);
610
611         b1 = bio1->ptr;
612         b2 = bio2->ptr;
613         
614         if (b1->peer != NULL || b2->peer != NULL)
615                 {
616                 BIOerr(BIO_F_BIO_MAKE_PAIR, BIO_R_IN_USE);
617                 return 0;
618                 }
619         
620         if (b1->buf == NULL)
621                 {
622                 b1->buf = Malloc(b1->size);
623                 if (b1->buf == NULL)
624                         {
625                         BIOerr(BIO_F_BIO_MAKE_PAIR, ERR_R_MALLOC_FAILURE);
626                         return 0;
627                         }
628                 b1->len = 0;
629                 b1->offset = 0;
630                 }
631         
632         if (b2->buf == NULL)
633                 {
634                 b2->buf = Malloc(b2->size);
635                 if (b2->buf == NULL)
636                         {
637                         BIOerr(BIO_F_BIO_MAKE_PAIR, ERR_R_MALLOC_FAILURE);
638                         return 0;
639                         }
640                 b2->len = 0;
641                 b2->offset = 0;
642                 }
643         
644         b1->peer = bio2;
645         b1->closed = 0;
646         b1->request = 0;
647         b2->peer = bio1;
648         b2->closed = 0;
649         b2->request = 0;
650
651         bio1->init = 1;
652         bio2->init = 1;
653
654         return 1;
655         }
656
657 static void bio_destroy_pair(BIO *bio)
658         {
659         struct bio_bio_st *b = bio->ptr;
660
661         if (b != NULL)
662                 {
663                 BIO *peer_bio = b->peer;
664
665                 if (peer_bio != NULL)
666                         {
667                         struct bio_bio_st *peer_b = peer_bio->ptr;
668
669                         assert(peer_b != NULL);
670                         assert(peer_b->peer == bio);
671
672                         peer_b->peer = NULL;
673                         peer_bio->init = 0;
674                         assert(peer_b->buf != NULL);
675                         peer_b->len = 0;
676                         peer_b->offset = 0;
677                         
678                         b->peer = NULL;
679                         bio->init = 0;
680                         assert(b->buf != NULL);
681                         b->len = 0;
682                         b->offset = 0;
683                         }
684                 }
685         }
686  
687
688 /* Exported convenience functions */
689 int BIO_new_bio_pair(BIO **bio1_p, size_t writebuf1,
690         BIO **bio2_p, size_t writebuf2)
691          {
692          BIO *bio1 = NULL, *bio2 = NULL;
693          long r;
694          int ret = 0;
695
696          bio1 = BIO_new(BIO_s_bio());
697          if (bio1 == NULL)
698                  goto err;
699          bio2 = BIO_new(BIO_s_bio());
700          if (bio2 == NULL)
701                  goto err;
702
703          if (writebuf1)
704                  {
705                  r = BIO_set_write_buf_size(bio1, writebuf1);
706                  if (!r)
707                          goto err;
708                  }
709          if (writebuf2)
710                  {
711                  r = BIO_set_write_buf_size(bio2, writebuf2);
712                  if (!r)
713                          goto err;
714                  }
715
716          r = BIO_make_bio_pair(bio1, bio2);
717          if (!r)
718                  goto err;
719          ret = 1;
720
721  err:
722          if (ret == 0)
723                  {
724                  if (bio1)
725                          {
726                          BIO_free(bio1);
727                          bio1 = NULL;
728                          }
729                  if (bio2)
730                          {
731                          BIO_free(bio2);
732                          bio2 = NULL;
733                          }
734                  }
735
736          *bio1_p = bio1;
737          *bio2_p = bio2;
738          return ret;
739          }
740
741 size_t BIO_ctrl_get_write_guarantee(BIO *bio)
742         {
743         return BIO_ctrl(bio, BIO_C_GET_WRITE_GUARANTEE, 0, NULL);
744         }
745
746 size_t BIO_ctrl_get_read_request(BIO *bio)
747         {
748         return BIO_ctrl(bio, BIO_C_GET_READ_REQUEST, 0, NULL);
749         }
750
751
752 /* BIO_nread0/nread/nwrite0/nwrite are availabe only for BIO pairs for now
753  * (conceivably some other BIOs could allow non-copying reads and writes too.)
754  */
755 int BIO_nread0(BIO *bio, char **buf)
756         {
757         long ret;
758
759         if (!bio->init)
760                 {
761                 BIOerr(BIO_F_BIO_NREAD0, BIO_R_UNINITIALIZED);
762                 return -2;
763                 }
764
765         ret = BIO_ctrl(bio, BIO_C_NREAD0, 0, buf);
766         if (ret > INT_MAX)
767                 return INT_MAX;
768         else
769                 return (int) ret;
770         }
771
772 int BIO_nread(BIO *bio, char **buf, int num)
773         {
774         int ret;
775
776         if (!bio->init)
777                 {
778                 BIOerr(BIO_F_BIO_NREAD, BIO_R_UNINITIALIZED);
779                 return -2;
780                 }
781
782         ret = (int) BIO_ctrl(bio, BIO_C_NREAD, num, buf);
783         if (ret > 0)
784                 bio->num_read += ret;
785         return ret;
786         }
787
788 int BIO_nwrite0(BIO *bio, char **buf)
789         {
790         long ret;
791
792         if (!bio->init)
793                 {
794                 BIOerr(BIO_F_BIO_NWRITE0, BIO_R_UNINITIALIZED);
795                 return -2;
796                 }
797
798         ret = BIO_ctrl(bio, BIO_C_NWRITE0, 0, buf);
799         if (ret > INT_MAX)
800                 return INT_MAX;
801         else
802                 return (int) ret;
803         }
804
805 int BIO_nwrite(BIO *bio, char **buf, int num)
806         {
807         int ret;
808
809         if (!bio->init)
810                 {
811                 BIOerr(BIO_F_BIO_NWRITE, BIO_R_UNINITIALIZED);
812                 return -2;
813                 }
814
815         ret = BIO_ctrl(bio, BIO_C_NWRITE, num, buf);
816         if (ret > 0)
817                 bio->num_read += ret;
818         return ret;
819         }