coap_session_internal.h

Go to the documentation of this file.

/*
 * coap_session_internal.h -- Structures, Enums & Functions that are not
 * exposed to application programming
 *
 * Copyright (C) 2010-2019 Olaf Bergmann <bergmann@tzi.org>
 *
 * SPDX-License-Identifier: BSD-2-Clause
 *
 * This file is part of the CoAP library libcoap. Please see README for terms
 * of use.
 */
 
#ifndef COAP_SESSION_INTERNAL_H_
#define COAP_SESSION_INTERNAL_H_
 
#include "coap_io_internal.h"
 
#define COAP_DEFAULT_SESSION_TIMEOUT 300
#define COAP_PARTIAL_SESSION_TIMEOUT_TICKS (30 * COAP_TICKS_PER_SECOND)
#define COAP_DEFAULT_MAX_HANDSHAKE_SESSIONS 100
 
struct coap_addr_hash_t {
  coap_address_t remote;       
  uint16_t lport;              
  coap_proto_t proto;          
};
 
struct coap_session_t {
  coap_proto_t proto;               
  coap_session_type_t type;         
  coap_session_state_t state;       
  unsigned ref;                     
  size_t tls_overhead;              
  size_t mtu;                       
  coap_addr_hash_t addr_hash;  
  UT_hash_handle hh;
  coap_addr_tuple_t addr_info;      
  int ifindex;                      
  coap_socket_t sock;               
  coap_endpoint_t *endpoint;        
  coap_context_t *context;          
  void *tls;                        
  uint16_t tx_mid;                  
  uint8_t con_active;               
  uint8_t csm_block_supported;      
  coap_mid_t last_ping_mid;         
  coap_queue_t *delayqueue;         
  coap_lg_xmit_t *lg_xmit;          
  coap_lg_crcv_t *lg_crcv;       
  coap_lg_srcv_t *lg_srcv;       
  size_t partial_write;             
  uint8_t read_header[8];           
  size_t partial_read;              
  coap_pdu_t *partial_pdu;          
  coap_tick_t last_rx_tx;
  coap_tick_t last_tx_rst;
  coap_tick_t last_ping;
  coap_tick_t last_pong;
  coap_tick_t csm_tx;
  coap_dtls_cpsk_t cpsk_setup_data; 
  coap_bin_const_t *psk_identity;   
  coap_bin_const_t *psk_key;        
  coap_bin_const_t *psk_hint;       
  void *app;                        
  unsigned int max_retransmit;      
  coap_fixed_point_t ack_timeout;   
  coap_fixed_point_t ack_random_factor; 
  unsigned int dtls_timeout_count;      
  int dtls_event;                       
  uint8_t block_mode;             
  uint64_t tx_token;              
};
 
struct coap_endpoint_t {
  struct coap_endpoint_t *next;
  coap_context_t *context;        
  coap_proto_t proto;             
  uint16_t default_mtu;           
  coap_socket_t sock;             
  coap_address_t bind_addr;       
  coap_session_t *sessions;       
};
 
void coap_session_send_csm(coap_session_t *session);
 
void coap_session_connected(coap_session_t *session);
 
int coap_session_refresh_psk_hint(coap_session_t *session,
                                  const coap_bin_const_t *psk_hint);
 
int coap_session_refresh_psk_key(coap_session_t *session,
                                 const coap_bin_const_t *psk_key);
 
coap_session_t *coap_new_server_session(
  coap_context_t *ctx,
  coap_endpoint_t *ep
);
 
ssize_t coap_session_send(coap_session_t *session,
  const uint8_t *data, size_t datalen);
 
ssize_t coap_session_write(coap_session_t *session,
  const uint8_t *data, size_t datalen);
 
ssize_t coap_session_send_pdu(coap_session_t *session, coap_pdu_t *pdu);
 
ssize_t
coap_session_delay_pdu(coap_session_t *session, coap_pdu_t *pdu,
                       coap_queue_t *node);
 
coap_session_t *coap_endpoint_get_session(coap_endpoint_t *endpoint,
  const coap_packet_t *packet, coap_tick_t now);
 
coap_session_t *coap_session_new_dtls_session(coap_session_t *session,
  coap_tick_t now);
 
void coap_session_free(coap_session_t *session);
void coap_session_mfree(coap_session_t *session);
 
#define SESSIONS_ADD(e, obj) \
  HASH_ADD(hh, (e), addr_hash, sizeof((obj)->addr_hash), (obj))
 
#define SESSIONS_DELETE(e, obj) \
  HASH_DELETE(hh, (e), (obj))
 
#define SESSIONS_ITER(e, el, rtmp)  \
  HASH_ITER(hh, (e), el, rtmp)
 
#define SESSIONS_ITER_SAFE(e, el, rtmp) \
for ((el) = (e); (el) && ((rtmp) = (el)->hh.next, 1); (el) = (rtmp))
 
#define SESSIONS_FIND(e, k, res) {                     \
    HASH_FIND(hh, (e), &(k), sizeof(k), (res)); \
  }
 
#endif /* COAP_SESSION_INTERNAL_H_ */