Home
last modified time | relevance | path

Searched refs:con (Results 1 – 25 of 222) sorted by relevance

123456789

/Linux-v6.1/net/ceph/
Dmessenger_v1.c111 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset() argument
113 BUG_ON(con->v1.out_skip); in con_out_kvec_reset()
115 con->v1.out_kvec_left = 0; in con_out_kvec_reset()
116 con->v1.out_kvec_bytes = 0; in con_out_kvec_reset()
117 con->v1.out_kvec_cur = &con->v1.out_kvec[0]; in con_out_kvec_reset()
120 static void con_out_kvec_add(struct ceph_connection *con, in con_out_kvec_add() argument
123 int index = con->v1.out_kvec_left; in con_out_kvec_add()
125 BUG_ON(con->v1.out_skip); in con_out_kvec_add()
126 BUG_ON(index >= ARRAY_SIZE(con->v1.out_kvec)); in con_out_kvec_add()
128 con->v1.out_kvec[index].iov_len = size; in con_out_kvec_add()
[all …]
Dmessenger_v2.c107 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv() argument
111 dout("%s con %p %s %zu\n", __func__, con, in ceph_tcp_recv()
112 iov_iter_is_discard(&con->v2.in_iter) ? "discard" : "need", in ceph_tcp_recv()
113 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv()
114 ret = do_recvmsg(con->sock, &con->v2.in_iter); in ceph_tcp_recv()
115 dout("%s con %p ret %d left %zu\n", __func__, con, ret, in ceph_tcp_recv()
116 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv()
195 static int ceph_tcp_send(struct ceph_connection *con) in ceph_tcp_send() argument
199 dout("%s con %p have %zu try_sendpage %d\n", __func__, con, in ceph_tcp_send()
200 iov_iter_count(&con->v2.out_iter), con->v2.out_iter_sendpage); in ceph_tcp_send()
[all …]
Dmessenger.c99 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_clear() argument
103 clear_bit(con_flag, &con->flags); in ceph_con_flag_clear()
106 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_set() argument
110 set_bit(con_flag, &con->flags); in ceph_con_flag_set()
113 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_test() argument
117 return test_bit(con_flag, &con->flags); in ceph_con_flag_test()
120 bool ceph_con_flag_test_and_clear(struct ceph_connection *con, in ceph_con_flag_test_and_clear() argument
125 return test_and_clear_bit(con_flag, &con->flags); in ceph_con_flag_test_and_clear()
128 bool ceph_con_flag_test_and_set(struct ceph_connection *con, in ceph_con_flag_test_and_set() argument
133 return test_and_set_bit(con_flag, &con->flags); in ceph_con_flag_test_and_set()
[all …]
/Linux-v6.1/drivers/usb/typec/ucsi/
Ducsi.c192 struct ucsi_connector *con; member
199 struct ucsi_connector *con = uwork->con; in ucsi_poll_worker() local
202 mutex_lock(&con->lock); in ucsi_poll_worker()
204 if (!con->partner) { in ucsi_poll_worker()
205 mutex_unlock(&con->lock); in ucsi_poll_worker()
210 ret = uwork->cb(con); in ucsi_poll_worker()
213 queue_delayed_work(con->wq, &uwork->work, uwork->delay); in ucsi_poll_worker()
217 mutex_unlock(&con->lock); in ucsi_poll_worker()
220 static int ucsi_partner_task(struct ucsi_connector *con, in ucsi_partner_task() argument
226 if (!con->partner) in ucsi_partner_task()
[all …]
Dpsy.c32 static int ucsi_psy_get_online(struct ucsi_connector *con, in ucsi_psy_get_online() argument
36 if (con->status.flags & UCSI_CONSTAT_CONNECTED && in ucsi_psy_get_online()
37 (con->status.flags & UCSI_CONSTAT_PWR_DIR) == TYPEC_SINK) in ucsi_psy_get_online()
42 static int ucsi_psy_get_voltage_min(struct ucsi_connector *con, in ucsi_psy_get_voltage_min() argument
47 switch (UCSI_CONSTAT_PWR_OPMODE(con->status.flags)) { in ucsi_psy_get_voltage_min()
49 pdo = con->src_pdos[0]; in ucsi_psy_get_voltage_min()
65 static int ucsi_psy_get_voltage_max(struct ucsi_connector *con, in ucsi_psy_get_voltage_max() argument
70 switch (UCSI_CONSTAT_PWR_OPMODE(con->status.flags)) { in ucsi_psy_get_voltage_max()
72 if (con->num_pdos > 0) { in ucsi_psy_get_voltage_max()
73 pdo = con->src_pdos[con->num_pdos - 1]; in ucsi_psy_get_voltage_max()
[all …]
Ddisplayport.c20 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()
68 command = UCSI_GET_CURRENT_CAM | UCSI_CONNECTOR_NUMBER(dp->con->num); in ucsi_displayport_enter()
77 ret = dp->con->port_altmode[cur] == alt ? 0 : -EBUSY; in ucsi_displayport_enter()
103 mutex_unlock(&dp->con->lock); in ucsi_displayport_enter()
115 mutex_lock(&dp->con->lock); in ucsi_displayport_exit()
126 command = UCSI_CMD_SET_NEW_CAM(dp->con->num, 0, dp->offset, 0); in ucsi_displayport_exit()
127 ret = ucsi_send_command(dp->con->ucsi, command, NULL, 0); in ucsi_displayport_exit()
147 mutex_unlock(&dp->con->lock); in ucsi_displayport_exit()
[all …]
/Linux-v6.1/net/tipc/
Dtopsrv.c116 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s);
118 static bool connected(struct tipc_conn *con) in connected() argument
120 return con && test_bit(CF_CONNECTED, &con->flags); in connected()
125 struct tipc_conn *con = container_of(kref, struct tipc_conn, kref); in tipc_conn_kref_release() local
126 struct tipc_topsrv *s = con->server; in tipc_conn_kref_release()
130 idr_remove(&s->conn_idr, con->conid); in tipc_conn_kref_release()
133 if (con->sock) in tipc_conn_kref_release()
134 sock_release(con->sock); in tipc_conn_kref_release()
136 spin_lock_bh(&con->outqueue_lock); in tipc_conn_kref_release()
137 list_for_each_entry_safe(e, safe, &con->outqueue, list) { in tipc_conn_kref_release()
[all …]
/Linux-v6.1/fs/dlm/
Dlowcomms.c122 struct connection *con; member
153 int (*connect)(struct connection *con, struct socket *sock,
161 void (*shutdown_action)(struct connection *con);
163 bool (*eof_condition)(struct connection *con);
213 static struct writequeue_entry *con_next_wq(struct connection *con) in con_next_wq() argument
217 if (list_empty(&con->writequeue)) in con_next_wq()
220 e = list_first_entry(&con->writequeue, struct writequeue_entry, in con_next_wq()
233 struct connection *con; in __find_con() local
235 hlist_for_each_entry_rcu(con, &connection_hash[r], list) { in __find_con()
236 if (con->nodeid == nodeid) in __find_con()
[all …]
/Linux-v6.1/include/linux/ceph/
Dmessenger.h29 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
33 struct ceph_connection *con,
35 int (*add_authorizer_challenge)(struct ceph_connection *con,
38 int (*verify_authorizer_reply) (struct ceph_connection *con);
39 int (*invalidate_authorizer)(struct ceph_connection *con);
42 void (*fault) (struct ceph_connection *con);
46 void (*peer_reset) (struct ceph_connection *con);
48 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
58 int (*get_auth_request)(struct ceph_connection *con,
61 int (*handle_auth_reply_more)(struct ceph_connection *con,
[all …]
/Linux-v6.1/drivers/infiniband/ulp/rtrs/
Drtrs.c70 int rtrs_iu_post_recv(struct rtrs_con *con, struct rtrs_iu *iu) in rtrs_iu_post_recv() argument
72 struct rtrs_path *path = con->path; in rtrs_iu_post_recv()
81 rtrs_wrn(con->path, in rtrs_iu_post_recv()
91 return ib_post_recv(con->qp, &wr, NULL); in rtrs_iu_post_recv()
95 int rtrs_post_recv_empty(struct rtrs_con *con, struct ib_cqe *cqe) in rtrs_post_recv_empty() argument
103 return ib_post_recv(con->qp, &wr, NULL); in rtrs_post_recv_empty()
126 int rtrs_iu_post_send(struct rtrs_con *con, struct rtrs_iu *iu, size_t size, in rtrs_iu_post_send() argument
129 struct rtrs_path *path = con->path; in rtrs_iu_post_send()
148 return rtrs_post_send(con->qp, head, &wr, NULL); in rtrs_iu_post_send()
152 int rtrs_iu_post_rdma_write_imm(struct rtrs_con *con, struct rtrs_iu *iu, in rtrs_iu_post_rdma_write_imm() argument
[all …]
Drtrs-clt.c186 return to_clt_con(clt_path->s.con[id]); in rtrs_permit_to_clt_con()
305 static void rtrs_rdma_error_recovery(struct rtrs_clt_con *con) in rtrs_rdma_error_recovery() argument
307 struct rtrs_clt_path *clt_path = to_clt_path(con->c.path); in rtrs_rdma_error_recovery()
329 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); in rtrs_clt_fast_reg_done() local
332 rtrs_err(con->c.path, "Failed IB_WR_REG_MR: %s\n", in rtrs_clt_fast_reg_done()
334 rtrs_rdma_error_recovery(con); in rtrs_clt_fast_reg_done()
349 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); in rtrs_clt_inv_rkey_done() local
352 rtrs_err(con->c.path, "Failed IB_WR_LOCAL_INV: %s\n", in rtrs_clt_inv_rkey_done()
354 rtrs_rdma_error_recovery(con); in rtrs_clt_inv_rkey_done()
366 struct rtrs_clt_con *con = req->con; in rtrs_inv_rkey() local
[all …]
Drtrs-srv.c176 struct rtrs_srv_con *con = to_srv_con(wc->qp->qp_context); in rtrs_srv_reg_mr_done() local
177 struct rtrs_path *s = con->c.path; in rtrs_srv_reg_mr_done()
194 struct rtrs_path *s = id->con->c.path; in rdma_write_sg()
265 flags = (atomic_inc_return(&id->con->c.wr_cnt) % s->signal_interval) ? in rdma_write_sg()
317 err = ib_post_send(id->con->c.qp, &id->tx_wr.wr, NULL); in rdma_write_sg()
335 static int send_io_resp_imm(struct rtrs_srv_con *con, struct rtrs_srv_op *id, in send_io_resp_imm() argument
338 struct rtrs_path *s = con->c.path; in send_io_resp_imm()
393 flags = (atomic_inc_return(&con->c.wr_cnt) % s->signal_interval) ? in send_io_resp_imm()
435 err = ib_post_send(id->con->c.qp, wr, NULL); in send_io_resp_imm()
480 struct rtrs_srv_con *con; in rtrs_srv_resp_rdma() local
[all …]
/Linux-v6.1/fs/proc/
Dconsoles.c29 struct console *con = v; in show_console_dev() local
33 if (con->device) { in show_console_dev()
36 driver = con->device(con, &index); in show_console_dev()
44 flags[a] = (con->flags & con_flags[a].flag) ? in show_console_dev()
49 seq_printf(m, "%s%d", con->name, con->index); in show_console_dev()
51 seq_printf(m, "%c%c%c (%s)", con->read ? 'R' : '-', in show_console_dev()
52 con->write ? 'W' : '-', con->unblank ? 'U' : '-', in show_console_dev()
63 struct console *con; in c_start() local
67 for_each_console(con) in c_start()
71 return con; in c_start()
[all …]
/Linux-v6.1/arch/arm/mach-s3c/
Dgpio-samsung.c181 u32 con; in samsung_gpio_setcfg_2bit() local
191 con = __raw_readl(reg); in samsung_gpio_setcfg_2bit()
192 con &= ~(0x3 << shift); in samsung_gpio_setcfg_2bit()
193 con |= cfg; in samsung_gpio_setcfg_2bit()
194 __raw_writel(con, reg); in samsung_gpio_setcfg_2bit()
212 u32 con; in samsung_gpio_getcfg_2bit() local
214 con = __raw_readl(chip->base); in samsung_gpio_getcfg_2bit()
215 con >>= off * 2; in samsung_gpio_getcfg_2bit()
216 con &= 3; in samsung_gpio_getcfg_2bit()
219 return S3C_GPIO_SPECIAL(con); in samsung_gpio_getcfg_2bit()
[all …]
/Linux-v6.1/drivers/gpu/drm/amd/amdgpu/
Damdgpu_ras.c124 static bool amdgpu_ras_check_bad_page_unlock(struct amdgpu_ras *con,
589 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); in amdgpu_ras_create_obj() local
592 if (!adev->ras_enabled || !con) in amdgpu_ras_create_obj()
602 obj = &con->objs[AMDGPU_RAS_BLOCK__LAST + head->sub_block_index]; in amdgpu_ras_create_obj()
604 obj = &con->objs[head->block]; in amdgpu_ras_create_obj()
612 list_add(&obj->node, &con->head); in amdgpu_ras_create_obj()
622 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); in amdgpu_ras_find_obj() local
626 if (!adev->ras_enabled || !con) in amdgpu_ras_find_obj()
637 obj = &con->objs[AMDGPU_RAS_BLOCK__LAST + head->sub_block_index]; in amdgpu_ras_find_obj()
639 obj = &con->objs[head->block]; in amdgpu_ras_find_obj()
[all …]
/Linux-v6.1/sound/soc/samsung/
Ds3c-i2s-v2.c34 static void dbg_showcon(const char *fn, u32 con) in dbg_showcon() argument
37 bit_set(con, S3C2412_IISCON_LRINDEX), in dbg_showcon()
38 bit_set(con, S3C2412_IISCON_TXFIFO_EMPTY), in dbg_showcon()
39 bit_set(con, S3C2412_IISCON_RXFIFO_EMPTY), in dbg_showcon()
40 bit_set(con, S3C2412_IISCON_TXFIFO_FULL), in dbg_showcon()
41 bit_set(con, S3C2412_IISCON_RXFIFO_FULL)); in dbg_showcon()
45 bit_set(con, S3C2412_IISCON_TXDMA_PAUSE), in dbg_showcon()
46 bit_set(con, S3C2412_IISCON_RXDMA_PAUSE), in dbg_showcon()
47 bit_set(con, S3C2412_IISCON_TXCH_PAUSE), in dbg_showcon()
48 bit_set(con, S3C2412_IISCON_RXCH_PAUSE)); in dbg_showcon()
[all …]
Dspdif.c184 u32 con, clkcon, cstas; in spdif_hw_params() local
201 con = readl(regs + CON) & CON_MASK; in spdif_hw_params()
205 con &= ~CON_FIFO_TH_MASK; in spdif_hw_params()
206 con |= (0x7 << CON_FIFO_TH_SHIFT); in spdif_hw_params()
207 con |= CON_USERDATA_23RDBIT; in spdif_hw_params()
208 con |= CON_PCM_DATA; in spdif_hw_params()
210 con &= ~CON_PCM_MASK; in spdif_hw_params()
213 con |= CON_PCM_16BIT; in spdif_hw_params()
230 con &= ~CON_MCLKDIV_MASK; in spdif_hw_params()
233 con |= CON_MCLKDIV_256FS; in spdif_hw_params()
[all …]
/Linux-v6.1/tools/perf/scripts/python/
Devent_analyzing_sample.py38 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")
135 …commq = con.execute("select comm, count(comm) from gen_events group by comm order by -count(comm)")
142 …symbolq = con.execute("select symbol, count(symbol) from gen_events group by symbol order by -coun…
[all …]
/Linux-v6.1/drivers/media/pci/bt8xx/
Dbttv-audio-hook.c57 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()
83 gpio_bits(0x300, con); in gvbctv3pci_audio()
88 unsigned int val, con; in gvbctv5pci_audio() local
97 con = 0x300; in gvbctv5pci_audio()
100 con = 0x100; in gvbctv5pci_audio()
103 con = 0x000; in gvbctv5pci_audio()
106 if (con != (val & 0x300)) { in gvbctv5pci_audio()
[all …]
/Linux-v6.1/drivers/net/ethernet/qlogic/qed/
Dqed_nvmetcp.c256 if (hash_con->con->icid == handle) in qed_nvmetcp_get_hash()
260 if (!hash_con || hash_con->con->icid != handle) in qed_nvmetcp_get_hash()
620 &hash_con->con); in qed_nvmetcp_acquire_conn()
629 *handle = hash_con->con->icid; in qed_nvmetcp_acquire_conn()
630 *fw_cid = hash_con->con->fw_cid; in qed_nvmetcp_acquire_conn()
652 qed_nvmetcp_release_connection(QED_AFFIN_HWFN(cdev), hash_con->con); in qed_nvmetcp_release_conn()
662 struct qed_nvmetcp_conn *con; in qed_nvmetcp_offload_conn() local
673 con = hash_con->con; in qed_nvmetcp_offload_conn()
676 con->layer_code = NVMETCP_SLOW_PATH_LAYER_CODE; in qed_nvmetcp_offload_conn()
677 con->sq_pbl_addr = conn_info->sq_pbl_addr; in qed_nvmetcp_offload_conn()
[all …]
Dqed_iscsi.c1029 struct qed_iscsi_conn *con; member
1068 if (hash_con->con->icid == handle) in qed_iscsi_get_hash()
1072 if (!hash_con || (hash_con->con->icid != handle)) in qed_iscsi_get_hash()
1167 &hash_con->con); in qed_iscsi_acquire_conn()
1175 *handle = hash_con->con->icid; in qed_iscsi_acquire_conn()
1176 *fw_cid = hash_con->con->fw_cid; in qed_iscsi_acquire_conn()
1198 qed_iscsi_release_connection(QED_AFFIN_HWFN(cdev), hash_con->con); in qed_iscsi_release_conn()
1209 struct qed_iscsi_conn *con; in qed_iscsi_offload_conn() local
1219 con = hash_con->con; in qed_iscsi_offload_conn()
1221 ether_addr_copy(con->local_mac, conn_info->src.mac); in qed_iscsi_offload_conn()
[all …]
Dqed_fcoe.c719 struct qed_fcoe_conn *con; member
760 if (hash_con->con->icid == handle) in qed_fcoe_get_hash()
764 if (!hash_con || (hash_con->con->icid != handle)) in qed_fcoe_get_hash()
865 &hash_con->con); in qed_fcoe_acquire_conn()
873 *handle = hash_con->con->icid; in qed_fcoe_acquire_conn()
874 *fw_cid = hash_con->con->fw_cid; in qed_fcoe_acquire_conn()
896 qed_fcoe_release_connection(QED_AFFIN_HWFN(cdev), hash_con->con); in qed_fcoe_release_conn()
907 struct qed_fcoe_conn *con; in qed_fcoe_offload_conn() local
917 con = hash_con->con; in qed_fcoe_offload_conn()
919 con->sq_pbl_addr = conn_info->sq_pbl_addr; in qed_fcoe_offload_conn()
[all …]
/Linux-v6.1/tools/perf/util/
Dbpf_lock_contention.c26 int lock_contention_prepare(struct lock_contention *con) in lock_contention_prepare() argument
30 struct evlist *evlist = con->evlist; in lock_contention_prepare()
31 struct target *target = con->target; in lock_contention_prepare()
39 bpf_map__set_value_size(skel->maps.stacks, con->max_stack * sizeof(u64)); in lock_contention_prepare()
40 bpf_map__set_max_entries(skel->maps.stacks, con->map_nr_entries); in lock_contention_prepare()
41 bpf_map__set_max_entries(skel->maps.lock_stat, con->map_nr_entries); in lock_contention_prepare()
91 skel->bss->stack_skip = con->stack_skip; in lock_contention_prepare()
109 int lock_contention_read(struct lock_contention *con) in lock_contention_read() argument
115 struct machine *machine = con->machine; in lock_contention_read()
116 u64 stack_trace[con->max_stack]; in lock_contention_read()
[all …]
/Linux-v6.1/drivers/tty/serial/
Dkgdboc.c48 static int (*earlycon_orig_exit)(struct console *con);
450 struct console *con; in kgdboc_earlycon_pre_exp_handler() local
464 for_each_console(con) in kgdboc_earlycon_pre_exp_handler()
465 if (con == kgdboc_earlycon_io_ops.cons) in kgdboc_earlycon_pre_exp_handler()
472 static int kgdboc_earlycon_deferred_exit(struct console *con) in kgdboc_earlycon_deferred_exit() argument
481 con->exit = earlycon_orig_exit; in kgdboc_earlycon_deferred_exit()
523 struct console *con; in kgdboc_earlycon_init() local
532 for_each_console(con) { in kgdboc_earlycon_init()
533 if (con->write && con->read && in kgdboc_earlycon_init()
534 (con->flags & (CON_BOOT | CON_ENABLED)) && in kgdboc_earlycon_init()
[all …]
/Linux-v6.1/drivers/usb/typec/
Dport-mapper.c55 int typec_link_ports(struct typec_port *con) in typec_link_ports() argument
57 struct each_port_arg arg = { .port = con, .match = NULL }; in typec_link_ports()
59 if (!has_acpi_companion(&con->dev)) in typec_link_ports()
77 return component_master_add_with_match(&con->dev, &typec_aggregate_ops, arg.match); in typec_link_ports()
80 void typec_unlink_ports(struct typec_port *con) in typec_unlink_ports() argument
82 if (has_acpi_companion(&con->dev)) in typec_unlink_ports()
83 component_master_del(&con->dev, &typec_aggregate_ops); in typec_unlink_ports()

123456789