Home | History | Annotate | Download | only in openssh 
      1 /* $OpenBSD: buffer.c,v 1.36 2014/04/30 05:29:56 djm Exp $ */
      2 
      3 /*
      4  * Copyright (c) 2012 Damien Miller <djm (at) mindrot.org>
      5  *
      6  * Permission to use, copy, modify, and distribute this software for any
      7  * purpose with or without fee is hereby granted, provided that the above
      8  * copyright notice and this permission notice appear in all copies.
      9  *
     10  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
     11  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
     12  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
     13  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
     14  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
     15  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
     16  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
     17  */
     18 
     19 /* Emulation wrappers for legacy OpenSSH buffer API atop sshbuf */
     20 
     21 #include "includes.h"
     22 
     23 #include <sys/types.h>
     24 
     25 #include "buffer.h"
     26 #include "log.h"
     27 #include "ssherr.h"
     28 
     29 void
     30 buffer_append(Buffer *buffer, const void *data, u_int len)
     31 {
     32 	int ret;
     33 
     34 	if ((ret = sshbuf_put(buffer, data, len)) != 0)
     35 		fatal("%s: %s", __func__, ssh_err(ret));
     36 }
     37 
     38 void *
     39 buffer_append_space(Buffer *buffer, u_int len)
     40 {
     41 	int ret;
     42 	u_char *p;
     43 
     44 	if ((ret = sshbuf_reserve(buffer, len, &p)) != 0)
     45 		fatal("%s: %s", __func__, ssh_err(ret));
     46 	return p;
     47 }
     48 
     49 int
     50 buffer_check_alloc(Buffer *buffer, u_int len)
     51 {
     52 	int ret = sshbuf_check_reserve(buffer, len);
     53 
     54 	if (ret == 0)
     55 		return 1;
     56 	if (ret == SSH_ERR_NO_BUFFER_SPACE)
     57 		return 0;
     58 	fatal("%s: %s", __func__, ssh_err(ret));
     59 }
     60 
     61 int
     62 buffer_get_ret(Buffer *buffer, void *buf, u_int len)
     63 {
     64 	int ret;
     65 
     66 	if ((ret = sshbuf_get(buffer, buf, len)) != 0) {
     67 		error("%s: %s", __func__, ssh_err(ret));
     68 		return -1;
     69 	}
     70 	return 0;
     71 }
     72 
     73 void
     74 buffer_get(Buffer *buffer, void *buf, u_int len)
     75 {
     76 	if (buffer_get_ret(buffer, buf, len) == -1)
     77 		fatal("%s: buffer error", __func__);
     78 }
     79 
     80 int
     81 buffer_consume_ret(Buffer *buffer, u_int bytes)
     82 {
     83 	int ret = sshbuf_consume(buffer, bytes);
     84 
     85 	if (ret == 0)
     86 		return 0;
     87 	if (ret == SSH_ERR_MESSAGE_INCOMPLETE)
     88 		return -1;
     89 	fatal("%s: %s", __func__, ssh_err(ret));
     90 }
     91 
     92 void
     93 buffer_consume(Buffer *buffer, u_int bytes)
     94 {
     95 	if (buffer_consume_ret(buffer, bytes) == -1)
     96 		fatal("%s: buffer error", __func__);
     97 }
     98 
     99 int
    100 buffer_consume_end_ret(Buffer *buffer, u_int bytes)
    101 {
    102 	int ret = sshbuf_consume_end(buffer, bytes);
    103 
    104 	if (ret == 0)
    105 		return 0;
    106 	if (ret == SSH_ERR_MESSAGE_INCOMPLETE)
    107 		return -1;
    108 	fatal("%s: %s", __func__, ssh_err(ret));
    109 }
    110 
    111 void
    112 buffer_consume_end(Buffer *buffer, u_int bytes)
    113 {
    114 	if (buffer_consume_end_ret(buffer, bytes) == -1)
    115 		fatal("%s: buffer error", __func__);
    116 }
    117 
    118 
    119