Lines Matching refs:assoc
162 rpc_cn_assoc_p_t /*assoc*/,
173 rpc_cn_assoc_p_t /*assoc*/,
178 rpc_cn_assoc_p_t /*assoc*/,
1004 rpc_cn_assoc_t *assoc;
1011 assoc = (rpc_cn_assoc_t *) spc_struct;
1017 if (assoc->assoc_ref_count == 0)
1147 ** assoc->assoc_status.
1161 rpc_cn_assoc_t *assoc;
1170 assoc = (rpc_cn_assoc_t *) spc_struct;
1184 send_frag_resp_pdu(assoc, fragbuf, req_header);
1191 rpc__cn_assoc_send_fragbuf (assoc,
1193 assoc->security.assoc_current_sec_context,
1195 &(assoc->assoc_status));
1197 RPC_CN_ASSOC_CHECK_ST (assoc, &(assoc->assoc_status));
1198 return (assoc->assoc_status);
1256 rpc_cn_assoc_t *assoc;
1265 assoc = (rpc_cn_assoc_t *) spc_struct;
1277 rpc__cn_assoc_send_fragbuf (assoc,
1281 &(assoc->assoc_status));
1282 RPC_CN_ASSOC_CHECK_ST (assoc, &(assoc->assoc_status));
1285 return (assoc->assoc_status);
1342 rpc_cn_assoc_t *assoc;
1350 assoc = (rpc_cn_assoc_t *) spc_struct;
1356 rpc__cn_assoc_grp_add_assoc (assoc->assoc_grp_id,
1357 assoc);
1360 return (assoc->assoc_status);
1417 rpc_cn_assoc_t *assoc;
1424 assoc = (rpc_cn_assoc_t *) spc_struct;
1429 rpc__cn_assoc_grp_rem_assoc (assoc->assoc_grp_id,
1430 assoc);
1432 return (assoc->assoc_status);
1488 rpc_cn_assoc_t *assoc;
1510 assoc = (rpc_cn_assoc_t *) spc_struct;
1512 old_client = (assoc->assoc_vers_minor <= RPC_C_CN_PROTO_VERS_COMPAT);
1530 return (save_sec_fragment(assoc, req_header));
1536 if (assoc->security.auth_buffer_info.auth_buffer != NULL)
1538 status = save_sec_fragment(assoc, req_header);
1549 assoc->security.assoc_current_sec_context = NULL;
1555 RPC_CN_FRAGBUF_ALLOC (fragbuf, rpc_g_cn_large_frag_size, &(assoc->assoc_status));
1581 assoc->assoc_status = rpc_s_bad_pkt;
1590 rpc__cn_assoc_syntax_negotiate (assoc,
1594 &assoc->assoc_status);
1599 if (assoc->assoc_status == rpc_s_ok)
1602 rpc__cn_assoc_process_auth_tlr (assoc,
1608 &assoc->security.assoc_current_sec_context,
1610 &assoc->assoc_status);
1618 if (assoc->assoc_status == rpc_s_ok)
1627 assoc->assoc_vers_minor);
1637 RPC_CN_ASSOC_INSERT_EVENT (assoc, &event);
1646 ("CN: call_rep->%p assoc->%p desc->%p error %x while processing alter context PDU \n",
1647 assoc->call_rep,
1648 assoc,
1649 assoc->cn_ctlblk.cn_sock,
1650 assoc->assoc_status));
1653 return (assoc->assoc_status);
1709 rpc_cn_assoc_t *assoc;
1721 assoc = (rpc_cn_assoc_t *) spc_struct;
1726 sec = assoc->security.assoc_current_sec_context;
1739 add_assoc_to_grp_action_rtn (spc_struct, (dce_pointer_t) assoc, sm);
1754 send_frag_resp_pdu(assoc, fragbuf, req_header);
1761 rpc__cn_assoc_send_fragbuf (assoc,
1763 assoc->security.assoc_current_sec_context,
1765 &(assoc->assoc_status));
1767 RPC_CN_ASSOC_CHECK_ST (assoc, &(assoc->assoc_status));
1770 return (assoc->assoc_status);
1826 rpc_cn_assoc_t *assoc;
1845 assoc = (rpc_cn_assoc_t *) spc_struct;
1846 old_client = (assoc->assoc_vers_minor <= RPC_C_CN_PROTO_VERS_COMPAT);
1858 return (save_sec_fragment (assoc, req_header));
1860 if (assoc->security.auth_buffer_info.auth_buffer != NULL)
1862 status = save_sec_fragment (assoc, req_header);
1866 assoc->security.assoc_current_sec_context = NULL;
1884 rpc__cn_assoc_process_auth_tlr (assoc,
1890 &assoc->security.assoc_current_sec_context,
1892 &assoc->assoc_status);
1893 if (assoc->assoc_status == rpc_s_ok && auth_len != 0)
1896 assoc->assoc_status = rpc_s_proto_unsupp_by_auth;
1899 sec = assoc->security.assoc_current_sec_context;
1902 new_state = (assoc->assoc_status == rpc_s_ok) ? RPC_C_ASSOC_AUTH3_ACK : RPC_C_ASSOC_AUTH3_NACK;
1904 assoc->assoc_status = rpc__cn_sm_eval_event (new_state, event_param, assoc, &assoc->assoc_state);
1905 assoc->assoc_flags &= ~RPC_C_CN_ASSOC_SCANNED;
1912 return (assoc->assoc_status);
1970 rpc_cn_assoc_t *assoc;
1997 assoc = (rpc_cn_assoc_t *) spc_struct;
2013 RPC_CN_FRAGBUF_ALLOC (fragbuf, rpc_g_cn_large_frag_size, &(assoc->assoc_status));
2035 assoc->assoc_status = rpc_s_protocol_error;
2044 assoc->security.assoc_have_uuid_crc = false;
2052 assoc->security.assoc_current_sec_context = NULL;
2057 assoc->assoc_status = rpc_s_rpc_prot_version_mismatch;
2066 assoc->assoc_vers_minor = RPC_CN_PKT_VERS_MINOR (req_header);
2067 old_client = (assoc->assoc_vers_minor <= RPC_C_CN_PROTO_VERS_COMPAT);
2095 serr = rpc__socket_set_bufs (assoc->cn_ctlblk.cn_sock,
2134 assoc->assoc_max_xmit_frag = RPC_CN_PKT_MAX_XMIT_FRAG (resp_header);
2135 assoc->assoc_max_recv_frag = RPC_CN_PKT_MAX_RECV_FRAG (resp_header);
2148 assoc->assoc_grp_id =
2151 assoc->transport_info,
2152 &(assoc->assoc_status));
2153 assoc_grp = RPC_CN_ASSOC_GRP (assoc->assoc_grp_id);
2154 if (assoc->assoc_status == rpc_s_ok)
2175 assoc->assoc_status = rpc_s_assoc_grp_max_exceeded;
2184 assoc->assoc_grp_id = rpc__cn_assoc_grp_alloc (assoc->cn_ctlblk.rpc_addr,
2185 assoc->transport_info,
2188 &(assoc->assoc_status));
2189 assoc_grp = RPC_CN_ASSOC_GRP (assoc->assoc_grp_id);
2192 if (assoc->assoc_status == rpc_s_ok)
2210 strlen ((char *)assoc->cn_ctlblk.cn_listening_endpoint) + 1;
2215 (char *)assoc->cn_ctlblk.cn_listening_endpoint, sec_addr->length);
2253 assoc->assoc_status = rpc_s_bad_pkt;
2259 rpc__cn_assoc_syntax_negotiate (assoc,
2263 &assoc->assoc_status);
2266 if (assoc->assoc_status == rpc_s_ok)
2269 rpc__cn_assoc_process_auth_tlr (assoc,
2275 &assoc->security.assoc_current_sec_context,
2277 &assoc->assoc_status);
2283 assoc->assoc_status = RPC_S_HEADER_FULL;
2291 assoc->assoc_status = RPC_S_HEADER_FULL;
2300 if (assoc->assoc_status == rpc_s_ok)
2309 assoc->assoc_vers_minor);
2334 assoc->assoc_vers_minor);
2344 rpc__cn_assoc_status_to_prej (assoc->assoc_status);
2355 RPC_CN_ASSOC_INSERT_EVENT (assoc, &event);
2357 return (assoc->assoc_status);
2414 rpc_cn_assoc_t *assoc;
2426 assoc = (rpc_cn_assoc_t *) spc_struct;
2463 RPC_CN_FRAGBUF_ALLOC (fragbuf, pdu_size, &(assoc->assoc_status));
2464 RPC_CN_ASSOC_CHECK_ST (assoc, &(assoc->assoc_status));
2476 assoc->assoc_vers_minor);
2481 rpc__cn_assoc_send_fragbuf (assoc,
2485 &(assoc->assoc_status));
2486 RPC_CN_ASSOC_CHECK_ST (assoc, &(assoc->assoc_status));
2488 return (assoc->assoc_status);
2547 rpc_cn_assoc_t *assoc;
2555 assoc = (rpc_cn_assoc_t *) spc_struct;
2561 RPC_CN_INCR_ACTIVE_SVR_ACTION(assoc, sm_p);
2562 return (assoc->assoc_status);
2620 rpc_cn_assoc_t *assoc;
2628 assoc = (rpc_cn_assoc_t *) spc_struct;
2634 RPC_CN_DECR_ACTIVE_SVR_ACTION(assoc, sm_p);
2635 return (assoc->assoc_status);
2691 rpc_cn_assoc_t *assoc;
2699 assoc = (rpc_cn_assoc_t *) spc_struct;
2705 if (assoc->cn_ctlblk.cn_state == RPC_C_CN_OPEN)
2707 rpc__cn_network_close_connect (assoc,
2708 &(assoc->assoc_status));
2709 RPC_CN_ASSOC_CHECK_ST (assoc, &(assoc->assoc_status));
2712 return (assoc->assoc_status);
2770 rpc_cn_assoc_t *assoc;
2779 assoc = (rpc_cn_assoc_t *) spc_struct;
2785 switch (assoc->assoc_state.cur_event)
2792 assoc->assoc_status = rpc_s_connection_closed;
2801 assoc->assoc_status = rpc_s_connection_aborted;
2811 assoc->assoc_status = assoc->assoc_local_status;
2817 if (assoc->assoc_status == rpc_s_ok)
2818 assoc->assoc_status = rpc_s_connection_aborted;
2829 assoc->cn_ctlblk.cn_rcvr_thread_id))
2831 RPC_CN_ASSOC_WAKEUP (assoc);
2835 return (assoc->assoc_status);
2893 rpc_cn_assoc_t *assoc;
2902 assoc = (rpc_cn_assoc_t *) spc_struct;
2907 if (assoc->call_rep != NULL)
2914 if (rpc__cthread_dequeue((rpc_call_rep_t *) assoc->call_rep))
2918 assoc->call_rep,
2919 RPC_CN_PKT_CALL_ID ((rpc_cn_packet_p_t) RPC_CN_CREP_SEND_HDR(assoc->call_rep))));
2920 binding_r = (rpc_binding_rep_t *) assoc->call_rep->binding_rep;
2922 rpc__cn_call_end ((rpc_call_rep_p_t *) &assoc->call_rep, &st);
2937 assoc->call_rep));
2938 RPC_CN_ASSOC_CANCEL_AND_WAKEUP (assoc);
2944 ("(cancel_calls_action_rtn) call_rep->%p assoc->%p no call ... do nothing\n",
2945 assoc->call_rep,
2946 assoc));
2949 return (assoc->assoc_status);
3006 rpc_cn_assoc_t *assoc;
3016 assoc = (rpc_cn_assoc_t *) spc_struct;
3019 sec = assoc->security.assoc_current_sec_context;
3033 * Note: the order in which this is done is important. The assoc
3037 * we're going to add the assoc could get deallocated which would result
3048 add_assoc_to_grp_action_rtn (spc_struct, (dce_pointer_t) assoc, sm);
3053 return (assoc->assoc_status);
3111 rpc_cn_assoc_t *assoc;
3119 assoc = (rpc_cn_assoc_t *) spc_struct;
3138 return (assoc->assoc_status);
3196 rpc_cn_assoc_t *assoc;
3204 assoc = (rpc_cn_assoc_t *) spc_struct;
3222 return (assoc->assoc_status);
3279 rpc_cn_assoc_t *assoc;
3287 assoc = (rpc_cn_assoc_t *) spc_struct;
3304 return (assoc->assoc_status);
3362 rpc_cn_assoc_t *assoc;
3370 assoc = (rpc_cn_assoc_t *) spc_struct;
3387 return (assoc->assoc_status);
3444 rpc_cn_assoc_t *assoc;
3452 assoc = (rpc_cn_assoc_t *) spc_struct;
3469 return (assoc->assoc_status);
3528 rpc_cn_assoc_t *assoc;
3536 assoc = (rpc_cn_assoc_t *) spc_struct;
3556 return (assoc->assoc_status);
3616 rpc_cn_assoc_t *assoc;
3627 assoc = (rpc_cn_assoc_t *) spc_struct;
3639 status = save_sec_fragment(assoc, req_header);
3652 RPC_CN_ASSOC_INSERT_EVENT (assoc, &event);
3713 rpc_cn_assoc_t *assoc;
3720 assoc = (rpc_cn_assoc_t *) spc_struct;
3730 return (assoc->assoc_status);
3758 ** assoc The association.
3791 rpc_cn_assoc_p_t assoc,
3852 rpc__cn_assoc_sec_lkup_by_id (assoc,
3908 &assoc->security.assoc_uuid_crc);
3914 if (assoc->security.auth_buffer_info.auth_buffer != NULL)
3917 assoc->security.auth_buffer_info.auth_buffer;
3918 local_auth_value_len = assoc->security.auth_buffer_info.auth_buffer_len;
3940 RPC_CN_AUTH_VFY_CLIENT_REQ (&assoc->security,
3957 if (assoc->raw_packet_p != NULL)
3963 &assoc->security,
3965 (rpc_cn_common_hdr_t *)assoc->raw_packet_p->data_p,
3966 assoc->raw_packet_p->data_size,
3978 &assoc->security,
3992 if (assoc->security.auth_buffer_info.auth_buffer)
3996 assoc->security.auth_buffer_info.auth_buffer));
3998 RPC_MEM_FREE(assoc->security.auth_buffer_info.auth_buffer,
4000 assoc->security.auth_buffer_info.auth_buffer = NULL;
4001 assoc->security.auth_buffer_info.auth_buffer_len = 0;
4002 assoc->security.auth_buffer_info.auth_buffer_max = 0;
4031 * long KRB message in assoc->security->krb_message.
4035 &assoc->security,
4065 ("CN: call_rep->%p assoc->%p desc->%p client verification failed security_context->%p auth_type->%x auth_level->%x auth_len->%x stub_pad_length->%x st->%x\n",
4066 assoc->call_rep,
4067 assoc,
4068 assoc->cn_ctlblk.cn_sock,
4079 RPC_LIST_ADD_TAIL (assoc->security.context_list,
4082 assoc->security.assoc_have_uuid_crc = true;
4094 if (assoc->raw_packet_p != NULL)
4096 rpc__cn_fragbuf_free (assoc->raw_packet_p);
4097 assoc->raw_packet_p = NULL;
4121 ** assoc The association.
4131 ** assoc->security.krb_message Contains the credentials
4143 INTERNAL void send_frag_resp_pdu(assoc,
4147 rpc_cn_assoc_p_t assoc;
4167 krb_message_ptr = &(assoc->security.krb_message);
4208 rpc__cn_assoc_send_fragbuf (assoc,
4210 assoc->security.assoc_current_sec_context,
4212 &(assoc->assoc_status));
4295 ** assoc The association.
4304 ** assoc->security.auth_buffer_info Contains the pieces of credentials
4316 INTERNAL unsigned32 save_sec_fragment(rpc_cn_assoc_p_t assoc,
4331 auth_buffer = assoc->security.auth_buffer_info.auth_buffer;
4332 auth_buffer_len = assoc->security.auth_buffer_info.auth_buffer_len;
4333 auth_buffer_max = assoc->security.auth_buffer_info.auth_buffer_max;
4360 assoc->security.auth_buffer_info.auth_buffer = auth_buffer;
4361 assoc->security.auth_buffer_info.auth_buffer_max = auth_buffer_max;
4378 assoc->security.auth_buffer_info.auth_buffer = auth_buffer;
4379 assoc->security.auth_buffer_info.auth_buffer_max = auth_buffer_max;
4458 assoc->security.auth_buffer_info.auth_buffer = auth_buffer;
4459 assoc->security.auth_buffer_info.auth_buffer_len = auth_buffer_len;
4460 assoc->security.auth_buffer_info.auth_buffer_max = auth_buffer_max;