cregit-Linux how code gets into the kernel

Release 4.8 net/tipc/link.c

Directory: net/tipc
/*
 * net/tipc/link.c: TIPC link code
 *
 * Copyright (c) 1996-2007, 2012-2016, Ericsson AB
 * Copyright (c) 2004-2007, 2010-2013, Wind River Systems
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the names of the copyright holders nor the names of its
 *    contributors may be used to endorse or promote products derived from
 *    this software without specific prior written permission.
 *
 * Alternatively, this software may be distributed under the terms of the
 * GNU General Public License ("GPL") version 2 as published by the Free
 * Software Foundation.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */

#include "core.h"
#include "subscr.h"
#include "link.h"
#include "bcast.h"
#include "socket.h"
#include "name_distr.h"
#include "discover.h"
#include "netlink.h"
#include "monitor.h"

#include <linux/pkt_sched.h>


struct tipc_stats {
	
u32 sent_info;		/* used in counting # sent packets */
	
u32 recv_info;		/* used in counting # recv'd packets */
	
u32 sent_states;
	
u32 recv_states;
	
u32 sent_probes;
	
u32 recv_probes;
	
u32 sent_nacks;
	
u32 recv_nacks;
	
u32 sent_acks;
	
u32 sent_bundled;
	
u32 sent_bundles;
	
u32 recv_bundled;
	
u32 recv_bundles;
	
u32 retransmitted;
	
u32 sent_fragmented;
	
u32 sent_fragments;
	
u32 recv_fragmented;
	
u32 recv_fragments;
	
u32 link_congs;		/* # port sends blocked by congestion */
	
u32 deferred_recv;
	
u32 duplicates;
	
u32 max_queue_sz;	/* send queue size high water mark */
	
u32 accu_queue_sz;	/* used for send queue size profiling */
	
u32 queue_sz_counts;	/* used for send queue size profiling */
	
u32 msg_length_counts;	/* used for message length profiling */
	
u32 msg_lengths_total;	/* used for message length profiling */
	
u32 msg_length_profile[7]; /* used for msg. length profiling */
};

/**
 * struct tipc_link - TIPC link data structure
 * @addr: network address of link's peer node
 * @name: link name character string
 * @media_addr: media address to use when sending messages over link
 * @timer: link timer
 * @net: pointer to namespace struct
 * @refcnt: reference counter for permanent references (owner node & timer)
 * @peer_session: link session # being used by peer end of link
 * @peer_bearer_id: bearer id used by link's peer endpoint
 * @bearer_id: local bearer id used by link
 * @tolerance: minimum link continuity loss needed to reset link [in ms]
 * @abort_limit: # of unacknowledged continuity probes needed to reset link
 * @state: current state of link FSM
 * @peer_caps: bitmap describing capabilities of peer node
 * @silent_intv_cnt: # of timer intervals without any reception from peer
 * @proto_msg: template for control messages generated by link
 * @pmsg: convenience pointer to "proto_msg" field
 * @priority: current link priority
 * @net_plane: current link network plane ('A' through 'H')
 * @mon_state: cookie with information needed by link monitor
 * @backlog_limit: backlog queue congestion thresholds (indexed by importance)
 * @exp_msg_count: # of tunnelled messages expected during link changeover
 * @reset_rcv_checkpt: seq # of last acknowledged message at time of link reset
 * @mtu: current maximum packet size for this link
 * @advertised_mtu: advertised own mtu when link is being established
 * @transmitq: queue for sent, non-acked messages
 * @backlogq: queue for messages waiting to be sent
 * @snt_nxt: next sequence number to use for outbound messages
 * @last_retransmitted: sequence number of most recently retransmitted message
 * @stale_count: # of identical retransmit requests made by peer
 * @ackers: # of peers that needs to ack each packet before it can be released
 * @acked: # last packet acked by a certain peer. Used for broadcast.
 * @rcv_nxt: next sequence number to expect for inbound messages
 * @deferred_queue: deferred queue saved OOS b'cast message received from node
 * @unacked_window: # of inbound messages rx'd without ack'ing back to peer
 * @inputq: buffer queue for messages to be delivered upwards
 * @namedq: buffer queue for name table messages to be delivered upwards
 * @next_out: ptr to first unsent outbound message in queue
 * @wakeupq: linked list of wakeup msgs waiting for link congestion to abate
 * @long_msg_seq_no: next identifier to use for outbound fragmented messages
 * @reasm_buf: head of partially reassembled inbound message fragments
 * @bc_rcvr: marks that this is a broadcast receiver link
 * @stats: collects statistics regarding link activity
 */

