| /linux/net/ceph/ |
| H A D | messenger_v1.c | 205 if (con->in_seq > con->in_seq_acked) { in prepare_write_message()
206 con->in_seq_acked = con->in_seq; in prepare_write_message()
225 con_out_kvec_add(con, sizeof(con->v1.out_hdr), &con->v1.out_hdr); in prepare_write_message()
235 memcpy(&con->v1.out_hdr, &con->out_msg->hdr, sizeof(con->v1.out_hdr)); in prepare_write_message()
271 con->in_seq_acked = con->in_seq; in prepare_write_ack()
292 con->in_seq_acked = con->in_seq; in prepare_write_seq()
595 con->in_front_crc = con->in_middle_crc = con->in_data_crc = 0; in prepare_read_message()
680 con, con->v1.in_reply.tag, in read_partial_connect()
843 con->ops->peer_reset(con); in process_connect()
1225 BUG_ON(con->in_msg->con != con); in read_partial_message()
[all …]
|
| H A D | messenger_v2.c | 682 con->in_front_crc, con->in_middle_crc, con->in_data_crc); in verify_epilogue_crcs()
712 WARN_ON(con->v2.hmac_tfm || con->v2.gcm_tfm || con->v2.gcm_req); in setup_crypto()
1465 ret = hmac_sha256(con, con->v2.in_sign_kvecs, con->v2.in_sign_kvec_cnt, in prepare_auth_signature()
1539 con->v2.client_cookie, con->v2.server_cookie, con->v2.global_seq, in prepare_session_reconnect()
1582 con->in_seq_acked, con->in_seq); in prepare_ack()
1583 con->in_seq_acked = con->in_seq; in prepare_ack()
1743 con->in_seq_acked = con->in_seq; in prepare_message()
1798 add_in_kvec(con, con->v2.in_buf, in prepare_read_preamble()
1854 add_in_kvec(con, con->v2.in_buf, in prepare_read_control_remainder()
2726 con->ops->peer_reset(con); in process_session_reset()
[all …]
|
| H A D | messenger.c | 357 con, con->state); in ceph_sock_data_ready()
514 WARN_ON(con->in_msg->con != con); in ceph_con_reset_protocol()
519 WARN_ON(con->out_msg->con != con); in ceph_con_reset_protocol()
1405 BUG_ON(con->in_msg->con != con); in ceph_con_process_message()
1447 con->ops->put(con); in queue_con_delay()
1463 con->ops->put(con); in cancel_con()
1509 con, con->delay); in con_backoff()
1535 con->ops->fault(con); in con_fault_finish()
1607 con->ops->put(con); in ceph_con_workfn()
1709 msg->con = con ? con->ops->get(con) : NULL; in msg_con_set()
[all …]
|
| /linux/drivers/usb/typec/ucsi/ |
| H A D | ucsi.c | 225 struct ucsi_connector *con = uwork->con; in ucsi_poll_worker() local
265 uwork->con = con; in ucsi_partner_task()
835 if (con->pd) in ucsi_register_device_pdos()
848 typec_port_set_usb_power_delivery(con->port, con->pd); in ucsi_register_device_pdos()
968 con->rdo = con->status.request_data_obj; in ucsi_pwr_opmode_change()
1102 ret = ucsi_send_command(con->ucsi, command, &con->cap, sizeof(con->cap)); in ucsi_check_connector_capability()
1121 ret = ucsi_send_command(con->ucsi, command, &con->status, sizeof(con->status)); in ucsi_check_connection()
1205 trace_ucsi_connector_change(con->num, &con->status); in ucsi_handle_connector_change()
1655 trace_ucsi_register_port(con->num, &con->status); in ucsi_register_port()
1766 for (con = connector; con->port; con++) { in ucsi_init()
[all …]
|
| H A D | psy.c | 70 pdo = con->src_pdos[0]; in ucsi_psy_get_voltage_min()
93 if (con->num_pdos > 0) { in ucsi_psy_get_voltage_max()
94 pdo = con->src_pdos[con->num_pdos - 1]; in ucsi_psy_get_voltage_max()
121 index = rdo_index(con->rdo); in ucsi_psy_get_voltage_now()
149 if (con->num_pdos > 0) { in ucsi_psy_get_current_max()
150 pdo = con->src_pdos[con->num_pdos - 1]; in ucsi_psy_get_current_max()
237 psy_cfg.drv_data = con; in ucsi_register_port_psy()
253 con->psy = power_supply_register(dev, &con->psy_desc, &psy_cfg); in ucsi_register_port_psy()
260 if (IS_ERR_OR_NULL(con->psy)) in ucsi_unregister_port_psy()
264 con->psy = NULL; in ucsi_unregister_port_psy()
[all …]
|
| H A D | displayport.c | 20 struct ucsi_connector *con; member
51 struct ucsi *ucsi = dp->con->ucsi; in ucsi_displayport_enter()
57 mutex_lock(&dp->con->lock); in ucsi_displayport_enter()
103 mutex_unlock(&dp->con->lock); in ucsi_displayport_enter()
115 mutex_lock(&dp->con->lock); in ucsi_displayport_exit()
147 mutex_unlock(&dp->con->lock); in ucsi_displayport_exit()
205 mutex_lock(&dp->con->lock); in ucsi_displayport_vdm()
212 mutex_unlock(&dp->con->lock); in ucsi_displayport_vdm()
218 mutex_unlock(&dp->con->lock); in ucsi_displayport_vdm()
262 mutex_unlock(&dp->con->lock); in ucsi_displayport_vdm()
[all …]
|
| /linux/net/tipc/ |
| H A D | topsrv.c | 121 return con && test_bit(CF_CONNECTED, &con->flags); in connected()
143 kfree(con); in tipc_conn_kref_release()
185 con = kzalloc(sizeof(*con), GFP_ATOMIC); in tipc_conn_alloc()
186 if (!con) in tipc_conn_alloc()
200 kfree(con); in tipc_conn_alloc()
213 return con; in tipc_conn_alloc()
225 return con; in tipc_conn_lookup()
322 if (!con) in tipc_topsrv_queue_evt()
355 if (!queue_work(con->server->send_wq, &con->swork)) in tipc_conn_write_space()
449 if (!queue_work(con->server->rcv_wq, &con->rwork)) in tipc_conn_data_ready()
[all …]
|
| /linux/fs/dlm/ |
| H A D | lowcomms.c | 309 con = kzalloc(sizeof(*con), alloc); in nodeid2con()
310 if (!con) in nodeid2con()
332 return con; in nodeid2con()
376 if (!con) { in nodeid_to_addr()
388 memcpy(&sas, &con->addr[con->curr_addr_index], in nodeid_to_addr()
393 if (con->curr_addr_index == con->addr_count) in nodeid_to_addr()
471 if (!con) { in dlm_lowcomms_addr()
825 con); in shutdown_connection()
1189 entry->con = con; in new_writequeue_entry()
1305 struct connection *con = e->con; in _dlm_lowcomms_commit_msg() local
[all …]
|
| /linux/kernel/printk/ |
| H A D | nbcon.c | 177 con->seq = 0; in nbcon_seq_force()
448 nbcon_state_read(con, cur); in nbcon_context_try_acquire_handover()
572 ctxt->pbufs = con->pbufs; in nbcon_context_try_acquire()
894 if (con->write_atomic) { in nbcon_emit_next_record()
895 done = con->write_atomic(con, wctxt); in nbcon_emit_next_record()
951 con->pbufs = kmalloc(sizeof(*con->pbufs), GFP_KERNEL); in nbcon_alloc()
952 if (!con->pbufs) { in nbcon_alloc()
975 BUG_ON(!con->pbufs); in nbcon_init()
977 nbcon_seq_force(con, con->seq); in nbcon_init()
993 kfree(con->pbufs); in nbcon_free()
[all …]
|
| H A D | conopt.c | 49 struct console_option *con; in console_opt_save() local
67 con = &conopt[i]; in console_opt_save()
69 if (con->name[0]) { in console_opt_save()
84 con->has_brl_opt = 1; in console_opt_save()
95 struct console_option *con; in console_opt_find() local
99 con = &conopt[i]; in console_opt_find()
101 return con; in console_opt_find()
123 struct console_option *con; in add_preferred_console_match() local
131 if (!con) in add_preferred_console_match()
140 if (con->has_brl_opt) in add_preferred_console_match()
[all …]
|
| H A D | internal.h | 17 #define con_printk(lvl, con, fmt, ...) \ argument
19 (con->flags & CON_NBCON) ? "" : "legacy ", \
20 (con->flags & CON_BOOT) ? "boot" : "", \
21 con->name, con->index, ##__VA_ARGS__)
75 u64 nbcon_seq_read(struct console *con);
76 void nbcon_seq_force(struct console *con, u64 seq);
77 bool nbcon_alloc(struct console *con);
78 void nbcon_init(struct console *con);
79 void nbcon_free(struct console *con);
99 static inline void nbcon_init(struct console *con) { } in nbcon_init() argument
[all …]
|
| /linux/tools/perf/util/ |
| H A D | bpf_lock_contention.c | 44 if (con->save_callstack) in lock_contention_prepare()
53 if (con->filters->nr_types) in lock_contention_prepare()
55 if (con->filters->nr_cgrps) in lock_contention_prepare()
59 if (con->filters->nr_syms) { in lock_contention_prepare()
70 con->filters->syms[i]); in lock_contention_prepare()
82 con->filters->addrs = addrs; in lock_contention_prepare()
133 if (con->filters->nr_types) { in lock_contention_prepare()
143 if (con->filters->nr_addrs) { in lock_contention_prepare()
422 account_end_timestamp(con); in lock_contention_read()
452 if (con->save_callstack) { in lock_contention_read()
[all …]
|
| /linux/include/linux/ceph/ |
| H A D | messenger.h | 34 struct ceph_connection *con,
40 int (*invalidate_authorizer)(struct ceph_connection *con);
43 void (*fault) (struct ceph_connection *con);
47 void (*peer_reset) (struct ceph_connection *con);
59 int (*get_auth_request)(struct ceph_connection *con,
66 int (*handle_auth_done)(struct ceph_connection *con,
94 int (*sparse_read)(struct ceph_connection *con,
280 struct ceph_connection *con; member
527 int ceph_tcp_connect(struct ceph_connection *con);
556 void ceph_con_v1_revoke(struct ceph_connection *con);
[all …]
|
| /linux/drivers/infiniband/ulp/rtrs/ |
| H A D | rtrs.c | 83 rtrs_wrn(con->path, in rtrs_iu_post_recv()
229 return con->cid >= con->path->irq_con_num; in is_pollqueue()
249 con->cq = cq; in create_cq()
286 if (con->cq) { in destroy_cq()
290 ib_cq_pool_put(con->cq, con->nr_cqe); in destroy_cq()
292 con->cq = NULL; in destroy_cq()
309 destroy_cq(con); in rtrs_cq_qp_create()
312 con->path = path; in rtrs_cq_qp_create()
320 if (con->qp) { in rtrs_cq_qp_destroy()
322 con->qp = NULL; in rtrs_cq_qp_destroy()
[all …]
|
| H A D | rtrs-clt.c | 368 struct rtrs_clt_con *con = req->con; in rtrs_inv_rkey() local
383 struct rtrs_clt_con *con = req->con; in complete_rdma_req() local
1083 struct rtrs_clt_con *con = req->con; in rtrs_clt_write_req() local
1177 struct rtrs_clt_con *con = req->con; in rtrs_clt_read_req() local
1621 con = kzalloc(sizeof(*con), GFP_KERNEL); in create_con()
1633 clt_path->s.con[cid] = &con->c; in create_con()
1642 clt_path->s.con[con->c.cid] = NULL; in destroy_con()
2183 con = to_clt_con(clt_path->s.con[cid]); in rtrs_clt_stop_and_destroy_conns()
2205 con = to_clt_con(clt_path->s.con[cid]); in rtrs_clt_stop_and_destroy_conns()
2363 con = to_clt_con(clt_path->s.con[i]); in init_conns()
[all …]
|
| H A D | rtrs-srv.c | 490 con = id->con; in rtrs_srv_resp_rdma()
511 con->c.cid); in rtrs_srv_resp_rdma()
1029 id->con = con; in process_read()
1082 id->con = con; in process_write()
1540 con = to_srv_con(srv_path->s.con[i]); in rtrs_srv_close_work()
1565 con = to_srv_con(srv_path->s.con[i]); in rtrs_srv_close_work()
1568 kfree(con); in rtrs_srv_close_work()
1657 con = kzalloc(sizeof(*con), GFP_KERNEL); in create_con()
1658 if (!con) { in create_con()
1712 srv_path->s.con[cid] = &con->c; in create_con()
[all …]
|
| /linux/arch/arm/mach-s3c/ |
| H A D | gpio-samsung.c | 73 u32 con; in samsung_gpio_setcfg_2bit() local
85 con |= cfg; in samsung_gpio_setcfg_2bit()
104 u32 con; in samsung_gpio_getcfg_2bit() local
107 con >>= off * 2; in samsung_gpio_getcfg_2bit()
108 con &= 3; in samsung_gpio_getcfg_2bit()
136 u32 con; in samsung_gpio_setcfg_4bit() local
148 con |= cfg; in samsung_gpio_setcfg_4bit()
171 u32 con; in samsung_gpio_getcfg_4bit() local
177 con >>= shift; in samsung_gpio_getcfg_4bit()
178 con &= 0xf; in samsung_gpio_getcfg_4bit()
[all …]
|
| /linux/fs/proc/ |
| H A D | consoles.c | 29 struct console *con = v; in show_console_dev() local
33 if (con->device) { in show_console_dev()
43 driver = con->device(con, &index); in show_console_dev()
53 flags[a] = (con->flags & con_flags[a].flag) ? in show_console_dev()
58 seq_printf(m, "%s%d", con->name, con->index); in show_console_dev()
60 seq_printf(m, "%c%c%c (%s)", con->read ? 'R' : '-', in show_console_dev()
61 con->write ? 'W' : '-', con->unblank ? 'U' : '-', in show_console_dev()
72 struct console *con; in c_start() local
81 for_each_console(con) in c_start()
85 return con; in c_start()
[all …]
|
| /linux/tools/perf/scripts/python/ |
| H A D | event_analyzing_sample.py | 38 con = sqlite3.connect("/dev/shm/perf.db") variable
39 con.isolation_level = None
48 con.execute("""
55 con.execute("""
97 con.execute("insert into gen_events values(?, ?, ?, ?)",
102 con.execute("insert into pebs_ll values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
111 con.close()
126 count = con.execute("select count(*) from gen_events")
159 count = con.execute("select count(*) from pebs_ll")
180 dseq = con.execute("select dse, count(dse) from pebs_ll group by dse order by -count(dse)")
[all …]
|
| /linux/drivers/gpu/drm/amd/amdgpu/ |
| H A D | amdgpu_ras.c | 798 if (!con) in amdgpu_ras_feature_enable()
854 if (!con) in amdgpu_ras_feature_enable_on_boot()
2382 if (!con || !con->eh_data || !bps || !count) in amdgpu_ras_badpages_read()
2546 if (!con || !con->eh_data || !bps || pages <= 0) in amdgpu_ras_add_bad_pages()
2590 if (!con || !con->eh_data) { in amdgpu_ras_save_bad_pages()
2675 if (!con || !con->eh_data) in amdgpu_ras_check_bad_page()
3305 if (con) in amdgpu_ras_init()
3308 con = kzalloc(sizeof(*con) + in amdgpu_ras_init()
3312 if (!con) in amdgpu_ras_init()
3320 con->objs = (struct ras_manager *)(con + 1); in amdgpu_ras_init()
[all …]
|
| /linux/drivers/media/pci/bt8xx/ |
| H A D | bttv-audio-hook.c | 57 unsigned int con; in gvbctv3pci_audio() local
74 con = 0x000; in gvbctv3pci_audio()
77 con = 0x300; in gvbctv3pci_audio()
80 con = 0x200; in gvbctv3pci_audio()
97 con = 0x300; in gvbctv5pci_audio()
100 con = 0x100; in gvbctv5pci_audio()
103 con = 0x000; in gvbctv5pci_audio()
277 con = 0x080000; in terratv_audio()
280 con = 0x180000; in terratv_audio()
283 con = 0; in terratv_audio()
[all …]
|
| /linux/tools/perf/tests/shell/ |
| H A D | lock_contention.sh | 61 if ! perf lock con -b true > /dev/null 2>&1 ; then
67 perf lock con -a -b -E 1 -q -- perf bench sched messaging > /dev/null 2> ${result}
97 if ! perf lock con -b true > /dev/null 2>&1 ; then
120 if ! perf lock con -b true > /dev/null 2>&1 ; then
137 if ! perf lock con -b true > /dev/null 2>&1 ; then
161 if ! perf lock con -b true > /dev/null 2>&1 ; then
193 if ! perf lock con -b true > /dev/null 2>&1 ; then
221 if ! perf lock con -b true > /dev/null 2>&1 ; then
249 if ! perf lock con -b true > /dev/null 2>&1 ; then
264 if ! perf lock con -b true > /dev/null 2>&1 ; then
[all …]
|
| /linux/drivers/net/ethernet/qlogic/qed/ |
| H A D | qed_nvmetcp.c | 620 &hash_con->con); in qed_nvmetcp_acquire_conn()
673 con = hash_con->con; in qed_nvmetcp_offload_conn()
688 memcpy(con->local_ip, conn_info->src.ip, sizeof(con->local_ip)); in qed_nvmetcp_offload_conn()
689 memcpy(con->remote_ip, conn_info->dst.ip, sizeof(con->remote_ip)); in qed_nvmetcp_offload_conn()
712 con->ttl = conn_info->ttl; in qed_nvmetcp_offload_conn()
714 con->mss = conn_info->mss; in qed_nvmetcp_offload_conn()
715 con->cwnd = conn_info->cwnd; in qed_nvmetcp_offload_conn()
717 con->connect_mode = 0; in qed_nvmetcp_offload_conn()
739 con = hash_con->con; in qed_nvmetcp_update_conn()
740 SET_FIELD(con->update_flag, in qed_nvmetcp_update_conn()
[all …]
|
| H A D | qed_iscsi.c | 1030 struct qed_iscsi_conn *con; member
1168 &hash_con->con); in qed_iscsi_acquire_conn()
1210 struct qed_iscsi_conn *con; in qed_iscsi_offload_conn() local
1220 con = hash_con->con; in qed_iscsi_offload_conn()
1224 memcpy(con->local_ip, conn_info->src.ip, sizeof(con->local_ip)); in qed_iscsi_offload_conn()
1225 memcpy(con->remote_ip, conn_info->dst.ip, sizeof(con->remote_ip)); in qed_iscsi_offload_conn()
1263 con->ttl = conn_info->ttl; in qed_iscsi_offload_conn()
1267 con->mss = conn_info->mss; in qed_iscsi_offload_conn()
1274 con->offl_flags = 0x1; in qed_iscsi_offload_conn()
1285 struct qed_iscsi_conn *con; in qed_iscsi_update_conn() local
[all …]
|
| /linux/drivers/usb/typec/ |
| H A D | port-mapper.c | 19 return component_bind_all(dev, &port->con); in typec_aggregate_bind()
26 component_unbind_all(dev, &port->con); in typec_aggregate_unbind()
60 int typec_link_ports(struct typec_port *con) in typec_link_ports() argument
62 struct each_port_arg arg = { .port = con, .match = NULL }; in typec_link_ports()
64 if (!has_acpi_companion(&con->dev)) in typec_link_ports()
82 return component_master_add_with_match(&con->dev, &typec_aggregate_ops, arg.match); in typec_link_ports()
85 void typec_unlink_ports(struct typec_port *con) in typec_unlink_ports() argument
87 if (has_acpi_companion(&con->dev)) in typec_unlink_ports()
88 component_master_del(&con->dev, &typec_aggregate_ops); in typec_unlink_ports()
|