/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 | 257 struct ucsi_connector *con = uwork->con; in ucsi_poll_worker() local 297 uwork->con = con; in ucsi_partner_task() 834 if (con->pd) in ucsi_register_device_pdos() 847 typec_port_set_usb_power_delivery(con->port, con->pd); in ucsi_register_device_pdos() 983 ret = ucsi_send_command(con->ucsi, command, &con->cap, sizeof(con->cap)); in ucsi_check_connector_capability() 999 con->rdo = con->status.request_data_obj; in ucsi_pwr_opmode_change() 1132 ret = ucsi_send_command(con->ucsi, command, &con->status, sizeof(con->status)); in ucsi_check_connection() 1217 trace_ucsi_connector_change(con->num, &con->status); in ucsi_handle_connector_change() 1681 trace_ucsi_register_port(con->num, &con->status); in ucsi_register_port() 1809 for (con = connector; con->port; con++) { in ucsi_init() [all …]
|
H A D | psy.c | 71 pdo = con->src_pdos[0]; in ucsi_psy_get_voltage_min() 94 if (con->num_pdos > 0) { in ucsi_psy_get_voltage_max() 95 pdo = con->src_pdos[con->num_pdos - 1]; in ucsi_psy_get_voltage_max() 122 index = rdo_index(con->rdo); in ucsi_psy_get_voltage_now() 150 if (con->num_pdos > 0) { in ucsi_psy_get_current_max() 151 pdo = con->src_pdos[con->num_pdos - 1]; in ucsi_psy_get_current_max() 176 u16 flags = con->status.flags; in ucsi_psy_get_current_now() 263 psy_cfg.drv_data = con; in ucsi_register_port_psy() 280 con->psy = power_supply_register(dev, &con->psy_desc, &psy_cfg); in ucsi_register_port_psy() 287 if (IS_ERR_OR_NULL(con->psy)) 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/fs/dlm/ |
H A D | lowcomms.c | 307 con = kzalloc(sizeof(*con), alloc); in nodeid2con() 308 if (!con) in nodeid2con() 330 return con; in nodeid2con() 374 if (!con) { in nodeid_to_addr() 386 memcpy(&sas, &con->addr[con->curr_addr_index], in nodeid_to_addr() 391 if (con->curr_addr_index == con->addr_count) in nodeid_to_addr() 469 if (!con) { in dlm_lowcomms_addr() 823 con); in shutdown_connection() 1181 entry->con = con; in new_writequeue_entry() 1297 struct connection *con = e->con; in _dlm_lowcomms_commit_msg() local [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/kernel/printk/ |
H A D | nbcon.c | 1026 con->write_atomic(con, wctxt); in nbcon_emit_next_record() 1028 con->write_thread(con, wctxt); in nbcon_emit_next_record() 1095 con->device_lock(con, &flags); in nbcon_emit_one() 1123 con->device_unlock(con, flags); in nbcon_emit_one() 1284 if (!con->kthread) in nbcon_kthread_stop() 1313 if (con->kthread) in nbcon_kthread_create() 1316 kt = kthread_run(nbcon_kthread_func, con, "pr/%s%d", con->name, con->index); in nbcon_kthread_create() 1322 con->kthread = kt; in nbcon_kthread_create() 1698 con->pbufs = kmalloc(sizeof(*con->pbufs), GFP_KERNEL); in nbcon_alloc() 1733 con->pbufs = NULL; in nbcon_free() [all …]
|
H A D | internal.h | 18 #define con_printk(lvl, con, fmt, ...) \ argument 20 (con->flags & CON_NBCON) ? "" : "legacy ", \ 21 (con->flags & CON_BOOT) ? "boot" : "", \ 22 con->name, con->index, ##__VA_ARGS__) 99 u64 nbcon_seq_read(struct console *con); 101 bool nbcon_alloc(struct console *con); 102 void nbcon_free(struct console *con); 107 bool nbcon_kthread_create(struct console *con); 108 void nbcon_kthread_stop(struct console *con); 127 if (use_atomic && !con->write_atomic) in console_is_usable() [all …]
|
/linux/tools/perf/util/ |
H A D | bpf_lock_contention.c | 44 if (con->save_callstack) in lock_contention_prepare() 57 if (con->filters->nr_types) { in lock_contention_prepare() 61 if (con->filters->nr_cgrps) { in lock_contention_prepare() 67 if (con->filters->nr_syms) { in lock_contention_prepare() 78 con->filters->syms[i]); in lock_contention_prepare() 90 con->filters->addrs = addrs; in lock_contention_prepare() 107 if (con->aggr_mode == LOCK_AGGR_CGROUP || con->filters->nr_cgrps) { in lock_contention_prepare() 149 if (con->filters->nr_types) { in lock_contention_prepare() 428 account_end_timestamp(con); in lock_contention_read() 458 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 1082 struct rtrs_clt_con *con = req->con; in rtrs_clt_write_req() local 1172 struct rtrs_clt_con *con = req->con; in rtrs_clt_read_req() local 1618 con = kzalloc(sizeof(*con), GFP_KERNEL); in create_con() 1630 clt_path->s.con[cid] = &con->c; in create_con() 1639 clt_path->s.con[con->c.cid] = NULL; in destroy_con() 2180 con = to_clt_con(clt_path->s.con[cid]); in rtrs_clt_stop_and_destroy_conns() 2202 con = to_clt_con(clt_path->s.con[cid]); in rtrs_clt_stop_and_destroy_conns() 2366 con = to_clt_con(clt_path->s.con[i]); in init_conns() [all …]
|
H A D | rtrs-srv.c | 493 con = id->con; in rtrs_srv_resp_rdma() 678 struct rtrs_srv_con *con = container_of(c, typeof(*con), c); in rtrs_srv_hb_err_handler() local 1045 id->con = con; in process_read() 1098 id->con = con; in process_write() 1557 con = to_srv_con(srv_path->s.con[i]); in rtrs_srv_close_work() 1582 con = to_srv_con(srv_path->s.con[i]); in rtrs_srv_close_work() 1585 kfree(con); in rtrs_srv_close_work() 1674 con = kzalloc(sizeof(*con), GFP_KERNEL); in create_con() 1675 if (!con) { in create_con() 1729 srv_path->s.con[cid] = &con->c; in create_con() [all …]
|
/linux/fs/proc/ |
H A D | consoles.c | 30 struct console *con = v; in show_console_dev() local 34 if (con->device) { in show_console_dev() 44 driver = con->device(con, &index); in show_console_dev() 54 flags[a] = (con->flags & con_flags[a].flag) ? in show_console_dev() 59 seq_printf(m, "%s%d", con->name, con->index); in show_console_dev() 62 ((con->flags & CON_NBCON) || con->write) ? 'W' : '-', in show_console_dev() 63 con->unblank ? 'U' : '-', flags); in show_console_dev() 74 struct console *con; in c_start() local 83 for_each_console(con) in c_start() 87 return con; in c_start() [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/drivers/gpu/drm/amd/amdgpu/ |
H A D | amdgpu_ras.c | 800 if (!con) in amdgpu_ras_feature_enable() 856 if (!con) in amdgpu_ras_feature_enable_on_boot() 2481 if (!con || !con->eh_data || !bps || !count) in amdgpu_ras_badpages_read() 2673 if (!con || !con->eh_data || !bps || pages <= 0) in amdgpu_ras_add_bad_pages() 2717 if (!con || !con->eh_data) { in amdgpu_ras_save_bad_pages() 2802 if (!con || !con->eh_data) in amdgpu_ras_check_bad_page() 3565 if (con) in amdgpu_ras_init() 3568 con = kzalloc(sizeof(*con) + in amdgpu_ras_init() 3572 if (!con) in amdgpu_ras_init() 3580 con->objs = (struct ras_manager *)(con + 1); in amdgpu_ras_init() [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/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()
|
/linux/include/linux/ |
H A D | console.h | 442 void (*device_lock)(struct console *con, unsigned long *flags); 458 void (*device_unlock)(struct console *con, unsigned long flags); 526 return data_race(READ_ONCE(con->flags)); in console_srcu_read_flags() 544 WRITE_ONCE(con->flags, flags); in console_srcu_write_flags() 551 return !hlist_unhashed(&con->node); in console_is_registered_locked() 570 ret = console_is_registered_locked(con); in console_is_registered() 585 #define for_each_console_srcu(con) \ argument 586 hlist_for_each_entry_srcu(con, &console_list, node, \ 597 #define for_each_console(con) \ argument 599 hlist_for_each_entry(con, &console_list, node) [all …]
|