struct tipc_link {
	
u32 addr;
	
char name[TIPC_MAX_LINK_NAME];
	
struct net *net;

	/* Management and link supervision data */
	
u32 peer_session;
	
u32 session;
	
u32 peer_bearer_id;
	
u32 bearer_id;
	
u32 tolerance;
	
u32 abort_limit;
	
u32 state;
	
u16 peer_caps;
	
bool active;
	
u32 silent_intv_cnt;
	
char if_name[TIPC_MAX_IF_NAME];
	
u32 priority;
	
char net_plane;
	
struct tipc_mon_state mon_state;
	
u16 rst_cnt;

	/* Failover/synch */
	
u16 drop_point;
	
struct sk_buff *failover_reasm_skb;

	/* Max packet negotiation */
	
u16 mtu;
	
u16 advertised_mtu;

	/* Sending */
	
struct sk_buff_head transmq;
	
struct sk_buff_head backlogq;
	struct {
		
u16 len;
		
u16 limit;
	} 
backlog[5];
	
u16 snd_nxt;
	
u16 last_retransm;
	
u16 window;
	
u32 stale_count;

	/* Reception */
	
u16 rcv_nxt;
	
u32 rcv_unacked;
	
struct sk_buff_head deferdq;
	
struct sk_buff_head *inputq;
	
struct sk_buff_head *namedq;

	/* Congestion handling */
	
struct sk_buff_head wakeupq;

	/* Fragmentation/reassembly */
	
struct sk_buff *reasm_buf;

	/* Broadcast */
	
u16 ackers;
	
u16 acked;
	
struct tipc_link *bc_rcvlink;
	
struct tipc_link *bc_sndlink;
	
int nack_state;
	
bool bc_peer_is_up;

	/* Statistics */
	
struct tipc_stats stats;
};

/*
 * Error message prefixes
 */

static const char *link_co_err = "Link tunneling error, ";

static const char *link_rst_msg = "Resetting link ";

/* Send states for broadcast NACKs
 */
enum {
	
BC_NACK_SND_CONDITIONAL,
	
BC_NACK_SND_UNCONDITIONAL,
	
BC_NACK_SND_SUPPRESS,
};

/*
 * Interval between NACKs when packets arrive out of order
 */

#define TIPC_NACK_INTV (TIPC_MIN_LINK_WIN * 2)

/* Wildcard value for link session numbers. When it is known that
 * peer endpoint is down, any session number must be accepted.
 */

#define ANY_SESSION 0x10000

/* Link FSM states:
 */
enum {
	
LINK_ESTABLISHED     = 0xe,
	
LINK_ESTABLISHING    = 0xe  << 4,
	
LINK_RESET           = 0x1  << 8,
	
LINK_RESETTING       = 0x2  << 12,
	
LINK_PEER_RESET      = 0xd  << 16,
	
LINK_FAILINGOVER     = 0xf  << 20,
	
LINK_SYNCHING        = 0xc  << 24
};

/* Link FSM state checking routines
 */

static int link_is_up(struct tipc_link *l) { return l->state & (LINK_ESTABLISHED | LINK_SYNCHING); }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy22100.00%2100.00%
Total22100.00%2100.00%

