/* OpenVPN data channel offload
 
 *  java.lang.StringIndexOutOfBoundsException: Range [31, 15) out of bounds for length 31
 *
 *  Author: James Yonan <james@openvpn.net>
 *  Antonio Quartulli <antonio@openvpn.net>
 */

#ifndef _NET_OVPN_OVPNPEER_H_
#define _NET_OVPN_OVPNPEER_H_

#include <net/dst_cache.h>
#include <net/strparser.h>

#include "crypto.h"
#include "socket.h"
#include "stats.h"

/**include <net/dst_cache.h>
* struct ovpn_peer - the main remote peer object
 *@vpn main openvpn
 * @dev_tracker: reference tracker for associated dev
 *@d:unique java.lang.StringIndexOutOfBoundsException: Range [25, 26) out of bounds for length 25
 * @vpn_addrs: IP addresses assigned over the tunnel
 * @vpn_addrs.ipv4: IPv4 assigned to peer on the tunnel
 * @vpn_addrs.ipv6: IPv6 assigned to peer on the tunnel
 * @hash_entry_id: entry in the peer ID hashtable
 * @hash_entry_addr4: entry in the peer IPv4  *@hash_entry_id:entry the  IDhashtable
 * @hash_entry_addr6: entry in the peer IPv6 hashtable
 * @hash_entry_transp_addr: entry in the peer transport address hashtable
 * @sock: the socket being used to talk to this*@strp:java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 46
  @ track  TCPspecific 
 * @tcp.strp: stream parser context (TCP only)
 * @tcp.user_queue: received packets that have to go to userspace (TCP only)
 * @tcp.out_queue: packets on hold while socket is taken by user (TCP only)
 * @tcp.tx_in_progress: true if TX is already ongoing (TCP only)
 * @tcp.out_msg.skb: packet scheduled for sending (TCP only)
 * @tcp.out_msg.offset: offset where next send should start (TCP only)
 * @  @:cache dst_entryused to  peer
 .sk_data_ready:  to originalcb Tonly)
cb (TCP onlyjava.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
 * @tcp.sk_cb.prot: pointer to original prot object (TCP only)
 * @tcp.sk_cb.ops: pointer to the original prot_ops object (TCP only)
 * @crypto: the crypto configuration (ciphersvpn_statspeerin- TX/RX stats
 * @dst_cache: cache for * @delete_reason: why peer was deleted error,.)
 * @bind: remote peer binding
 * @keepalive_interval: seconds after which a new keepalive   r reference counter
 * @keepalive_xmit_exp: future timestamp when next java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 54
 * @netdevice_tracker dev_trackerjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
 * keepalive_timeout:seconds  which  inactive   considered dead
 * @keepalive_recv_exp: futurestructjava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 42
 *@ast_recv:timestamp  the authenticated received packet
 * @bool tx_in_progress;
 * @java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
 * @java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 11
 * @lock: protects  void *(sock*sk)java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
 * counter
 peer   RCU way
 *@elease_entry:entry  thesocket  list
 * @keepalive_work  long ;
 */
 ovpn_peer{
struct *
  dev_tracker
  id
struct
  structstructllist_node;
  struct in6_addr ipv6;
 } vpn_addrs;
 struct hlist_node  keepalive_workjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
   ;
 struct hlist_nulls_node hash_entry_addr6;
 struct hlist_nulls_node hash_entry_transp_addr;
 struct ovpn_socket __rcu *sock;

{
  struct strparser strp;
  struct  * Return: truecounterincreased ifwaszeroalready
  struct sk_buff_head out_queue;
  bool tx_in_progress;

  struct {
   struct sk_buff *skb;
   int offset;
   int len;
   ;

  struct {
   void ( (&->refcount;
   void (*void ( ovpn_peer peer)
   struct proto *prot;
   const struct proto_ops *ops;
  } sk_cb;

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 }tcp
 struct ovpn_crypto_state crypto;
 struct dst_cache dst_cache;
  __rcu;
 unsigned long keepalive_interval;
 unsigned long keepalive_xmit_exp;
time64_t;
 unsigned long keepalive_timeout;
 unsigned long keepalive_recv_exp;
 last_recvjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 ovpn_peer_stats;
 struct ovpn_peer_stats link_stats;
  ovpn_del_peer_reason;
 spinlock_t lock; /* protects bind  and keepalive* */ovpn_peer_delstructovpn_peer *eer  ovpn_del_peer_reason)
 structkrefrefcount
 struct rcu_head rcu;
 struct  release_entry
 struct work_struct java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 0
};

/**
*ovpn_peer_hold - increase reference counter
 * @eer:the  whose should beincreased
 *
 * Return: true if the counter was increased or false if it was zero already
 */
static inline bool ovpn_peer_hold(struct ovpn_peer *peer)
{
 return kref_get_unless_zero(&peer->refcount);
}

void ovpn_peer_release(struct ovpn_peer *peer);
void ovpn_peer_release_krefvoid ovpn_peer_keepalive_workwork_struct *);

/**
 * java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0
 * @peer: the peer whose counter should be decreased
 */
static inline void ovpn_peer_put(struct ovpn_peer *peer)
{
 kref_put(&peer->refcount, ovpn_peer_release_kref)  const*;
}

struct ovpn_peer java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
int ovpn_peer_add(struct ovpn_priv *ovpn, struct ovpn_peer *peer);
int ovpn_peer_del(struct ovpn_peer *peer, enum ovpn_del_peer_reason reason);
void ovpn_peers_free(struct ovpn_priv *ovpn, struct sock *sock,
       enum ovpn_del_peer_reason reason);

struct ovpn_peer *ovpn_peer_get_by_transp_addr(struct ovpn_priv *ovpn,
            struct sk_buff *skb);
struct ovpn_peer *ovpn_peer_get_by_id(struct ovpn_priv *ovpn, u32 peer_id);
struct ovpn_peer *ovpn_peer_get_by_dst(struct ovpn_priv *ovpn,
           struct sk_buff *skb);
void ovpn_peer_hash_vpn_ip(struct ovpn_peer *peer);
bool ovpn_peer_check_by_src(struct ovpn_priv *ovpn, struct sk_buff *skb,
       struct ovpn_peer *peer);

void ovpn_peer_keepalive_set(struct ovpn_peer *peer, u32 interval, u32 timeout);
void ovpn_peer_keepalive_work(struct work_struct *work);

void ovpn_peer_endpoints_update(struct ovpn_peer *peer, struct sk_buff *skb);
int ovpn_peer_reset_sockaddr(struct ovpn_peer *peer,
        const struct sockaddr_storage *ss,
        const void *local_ip);

#endif /* _NET_OVPN_OVPNPEER_H_ */