/titanic_44/usr/src/uts/common/inet/tcp/ |
H A D | tcp_timers.c | 140 tcp_t *tcp = connp->conn_tcp; in tcp_timeout() local 144 TCP_DBGSTAT(tcp->tcp_tcps, tcp_timeout_calls); in tcp_timeout() 146 if (tcp->tcp_timercache == NULL) { in tcp_timeout() 149 TCP_DBGSTAT(tcp->tcp_tcps, tcp_timeout_cached_alloc); in tcp_timeout() 150 mp = tcp->tcp_timercache; in tcp_timeout() 151 tcp->tcp_timercache = mp->b_next; in tcp_timeout() 194 tcp_t *tcp = connp->conn_tcp; in tcp_timer_handler() local 215 if (tcp->tcp_state != TCPS_CLOSED) { in tcp_timer_handler() 218 tcp->tcp_timer_tid = 0; in tcp_timer_handler() 331 tcp_timermp_free(tcp_t *tcp) in tcp_timermp_free() argument [all …]
|
H A D | tcp.c | 280 static int tcp_connect_ipv4(tcp_t *tcp, ipaddr_t *dstaddrp, 282 static int tcp_connect_ipv6(tcp_t *tcp, in6_addr_t *dstaddrp, 285 static void tcp_iss_init(tcp_t *tcp); 286 static void tcp_reinit(tcp_t *tcp); 287 static void tcp_reinit_values(tcp_t *tcp); 290 static void tcp_update_lso(tcp_t *tcp, ip_xmit_attr_t *ixa); 291 static void tcp_update_zcopy(tcp_t *tcp); 422 tcp_set_recv_threshold(tcp_t *tcp, uint32_t new_rcvthresh) in tcp_set_recv_threshold() argument 426 if (IPCL_IS_NONSTR(tcp->tcp_connp)) { in tcp_set_recv_threshold() 427 conn_t *connp = tcp->tcp_connp; in tcp_set_recv_threshold() [all …]
|
H A D | tcp_input.c | 84 #define TCP_IS_DETACHED_NONEAGER(tcp) \ argument 85 (TCP_IS_DETACHED(tcp) && \ 86 (!(tcp)->tcp_hard_binding)) 115 #define SET_TIME_WAIT(tcps, tcp, connp) \ argument 117 (tcp)->tcp_state = TCPS_TIME_WAIT; \ 118 if ((tcp)->tcp_listen_cnt != NULL) \ 119 TCP_DECR_LISTEN_CNT(tcp); \ 123 if (!TCP_IS_DETACHED(tcp)) { \ 124 TCP_TIMER_RESTART(tcp, (tcps)->tcps_time_wait_interval); \ 126 tcp_time_wait_append(tcp); \ [all …]
|
H A D | tcp_time_wait.c | 59 tcp_time_wait_remove(tcp_t *tcp, tcp_squeue_priv_t *tcp_time_wait) in tcp_time_wait_remove() argument 65 squeue_getprivate(tcp->tcp_connp->conn_sqp, SQPRIVATE_TCP)); in tcp_time_wait_remove() 73 if (tcp->tcp_time_wait_expire == 0) { in tcp_time_wait_remove() 74 ASSERT(tcp->tcp_time_wait_next == NULL); in tcp_time_wait_remove() 75 ASSERT(tcp->tcp_time_wait_prev == NULL); in tcp_time_wait_remove() 80 ASSERT(TCP_IS_DETACHED(tcp)); in tcp_time_wait_remove() 81 ASSERT(tcp->tcp_state == TCPS_TIME_WAIT); in tcp_time_wait_remove() 83 if (tcp == tcp_time_wait->tcp_time_wait_head) { in tcp_time_wait_remove() 84 ASSERT(tcp->tcp_time_wait_prev == NULL); in tcp_time_wait_remove() 85 tcp_time_wait->tcp_time_wait_head = tcp->tcp_time_wait_next; in tcp_time_wait_remove() [all …]
|
H A D | tcp_output.c | 58 static void tcp_wput_iocdata(tcp_t *tcp, mblk_t *mp); 87 tcp_t *tcp; in tcp_wput() local 98 tcp = connp->conn_tcp; in tcp_wput() 99 ASSERT(tcp != NULL); in tcp_wput() 103 mutex_enter(&tcp->tcp_non_sq_lock); in tcp_wput() 104 tcp->tcp_squeue_bytes += size; in tcp_wput() 105 if (TCP_UNSENT_BYTES(tcp) > connp->conn_sndbuf) { in tcp_wput() 106 tcp_setqfull(tcp); in tcp_wput() 108 mutex_exit(&tcp->tcp_non_sq_lock); in tcp_wput() 124 tcp = connp->conn_tcp; in tcp_wput() [all …]
|
H A D | tcp_fusion.c | 82 tcp_fuse(tcp_t *tcp, uchar_t *iphdr, tcpha_t *tcpha) in tcp_fuse() argument 84 conn_t *peer_connp, *connp = tcp->tcp_connp; in tcp_fuse() 86 tcp_stack_t *tcps = tcp->tcp_tcps; in tcp_fuse() 90 ASSERT(!tcp->tcp_fused); in tcp_fuse() 91 ASSERT(tcp->tcp_loopback); in tcp_fuse() 92 ASSERT(tcp->tcp_loopback_peer == NULL); in tcp_fuse() 103 ASSERT(tcp->tcp_saved_listener != NULL); in tcp_fuse() 140 ASSERT(peer_tcp != NULL && peer_tcp != tcp && !peer_tcp->tcp_fused); in tcp_fuse() 160 if (!tcp->tcp_unfusable && !peer_tcp->tcp_unfusable && in tcp_fuse() 161 tcp->tcp_xmit_head == NULL && peer_tcp->tcp_xmit_head == NULL) { in tcp_fuse() [all …]
|
H A D | tcp_opt_data.c | 364 tcp_t *tcp = connp->conn_tcp; in tcp_opt_get() local 378 *i1 = tcp->tcp_snd_zcopy_on ? in tcp_opt_get() 382 *i1 = (tcp->tcp_state == TCPS_LISTEN); in tcp_opt_get() 389 *i1 = (tcp->tcp_naglim == 1) ? TCP_NODELAY : 0; in tcp_opt_get() 392 *i1 = tcp->tcp_mss; in tcp_opt_get() 395 *i1 = (int)tcp->tcp_first_timer_threshold; in tcp_opt_get() 398 *i1 = tcp->tcp_second_timer_threshold; in tcp_opt_get() 401 *i1 = tcp->tcp_first_ctimer_threshold; in tcp_opt_get() 404 *i1 = tcp->tcp_second_ctimer_threshold; in tcp_opt_get() 407 *i1 = tcp->tcp_init_cwnd; in tcp_opt_get() [all …]
|
H A D | tcp_tpi.c | 51 tcp_use_pure_tpi(tcp_t *tcp) in tcp_use_pure_tpi() argument 53 conn_t *connp = tcp->tcp_connp; in tcp_use_pure_tpi() 56 tcp->tcp_acceptor_id = (t_uscalar_t)connp->conn_rq; in tcp_use_pure_tpi() 58 tcp->tcp_acceptor_id = connp->conn_dev; in tcp_use_pure_tpi() 64 tcp_acceptor_hash_insert(tcp->tcp_acceptor_id, tcp); in tcp_use_pure_tpi() 66 tcp->tcp_issocket = B_FALSE; in tcp_use_pure_tpi() 67 TCP_STAT(tcp->tcp_tcps, tcp_sock_fallback); in tcp_use_pure_tpi() 72 tcp_err_ack(tcp_t *tcp, mblk_t *mp, int t_error, int sys_error) in tcp_err_ack() argument 75 putnext(tcp->tcp_connp->conn_rq, mp); in tcp_err_ack() 80 tcp_err_ack_prim(tcp_t *tcp, mblk_t *mp, int primitive, in tcp_err_ack_prim() argument [all …]
|
H A D | tcp_socket.c | 241 tcp_t *tcp = connp->conn_tcp; in tcp_listen() local 263 (uintptr_t)(tcp->tcp_conn_req_max + in tcp_listen() 264 tcp->tcp_tcps->tcps_conn_req_max_q0)); in tcp_listen() 346 tcp_t *tcp = connp->conn_tcp; in tcp_getpeername() local 351 ASSERT(tcp != NULL); in tcp_getpeername() 352 if (tcp->tcp_state < TCPS_SYN_RCVD) in tcp_getpeername() 484 tcp_t *tcp; in tcp_sendmsg() local 502 tcp = connp->conn_tcp; in tcp_sendmsg() 503 ASSERT(tcp != NULL); in tcp_sendmsg() 505 tcpstate = tcp->tcp_state; in tcp_sendmsg() [all …]
|
H A D | tcp_bind.c | 68 tcp_bind_hash_insert(tf_t *tbf, tcp_t *tcp, int caller_holds_lock) in tcp_bind_hash_insert() argument 73 conn_t *connp = tcp->tcp_connp; in tcp_bind_hash_insert() 76 if (tcp->tcp_ptpbhn != NULL) { in tcp_bind_hash_insert() 78 tcp_bind_hash_remove(tcp); in tcp_bind_hash_insert() 124 tcpnext->tcp_ptpbhn = &tcp->tcp_bind_hash_port; in tcp_bind_hash_insert() 128 &(tcp->tcp_bind_hash); in tcp_bind_hash_insert() 133 tcpnext->tcp_ptpbhn = &tcp->tcp_bind_hash_port; in tcp_bind_hash_insert() 137 &(tcp->tcp_bind_hash); in tcp_bind_hash_insert() 143 tcp->tcp_bind_hash_port = tcpnext; in tcp_bind_hash_insert() 144 tcp->tcp_bind_hash = tcphash; in tcp_bind_hash_insert() [all …]
|
/titanic_44/usr/src/stand/lib/tcp/ |
H A D | tcp.c | 111 tcp_t *tcp; member 229 #define SET_WS_VALUE(tcp) \ argument 232 uint32_t rwnd = (tcp)->tcp_rwnd; \ 236 (tcp)->tcp_rcv_ws = i; \ 246 #define SET_ECT(tcp, iph) \ argument 247 if ((tcp)->tcp_ipversion == IPV4_VERSION) { \ 276 #define TCP_TIMER_RESTART(tcp, intvl) \ argument 277 (tcp)->tcp_rto_timeout = prom_gettime() + intvl; \ 278 (tcp)->tcp_timer_running = B_TRUE; 468 tcp_drain_input(tcp_t *tcp, int sock_id, int timeout) in tcp_drain_input() argument [all …]
|
/titanic_44/usr/src/cmd/cmd-inet/etc/ |
H A D | services | 27 tcpmux 1/tcp 28 echo 7/tcp 30 discard 9/tcp sink null 32 systat 11/tcp users 33 daytime 13/tcp 35 netstat 15/tcp 36 qotd 17/tcp # Quote of the Day 37 chargen 19/tcp ttytst source 39 ftp-data 20/tcp 40 ftp 21/tcp [all …]
|
/titanic_44/usr/src/uts/common/io/bnxe/577xx/drivers/common/lm/l4/ |
H A D | lm_l4sp.c | 24 lm_tcp_state_t * tcp, 107 IN lm_tcp_state_t * tcp) in lm_tcp_erase_connection() argument 117 DbgMessage(pdev, FATAL, "##lm_tcp_erase_connection(0x%x)\n",tcp->cid); in lm_tcp_erase_connection() 118 if (tcp->ulp_type == TOE_CONNECTION_TYPE) { in lm_tcp_erase_connection() 119 rx_con = tcp->rx_con; in lm_tcp_erase_connection() 120 tx_con = tcp->tx_con; in lm_tcp_erase_connection() 123 lm_tcp_abort_bufs(pdev, tcp, tx_con, LM_STATUS_CONNECTION_CLOSED); in lm_tcp_erase_connection() 125 DbgMessage(pdev, FATAL, "##lm_tcp_erase_connection(0x%x): Tx aborted\n",tcp->cid); in lm_tcp_erase_connection() 135 DbgMessage(pdev, FATAL, "##lm_tcp_erase_connection(0x%x): under indication\n",tcp->cid); in lm_tcp_erase_connection() 140 lm_tcp_abort_bufs(pdev, tcp, rx_con, LM_STATUS_CONNECTION_CLOSED); in lm_tcp_erase_connection() [all …]
|
H A D | lm_l4rx.c | 25 lm_tcp_state_t * tcp, 32 lm_tcp_state_t *tcp, 39 lm_tcp_state_t * tcp, 45 lm_tcp_state_t * tcp, 53 lm_tcp_state_t * tcp, 80 lm_tcp_state_t * tcp, in _lm_tcp_isle_find() argument 87 DbgBreakIf(!(tcp && tcp->rx_con)); in _lm_tcp_isle_find() 88 gen_info = &tcp->rx_con->u.rx.gen_info; in _lm_tcp_isle_find() 107 lm_tcp_state_t * tcp, in _lm_tcp_isle_remove() argument 119 DbgBreakIf(!(tcp && tcp->rx_con)); in _lm_tcp_isle_remove() [all …]
|
H A D | lm_l4tx.c | 54 lm_tcp_state_t *tcp, in lm_tcp_tx_write_db() argument 57 lm_tcp_con_t *tx_con = tcp->tx_con; in lm_tcp_tx_write_db() 66 _lm_tcp_tx_write_db(pdev, tx_con, tcp->cid, tx_con->db_more_bytes, tx_con->db_more_bds, 0); in lm_tcp_tx_write_db() 76 "skipped doorbell ringing for cid=%d\n", tcp->cid); in lm_tcp_tx_write_db() 90 lm_tcp_state_t *tcp, in lm_tcp_tx_post_buf() argument 103 DbgBreakIf(!(pdev && tcp && tcp_buf && frag_list)); in lm_tcp_tx_post_buf() 104 DbgBreakIf(tcp->cid && (tcp != lm_cid_cookie(pdev, TOE_CONNECTION_TYPE, tcp->cid))); in lm_tcp_tx_post_buf() 106 tx_con = tcp->tx_con; in lm_tcp_tx_post_buf() 115 tcp->cid, tx_con->flags); in lm_tcp_tx_post_buf() 122 tcp->cid, lm_bd_chain_avail_bds(tx_chain), frag_list->cnt); in lm_tcp_tx_post_buf() [all …]
|
/titanic_44/usr/src/cmd/cmd-inet/usr.sbin/snoop/ |
H A D | snoop_tcp.c | 78 interpret_tcp(int flags, struct tcphdr *tcp, int iplen, int fraglen) in interpret_tcp() argument 88 hdrlen = tcp->th_off * 4; in interpret_tcp() 89 data = (char *)tcp + hdrlen; in interpret_tcp() 101 ntohs(tcp->th_dport), ntohs(tcp->th_sport)); in interpret_tcp() 105 if (tcp->th_flags & tcp_flags[i].tf_flag) { in interpret_tcp() 112 if (tcp->th_flags & TH_URG) { in interpret_tcp() 114 ntohs(tcp->th_urp)); in interpret_tcp() 117 if (tcp->th_flags & TH_ACK) { in interpret_tcp() 119 ntohl(tcp->th_ack)); in interpret_tcp() 122 if (ntohl(tcp->th_seq)) { in interpret_tcp() [all …]
|
/titanic_44/usr/src/cmd/dtrace/test/tst/common/ip/ |
H A D | tst.localtcpstate.ksh.out | 5 tcp:::send - yes 6 tcp:::receive - yes 7 tcp:::state-change to syn-sent - yes 8 tcp:::state-change to syn-received - yes 9 tcp:::state-change to established - yes 10 tcp:::state-change to fin-wait-1 - yes 11 tcp:::state-change to close-wait - yes 12 tcp:::state-change to fin-wait-2 - yes 13 tcp:::state-change to last-ack - yes 14 tcp:::state-change to time-wait - yes [all …]
|
H A D | tst.remotetcpstate.ksh.out | 5 tcp:::send - yes 6 tcp:::receive - yes 7 tcp:::state-change to syn-sent - yes 8 tcp:::state-change to established - yes 9 tcp:::state-change to fin-wait-1 - yes 10 tcp:::state-change to close-wait - yes 11 tcp:::state-change to fin-wait-2 - yes 12 tcp:::state-change to time-wait - yes 13 tcp:::connect-request - yes 14 tcp:::connect-established - yes
|
/titanic_44/usr/src/uts/common/io/myri10ge/drv/ |
H A D | myri10ge_lro.c | 79 struct tcphdr *tcp; in myri10ge_lro_flush() local 94 tcp = (struct tcphdr *)(ip + 1); in myri10ge_lro_flush() 95 tcp->th_ack = lro->ack_seq; in myri10ge_lro_flush() 96 tcp->th_win = lro->window; in myri10ge_lro_flush() 97 tcp->th_flags = lro->flags; in myri10ge_lro_flush() 100 ts_ptr = (uint32_t *)(tcp + 1); in myri10ge_lro_flush() 109 tcp->th_sum = 0; in myri10ge_lro_flush() 114 tcp_csum += myri10ge_csum_generic((uint16_t *)tcp, in myri10ge_lro_flush() 115 tcp->th_off << 2); in myri10ge_lro_flush() 118 tcp->th_sum = 0xffff ^ tcp_csum; in myri10ge_lro_flush() [all …]
|
/titanic_44/usr/src/cmd/krb5/krb5kdc/ |
H A D | network.c | 187 } tcp; member 819 newconn->u.tcp.addrbuf, sizeof(newconn->u.tcp.addrbuf), in accept_tcp_connection() 822 strcpy(newconn->u.tcp.addrbuf, "???"); in accept_tcp_connection() 825 p = newconn->u.tcp.addrbuf; in accept_tcp_connection() 826 end = p + sizeof(newconn->u.tcp.addrbuf); in accept_tcp_connection() 835 s, newconn->u.tcp.addrbuf); in accept_tcp_connection() 838 newconn->u.tcp.addr_s = addr_s; in accept_tcp_connection() 839 newconn->u.tcp.addrlen = addrlen; in accept_tcp_connection() 840 newconn->u.tcp.bufsiz = 1024 * 1024; in accept_tcp_connection() 841 newconn->u.tcp.buffer = malloc(newconn->u.tcp.bufsiz); in accept_tcp_connection() [all …]
|
/titanic_44/usr/src/uts/common/io/xge/hal/xgehal/ |
H A D | xgehal-device-fp.c | 715 __hal_lro_check_for_session_match(lro_t *lro, tcplro_t *tcp, iplro_t *ip) in __hal_lro_check_for_session_match() argument 727 if ((lro->tcp_hdr->source != tcp->source)) in __hal_lro_check_for_session_match() 731 if ((lro->tcp_hdr->dest != tcp->dest)) in __hal_lro_check_for_session_match() 744 __hal_tcp_seg_len(iplro_t *ip, tcplro_t *tcp) in __hal_tcp_seg_len() argument 750 ((tcp->doff_res)>>2)); in __hal_tcp_seg_len() 796 __hal_tcp_lro_capable(iplro_t *ip, tcplro_t *tcp, lro_t *lro, int *ts_off) in __hal_tcp_lro_capable() argument 805 ch = ntohs(*((u8 *)((u8 *)tcp + i)) ); in __hal_tcp_lro_capable() 810 if ((TCP_FAST_PATH_HDR_MASK2 != tcp->ctrl) && in __hal_tcp_lro_capable() 811 (TCP_FAST_PATH_HDR_MASK3 != tcp->ctrl)) in __hal_tcp_lro_capable() 815 if (TCP_FAST_PATH_HDR_MASK1 != tcp->doff_res) { in __hal_tcp_lro_capable() [all …]
|
/titanic_44/usr/src/cmd/ipf/lib/common/ |
H A D | printpacket.c | 19 struct tcphdr *tcp; local 52 tcp = (struct tcphdr *)((char *)ip + (IP_HL(ip) << 2)); 59 printf(",%d", ntohs(tcp->th_sport)); 64 printf(",%d", ntohs(tcp->th_dport)); 65 if ((ip->ip_p == IPPROTO_TCP) && (tcp->th_flags != 0)) { 67 if (tcp->th_flags & TH_FIN) 69 if (tcp->th_flags & TH_SYN) 71 if (tcp->th_flags & TH_RST) 73 if (tcp->th_flags & TH_PUSH) 75 if (tcp->th_flags & TH_ACK) [all …]
|
/titanic_44/usr/src/uts/common/io/bnxe/577xx/drivers/common/lm/l4/include/ |
H A D | lm_l4if.h | 43 lm_tcp_state_t *tcp, 58 lm_tcp_state_t *tcp, 67 lm_tcp_state_t *tcp, 76 lm_tcp_state_t *tcp 88 lm_tcp_state_t *tcp); 122 lm_tcp_state_t *tcp); 144 lm_tcp_state_t *tcp); 148 lm_tcp_state_t *tcp, 154 lm_tcp_state_t *tcp, 159 lm_tcp_state_t *tcp, [all …]
|
/titanic_44/usr/src/uts/common/inet/ |
H A D | tcp_impl.h | 101 #define TCP_IS_SOCKET(tcp) ((tcp)->tcp_issocket) argument 106 #define TCP_IS_DETACHED(tcp) ((tcp)->tcp_detached) argument 121 #define TCP_TIMER(tcp, f, tim) \ argument 122 tcp_timeout(tcp->tcp_connp, f, tim) 123 #define TCP_TIMER_CANCEL(tcp, id) \ argument 124 tcp_timeout_cancel(tcp->tcp_connp, id) 129 #define TCP_TIMER_RESTART(tcp, intvl) { \ argument 130 if ((tcp)->tcp_timer_tid != 0) \ 131 (void) TCP_TIMER_CANCEL((tcp), (tcp)->tcp_timer_tid); \ 132 (tcp)->tcp_timer_tid = TCP_TIMER((tcp), tcp_timer, (intvl)); \ [all …]
|
/titanic_44/usr/src/cmd/fs.d/ufs/fsck/ |
H A D | pass3b.c | 302 struct type_counts_s *tcp, *tcp_all, *tcp_def, *tcp_norm; in bufchk() local 357 tcp = &type_counts[fsdp->fsd_type]; in bufchk() 364 tcp->nuser_objs++; in bufchk() 367 tcp->ngroup_objs++; in bufchk() 370 tcp->nother_objs++; in bufchk() 373 tcp->nclass_objs++; in bufchk() 376 tcp->ndef_user_objs++; in bufchk() 379 tcp->ndef_group_objs++; in bufchk() 382 tcp->ndef_other_objs++; in bufchk() 385 tcp->ndef_class_objs++; in bufchk() [all …]
|