static int tipc_link_proto_rcv(struct tipc_link *l, struct sk_buff *skb, struct sk_buff_head *xmitq); static void tipc_link_build_proto_msg(struct tipc_link *l, int mtyp, bool probe, u16 rcvgap, int tolerance, int priority, struct sk_buff_head *xmitq); static void link_print(struct tipc_link *l, const char *str); static void tipc_link_build_nack_msg(struct tipc_link *l, struct sk_buff_head *xmitq); static void tipc_link_build_bc_init_msg(struct tipc_link *l, struct sk_buff_head *xmitq); static bool tipc_link_release_pkts(struct tipc_link *l, u16 to); /* * Simple non-static link routines (i.e. referenced outside this file) */
bool tipc_link_is_up(struct tipc_link *l) { return link_is_up(l); }

Contributors

PersonTokensPropCommitsCommitProp
per lidenper liden1168.75%250.00%
jon paul maloyjon paul maloy425.00%125.00%
paul gortmakerpaul gortmaker16.25%125.00%
Total16100.00%4100.00%


bool tipc_link_peer_is_down(struct tipc_link *l) { return l->state == LINK_PEER_RESET; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy17100.00%1100.00%
Total17100.00%1100.00%


bool tipc_link_is_reset(struct tipc_link *l) { return l->state & (LINK_RESET | LINK_FAILINGOVER | LINK_ESTABLISHING); }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy23100.00%1100.00%
Total23100.00%1100.00%


bool tipc_link_is_establishing(struct tipc_link *l) { return l->state == LINK_ESTABLISHING; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy17100.00%1100.00%
Total17100.00%1100.00%


bool tipc_link_is_synching(struct tipc_link *l) { return l->state == LINK_SYNCHING; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy17100.00%1100.00%
Total17100.00%1100.00%


bool tipc_link_is_failingover(struct tipc_link *l) { return l->state == LINK_FAILINGOVER; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy17100.00%1100.00%
Total17100.00%1100.00%


bool tipc_link_is_blocked(struct tipc_link *l) { return l->state & (LINK_RESETTING | LINK_PEER_RESET | LINK_FAILINGOVER); }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy23100.00%1100.00%
Total23100.00%1100.00%


static bool link_is_bc_sndlink(struct tipc_link *l) { return !l->bc_sndlink; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy1694.12%150.00%
fengguang wufengguang wu15.88%150.00%
Total17100.00%2100.00%


static bool link_is_bc_rcvlink(struct tipc_link *l) { return ((l->bc_rcvlink == l) && !link_is_bc_sndlink(l)); }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy2796.43%150.00%
fengguang wufengguang wu13.57%150.00%
Total28100.00%2100.00%


int tipc_link_is_active(struct tipc_link *l) { return l->active; }

Contributors

PersonTokensPropCommitsCommitProp
per lidenper liden853.33%240.00%
jon paul maloyjon paul maloy640.00%240.00%
paul gortmakerpaul gortmaker16.67%120.00%
Total15100.00%5100.00%


void tipc_link_set_active(struct tipc_link *l, bool active) { l->active = active; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy1894.74%266.67%
per lidenper liden15.26%133.33%
Total19100.00%3100.00%


u32 tipc_link_id(struct tipc_link *l) { return l->peer_bearer_id << 16 | l->bearer_id; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy21100.00%2100.00%
Total21100.00%2100.00%


int tipc_link_window(struct tipc_link *l) { return l->window; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy15100.00%3100.00%
Total15100.00%3100.00%


int tipc_link_prio(struct tipc_link *l) { return l->priority; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy15100.00%3100.00%
Total15100.00%3100.00%


unsigned long tipc_link_tolerance(struct tipc_link *l) { return l->tolerance; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy16100.00%2100.00%
Total16100.00%2100.00%


struct sk_buff_head *tipc_link_inputq(struct tipc_link *l) { return l->inputq; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy17100.00%2100.00%
Total17100.00%2100.00%


char tipc_link_plane(struct tipc_link *l) { return l->net_plane; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy15100.00%1100.00%
Total15100.00%1100.00%


void tipc_link_add_bc_peer(struct tipc_link *snd_l, struct tipc_link *uc_l, struct sk_buff_head *xmitq) { struct tipc_link *rcv_l = uc_l->bc_rcvlink; snd_l->ackers++; rcv_l->acked = snd_l->snd_nxt - 1; snd_l->state = LINK_ESTABLISHED; tipc_link_build_bc_init_msg(uc_l, xmitq); }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy57100.00%2100.00%
Total57100.00%2100.00%


void tipc_link_remove_bc_peer(struct tipc_link *snd_l, struct tipc_link *rcv_l, struct sk_buff_head *xmitq) { u16 ack = snd_l->snd_nxt - 1; snd_l->ackers--; rcv_l->bc_peer_is_up = true; rcv_l->state = LINK_ESTABLISHED; tipc_link_bc_ack_rcv(rcv_l, ack, xmitq); tipc_link_reset(rcv_l); rcv_l->state = LINK_RESET; if (!snd_l->ackers) { tipc_link_reset(snd_l); snd_l->state = LINK_RESET; __skb_queue_purge(xmitq); } }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy91100.00%5100.00%
Total91100.00%5100.00%


int tipc_link_bc_peers(struct tipc_link *l) { return l->ackers; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy15100.00%1100.00%
Total15100.00%1100.00%


void tipc_link_set_mtu(struct tipc_link *l, int mtu) { l->mtu = mtu; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy19100.00%1100.00%
Total19100.00%1100.00%


int tipc_link_mtu(struct tipc_link *l) { return l->mtu; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy15100.00%1100.00%
Total15100.00%1100.00%


u16 tipc_link_rcv_nxt(struct tipc_link *l) { return l->rcv_nxt; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy15100.00%1100.00%
Total15100.00%1100.00%


u16 tipc_link_acked(struct tipc_link *l) { return l->acked; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy15100.00%1100.00%
Total15100.00%1100.00%


char *tipc_link_name(struct tipc_link *l) { return l->name; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy16100.00%1100.00%
Total16100.00%1100.00%

/** * tipc_link_create - create a new link * @n: pointer to associated node * @if_name: associated interface name * @bearer_id: id (index) of associated bearer * @tolerance: link tolerance to be used by link * @net_plane: network plane (A,B,c..) this link belongs to * @mtu: mtu to be advertised by link * @priority: priority to be used by link * @window: send window to be used by link * @session: session to be used by link * @ownnode: identity of own node * @peer: node id of peer node * @peer_caps: bitmap describing peer node capabilities * @bc_sndlink: the namespace global link used for broadcast sending * @bc_rcvlink: the peer specific link used for broadcast reception * @inputq: queue to put messages ready for delivery * @namedq: queue to put binding table update messages ready for delivery * @link: return value, pointer to put the created link * * Returns true if link was created, otherwise false */
bool tipc_link_create(struct net *net, char *if_name, int bearer_id, int tolerance, char net_plane, u32 mtu, int priority, int window, u32 session, u32 ownnode, u32 peer, u16 peer_caps, struct tipc_link *bc_sndlink, struct tipc_link *bc_rcvlink, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link **link) { struct tipc_link *l; l = kzalloc(sizeof(*l), GFP_ATOMIC); if (!l) return false; *link = l; l->session = session; /* Note: peer i/f name is completed by reset/activate message */ sprintf(l->name, "%u.%u.%u:%s-%u.%u.%u:unknown", tipc_zone(ownnode), tipc_cluster(ownnode), tipc_node(ownnode), if_name, tipc_zone(peer), tipc_cluster(peer), tipc_node(peer)); strcpy(l->if_name, if_name); l->addr = peer; l->peer_caps = peer_caps; l->net = net; l->peer_session = ANY_SESSION; l->bearer_id = bearer_id; l->tolerance = tolerance; l->net_plane = net_plane; l->advertised_mtu = mtu; l->mtu = mtu; l->priority = priority; tipc_link_set_queue_limits(l, window); l->ackers = 1; l->bc_sndlink = bc_sndlink; l->bc_rcvlink = bc_rcvlink; l->inputq = inputq; l->namedq = namedq; l->state = LINK_RESETTING; __skb_queue_head_init(&l->transmq); __skb_queue_head_init(&l->backlogq); __skb_queue_head_init(&l->deferdq); skb_queue_head_init(&l->wakeupq); skb_queue_head_init(l->inputq); return true; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy21069.31%1460.87%
per lidenper liden7123.43%14.35%
ying xueying xue123.96%313.04%
allan stephensallan stephens82.64%313.04%
richard alperichard alpe10.33%14.35%
panagiotis issaris*panagiotis issaris*10.33%14.35%
Total303100.00%23100.00%

/** * tipc_link_bc_create - create new link to be used for broadcast * @n: pointer to associated node * @mtu: mtu to be used * @window: send window to be used * @inputq: queue to put messages ready for delivery * @namedq: queue to put binding table update messages ready for delivery * @link: return value, pointer to put the created link * * Returns true if link was created, otherwise false */
bool tipc_link_bc_create(struct net *net, u32 ownnode, u32 peer, int mtu, int window, u16 peer_caps, struct sk_buff_head *inputq, struct sk_buff_head *namedq, struct tipc_link *bc_sndlink, struct tipc_link **link) { struct tipc_link *l; if (!tipc_link_create(net, "", MAX_BEARERS, 0, 'Z', mtu, 0, window, 0, ownnode, peer, peer_caps, bc_sndlink, NULL, inputq, namedq, link)) return false; l = *link; strcpy(l->name, tipc_bclink_name); tipc_link_reset(l); l->state = LINK_RESET; l->ackers = 0; l->bc_rcvlink = l; /* Broadcast send link is always up */ if (link_is_bc_sndlink(l)) l->state = LINK_ESTABLISHED; return true; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy148100.00%5100.00%
Total148100.00%5100.00%

/** * tipc_link_fsm_evt - link finite state machine * @l: pointer to link * @evt: state machine event to be processed */
int tipc_link_fsm_evt(struct tipc_link *l, int evt) { int rc = 0; switch (l->state) { case LINK_RESETTING: switch (evt) { case LINK_PEER_RESET_EVT: l->state = LINK_PEER_RESET; break; case LINK_RESET_EVT: l->state = LINK_RESET; break; case LINK_FAILURE_EVT: case LINK_FAILOVER_BEGIN_EVT: case LINK_ESTABLISH_EVT: case LINK_FAILOVER_END_EVT: case LINK_SYNCH_BEGIN_EVT: case LINK_SYNCH_END_EVT: default: goto illegal_evt; } break; case LINK_RESET: switch (evt) { case LINK_PEER_RESET_EVT: l->state = LINK_ESTABLISHING; break; case LINK_FAILOVER_BEGIN_EVT: l->state = LINK_FAILINGOVER; case LINK_FAILURE_EVT: case LINK_RESET_EVT: case LINK_ESTABLISH_EVT: case LINK_FAILOVER_END_EVT: break; case LINK_SYNCH_BEGIN_EVT: case LINK_SYNCH_END_EVT: default: goto illegal_evt; } break; case LINK_PEER_RESET: switch (evt) { case LINK_RESET_EVT: l->state = LINK_ESTABLISHING; break; case LINK_PEER_RESET_EVT: case LINK_ESTABLISH_EVT: case LINK_FAILURE_EVT: break; case LINK_SYNCH_BEGIN_EVT: case LINK_SYNCH_END_EVT: case LINK_FAILOVER_BEGIN_EVT: case LINK_FAILOVER_END_EVT: default: goto illegal_evt; } break; case LINK_FAILINGOVER: switch (evt) { case LINK_FAILOVER_END_EVT: l->state = LINK_RESET; break; case LINK_PEER_RESET_EVT: case LINK_RESET_EVT: case LINK_ESTABLISH_EVT: case LINK_FAILURE_EVT: break; case LINK_FAILOVER_BEGIN_EVT: case LINK_SYNCH_BEGIN_EVT: case LINK_SYNCH_END_EVT: default: goto illegal_evt; } break; case LINK_ESTABLISHING: switch (evt) { case LINK_ESTABLISH_EVT: l->state = LINK_ESTABLISHED; break; case LINK_FAILOVER_BEGIN_EVT: l->state = LINK_FAILINGOVER; break; case LINK_RESET_EVT: l->state = LINK_RESET; break; case LINK_FAILURE_EVT: case LINK_PEER_RESET_EVT: case LINK_SYNCH_BEGIN_EVT: case LINK_FAILOVER_END_EVT: break; case LINK_SYNCH_END_EVT: default: goto illegal_evt; } break; case LINK_ESTABLISHED: switch (evt) { case LINK_PEER_RESET_EVT: l->state = LINK_PEER_RESET; rc |= TIPC_LINK_DOWN_EVT; break; case LINK_FAILURE_EVT: l->state = LINK_RESETTING; rc |= TIPC_LINK_DOWN_EVT; break; case LINK_RESET_EVT: l->state = LINK_RESET; break; case LINK_ESTABLISH_EVT: case LINK_SYNCH_END_EVT: break; case LINK_SYNCH_BEGIN_EVT: l->state = LINK_SYNCHING; break; case LINK_FAILOVER_BEGIN_EVT: case LINK_FAILOVER_END_EVT: default: goto illegal_evt; } break; case LINK_SYNCHING: switch (evt) { case LINK_PEER_RESET_EVT: l->state = LINK_PEER_RESET; rc |= TIPC_LINK_DOWN_EVT; break; case LINK_FAILURE_EVT: l->state = LINK_RESETTING; rc |= TIPC_LINK_DOWN_EVT; break; case LINK_RESET_EVT: l->state = LINK_RESET; break; case LINK_ESTABLISH_EVT: case LINK_SYNCH_BEGIN_EVT: break; case LINK_SYNCH_END_EVT: l->state = LINK_ESTABLISHED; break; case LINK_FAILOVER_BEGIN_EVT: case LINK_FAILOVER_END_EVT: default: goto illegal_evt; } break; default: pr_err("Unknown FSM state %x in %s\n", l->state, l->name); } return rc; illegal_evt: pr_err("Illegal FSM event %x in state %x on link %s\n", evt, l->state, l->name); return rc; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy45797.44%1184.62%
per lidenper liden112.35%17.69%
ying xueying xue10.21%17.69%
Total469100.00%13100.00%

/* link_profile_stats - update statistical profiling of traffic */
static void link_profile_stats(struct tipc_link *l) { struct sk_buff *skb; struct tipc_msg *msg; int length; /* Update counters used in statistical profiling of send traffic */ l->stats.accu_queue_sz += skb_queue_len(&l->transmq); l->stats.queue_sz_counts++; skb = skb_peek(&l->transmq); if (!skb) return; msg = buf_msg(skb); length = msg_size(msg); if (msg_user(msg) == MSG_FRAGMENTER) { if (msg_type(msg) != FIRST_FRAGMENT) return; length = msg_size(msg_get_wrapped(msg)); } l->stats.msg_lengths_total += length; l->stats.msg_length_counts++; if (length <= 64) l->stats.msg_length_profile[0]++; else if (length <= 256) l->stats.msg_length_profile[1]++; else if (length <= 1024) l->stats.msg_length_profile[2]++; else if (length <= 4096) l->stats.msg_length_profile[3]++; else if (length <= 16384) l->stats.msg_length_profile[4]++; else if (length <= 32768) l->stats.msg_length_profile[5]++; else l->stats.msg_length_profile[6]++; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy23098.29%375.00%
per lidenper liden41.71%125.00%
Total234100.00%4100.00%

/* tipc_link_timeout - perform periodic task as instructed from node timeout */
int tipc_link_timeout(struct tipc_link *l, struct sk_buff_head *xmitq) { int mtyp = 0; int rc = 0; bool state = false; bool probe = false; bool setup = false; u16 bc_snt = l->bc_sndlink->snd_nxt - 1; u16 bc_acked = l->bc_rcvlink->acked; struct tipc_mon_state *mstate = &l->mon_state; switch (l->state) { case LINK_ESTABLISHED: case LINK_SYNCHING: mtyp = STATE_MSG; link_profile_stats(l); tipc_mon_get_state(l->net, l->addr, mstate, l->bearer_id); if (mstate->reset || (l->silent_intv_cnt > l->abort_limit)) return tipc_link_fsm_evt(l, LINK_FAILURE_EVT); state = bc_acked != bc_snt; state |= l->bc_rcvlink->rcv_unacked; state |= l->rcv_unacked; state |= !skb_queue_empty(&l->transmq); state |= !skb_queue_empty(&l->deferdq); probe = mstate->probing; probe |= l->silent_intv_cnt; if (probe || mstate->monitoring) l->silent_intv_cnt++; break; case LINK_RESET: setup = l->rst_cnt++ <= 4; setup |= !(l->rst_cnt % 16); mtyp = RESET_MSG; break; case LINK_ESTABLISHING: setup = true; mtyp = ACTIVATE_MSG; break; case LINK_PEER_RESET: case LINK_RESETTING: case LINK_FAILINGOVER: break; default: break; } if (state || probe || setup) tipc_link_build_proto_msg(l, mtyp, probe, 0, 0, 0, xmitq); return rc; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy27898.58%1090.91%
ying xueying xue41.42%19.09%
Total282100.00%11100.00%

/** * link_schedule_user - schedule a message sender for wakeup after congestion * @link: congested link * @list: message that was attempted sent * Create pseudo msg to send back to user when congestion abates * Does not consume buffer list */
static int link_schedule_user(struct tipc_link *link, struct sk_buff_head *list) { struct tipc_msg *msg = buf_msg(skb_peek(list)); int imp = msg_importance(msg); u32 oport = msg_origport(msg); u32 addr = tipc_own_addr(link->net); struct sk_buff *skb; /* This really cannot happen... */ if (unlikely(imp > TIPC_CRITICAL_IMPORTANCE)) { pr_warn("%s<%s>, send queue full", link_rst_msg, link->name); return -ENOBUFS; } /* Non-blocking sender: */ if (TIPC_SKB_CB(skb_peek(list))->wakeup_pending) return -ELINKCONG; /* Create and schedule wakeup pseudo message */ skb = tipc_msg_create(SOCK_WAKEUP, 0, INT_H_SIZE, 0, addr, addr, oport, 0, 0); if (!skb) return -ENOBUFS; TIPC_SKB_CB(skb)->chain_sz = skb_queue_len(list); TIPC_SKB_CB(skb)->chain_imp = imp; skb_queue_tail(&link->wakeupq, skb); link->stats.link_congs++; return -ELINKCONG; }

Contributors

PersonTokensPropCommitsCommitProp
jon paul maloyjon paul maloy13977.65%654.55%
per lidenper liden3217.88%19.09%
allan stephensallan stephens42.23%19.09%
ying xueying xue31.68%218.18%
paul gortmakerpaul gortmaker10.56%19.09%
Total179100.00%11100.00%

/** * link_prepare_wakeup - prepare users for wakeup after congestion * @link: congested link * Move a number of waiting users, as permitted by available space in * the send queue, from link wait queue to node wait queue for wakeup */
void link_prepare_wakeup(struct tipc_link *l) { int pnd[TIPC_SYSTEM_IMPORTANCE + 1] = {0,}; int imp, lim; struct sk_buff *skb, *tmp; skb_queue_walk_safe(&l->wakeupq, skb, tmp) { imp = TIPC_SKB_CB(skb)->chain_imp; lim = l->window + l->backlog[imp].limit; pnd[imp] += TIPC_SKB_CB(skb)->chain_sz; if ((pnd[imp] + l->backlog[imp].len) >= lim) break; skb_unlink(skb,