Home
last modified time | relevance | path

Searched refs:connection (Results 1 – 25 of 111) sorted by relevance

12345

/titanic_41/usr/src/cmd/ndmpd/ndmp/
H A Dndmpd_comm.c99 static int ndmp_recv_msg(ndmp_connection_t *connection);
100 static int ndmp_process_messages(ndmp_connection_t *connection,
102 static ndmp_msg_handler_t *ndmp_get_handler(ndmp_connection_t *connection,
137 ndmp_connection_t *connection; in ndmp_create_connection() local
139 connection = ndmp_malloc(sizeof (ndmp_connection_t)); in ndmp_create_connection()
140 if (connection == NULL) in ndmp_create_connection()
143 connection->conn_sock = -1; in ndmp_create_connection()
144 connection->conn_my_sequence = 0; in ndmp_create_connection()
145 connection->conn_authorized = FALSE; in ndmp_create_connection()
146 connection->conn_eof = FALSE; in ndmp_create_connection()
[all …]
H A Dndmpd_scsi.c53 static void scsi_open_send_reply(ndmp_connection_t *connection, int err);
54 static void common_open(ndmp_connection_t *connection, char *devname);
55 static void common_set_target(ndmp_connection_t *connection, char *device,
78 ndmpd_scsi_open_v2(ndmp_connection_t *connection, void *body) in ndmpd_scsi_open_v2() argument
82 common_open(connection, request->device.name); in ndmpd_scsi_open_v2()
100 ndmpd_scsi_close_v2(ndmp_connection_t *connection, void *body) in ndmpd_scsi_close_v2() argument
103 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_scsi_close_v2()
108 ndmp_send_reply(connection, (void *) &reply, in ndmpd_scsi_close_v2()
126 ndmp_send_reply(connection, (void *) &reply, in ndmpd_scsi_close_v2()
150 ndmpd_scsi_get_state_v2(ndmp_connection_t *connection, void *body) in ndmpd_scsi_get_state_v2() argument
[all …]
H A Dndmpd_tape.c52 static void tape_open_send_reply(ndmp_connection_t *connection, int err);
56 static void common_tape_open(ndmp_connection_t *connection, char *devname,
58 static void common_tape_close(ndmp_connection_t *connection);
109 ndmpd_tape_open_v2(ndmp_connection_t *connection, void *body) in ndmpd_tape_open_v2() argument
112 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_tape_open_v2()
157 tape_open_send_reply(connection, err); in ndmpd_tape_open_v2()
161 switch (ndmp_open_list_add(connection, adptnm, sid, lun, devid)) { in ndmpd_tape_open_v2()
175 tape_open_send_reply(connection, err); in ndmpd_tape_open_v2()
188 tape_open_send_reply(connection, NDMP_NO_TAPE_LOADED_ERR); in ndmpd_tape_open_v2()
213 tape_open_send_reply(connection, err); in ndmpd_tape_open_v2()
[all …]
H A Dndmpd_connect.c65 static struct conn_list *ndmp_connect_list_find(ndmp_connection_t *connection);
75 static void ndmp_connect_get_v2(ndmp_connection_t *connection,
85 static void ndmp_connect_get_v3(ndmp_connection_t *connection,
142 ndmpd_connect_open_v2(ndmp_connection_t *connection, void *body) in ndmpd_connect_open_v2() argument
150 if (!(session = (ndmpd_session_t *)ndmp_get_client_data(connection))) in ndmpd_connect_open_v2()
159 ndmp_send_reply(connection, (void *) &reply, in ndmpd_connect_open_v2()
171 ndmp_set_version(connection, request->protocol_version); in ndmpd_connect_open_v2()
190 ndmpd_connect_client_auth_v2(ndmp_connection_t *connection, void *body) in ndmpd_connect_client_auth_v2() argument
220 ndmpd_audit_connect(connection, EINVAL); in ndmpd_connect_client_auth_v2()
230 ndmp_set_authorized(connection, FALSE); in ndmpd_connect_client_auth_v2()
[all …]
H A Dndmpd_config.c105 ndmpd_config_get_host_info_v2(ndmp_connection_t *connection, void *body) in ndmpd_config_get_host_info_v2() argument
141 ndmp_send_reply(connection, (void *) &reply, in ndmpd_config_get_host_info_v2()
160 ndmpd_config_get_butype_attr_v2(ndmp_connection_t *connection, void *body) in ndmpd_config_get_butype_attr_v2() argument
180 ndmp_send_reply(connection, (void *) &reply, in ndmpd_config_get_butype_attr_v2()
200 ndmpd_config_get_mover_type_v2(ndmp_connection_t *connection, void *body) in ndmpd_config_get_mover_type_v2() argument
212 ndmp_send_reply(connection, (void *) &reply, in ndmpd_config_get_mover_type_v2()
232 ndmpd_config_get_auth_attr_v2(ndmp_connection_t *connection, void *body) in ndmpd_config_get_auth_attr_v2() argument
236 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_config_get_auth_attr_v2()
263 ndmp_send_reply(connection, (void *) &reply, in ndmpd_config_get_auth_attr_v2()
289 ndmpd_config_get_host_info_v3(ndmp_connection_t *connection, void *body) in ndmpd_config_get_host_info_v3() argument
[all …]
H A Dndmpd_data.c98 ndmpd_data_get_state_v2(ndmp_connection_t *connection, void *body) in ndmpd_data_get_state_v2() argument
101 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_data_get_state_v2()
121 ndmp_send_reply(connection, &reply, in ndmpd_data_get_state_v2()
139 ndmpd_data_start_backup_v2(ndmp_connection_t *connection, void *body) in ndmpd_data_start_backup_v2() argument
143 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_data_start_backup_v2()
161 ndmp_send_reply(connection, &reply, in ndmpd_data_start_backup_v2()
180 ndmpd_data_start_recover_v2(ndmp_connection_t *connection, void *body) in ndmpd_data_start_recover_v2() argument
184 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_data_start_recover_v2()
200 ndmp_send_reply(connection, &reply, in ndmpd_data_start_recover_v2()
222 ndmpd_data_get_env_v2(ndmp_connection_t *connection, void *body) in ndmpd_data_get_env_v2() argument
[all …]
H A Dndmpd_mover.c137 ndmpd_mover_get_state_v2(ndmp_connection_t *connection, void *body) in ndmpd_mover_get_state_v2() argument
140 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_mover_get_state_v2()
159 ndmp_send_reply(connection, (void *) &reply, in ndmpd_mover_get_state_v2()
177 ndmpd_mover_listen_v2(ndmp_connection_t *connection, void *body) in ndmpd_mover_listen_v2() argument
181 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_mover_listen_v2()
191 ndmp_send_reply(connection, (void *) &reply, in ndmpd_mover_listen_v2()
202 ndmp_send_reply(connection, (void *) &reply, in ndmpd_mover_listen_v2()
223 ndmp_send_reply(connection, (void *) &reply, in ndmpd_mover_listen_v2()
242 ndmpd_mover_continue_v2(ndmp_connection_t *connection, void *body) in ndmpd_mover_continue_v2() argument
245 ndmpd_session_t *session = ndmp_get_client_data(connection); in ndmpd_mover_continue_v2()
[all …]
/titanic_41/usr/src/cmd/hal/hald/
H A Dhald_dbus.c56 raise_error (DBusConnection *connection,
76 raise_error (DBusConnection *connection, in raise_error() argument
93 if (!dbus_connection_send (connection, reply, NULL)) in raise_error()
105 raise_no_such_device (DBusConnection *connection, in raise_no_such_device() argument
109 connection, in_reply_to, in raise_no_such_device()
124 raise_no_such_property (DBusConnection *connection, in raise_no_such_property() argument
129 connection, in_reply_to, in raise_no_such_property()
144 raise_property_type_error (DBusConnection *connection, in raise_property_type_error() argument
149 connection, in_reply_to, in raise_property_type_error()
164 raise_syntax (DBusConnection *connection, in raise_syntax() argument
[all …]
/titanic_41/usr/src/cmd/hotplug/
H A Dhotplug.c247 char *connection = NULL; in cmd_list() local
267 parse_target(argc, argv, &path, &connection, usage_str); in cmd_list()
274 if ((root = hp_init(path, connection, flags)) == NULL) { in cmd_list()
299 char *connection = NULL; in cmd_online() local
304 parse_target(argc, argv, &path, &connection, usage_str); in cmd_online()
307 if ((path == NULL) || (connection == NULL)) { in cmd_online()
314 if ((root = hp_init(path, connection, 0)) == NULL) { in cmd_online()
359 char *connection = NULL; in cmd_offline() local
366 parse_target(argc, argv, &path, &connection, usage_str); in cmd_offline()
369 if ((path == NULL) || (connection == NULL)) { in cmd_offline()
[all …]
/titanic_41/usr/src/lib/print/libpapi-ipp/common/
H A Dipp-support.c225 if (svc->connection == NULL) in _default_destination()
323 return (httpWrite(svc->connection, buffer, length)); in ipp_request_write()
333 while ((rc = httpRead(svc->connection, p, i)) != i) { in ipp_request_read()
364 httpClearFields(svc->connection); in ipp_send_initial_request_block()
366 httpSetField(svc->connection, HTTP_FIELD_TRANSFER_ENCODING, in ipp_send_initial_request_block()
370 httpSetField(svc->connection, HTTP_FIELD_CONTENT_LENGTH, in ipp_send_initial_request_block()
373 httpSetField(svc->connection, HTTP_FIELD_CONTENT_TYPE, in ipp_send_initial_request_block()
375 httpSetField(svc->connection, HTTP_FIELD_AUTHORIZATION, in ipp_send_initial_request_block()
376 svc->connection->authstring); in ipp_send_initial_request_block()
379 httpFlush(svc->connection); in ipp_send_initial_request_block()
[all …]
H A Dservice.c72 if (svc->connection != NULL) /* alread connected ? */ in service_connect()
109 svc->connection = httpConnectEncrypt(svc->uri->host, port, in service_connect()
111 if (svc->connection == NULL) { in service_connect()
184 if (svc->connection != NULL) in papiServiceDestroy()
185 httpClose(svc->connection); in papiServiceDestroy()
239 httpEncryption(svc->connection, in papiServiceSetEncryption()
H A Djob.c276 if (svc->connection == NULL) in internal_job_submit()
374 if (svc->connection == NULL) in papiJobStreamOpen()
385 *stream = svc->connection; in papiJobStreamOpen()
448 status = httpUpdate(svc->connection); in papiJobStreamClose()
452 httpWait(svc->connection, 1000); in papiJobStreamClose()
486 if (svc->connection == NULL) in papiJobQuery()
533 if (svc->connection == NULL) in _job_cancel_hold_release_restart_promote()
600 if (svc->connection == NULL) in papiJobMove()
643 if (svc->connection == NULL) in papiJobModify()
H A Dprinter.c94 if (svc->connection == NULL) in papiPrintersList()
150 if (svc->connection == NULL) in papiPrinterQuery()
196 if (svc->connection == NULL) in _printer_enable_disable_pause_resume_delete()
280 if (svc->connection == NULL) in papiPrinterModify()
330 if (svc->connection == NULL) in papiPrinterPurgeJobs()
378 if (svc->connection == NULL) in papiPrinterListJobs()
/titanic_41/usr/src/cmd/hotplugd/
H A Dhotplugd_door.c297 char *connection; in cmd_getinfo() local
310 if (nvlist_lookup_string(args, HPD_CONNECTION, &connection) != 0) in cmd_getinfo()
311 connection = NULL; in cmd_getinfo()
316 if ((rv = getinfo(path, connection, flags, &root)) == 0) { in cmd_getinfo()
369 char *path, *connection; in cmd_changestate() local
378 (nvlist_lookup_string(args, HPD_CONNECTION, &connection) != 0) || in cmd_changestate()
395 audit_changestate(uc, HP_MODIFY_AUTH, path, connection, in cmd_changestate()
402 status = changestate(path, connection, state, flags, &old_state, &root); in cmd_changestate()
406 audit_changestate(uc, HP_MODIFY_AUTH, path, connection, state, in cmd_changestate()
468 char *path, *connection, *options; in cmd_private() local
[all …]
H A Dhotplugd_info.c68 getinfo(const char *path, const char *connection, uint_t flags, hp_node_t *retp) in getinfo() argument
79 (connection == NULL) ? "NULL" : connection, flags); in getinfo()
86 if ((rv = copy_devinfo(basepath, connection, flags, &root)) != 0) { in getinfo()
136 copy_devinfo(const char *path, const char *connection, uint_t flags, in copy_devinfo() argument
157 if (connection != NULL) in copy_devinfo()
158 rv = copy_hotplug(NULL, di_root, connection, flags, &hp_root); in copy_devinfo()
241 copy_hotplug(hp_node_t parent, di_node_t dev, const char *connection, in copy_hotplug() argument
276 if ((connection == NULL) && (di_hp_depends_on(hp) != -1)) in copy_hotplug()
280 if ((connection != NULL) && in copy_hotplug()
281 (strcmp(di_hp_name(hp), connection) != 0)) in copy_hotplug()
[all …]
H A Dhotplugd_impl.c64 changestate(const char *path, const char *connection, int state, uint_t flags, in changestate() argument
73 path, connection, state, flags); in changestate()
82 if ((rv = getinfo(path, connection, 0, &root)) != 0) { in changestate()
133 if (modctl(MODHPOPS, MODHPOPS_CHANGE_STATE, path, connection, state)) in changestate()
165 private_options(const char *path, const char *connection, hp_cmd_t cmd, in private_options() argument
174 path, connection, options); in private_options()
198 if (modctl(MODHPOPS, MODHPOPS_BUS_GET, path, connection, in private_options()
203 if (modctl(MODHPOPS, MODHPOPS_BUS_SET, path, connection, in private_options()
H A Dhotplugd_impl.h64 int getinfo(const char *path, const char *connection, uint_t flags,
66 int changestate(const char *path, const char *connection, int state,
68 int private_options(const char *path, const char *connection,
/titanic_41/usr/src/cmd/krb5/krb5kdc/
H A Dnetwork.c153 struct connection { struct
156 void (*service)(struct connection *, const char *, int); argument
225 static SET(struct connection *) connections;
284 static struct connection *
286 void (*service)(struct connection *, const char *, int)) in add_fd() argument
288 struct connection *newconn; in add_fd()
312 static void process_packet(struct connection *, const char *, int);
313 static void accept_tcp_connection(struct connection *, const char *, int);
314 static void process_tcp_connection(struct connection *, const char *, int);
316 static struct connection *
[all …]
/titanic_41/usr/src/cmd/hal/addons/network-devices/
H A Daddon-network-discovery.c149 nds_filter_function(DBusConnection *connection, DBusMessage *message, in nds_filter_function() argument
217 if (!dbus_connection_send(connection, reply, NULL)) { in nds_filter_function()
220 dbus_connection_flush(connection); in nds_filter_function()
229 DBusConnection *connection; in nds_claim_interface() local
249 if ((connection = libhal_ctx_get_dbus_connection(ctx)) == NULL) { in nds_claim_interface()
260 dbus_connection_setup_with_g_main(connection, NULL); in nds_claim_interface()
261 dbus_connection_add_filter(connection, nds_filter_function, ctx, NULL); in nds_claim_interface()
262 dbus_connection_set_exit_on_disconnect(connection, 0); in nds_claim_interface()
/titanic_41/usr/src/lib/libhotplug/common/
H A Dlibhotplug.c61 hp_init(const char *path, const char *connection, uint_t flags) in hp_init() argument
69 (void *)path, (void *)connection, flags); in hp_init()
79 if ((args = i_hp_set_args(HP_CMD_GETINFO, path, connection, flags, in hp_init()
440 hp_path(hp_node_t node, char *path, char *connection) in hp_path() argument
449 (void *)path, (void *)connection); in hp_path()
451 if ((node == NULL) || (path == NULL) || (connection == NULL)) { in hp_path()
457 (void) memset(connection, 0, MAXPATHLEN); in hp_path()
463 (void) strlcpy(connection, node->hp_name, MAXPATHLEN); in hp_path()
514 char connection[MAXPATHLEN]; in hp_set_state() local
557 if ((rv = hp_path(node, path, connection)) != 0) in hp_set_state()
[all …]
H A Dlibhotplug.h77 hp_node_t hp_init(const char *path, const char *connection, uint_t flags);
90 int hp_path(hp_node_t node, char *path, char *connection);
/titanic_41/usr/src/cmd/policykit/
H A Dpolkit-is-privileged.c85 DBusConnection *connection = NULL; in main() local
148 connection = dbus_bus_get (DBUS_BUS_SYSTEM, &error); in main()
149 if (connection == NULL) { in main()
155 ctx = libpolkit_new_context (connection); in main()
/titanic_41/usr/src/lib/hal/libhal/common/
H A Dlibhal.c258 DBusConnection *connection; /**< D-BUS connection */ member
447 reply = dbus_connection_send_with_reply_and_block (ctx->connection, in libhal_device_get_all_properties()
947 filter_func (DBusConnection * connection, in filter_func() argument
1102 reply = dbus_connection_send_with_reply_and_block (ctx->connection, message, -1, &_error); in libhal_get_all_devices()
1168 reply = dbus_connection_send_with_reply_and_block (ctx->connection, in libhal_device_get_property_type()
1230 reply = dbus_connection_send_with_reply_and_block (ctx->connection, in libhal_device_get_property_strlist()
1303 reply = dbus_connection_send_with_reply_and_block (ctx->connection, in libhal_device_get_property_string()
1376 reply = dbus_connection_send_with_reply_and_block (ctx->connection, in libhal_device_get_property_int()
1447 reply = dbus_connection_send_with_reply_and_block (ctx->connection, in libhal_device_get_property_uint64()
1517 reply = dbus_connection_send_with_reply_and_block (ctx->connection, in libhal_device_get_property_double()
[all …]
/titanic_41/usr/src/cmd/ipf/examples/
H A Dexample.102 # pass ack packets (ie established connection)
7 # block incoming connection requests to my internal network from the big bad
/titanic_41/usr/src/lib/print/mod_ipp/
H A Dmod_ipp.c251 s = ap_get_remote_host(r->connection, r->per_dir_config, in ipp_handler()
254 s = ap_get_remote_host(r->connection, r->per_dir_config, in ipp_handler()
308 r->connection->conn_config, &core_module); in ipp_handler()
313 sockfd = ap_bfileno(r->connection->client, B_RD); in ipp_handler()

12345