Lines Matching defs:peer_tep
1663 tl_endpt_t *peer_tep = tep->te_conp;
1666 if ((peer_tep != NULL) && !peer_tep->te_closing)
1667 peer_tep->te_wq->q_next = NULL;
1939 tl_endpt_t *peer_tep = tep->te_conp;
1945 IMPLY(peer_tep, tep->te_serializer == peer_tep->te_serializer);
1950 if ((peer_tep != NULL) &&
1951 !peer_tep->te_closing &&
1956 ((peer_tep->te_state == TS_DATA_XFER) ||
1957 (peer_tep->te_state == TS_WREQ_ORDREL)) &&
1958 ((peer_rq = peer_tep->te_rq) != NULL) &&
2087 tl_endpt_t *peer_tep;
2093 ((peer_tep = tep->te_conp) != NULL) &&
2094 !peer_tep->te_closing &&
2098 TL_QENABLE(peer_tep);
2809 tl_endpt_t *peer_tep = NULL;
2965 peer_tep = (IS_SOCKET(tep) ?
2969 if (peer_tep == NULL) {
2973 } else if (peer_tep->te_nicon >= peer_tep->te_qlen) {
2987 if (peer_tep != NULL)
2988 tl_refrele(peer_tep);
3011 ASSERT(IS_COTS(peer_tep));
3018 tl_serializer_refhold(peer_tep->te_ser);
3020 tep->te_ser = peer_tep->te_ser;
3022 tep->te_oconp = peer_tep;
3047 tl_endpt_t *peer_tep = tep->te_oconp;
3082 if (peer_tep->te_closing ||
3083 !((peer_tep->te_state == TS_IDLE) ||
3084 (peer_tep->te_state == TS_WRES_CIND))) {
3087 peer_tep->te_state));
3102 if (peer_tep->te_flag & (TL_SETCRED|TL_SETUCRED)) {
3105 if (peer_tep->te_flag & TL_SETCRED) {
3213 if (peer_tep != NULL && peer_tep->te_credp != NULL &&
3215 mblk_setcred(confmp, peer_tep->te_credp, peer_tep->te_cpid);
3252 if (peer_tep->te_flag & (TL_SETCRED|TL_SETUCRED)) {
3259 peer_tep->te_flag, peer_tep->te_credp);
3277 * increment references for both peer_tep and tep: peer_tep is placed on
3282 list_insert_tail(&peer_tep->te_iconp, tip);
3283 peer_tep->te_nicon++;
3285 peer_tep->te_state = NEXTSTATE(TE_CONN_IND, peer_tep->te_state);
3289 putnext(peer_tep->te_rq, cimp);
3307 ASSERT(peer_tep->te_refcnt >= 2);
3861 tl_endpt_t *peer_tep = tep->te_conp;
3874 if ((peer_tep != NULL) && peer_tep->te_closing) {
3876 peer_tep = NULL;
3960 peer_tep = tip->ti_tep;
4001 if (peer_tep != NULL && !peer_tep->te_closing) {
4015 save_state = peer_tep->te_state;
4016 peer_tep->te_state = TS_IDLE;
4018 TL_REMOVE_PEER(peer_tep->te_oconp);
4019 enableok(peer_tep->te_wq);
4020 TL_QENABLE(peer_tep);
4031 } else if ((peer_tep = tep->te_oconp) != NULL) { /* client */
4064 tl_icon_queuemsg(peer_tep, tep->te_seqno, dimp);
4065 peer_tep = NULL;
4076 tip = tl_icon_find(peer_tep, tep->te_seqno);
4079 save_state = peer_tep->te_state;
4080 if (peer_tep->te_nicon == 1)
4081 peer_tep->te_state =
4083 peer_tep->te_state);
4085 peer_tep->te_state =
4087 peer_tep->te_state);
4088 tl_freetip(peer_tep, tip);
4093 } else if ((peer_tep = tep->te_conp) != NULL) { /* connected! */
4105 save_state = peer_tep->te_state;
4106 peer_tep->te_state = TS_IDLE;
4117 if (peer_tep == NULL) {
4129 (void) putnextctl1(peer_tep->te_rq, M_FLUSH, FLUSHRW);
4142 putnext(peer_tep->te_rq, dimp);
4145 ASSERT(! peer_tep->te_closing);
4157 TL_QENABLE(peer_tep);
4158 ASSERT(peer_tep != NULL && peer_tep->te_conp != NULL);
4159 TL_UNCONNECT(peer_tep->te_conp);
4165 peer_tep->te_wq->q_next = NULL;
4256 tl_endpt_t *peer_tep = tep->te_conp;
4267 if (peer_tep == NULL || peer_tep->te_closing) {
4276 ack_sz += peer_tep->te_alen;
4297 taa->REMADDR_length = peer_tep->te_alen;
4301 bcopy(peer_tep->te_abuf, addr_startp,
4302 peer_tep->te_alen);
4304 taa->REMADDR_offset + peer_tep->te_alen;
4416 tl_endpt_t *peer_tep;
4557 if (((peer_tep = tep->te_conp) == NULL) || peer_tep->te_closing) {
4565 ASSERT(tep->te_serializer == peer_tep->te_serializer);
4566 peer_rq = peer_tep->te_rq;
4581 switch (peer_tep->te_state) {
4589 tl_merror(peer_tep->te_wq, mp, EPROTO);
4600 * peer_tep->te_state = NEXTSTATE(TE_DATA_IND, peer_tep->te_state);
4617 tl_endpt_t *peer_tep;
4724 if (((peer_tep = tep->te_conp) == NULL) || peer_tep->te_closing) {
4732 peer_rq = peer_tep->te_rq;
4747 switch (peer_tep->te_state) {
4755 tl_merror(peer_tep->te_wq, mp, EPROTO);
4759 * peer_tep->te_state = NEXTSTATE(TE_DATA_IND, peer_tep->te_state);
4781 tl_endpt_t *peer_tep;
4848 if (((peer_tep = tep->te_conp) == NULL) || peer_tep->te_closing) {
4856 peer_rq = peer_tep->te_rq;
4871 switch (peer_tep->te_state) {
4879 tl_merror(peer_tep->te_wq, mp, EPROTO);
4882 peer_tep->te_state = NEXTSTATE(TE_ORDREL_IND, peer_tep->te_state);
5000 tl_endpt_t *peer_tep;
5117 peer_tep = tep->te_lastep;
5119 if ((peer_tep == NULL) || peer_tep->te_closing ||
5120 (peer_tep->te_state != TS_IDLE) ||
5121 !tl_eqaddr(&destaddr, &peer_tep->te_ap)) {
5126 peer_tep = (IS_SOCKET(tep) ?
5130 if (peer_tep == NULL) {
5144 tep->te_lastep = peer_tep;
5147 if (peer_tep->te_state != TS_IDLE) {
5154 ASSERT(peer_tep->te_rq != NULL);
5161 if (!canputnext(peer_tep->te_rq) && !(tep->te_closing)) {
5166 list_insert_head(&peer_tep->te_flowlist, tep);
5167 tep->te_flowq = peer_tep;
5178 if (peer_tep->te_flag & (TL_SETCRED|TL_SETUCRED|TL_SOCKUCRED)) {
5182 if (peer_tep->te_flag & TL_SETCRED) {
5187 } else if (peer_tep->te_flag & TL_SETUCRED) {
5206 !(peer_tep->te_flag & (TL_SETCRED|TL_SETUCRED|TL_SOCKUCRED))) {
5241 if (peer_tep->te_flag & (TL_SETCRED|TL_SETUCRED|TL_SOCKUCRED)) {
5253 peer_tep->te_flag, peer_tep->te_credp);
5270 peer_tep->te_state = NEXTSTATE(TE_UNITDATA_IND, peer_tep->te_state);
5271 putnext(peer_tep->te_rq, mp);
5285 tl_endpt_t *peer_tep = NULL;
5287 (mod_hash_val_t *)&peer_tep, tl_find_callback);
5294 EQUIV(rc == 0, peer_tep != NULL);
5296 (tep->te_zoneid == peer_tep->te_zoneid) &&
5297 (tep->te_transport == peer_tep->te_transport));
5299 if ((rc == 0) && (peer_tep->te_closing)) {
5300 tl_refrele(peer_tep);
5301 peer_tep = NULL;
5304 return (peer_tep);
5315 tl_endpt_t *peer_tep = NULL;
5319 (mod_hash_val_t *)&peer_tep, tl_find_callback);
5322 EQUIV(rc == 0, peer_tep != NULL);
5323 IMPLY(rc == 0, (tep->te_transport == peer_tep->te_transport));
5325 if (peer_tep != NULL) {
5327 if (peer_tep->te_closing)
5335 if ((peer_tep->te_zoneid != tep->te_zoneid) &&
5337 (peer_tep->te_zoneid != GLOBAL_ZONEID))
5341 return (peer_tep);
5344 tl_refrele(peer_tep);
5478 tl_endpt_t *peer_tep = tep->te_conp;
5489 if ((peer_tep != NULL) && peer_tep->te_closing) {
5491 peer_tep = NULL;
5607 } else if (peer_tep != NULL) {
5615 ASSERT(tep->te_ser == peer_tep->te_ser);
5616 if (IS_COTSORD(peer_tep) &&
5617 (peer_tep->te_state == TS_WIND_ORDREL ||
5618 peer_tep->te_state == TS_DATA_XFER)) {
5624 peer_tep->te_state,
5625 NEXTSTATE(TE_ORDREL_IND, peer_tep->te_state)));
5636 TL_QENABLE(peer_tep);
5639 peer_tep->te_state =
5640 NEXTSTATE(TE_ORDREL_IND, peer_tep->te_state);
5642 putnext(peer_tep->te_rq, d_mp);
5648 TL_QENABLE(peer_tep);
5649 } else if (IS_COTSORD(peer_tep) &&
5650 peer_tep->te_state == TS_WREQ_ORDREL) {
5659 tl_discon_ind(peer_tep, 0);
5664 tl_discon_ind(peer_tep, ECONNRESET);
5672 peer_tep = tep->te_conp;
5673 TL_REMOVE_PEER(peer_tep->te_conp);