|
Packit |
aea12f |
/*
|
|
Packit |
aea12f |
* Copyright (C) 2000-2012 Free Software Foundation, Inc.
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
* Author: Nikos Mavrogiannopoulos
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
* This file is part of GnuTLS.
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
* The GnuTLS is free software; you can redistribute it and/or
|
|
Packit |
aea12f |
* modify it under the terms of the GNU Lesser General Public License
|
|
Packit |
aea12f |
* as published by the Free Software Foundation; either version 2.1 of
|
|
Packit |
aea12f |
* the License, or (at your option) any later version.
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
* This library is distributed in the hope that it will be useful, but
|
|
Packit |
aea12f |
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit |
aea12f |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit |
aea12f |
* Lesser General Public License for more details.
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
* You should have received a copy of the GNU Lesser General Public License
|
|
Packit |
aea12f |
* along with this program. If not, see <https://www.gnu.org/licenses/>
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
*/
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
#ifndef GNUTLS_LIB_BUFFERS_H
|
|
Packit |
aea12f |
#define GNUTLS_LIB_BUFFERS_H
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
#include "mbuffers.h"
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
#define MBUFFER_FLUSH 1
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
void
|
|
Packit |
aea12f |
_gnutls_record_buffer_put(gnutls_session_t session,
|
|
Packit Service |
991b93 |
content_type_t type, uint64_t seq,
|
|
Packit |
aea12f |
mbuffer_st * bufel);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
inline static int _gnutls_record_buffer_get_size(gnutls_session_t session)
|
|
Packit |
aea12f |
{
|
|
Packit |
aea12f |
return session->internals.record_buffer.byte_length;
|
|
Packit |
aea12f |
}
|
|
Packit |
aea12f |
|
|
Packit Service |
991b93 |
#define NO_TIMEOUT_FUNC_SET(session) unlikely(session->internals.pull_timeout_func == gnutls_system_recv_timeout \
|
|
Packit Service |
991b93 |
&& session->internals.pull_func != system_read)
|
|
Packit Service |
991b93 |
|
|
Packit |
aea12f |
/*-
|
|
Packit |
aea12f |
* record_check_unprocessed:
|
|
Packit |
aea12f |
* @session: is a #gnutls_session_t structure.
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
* This function checks if there are unprocessed data
|
|
Packit |
aea12f |
* in the gnutls record buffers. Those data might not
|
|
Packit |
aea12f |
* be complete records.
|
|
Packit |
aea12f |
*
|
|
Packit |
aea12f |
* Returns: Returns the size of the data or zero.
|
|
Packit |
aea12f |
-*/
|
|
Packit |
aea12f |
inline static size_t record_check_unprocessed(gnutls_session_t session)
|
|
Packit |
aea12f |
{
|
|
Packit |
aea12f |
return session->internals.record_recv_buffer.byte_length;
|
|
Packit |
aea12f |
}
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
int _gnutls_record_buffer_get(content_type_t type,
|
|
Packit |
aea12f |
gnutls_session_t session, uint8_t * data,
|
|
Packit |
aea12f |
size_t length, uint8_t seq[8]);
|
|
Packit |
aea12f |
int _gnutls_record_buffer_get_packet(content_type_t type,
|
|
Packit |
aea12f |
gnutls_session_t session,
|
|
Packit |
aea12f |
gnutls_packet_t *packet);
|
|
Packit |
aea12f |
ssize_t _gnutls_io_read_buffered(gnutls_session_t, size_t n,
|
|
Packit |
aea12f |
content_type_t, unsigned int *ms);
|
|
Packit |
aea12f |
int _gnutls_io_clear_peeked_data(gnutls_session_t session);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
ssize_t _gnutls_io_write_buffered(gnutls_session_t session,
|
|
Packit |
aea12f |
mbuffer_st * bufel, unsigned int mflag);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
int _gnutls_handshake_io_cache_int(gnutls_session_t,
|
|
Packit |
aea12f |
gnutls_handshake_description_t,
|
|
Packit |
aea12f |
mbuffer_st * bufel);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
ssize_t
|
|
Packit |
aea12f |
_gnutls_handshake_io_recv_int(gnutls_session_t session,
|
|
Packit |
aea12f |
gnutls_handshake_description_t htype,
|
|
Packit |
aea12f |
handshake_buffer_st * hsk,
|
|
Packit |
aea12f |
unsigned int optional);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
ssize_t _gnutls_io_write_flush(gnutls_session_t session);
|
|
Packit |
aea12f |
int _gnutls_io_check_recv(gnutls_session_t session, unsigned int ms);
|
|
Packit |
aea12f |
ssize_t _gnutls_handshake_io_write_flush(gnutls_session_t session);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
inline static void _gnutls_handshake_buffer_clear(handshake_buffer_st *
|
|
Packit |
aea12f |
hsk)
|
|
Packit |
aea12f |
{
|
|
Packit |
aea12f |
_gnutls_buffer_clear(&hsk->data);
|
|
Packit |
aea12f |
hsk->htype = -1;
|
|
Packit |
aea12f |
}
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
inline static void _gnutls_handshake_buffer_init(handshake_buffer_st * hsk)
|
|
Packit |
aea12f |
{
|
|
Packit |
aea12f |
memset(hsk, 0, sizeof(*hsk));
|
|
Packit |
aea12f |
_gnutls_buffer_init(&hsk->data);
|
|
Packit |
aea12f |
hsk->htype = -1;
|
|
Packit |
aea12f |
}
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
inline static void _gnutls_handshake_recv_buffer_clear(gnutls_session_t
|
|
Packit |
aea12f |
session)
|
|
Packit |
aea12f |
{
|
|
Packit |
aea12f |
int i;
|
|
Packit |
aea12f |
for (i = 0; i < session->internals.handshake_recv_buffer_size; i++)
|
|
Packit |
aea12f |
_gnutls_handshake_buffer_clear(&session->internals.
|
|
Packit |
aea12f |
handshake_recv_buffer[i]);
|
|
Packit |
aea12f |
session->internals.handshake_recv_buffer_size = 0;
|
|
Packit |
aea12f |
_mbuffer_head_clear(&session->internals.handshake_header_recv_buffer);
|
|
Packit |
aea12f |
}
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
inline static void _gnutls_handshake_recv_buffer_init(gnutls_session_t
|
|
Packit |
aea12f |
session)
|
|
Packit |
aea12f |
{
|
|
Packit |
aea12f |
int i;
|
|
Packit |
aea12f |
for (i = 0; i < MAX_HANDSHAKE_MSGS; i++) {
|
|
Packit |
aea12f |
_gnutls_handshake_buffer_init(&session->internals.
|
|
Packit |
aea12f |
handshake_recv_buffer[i]);
|
|
Packit |
aea12f |
}
|
|
Packit |
aea12f |
session->internals.handshake_recv_buffer_size = 0;
|
|
Packit |
aea12f |
_mbuffer_head_init(&session->internals.handshake_header_recv_buffer);
|
|
Packit |
aea12f |
}
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
int _gnutls_parse_record_buffered_msgs(gnutls_session_t session);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
ssize_t
|
|
Packit |
aea12f |
_gnutls_recv_in_buffers(gnutls_session_t session, content_type_t type,
|
|
Packit |
aea12f |
gnutls_handshake_description_t htype,
|
|
Packit |
aea12f |
unsigned int ms);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
#define _gnutls_handshake_io_buffer_clear( session) \
|
|
Packit |
aea12f |
_mbuffer_head_clear( &session->internals.handshake_send_buffer); \
|
|
Packit |
aea12f |
_gnutls_handshake_recv_buffer_clear( session);
|
|
Packit |
aea12f |
|
|
Packit |
aea12f |
#endif /* GNUTLS_LIB_BUFFERS_H */
|