| /onnv/onnv-gate/usr/src/lib/mms/mms/common/ |
| mms_sock.h | 35 int mms_read(mms_t *conn, char *buf, int len);
36 int mms_write(mms_t *conn, struct iovec *iov, int num);
38 int mms_read_has_error(mms_t *conn);
39 int mms_write_has_error(mms_t *conn);
47 int mms_ssl_has_cert_clause(void *ssl_data, mms_t *conn);
48 int mms_ssl_build_cert_clause(void *ssl_data, mms_t *conn,
50 int mms_ssl_verify_cert_clause(void *ssl_data, mms_t *conn,
56 int mms_ssl_check_conn_cert(void *ssl_data, mms_t *conn);
57 int mms_ssl_connect(void *ssl_data, mms_t *conn);
58 int mms_ssl_accept(void *ssl_data, mms_t *conn);
[all...] |
| mms_sock.c | 49 mms_connect(char *host, char *service, void *ssl_data, mms_t *conn)
59 (void) memset(conn, 0, sizeof (mms_t));
60 conn->mms_fd = -1;
69 mms_sys_error(&conn->mms_err, MMS_ERR_GETHOSTNAME);
76 mms_gai_error(&conn->mms_err, MMS_ERR_GETADDRINFO, n);
80 mms_error(&conn->mms_err, MMS_ERR_RES_NULL);
103 mms_error(&conn->mms_err, MMS_ERR_SERVICE_NOT_FOUND);
107 conn->mms_fd = sockfd;
110 if (ssl_data && mms_ssl_connect(ssl_data, conn)) {
120 mms_accept(int serv_fd, void *ssl_data, mms_t *conn)
[all...] |
| mms_rw.c | 86 mms_writer(mms_t *conn, char *buf)
127 if ((rc = mms_write(conn, iov_start, niov)) < 0) {
128 if (mms_write_has_error(conn) == 0)
203 mms_reader(mms_t *conn, char **cmdbuf)
216 while ((rc = mms_read(conn, hdr, MMS_SOCK_HDR_SIZE)) < 0) {
217 if (mms_read_has_error(conn) == 0) {
235 mms_error(&conn->mms_err, MMS_ERR_READ);
244 mms_error(&conn->mms_err, MMS_ERR_NOMEM);
248 while ((rc = mms_read(conn, buf, bufsize)) < 0) {
249 if (mms_read_has_error(conn) == 0)
[all...] |
| connect.c | 170 * conn Structure which will contain the socket connection
197 mms_t *conn,
219 if (mms_connect(net->cli_host, net->cli_port, ssl_data, conn)) {
220 mms_get_error_string(&conn->mms_err, ebuf, MMS_EBUF_LEN);
231 if (mms_ssl_has_cert_clause(ssl_data, conn)) {
236 if (mms_ssl_build_cert_clause(ssl_data, conn,
296 if ((n = mms_writer(conn, cmd_str)) != len) {
297 mms_get_error_string(&conn->mms_err, ebuf, MMS_EBUF_LEN);
301 mms_close(conn);
307 if ((n = mms_reader(conn, &rsp)) <= 0)
[all...] |
| /onnv/onnv-gate/usr/src/cmd/hal/hald/ |
| hald_dbus.h | 33 DBusHandlerResult manager_get_all_devices (DBusConnection *conn,
35 DBusHandlerResult manager_find_device_string_match (DBusConnection *conn,
37 DBusHandlerResult manager_find_device_by_capability (DBusConnection *conn,
39 DBusHandlerResult manager_device_exists (DBusConnection *conn,
41 DBusHandlerResult device_get_all_properties (DBusConnection *conn,
43 DBusHandlerResult device_get_property (DBusConnection *conn,
45 DBusHandlerResult device_get_property_type (DBusConnection *conn,
47 DBusHandlerResult device_set_property (DBusConnection *conn,
49 DBusHandlerResult device_add_capability (DBusConnection *conn,
51 DBusHandlerResult device_remove_capability (DBusConnection *conn,
[all...] |
| /onnv/onnv-gate/usr/src/uts/common/inet/ |
| sdp_itf.h | 86 extern int sdp_bind(struct sdp_conn_struct_t *conn, struct sockaddr *addr,
88 extern void sdp_close(struct sdp_conn_struct_t *conn);
89 extern int sdp_connect(struct sdp_conn_struct_t *conn,
95 extern int sdp_disconnect(struct sdp_conn_struct_t *conn, int flags);
96 extern int sdp_shutdown(struct sdp_conn_struct_t *conn, int flag);
97 extern int sdp_polldata(struct sdp_conn_struct_t *conn, int flag);
98 extern int sdp_get_opt(struct sdp_conn_struct_t *conn, int level, int opt,
100 extern int sdp_getpeername(struct sdp_conn_struct_t *conn,
102 extern int sdp_getsockname(struct sdp_conn_struct_t *conn,
105 extern int sdp_listen(struct sdp_conn_struct_t *conn, int backlog)
[all...] |
| sctp_itf.h | 80 extern int sctp_bind(struct sctp_s *conn, struct sockaddr *addr,
82 extern int sctp_bindx(struct sctp_s *conn, const void *addrs, int addrcnt,
84 extern void sctp_close(struct sctp_s *conn);
85 extern int sctp_connect(struct sctp_s *conn, const struct sockaddr *dst,
90 extern int sctp_disconnect(struct sctp_s *conn);
91 extern int sctp_get_opt(struct sctp_s *conn, int level, int opt, void *opts,
93 extern int sctp_getpeername(struct sctp_s *conn, struct sockaddr *addr,
95 extern int sctp_getsockname(struct sctp_s *conn, struct sockaddr *addr,
98 extern int sctp_listen(struct sctp_s *conn);
99 extern void sctp_recvd(struct sctp_s *conn, int len)
[all...] |
| /onnv/onnv-gate/usr/src/uts/common/rpc/ |
| rpc_rdma.h | 106 RDMA_CC_CLNT, /* CONN is for a client */
107 RDMA_CC_SRV /* CONN is for a server */
343 typedef struct conn { struct
344 rdma_mod_t *c_rdmamod; /* RDMA transport info for conn */
349 struct conn *c_next; /* next in list of connections */
350 struct conn *c_prev; /* prev in list of connections */
362 time_t c_last_used; /* last time any activity on the conn */
363 } CONN;
370 CONN *conn; member in struct:rdma_recv_data
[all...] |
| /onnv/onnv-gate/usr/src/lib/libsasl/lib/ |
| common.c | 111 int (*_sasl_client_idle_hook)(sasl_conn_t *conn) = NULL;
112 int (*_sasl_server_idle_hook)(sasl_conn_t *conn) = NULL;
272 int sasl_encode(sasl_conn_t *conn, const char *input,
279 if(!conn) return SASL_BADPARAM;
281 PARAMERROR(conn);
291 result = sasl_encodev(conn, &tmp, 1, output, outputlen);
293 RETURN(conn, result);
298 int sasl_encodev(sasl_conn_t *conn,
311 if (!conn) return SASL_BADPARAM;
313 PARAMERROR(conn);
1433 sasl_conn_t * conn; local
1511 sasl_conn_t *conn; local
[all...] |
| server.c | 117 static int _sasl_checkpass(sasl_conn_t *conn,
128 * conn -- SASL connection
149 int sasl_setpass(sasl_conn_t *conn,
157 sasl_server_conn_t *s_conn = (sasl_server_conn_t *) conn;
164 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx;
173 if (!conn) return SASL_BADPARAM;
174 if (conn->type != SASL_CONN_SERVER) PARAMERROR(conn);
178 PARAMERROR(conn);
[all...] |
| client.c | 332 client_idle(sasl_conn_t *conn)
336 _sasl_global_context_t *gctx = conn == NULL ? _sasl_gbl_ctx() : conn->gctx;
352 conn,
353 conn ? ((sasl_client_conn_t *)conn)->cparams : NULL))
596 sasl_client_conn_t *conn; local
631 conn = (sasl_client_conn_t *)*pconn;
633 conn->mech = NULL;
635 conn->cparams=sasl_ALLOC(sizeof(sasl_client_params_t))
[all...] |
| external.c | 82 || !sparams->utils->conn)
85 if (!sparams->utils->conn->external.auth_id)
106 || !sparams->utils->conn
113 if (!sparams->utils->conn->external.auth_id)
117 (!strcmp(sparams->utils->conn->external.auth_id, "anonymous"))) {
119 sasl_seterror(sparams->utils->conn,0,
122 sasl_seterror(sparams->utils->conn,0,"anonymous login not allowed");
139 result = sparams->canon_user(sparams->utils->conn,
143 result = sparams->canon_user(sparams->utils->conn,
144 sparams->utils->conn->external.auth_id, 0
[all...] |
| checkpw.c | 150 static int auxprop_verify_password(sasl_conn_t *conn,
162 sasl_server_conn_t *sconn = (sasl_server_conn_t *)conn;
168 if (!conn || !userstr)
181 result = _sasl_canon_user(conn, userstr, 0,
183 &(conn->oparams));
263 int _sasl_auxprop_verify_apop(sasl_conn_t *conn,
278 sasl_server_conn_t *sconn = (sasl_server_conn_t *)conn;
282 if (!conn || !userstr || !challenge || !response)
283 PARAMERROR(conn)
291 _sasl_log(conn, SASL_LOG_ERR, "could not perform password lookup")
[all...] |
| saslint.h | 74 #define RETURN(conn, val) { if(conn && (val) < SASL_OK) \
75 (conn)->error_code = (val); \
78 #define MEMERROR(conn) {\
79 if(conn) sasl_seterror( (conn), 0, \
81 RETURN(conn, SASL_NOMEM) }
82 #define PARAMERROR(conn) {\
83 if(conn) sasl_seterror( (conn), SASL_NOLOG,
[all...] |
| /onnv/onnv-gate/usr/src/cmd/isns/isnsd/ |
| server.c | 64 conn_arg_t *conn; local
70 conn = (conn_arg_t *)arg;
72 conn->out_packet.pdu = NULL;
73 conn->out_packet.sz = 0;
79 isns_rcv_pdu(conn->so, &pdu, &pdu_sz, ISNS_RCV_TIMEOUT) > 0) {
83 struct sockaddr_storage *ssp = &conn->ss;
146 conn->in_packet.pdu = combined_pdu;
147 conn->out_packet.pl = 0;
148 conn->ec = 0;
150 if (packet_split_verify(conn) == 0)
238 conn_arg_t *conn; local
[all...] |
| func.c | 94 * conn - the argument of the connection.
101 conn_arg_t *conn
106 isns_pdu_t *pdu = conn->in_packet.pdu;
117 conn->in_packet.source = source;
129 * conn - the argument of the connection.
136 conn_arg_t *conn
141 isns_pdu_t *pdu = conn->in_packet.pdu;
147 conn->in_packet.key = key;
148 conn->in_packet.key_len = key_len;
159 * conn - the argument of the connection
[all...] |
| /onnv/onnv-gate/usr/src/lib/fm/libldom/sparc/ |
| ldom_xmpp_client.c | 72 static int iowrite(xmpp_conn_t *conn, char *buf, int size);
77 static void xmpp_close(xmpp_conn_t *conn);
78 static int start_tls(xmpp_conn_t *conn);
79 static void handle_ldm_resp(xmpp_conn_t *conn, char *buf, size_t buf_size);
80 static void handle_ldm_event(xmpp_conn_t *conn, char *buf, size_t buf_size);
194 xmpp_conn_t *conn = (xmpp_conn_t *)state; local
197 conn->state = CONN_STATE_DONE;
199 (void) iowrite(conn, START_TLS, strlen(START_TLS));
201 if (start_tls(conn)) {
202 conn->state = CONN_STATE_FAILURE
344 xmpp_conn_t conn; local
529 xmpp_conn_t conn; local
[all...] |
| /onnv/onnv-gate/usr/src/cmd/ssh/sftp/ |
| sftp-client.c | 297 sftp_proto_version(struct sftp_conn *conn)
299 return(conn->version);
303 do_close(struct sftp_conn *conn, char *handle, u_int handle_len)
310 id = conn->msg_id++;
314 send_msg(conn->fd_out, &msg);
317 status = get_status(conn->fd_in, id);
328 do_lsreaddir(struct sftp_conn *conn, char *path, int printflag,
335 id = conn->msg_id++;
341 send_msg(conn->fd_out, &msg);
345 handle = get_handle(conn->fd_in, id, &handle_len)
[all...] |
| sftp-glob.c | 46 struct sftp_conn *conn; member in struct:__anon1801
56 if (do_readdir(cur.conn, (char *)path, &r->dir)) {
120 if (!(a = do_lstat(cur.conn, (char *)path, 0)))
133 if (!(a = do_stat(cur.conn, (char *)path, 0)))
142 remote_glob(struct sftp_conn *conn, const char *pattern, int flags,
152 cur.conn = conn;
|
| /onnv/onnv-gate/usr/src/lib/libsasl/include/ |
| sasl.h | 544 * conn -- connection context
554 typedef int sasl_getsecret_t(sasl_conn_t *conn, void *context, int id,
600 * conn -- connection context
611 typedef int sasl_authorize_t(sasl_conn_t *conn,
634 typedef int sasl_server_userdb_checkpass_t(sasl_conn_t *conn,
650 typedef int sasl_server_userdb_setpass_t(sasl_conn_t *conn,
687 typedef int sasl_canon_user_t(sasl_conn_t *conn,
740 * conn -- mandatory connection context
745 LIBSASL_API const char *sasl_errdetail(sasl_conn_t *conn);
762 * if conn is NULL, function does nothin
[all...] |
| /onnv/onnv-gate/usr/src/cmd/fm/modules/common/event-transport/ |
| etm_xport_api.h | 63 int (*cb_func)(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag,
74 etm_xport_cb_func(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag,
96 etm_xport_close(fmd_hdl_t *hdl, etm_xport_conn_t conn);
107 etm_xport_read(fmd_hdl_t *hdl, etm_xport_conn_t conn, hrtime_t timeout,
115 etm_xport_write(fmd_hdl_t *hdl, etm_xport_conn_t conn, hrtime_t timeout,
|
| /onnv/onnv-gate/usr/src/common/mms/mms/ |
| mms_network.h | 89 int mms_reader(mms_t *conn, char **buf);
90 int mms_writer(mms_t *conn, char *buf);
91 void mms_close(mms_t *conn);
96 mms_t *conn,
99 int mms_mmdisconnect(mms_t *conn);
|
| /onnv/onnv-gate/usr/src/cmd/krb5/krb5kdc/ |
| network.c | 340 struct connection *conn;
343 FOREACH_ELT(connections, i, conn)
344 if (conn == xconn) {
730 static void process_packet(struct connection *conn, const char *prog,
742 int port_fd = conn->fd;
799 static void accept_tcp_connection(struct connection *conn, const char *prog,
810 s = accept(conn->fd, addr, &addrlen);
895 kill_tcp_connection(struct connection *conn)
897 if (conn->u.tcp.response)
898 krb5_free_data(kdc_context, conn->u.tcp.response)
337 struct connection *conn; local
1128 struct connection *conn; local
[all...] |
| /onnv/onnv-gate/usr/src/lib/gss_mechs/mech_krb5/krb5/os/ |
| sendto_kdc.c | 614 static int service_tcp_fd (struct conn_state *conn,
616 static int service_udp_fd (struct conn_state *conn,
839 maybe_send (struct conn_state *conn,
847 dprint("maybe_send(@%p) state=%s type=%s\n", conn,
849 state_strings[conn->state],
850 conn->is_udp ? "udp" : "tcp");
851 if (conn->state == INITIALIZING)
852 return start_connection(conn, selstate, callback_info, callback_buffer);
855 if (conn->state == FAILED) {
860 if (conn->addr->ai_socktype == SOCK_STREAM)
[all...] |
| /onnv/onnv-gate/usr/src/cmd/iscsi/iscsitgtd/ |
| util_port.c | 86 iscsi_conn_t *conn; local
182 if ((conn = calloc(1, sizeof (iscsi_conn_t))) == NULL) {
197 conn->c_initiator_sockaddr = st;
207 conn->c_target_sockaddr = st;
209 conn->c_fd = fd;
210 conn->c_mgmtq = q;
211 conn->c_up_at = time(NULL);
212 conn->c_state = S1_FREE;
213 (void) pthread_mutex_init(&conn->c_mutex, NULL);
214 (void) pthread_mutex_init(&conn->c_state_mutex, NULL)
[all...] |
