Home
last modified time | relevance | path

Searched refs:clientp (Results 1 – 25 of 30) sorted by relevance

12

/titanic_41/usr/src/cmd/vntsd/
H A Dcmd.c69 typedef int (*e_func_t)(vntsd_client_t *clientp);
79 genbrk(vntsd_client_t *clientp) in genbrk() argument
84 assert(clientp); in genbrk()
85 assert(clientp->cons); in genbrk()
87 consp = clientp->cons; in genbrk()
89 consp->vcc_fd, clientp->sockfd); in genbrk()
92 if (consp->clientpq->handle != clientp) { in genbrk()
94 return (vntsd_write_line(clientp, in genbrk()
109 genaltbrk(vntsd_client_t *clientp) in genaltbrk() argument
114 assert(clientp); in genaltbrk()
[all …]
H A Dread.c55 write_vcc(vntsd_client_t *clientp, char c) in write_vcc() argument
60 assert(clientp); in write_vcc()
61 assert(clientp->cons); in write_vcc()
63 n = write(clientp->cons->vcc_fd, &c, 1); in write_vcc()
68 return (vntsd_cons_chk_intr(clientp)); in write_vcc()
84 acquire_writer(vntsd_client_t *clientp) in acquire_writer() argument
91 clientp->sockfd); in acquire_writer()
93 assert(clientp != NULL); in acquire_writer()
94 consp = clientp->cons; in acquire_writer()
101 if (consp->clientpq->handle == clientp) { in acquire_writer()
[all …]
H A Dconsole.c77 write_connect_msg(vntsd_client_t *clientp, char *group_name, in write_connect_msg() argument
84 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) != in write_connect_msg()
93 if ((rv = vntsd_write_line(clientp, buf)) != VNTSD_SUCCESS) { in write_connect_msg()
97 if ((rv = vntsd_write_line(clientp, in write_connect_msg()
132 list_all_domains(vntsd_group_t *groupp, vntsd_client_t *clientp) in list_all_domains() argument
137 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) in list_all_domains()
152 if ((rv = vntsd_write_line(clientp, vntsd_line)) != VNTSD_SUCCESS) { in list_all_domains()
159 &(clientp->sockfd)) != NULL) { in list_all_domains()
170 display_help(vntsd_client_t *clientp) in display_help() argument
175 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) in display_help()
[all …]
H A Dcommon.c56 vntsd_write_line(vntsd_client_t *clientp, char *line) in vntsd_write_line() argument
60 rv = vntsd_write_client(clientp, line, strlen(line)); in vntsd_write_line()
62 rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN); in vntsd_write_line()
70 vntsd_write_lines(vntsd_client_t *clientp, char *lines) in vntsd_write_lines() argument
90 (void) vntsd_write_line(clientp, line); in vntsd_write_lines()
104 vntsd_get_yes_no(vntsd_client_t *clientp, char *msg, int *yes_no) in vntsd_get_yes_no() argument
115 if ((rv = vntsd_write_client(clientp, msg, strlen(msg))) in vntsd_get_yes_no()
120 if ((rv = vntsd_write_client(clientp, yesno, strlen(yesno))) != in vntsd_get_yes_no()
125 if ((rv = vntsd_read_data(clientp, &c)) in vntsd_get_yes_no()
131 if ((rv = vntsd_write_client(clientp, &c, 1)) != in vntsd_get_yes_no()
[all …]
H A Dlisten.c202 vntsd_client_t *clientp; in create_console_thread() local
212 clientp = (vntsd_client_t *)malloc(sizeof (vntsd_client_t)); in create_console_thread()
213 if (clientp == NULL) { in create_console_thread()
218 bzero(clientp, sizeof (vntsd_client_t)); in create_console_thread()
220 clientp->sockfd = sockfd; in create_console_thread()
221 clientp->cons_tid = (thread_t)-1; in create_console_thread()
223 (void) mutex_init(&clientp->lock, USYNC_THREAD|LOCK_ERRORCHECK, NULL); in create_console_thread()
231 vntsd_free_client(clientp); in create_console_thread()
236 if ((rv = vntsd_que_append(&groupp->no_cons_clientpq, clientp)) in create_console_thread()
239 vntsd_free_client(clientp); in create_console_thread()
[all …]
H A Dvntsd.h345 vntsd_client_t *clientp; /* client */ member
430 int vntsd_read(vntsd_client_t *clientp);
446 int vntsd_read_char(vntsd_client_t *clientp, char *c);
447 int vntsd_read_line(vntsd_client_t *clientp, char *buf, int *size);
448 int vntsd_read_data(vntsd_client_t *clientp, char *c);
449 int vntsd_get_yes_no(vntsd_client_t *clientp, char *msg,
451 int vntsd_ctrl_cmd(vntsd_client_t *clientp, char c);
452 int vntsd_process_daemon_cmd(vntsd_client_t *clientp, char c);
453 int vntsd_telnet_cmd(vntsd_client_t *clientp, char c);
459 int vntsd_write_line(vntsd_client_t *clientp, char *line);
[all …]
H A Dwrite.c192 write_one_client(vntsd_client_t *clientp, write_buf_t *write_buf) in write_one_client() argument
196 rv = vntsd_write_client(clientp, write_buf->buf, write_buf->sz); in write_one_client()
198 (void) mutex_lock(&clientp->lock); in write_one_client()
199 clientp->status |= VNTSD_CLIENT_IO_ERR; in write_one_client()
200 assert(clientp->cons); in write_one_client()
201 (void) thr_kill(clientp->cons_tid, NULL); in write_one_client()
202 (void) mutex_unlock(&clientp->lock); in write_one_client()
H A Dvntsdvcc.c56 vntsd_notify_client_cons_del(vntsd_client_t *clientp) in vntsd_notify_client_cons_del() argument
58 (void) mutex_lock(&clientp->lock); in vntsd_notify_client_cons_del()
59 clientp->status |= VNTSD_CLIENT_CONS_DELETED; in vntsd_notify_client_cons_del()
60 (void) thr_kill(clientp->cons_tid, SIGUSR1); in vntsd_notify_client_cons_del()
61 (void) mutex_unlock(&clientp->lock); in vntsd_notify_client_cons_del()
513 vntsd_client_t *clientp; in deleted_cons_by_consno() local
529 clientp = (vntsd_client_t *)consp->clientpq->handle; in deleted_cons_by_consno()
531 if (clientp->status & VNTSD_CLIENT_CONS_DELETED) in deleted_cons_by_consno()
/titanic_41/usr/src/uts/common/io/ib/mgt/ibmf/
H A Dibmf_trans.c40 ibmf_i_terminate_transaction(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, in ibmf_i_terminate_transaction() argument
47 "status = 0x%x\n", tnf_opaque, clientp, clientp, in ibmf_i_terminate_transaction()
110 ibmf_client_t *clientp; in ibmf_i_notify_client() local
118 clientp = msgimplp->im_client; in ibmf_i_notify_client()
160 ibmf_i_free_ud_dest(clientp, msgimplp); in ibmf_i_notify_client()
161 ibmf_i_clean_ud_dest_list(clientp->ic_myci, B_FALSE); in ibmf_i_notify_client()
174 mutex_enter(&clientp->ic_mutex); in ibmf_i_notify_client()
175 IBMF_RECV_CB_CLEANUP(clientp); in ibmf_i_notify_client()
176 mutex_exit(&clientp->ic_mutex); in ibmf_i_notify_client()
210 mutex_enter(&clientp->ic_mutex); in ibmf_i_notify_client()
[all …]
H A Dibmf_msg.c42 ibmf_i_client_add_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp) in ibmf_i_client_add_msg() argument
47 tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp); in ibmf_i_client_add_msg()
51 mutex_enter(&clientp->ic_msg_mutex); in ibmf_i_client_add_msg()
63 if (clientp->ic_term_msg_list == NULL) { in ibmf_i_client_add_msg()
64 clientp->ic_term_msg_list = clientp->ic_term_msg_last = in ibmf_i_client_add_msg()
67 msgimplp->im_msg_prev = clientp->ic_term_msg_last; in ibmf_i_client_add_msg()
68 clientp->ic_term_msg_last->im_msg_next = msgimplp; in ibmf_i_client_add_msg()
69 clientp->ic_term_msg_last = msgimplp; in ibmf_i_client_add_msg()
77 clientp->ic_msgs_active++; in ibmf_i_client_add_msg()
78 mutex_enter(&clientp->ic_kstat_mutex); in ibmf_i_client_add_msg()
[all …]
H A Dibmf_send.c49 ibmf_i_issue_pkt(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, in ibmf_i_issue_pkt() argument
63 "qp_hdl = %p, swqep = %p\n", tnf_opaque, clientp, clientp, in ibmf_i_issue_pkt()
68 ASSERT(MUTEX_NOT_HELD(&clientp->ic_mutex)); in ibmf_i_issue_pkt()
77 ibt_qp_handle = clientp->ic_qp->iq_qp_handle; in ibmf_i_issue_pkt()
84 ibmf_i_init_send_wqe(clientp, msgimplp, sgl, send_wqep, in ibmf_i_issue_pkt()
97 mutex_enter(&clientp->ic_kstat_mutex); in ibmf_i_issue_pkt()
98 IBMF_ADD32_KSTATS(clientp, send_pkt_failed, 1); in ibmf_i_issue_pkt()
99 mutex_exit(&clientp->ic_kstat_mutex); in ibmf_i_issue_pkt()
114 mutex_enter(&clientp->ic_mutex); in ibmf_i_issue_pkt()
115 clientp->ic_sends_active++; in ibmf_i_issue_pkt()
[all …]
H A Dibmf.c32 #define IBMF_SET_CLIENT_SIGNATURE(clientp) { \ argument
33 (clientp)->ic_client_sig = (void *)0xf00DdEaD; \
36 #define IBMF_VERIFY_CLIENT_SIGNATURE(clientp) \ argument
37 (((clientp) != NULL && (clientp)->ic_client_sig == \
228 ibmf_client_t *clientp; in ibmf_unregister() local
234 clientp = (ibmf_client_t *)*ibmf_handlep; in ibmf_unregister()
259 if (IBMF_VERIFY_CLIENT_SIGNATURE(clientp) == B_FALSE) { in ibmf_unregister()
272 mutex_enter(&clientp->ic_mutex); in ibmf_unregister()
273 while (clientp->ic_recv_cb == NULL && clientp->ic_msgs_alloced != 0 && in ibmf_unregister()
275 mutex_exit(&clientp->ic_mutex); in ibmf_unregister()
[all …]
H A Dibmf_rmpp.c40 static void ibmf_i_rmpp_sender_active_flow(ibmf_client_t *clientp,
42 static void ibmf_i_rmpp_sender_switch_flow(ibmf_client_t *clientp,
44 static void ibmf_i_rmpp_recvr_flow_main(ibmf_client_t *clientp,
46 static void ibmf_i_rmpp_recvr_active_flow(ibmf_client_t *clientp,
48 static void ibmf_i_rmpp_recvr_term_flow(ibmf_client_t *clientp,
57 ibmf_i_is_rmpp(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle) in ibmf_i_is_rmpp() argument
64 "ibmf_qp_handle = 0x%p\n", tnf_opaque, clientp, clientp, in ibmf_i_is_rmpp()
67 if ((clientp->ic_reg_flags & IBMF_REG_FLAG_RMPP) == 0) { in ibmf_i_is_rmpp()
90 ibmf_i_rmpp_sender_active_flow(ibmf_client_t *clientp, ibmf_qp_handle_t qp_hdl, in ibmf_i_rmpp_sender_active_flow() argument
101 "msgp = 0x%p, madp = 0x%p\n", tnf_opaque, clientp, clientp, in ibmf_i_rmpp_sender_active_flow()
[all …]
H A Dibmf_recv.c72 static void ibmf_i_handle_non_rmpp(ibmf_client_t *clientp,
100 ibmf_client_t *clientp; in ibmf_i_handle_recv_completion() local
294 class, &clientp); in ibmf_i_handle_recv_completion()
297 recv_wqep->recv_client = clientp; in ibmf_i_handle_recv_completion()
304 mutex_enter(&clientp->ic_kstat_mutex); in ibmf_i_handle_recv_completion()
305 IBMF_ADD32_KSTATS(clientp, recv_cb_active, 1); in ibmf_i_handle_recv_completion()
306 mutex_exit(&clientp->ic_kstat_mutex); in ibmf_i_handle_recv_completion()
308 if ((clientp->ic_reg_flags & IBMF_REG_FLAG_NO_OFFLOAD) == 0) { in ibmf_i_handle_recv_completion()
310 ret = taskq_dispatch(clientp->ic_recv_taskq, in ibmf_i_handle_recv_completion()
313 mutex_enter(&clientp->ic_kstat_mutex); in ibmf_i_handle_recv_completion()
[all …]
H A Dibmf_dr.c37 static int ibmf_i_dr_loopback_filter(ibmf_client_t *clientp,
39 static void ibmf_i_dr_loopback_term(ibmf_client_t *clientp,
114 ibmf_i_dr_loopback_term(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, in ibmf_i_dr_loopback_term() argument
122 tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp); in ibmf_i_dr_loopback_term()
163 ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt); in ibmf_i_dr_loopback_term()
180 ibmf_i_client_rem_msg(clientp, msgimplp, &refcnt); in ibmf_i_dr_loopback_term()
183 msgimplp->im_trans_cb((ibmf_handle_t)clientp, in ibmf_i_dr_loopback_term()
210 ibmf_i_dr_loopback_filter(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, in ibmf_i_dr_loopback_filter() argument
224 tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp); in ibmf_i_dr_loopback_filter()
242 ret = ibmf_i_lookup_client_by_mgmt_class(clientp->ic_myci, in ibmf_i_dr_loopback_filter()
[all …]
H A Dibmf_ud_dest.c327 ibmf_i_alloc_ud_dest(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp, in ibmf_i_alloc_ud_dest() argument
340 tnf_opaque, clientp, clientp, tnf_opaque, msg, msgimplp, in ibmf_i_alloc_ud_dest()
347 cip = clientp->ic_myci; in ibmf_i_alloc_ud_dest()
389 if ((clientp->ic_base_lid == 0) && (clientp->ic_qp->iq_qp_num != 0)) { in ibmf_i_alloc_ud_dest()
392 clientp->ic_client_info.ci_guid, in ibmf_i_alloc_ud_dest()
393 clientp->ic_client_info.port_num, NULL, in ibmf_i_alloc_ud_dest()
394 &clientp->ic_base_lid); in ibmf_i_alloc_ud_dest()
395 if (clientp->ic_base_lid == 0) { in ibmf_i_alloc_ud_dest()
406 adds_vec.av_src_path = addrp->ia_local_lid - clientp->ic_base_lid; in ibmf_i_alloc_ud_dest()
409 adds_vec.av_port_num = clientp->ic_client_info.port_num; in ibmf_i_alloc_ud_dest()
[all …]
H A Dibmf_timers.c187 ibmf_client_t *clientp = (ibmf_client_t *)msgimplp->im_client; in ibmf_i_recv_timeout() local
250 mutex_enter(&clientp->ic_kstat_mutex); in ibmf_i_recv_timeout()
251 IBMF_ADD32_KSTATS(clientp, rmpp_errors, 1); in ibmf_i_recv_timeout()
252 mutex_exit(&clientp->ic_kstat_mutex); in ibmf_i_recv_timeout()
296 ibmf_i_client_rem_msg(clientp, msgimplp, &ref_cnt); in ibmf_i_recv_timeout()
320 ibmf_i_free_ud_dest(clientp, msgimplp); in ibmf_i_recv_timeout()
322 clientp->ic_myci, B_FALSE); in ibmf_i_recv_timeout()
341 mutex_enter(&clientp->ic_mutex); in ibmf_i_recv_timeout()
342 clientp->ic_msgs_alloced--; in ibmf_i_recv_timeout()
343 mutex_exit(&clientp->ic_mutex); in ibmf_i_recv_timeout()
[all …]
H A Dibmf_impl.c1357 ibmf_i_free_client(ibmf_client_t *clientp) in ibmf_i_free_client() argument
1361 tnf_opaque, clientp, clientp); in ibmf_i_free_client()
1364 if (clientp->ic_kstatp != NULL) { in ibmf_i_free_client()
1365 kstat_delete(clientp->ic_kstatp); in ibmf_i_free_client()
1366 clientp->ic_kstatp = NULL; in ibmf_i_free_client()
1370 if (clientp->ic_init_state_class & IBMF_CI_INIT_SEND_TASKQ_DONE) { in ibmf_i_free_client()
1371 if ((clientp->ic_reg_flags & IBMF_REG_FLAG_NO_OFFLOAD) == 0) { in ibmf_i_free_client()
1372 taskq_destroy(clientp->ic_send_taskq); in ibmf_i_free_client()
1374 clientp->ic_init_state_class &= ~IBMF_CI_INIT_SEND_TASKQ_DONE; in ibmf_i_free_client()
1377 if (clientp->ic_init_state_class & IBMF_CI_INIT_RECV_TASKQ_DONE) { in ibmf_i_free_client()
[all …]
H A Dibmf_handlers.c170 ibmf_client_t *clientp; in ibmf_i_callback_clients() local
213 for (clientp = cip->ci_clients, nclients = 0; clientp != NULL; in ibmf_i_callback_clients()
214 clientp = clientp->ic_next, nclients++) in ibmf_i_callback_clients()
259 for (clientp = cip->ci_clients, iclient = 0; in ibmf_i_callback_clients()
260 clientp != NULL; in ibmf_i_callback_clients()
261 clientp = clientp->ic_next, iclient++) { in ibmf_i_callback_clients()
263 cb_array[iclient] = clientp->ic_async_cb; in ibmf_i_callback_clients()
264 cb_args_array[iclient] = clientp->ic_async_cb_arg; in ibmf_i_callback_clients()
265 client_array[iclient] = (ibmf_handle_t)clientp; in ibmf_i_callback_clients()
H A Dibmf_saa.c45 #define IBMF_SAA_SET_CLIENT_SIGNATURE(clientp) { \ argument
46 (clientp)->saa_client_sig = (void *)0xACEDFACE; \
49 #define IBMF_SAA_VERIFY_CLIENT_SIGNATURE(clientp) \ argument
50 (((clientp) != NULL && (clientp)->saa_client_sig == \
53 #define IBMF_SAA_CLEAR_CLIENT_SIGNATURE(clientp) { \ argument
54 (clientp)->saa_client_sig = 0; \
338 tnf_opaque, clientp, saa_client, in ibmf_sa_session_open()
571 "freeing client memory", tnf_opaque, clientp, *ibmf_saa_handle); in ibmf_sa_session_close()
650 saa_client_data_t *clientp; in ibmf_sa_access() local
708 clientp = (saa_client_data_t *)ibmf_saa_handle; in ibmf_sa_access()
[all …]
/titanic_41/usr/src/uts/common/sys/ib/mgt/ibmf/
H A Dibmf_kstat.h69 #define IBMF_ADD32_KSTATS(clientp, xx, val) \ argument
70 if ((clientp != NULL) && (clientp->ic_kstatp != NULL)) { \
72 kp = (ibmf_kstat_t *)clientp->ic_kstatp->ks_data; \
76 #define IBMF_SUB32_KSTATS(clientp, xx, val) \ argument
77 if ((clientp != NULL) && (clientp->ic_kstatp != NULL)) { \
79 kp = (ibmf_kstat_t *)clientp->ic_kstatp->ks_data; \
H A Dibmf_impl.h616 void ibmf_i_free_client(ibmf_client_t *clientp);
625 int ibmf_i_alloc_qp(ibmf_client_t *clientp, ib_pkey_t p_key,
638 int ibmf_i_issue_pkt(ibmf_client_t *clientp, ibmf_msg_impl_t *msgp,
640 int ibmf_i_alloc_ud_dest(ibmf_client_t *clientp,
642 void ibmf_i_free_ud_dest(ibmf_client_t *clientp,
663 int ibmf_i_send_pkt(ibmf_client_t *clientp, ibmf_qp_handle_t ibmf_qp_handle,
665 int ibmf_i_send_single_pkt(ibmf_client_t *clientp,
671 void ibmf_i_init_send_wqe(ibmf_client_t *clientp,
689 void ibmf_i_client_add_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp);
690 void ibmf_i_client_rem_msg(ibmf_client_t *clientp, ibmf_msg_impl_t *msgimplp,
[all …]
/titanic_41/usr/src/lib/lvm/libmeta/common/
H A Dmeta_mh.c65 CLIENT *clientp; member
80 if (hp->clientp != NULL) { in close_metamhd()
81 auth_destroy(hp->clientp->cl_auth); in close_metamhd()
82 clnt_destroy(hp->clientp); in close_metamhd()
96 CLIENT *clientp; in open_metamhd() local
105 if ((clientp = meta_client_create(hostname, METAMHD, METAMHD_VERSION, in open_metamhd()
111 auth_destroy(clientp->cl_auth); in open_metamhd()
112 clientp->cl_auth = authsys_create_default(); in open_metamhd()
113 assert(clientp->cl_auth != NULL); in open_metamhd()
119 hp->clientp = clientp; in open_metamhd()
[all …]
/titanic_41/usr/src/cmd/ypcmd/
H A Dypinit.sh44 clientp=F
90 -c) clientp=T;;
118 -c) clientp=T; non_interactive=T;
137 -c) clientp=T; non_interactive=T;
266 ( test $clientp = T && `is_valid_ipaddr $h` )
353 if [ $clientp = T ]
/titanic_41/usr/src/lib/pam_modules/krb5/
H A Dkrb5_authenticate.c507 krb5_principal me = NULL, clientp = NULL; in attempt_krb5_auth() local
567 clientp = my_creds->client; in attempt_krb5_auth()
974 if (clientp && my_creds->client && clientp != my_creds->client) in attempt_krb5_auth()
975 krb5_free_principal(kmd->kcontext, clientp); in attempt_krb5_auth()

12