Home
last modified time | relevance | path

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

123456789

/linux/net/ceph/
H A Dmessenger_v1.c110 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset() argument
112 BUG_ON(con->v1.out_skip); in con_out_kvec_reset()
114 con->v1.out_kvec_left = 0; in con_out_kvec_reset()
115 con->v1.out_kvec_bytes = 0; in con_out_kvec_reset()
116 con->v1.out_kvec_cur = &con->v1.out_kvec[0]; in con_out_kvec_reset()
119 static void con_out_kvec_add(struct ceph_connection *con, in con_out_kvec_add() argument
122 int index = con->v1.out_kvec_left; in con_out_kvec_add()
124 BUG_ON(con->v1.out_skip); in con_out_kvec_add()
125 BUG_ON(index >= ARRAY_SIZE(con->v1.out_kvec)); in con_out_kvec_add()
127 con->v1.out_kvec[index].iov_len = size; in con_out_kvec_add()
[all …]
H A Dmessenger_v2.c108 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv() argument
112 dout("%s con %p %s %zu\n", __func__, con, in ceph_tcp_recv()
113 iov_iter_is_discard(&con->v2.in_iter) ? "discard" : "need", in ceph_tcp_recv()
114 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv()
115 ret = do_recvmsg(con->sock, &con->v2.in_iter); in ceph_tcp_recv()
116 dout("%s con %p ret %d left %zu\n", __func__, con, ret, in ceph_tcp_recv()
117 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 …]
H A Dmessenger.c100 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_clear() argument
104 clear_bit(con_flag, &con->flags); in ceph_con_flag_clear()
107 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_set() argument
111 set_bit(con_flag, &con->flags); in ceph_con_flag_set()
114 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_test() argument
118 return test_bit(con_flag, &con->flags); in ceph_con_flag_test()
121 bool ceph_con_flag_test_and_clear(struct ceph_connection *con, in ceph_con_flag_test_and_clear() argument
126 return test_and_clear_bit(con_flag, &con->flags); in ceph_con_flag_test_and_clear()
129 bool ceph_con_flag_test_and_set(struct ceph_connection *con, in ceph_con_flag_test_and_set() argument
134 return test_and_set_bit(con_flag, &con->flags); in ceph_con_flag_test_and_set()
[all …]
/linux/net/tipc/
H A Dtopsrv.c117 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s);
119 static bool connected(struct tipc_conn *con) in connected() argument
121 return con && test_bit(CF_CONNECTED, &con->flags); in connected()
126 struct tipc_conn *con = container_of(kref, struct tipc_conn, kref); in tipc_conn_kref_release() local
127 struct tipc_topsrv *s = con->server; in tipc_conn_kref_release()
131 idr_remove(&s->conn_idr, con->conid); in tipc_conn_kref_release()
134 if (con->sock) in tipc_conn_kref_release()
135 sock_release(con->sock); in tipc_conn_kref_release()
137 spin_lock_bh(&con->outqueue_lock); in tipc_conn_kref_release()
138 list_for_each_entry_safe(e, safe, &con->outqueue, list) { in tipc_conn_kref_release()
[all …]
/linux/kernel/printk/
H A Dnbcon.c133 static inline void nbcon_state_set(struct console *con, struct nbcon_state *new) in nbcon_state_set() argument
135 atomic_set(&ACCESS_PRIVATE(con, nbcon_state), new->atom); in nbcon_state_set()
143 static inline void nbcon_state_read(struct console *con, struct nbcon_state *state) in nbcon_state_read() argument
145 state->atom = atomic_read(&ACCESS_PRIVATE(con, nbcon_state)); in nbcon_state_read()
156 static inline bool nbcon_state_try_cmpxchg(struct console *con, struct nbcon_state *cur, in nbcon_state_try_cmpxchg() argument
159 return atomic_try_cmpxchg(&ACCESS_PRIVATE(con, nbcon_state), &cur->atom, new->atom); in nbcon_state_try_cmpxchg()
168 u64 nbcon_seq_read(struct console *con) in nbcon_seq_read() argument
170 unsigned long nbcon_seq = atomic_long_read(&ACCESS_PRIVATE(con, nbcon_seq)); in nbcon_seq_read()
183 void nbcon_seq_force(struct console *con, u64 seq) in nbcon_seq_force() argument
193 atomic_long_set(&ACCESS_PRIVATE(con, nbcon_seq), __u64seq_to_ulseq(valid_seq)); in nbcon_seq_force()
[all …]
H A Dinternal.h17 #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__)
102 u64 nbcon_seq_read(struct console *con);
103 void nbcon_seq_force(struct console *con, u64 seq);
104 bool nbcon_alloc(struct console *con);
105 void nbcon_free(struct console *con);
108 bool nbcon_legacy_emit_next_record(struct console *con, bool *handover,
110 bool nbcon_kthread_create(struct console *con);
[all …]
H A Dprintk.c2511 static bool __pr_flush(struct console *con, int timeout_ms, bool reset_on_progress);
2523 static bool __pr_flush(struct console *con, int timeout_ms, bool reset_on_progress) { return true; } in __pr_flush() argument
2787 struct console *con; in console_suspend_all() local
2805 for_each_console(con) in console_suspend_all()
2806 console_srcu_write_flags(con, con->flags | CON_SUSPENDED); in console_suspend_all()
2821 struct console *con; in console_resume_all() local
2832 for_each_console(con) in console_resume_all()
2833 console_srcu_write_flags(con, con->flags & ~CON_SUSPENDED); in console_resume_all()
3126 static bool console_emit_next_record(struct console *con, bool *handover, int cookie) in console_emit_next_record() argument
3128 bool is_extended = console_srcu_read_flags(con) & CON_EXTENDED; in console_emit_next_record()
[all …]
/linux/tools/perf/util/
H A Dbpf_lock_contention.c37 static void check_slab_cache_iter(struct lock_contention *con) in check_slab_cache_iter() argument
43 con->btf = btf__load_vmlinux_btf(); in check_slab_cache_iter()
44 if (con->btf == NULL) { in check_slab_cache_iter()
49 ret = btf__find_by_name_kind(con->btf, "bpf_iter__kmem_cache", BTF_KIND_STRUCT); in check_slab_cache_iter()
58 bpf_map__set_max_entries(skel->maps.slab_caches, con->map_nr_entries); in check_slab_cache_iter()
111 static void init_numa_data(struct lock_contention *con) in init_numa_data() argument
120 if (!con->btf) in init_numa_data()
128 ret = btf__find_by_name_kind(con->btf, "zone", BTF_KIND_STRUCT); in init_numa_data()
134 ret = btf__resolve_size(con->btf, ret); in init_numa_data()
142 sym = machine__find_kernel_symbol_by_name(con in init_numa_data()
183 lock_contention_prepare(struct lock_contention * con) lock_contention_prepare() argument
490 account_end_timestamp(struct lock_contention * con) account_end_timestamp() argument
561 lock_contention_get_name(struct lock_contention * con,struct contention_key * key,u64 * stack_trace,u32 flags) lock_contention_get_name() argument
661 pop_owner_stack_trace(struct lock_contention * con) pop_owner_stack_trace() argument
718 lock_contention_read(struct lock_contention * con) lock_contention_read() argument
836 lock_contention_finish(struct lock_contention * con) lock_contention_finish() argument
[all...]
H A Dlock-contention.h174 int lock_contention_prepare(struct lock_contention *con);
177 int lock_contention_read(struct lock_contention *con);
178 int lock_contention_finish(struct lock_contention *con);
180 struct lock_stat *pop_owner_stack_trace(struct lock_contention *con);
184 static inline int lock_contention_prepare(struct lock_contention *con __maybe_unused) in lock_contention_prepare()
191 static inline int lock_contention_finish(struct lock_contention *con __maybe_unused) in lock_contention_finish()
196 static inline int lock_contention_read(struct lock_contention *con __maybe_unused) in lock_contention_read()
201 static inline struct lock_stat *pop_owner_stack_trace(struct lock_contention *con __maybe_unused) in pop_owner_stack_trace()
/linux/include/linux/ceph/
H A Dmessenger.h31 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
35 struct ceph_connection *con,
37 int (*add_authorizer_challenge)(struct ceph_connection *con,
40 int (*verify_authorizer_reply) (struct ceph_connection *con);
41 int (*invalidate_authorizer)(struct ceph_connection *con);
44 void (*fault) (struct ceph_connection *con);
48 void (*peer_reset) (struct ceph_connection *con);
50 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
60 int (*get_auth_request)(struct ceph_connection *con,
63 int (*handle_auth_reply_more)(struct ceph_connection *con,
[all …]
/linux/drivers/infiniband/ulp/rtrs/
H A Drtrs.c72 int rtrs_iu_post_recv(struct rtrs_con *con, struct rtrs_iu *iu) in rtrs_iu_post_recv() argument
74 struct rtrs_path *path = con->path; in rtrs_iu_post_recv()
83 rtrs_wrn(con->path, in rtrs_iu_post_recv()
93 return ib_post_recv(con->qp, &wr, NULL); in rtrs_iu_post_recv()
97 int rtrs_post_recv_empty(struct rtrs_con *con, struct ib_cqe *cqe) in rtrs_post_recv_empty() argument
105 return ib_post_recv(con->qp, &wr, NULL); in rtrs_post_recv_empty()
128 int rtrs_iu_post_send(struct rtrs_con *con, struct rtrs_iu *iu, size_t size, in rtrs_iu_post_send() argument
131 struct rtrs_path *path = con->path; in rtrs_iu_post_send()
150 return rtrs_post_send(con->qp, head, &wr, NULL); in rtrs_iu_post_send()
154 int rtrs_iu_post_rdma_write_imm(struct rtrs_con *con, struct rtrs_iu *iu, in rtrs_iu_post_rdma_write_imm() argument
[all …]
H A Drtrs-clt.c188 return to_clt_con(clt_path->s.con[id]); in rtrs_permit_to_clt_con()
307 static void rtrs_rdma_error_recovery(struct rtrs_clt_con *con) in rtrs_rdma_error_recovery() argument
309 struct rtrs_clt_path *clt_path = to_clt_path(con->c.path); in rtrs_rdma_error_recovery()
331 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); in rtrs_clt_fast_reg_done() local
334 rtrs_err_rl(con->c.path, "Failed IB_WR_REG_MR: %s\n", in rtrs_clt_fast_reg_done()
336 rtrs_rdma_error_recovery(con); in rtrs_clt_fast_reg_done()
351 struct rtrs_clt_con *con = to_clt_con(wc->qp->qp_context); in rtrs_clt_inv_rkey_done() local
354 rtrs_err_rl(con->c.path, "Failed IB_WR_LOCAL_INV: %s\n", in rtrs_clt_inv_rkey_done()
356 rtrs_rdma_error_recovery(con); in rtrs_clt_inv_rkey_done()
368 struct rtrs_clt_con *con = req->con; in rtrs_inv_rkey() local
[all …]
/linux/arch/arm/mach-s3c/
H A Dgpio-samsung.c73 u32 con; in samsung_gpio_setcfg_2bit() local
83 con = __raw_readl(reg); in samsung_gpio_setcfg_2bit()
84 con &= ~(0x3 << shift); in samsung_gpio_setcfg_2bit()
85 con |= cfg; in samsung_gpio_setcfg_2bit()
86 __raw_writel(con, reg); in samsung_gpio_setcfg_2bit()
104 u32 con; in samsung_gpio_getcfg_2bit() local
106 con = __raw_readl(chip->base); in samsung_gpio_getcfg_2bit()
107 con >>= off * 2; in samsung_gpio_getcfg_2bit()
108 con &= 3; in samsung_gpio_getcfg_2bit()
111 return S3C_GPIO_SPECIAL(con); in samsung_gpio_getcfg_2bit()
[all …]
/linux/fs/proc/
H A Dconsoles.c30 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()
61 seq_printf(m, "%c%c%c (%s)", con->read ? 'R' : '-', 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()
[all …]
/linux/tools/perf/scripts/python/
H A 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/drivers/media/pci/bt8xx/
H A 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/drivers/net/ethernet/qlogic/qed/
H A 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 …]
H A Dqed_iscsi.c1030 struct qed_iscsi_conn *con; member
1069 if (hash_con->con->icid == handle) in qed_iscsi_get_hash()
1073 if (!hash_con || (hash_con->con->icid != handle)) in qed_iscsi_get_hash()
1168 &hash_con->con); in qed_iscsi_acquire_conn()
1176 *handle = hash_con->con->icid; in qed_iscsi_acquire_conn()
1177 *fw_cid = hash_con->con->fw_cid; in qed_iscsi_acquire_conn()
1199 qed_iscsi_release_connection(QED_AFFIN_HWFN(cdev), hash_con->con); in qed_iscsi_release_conn()
1210 struct qed_iscsi_conn *con; in qed_iscsi_offload_conn() local
1220 con = hash_con->con; in qed_iscsi_offload_conn()
1222 ether_addr_copy(con->local_mac, conn_info->src.mac); in qed_iscsi_offload_conn()
[all …]
/linux/tools/perf/tests/shell/
H A Dlock_contention.sh72 if ! perf lock con -b true > /dev/null 2>&1 ; then
78 perf lock con -a -b -E 1 -q -- ${msg_workload} > /dev/null 2> ${result}
110 if ! perf lock con -b true > /dev/null 2>&1 ; then
115 perf lock con -a -b -t -E 1 -q -- ${msg_workload} > /dev/null 2> ${result}
133 if ! perf lock con -b true > /dev/null 2>&1 ; then
138 perf lock con -a -b -l -E 1 -q -- ${msg_workload} > /dev/null 2> ${result}
150 if ! perf lock con -b true > /dev/null 2>&1 ; then
156 perf lock con -a -b --lock-cgroup -E 1 -q -- ${msg_workload} > /dev/null 2> ${result}
174 if ! perf lock con -b true > /dev/null 2>&1 ; then
178 perf lock con
[all...]
/linux/include/linux/
H A Dconsole.h388 void (*write_atomic)(struct console *con, struct nbcon_write_context *wctxt);
419 void (*write_thread)(struct console *con, struct nbcon_write_context *wctxt);
446 void (*device_lock)(struct console *con, unsigned long *flags);
462 void (*device_unlock)(struct console *con, unsigned long flags);
522 static inline short console_srcu_read_flags(const struct console *con) in console_srcu_read_flags() argument
530 return data_race(READ_ONCE(con->flags)); in console_srcu_read_flags()
543 static inline void console_srcu_write_flags(struct console *con, short flags) in console_srcu_write_flags() argument
548 WRITE_ONCE(con->flags, flags); in console_srcu_write_flags()
552 static inline bool console_is_registered_locked(const struct console *con) in console_is_registered_locked() argument
555 return !hlist_unhashed(&con->node); in console_is_registered_locked()
[all …]
/linux/drivers/usb/typec/ucsi/
H A Ddisplayport.c20 struct ucsi_connector *con; member
51 struct ucsi *ucsi = dp->con->ucsi; in ucsi_displayport_enter()
57 if (!ucsi_con_mutex_lock(dp->con)) in ucsi_displayport_enter()
69 command = UCSI_GET_CURRENT_CAM | UCSI_CONNECTOR_NUMBER(dp->con->num); in ucsi_displayport_enter()
78 ret = dp->con->port_altmode[cur] == alt ? 0 : -EBUSY; in ucsi_displayport_enter()
107 ucsi_con_mutex_unlock(dp->con); in ucsi_displayport_enter()
119 if (!ucsi_con_mutex_lock(dp->con)) in ucsi_displayport_exit()
131 command = UCSI_CMD_SET_NEW_CAM(dp->con->num, 0, dp->offset, 0); in ucsi_displayport_exit()
132 ret = ucsi_send_command(dp->con->ucsi, command, NULL, 0); in ucsi_displayport_exit()
152 ucsi_con_mutex_unlock(dp->con); in ucsi_displayport_exit()
312 ucsi_register_displayport(struct ucsi_connector * con,bool override,int offset,struct typec_altmode_desc * desc) ucsi_register_displayport() argument
[all...]
H A Dtrace.h42 TP_PROTO(int port, struct ucsi_connector *con),
43 TP_ARGS(port, con),
57 __entry->change = UCSI_CONSTAT(con, CHANGE);
58 __entry->opmode = UCSI_CONSTAT(con, PWR_OPMODE);
59 __entry->connected = UCSI_CONSTAT(con, CONNECTED);
60 __entry->pwr_dir = UCSI_CONSTAT(con, PWR_DIR);
61 __entry->partner_flags = UCSI_CONSTAT(con, PARTNER_FLAGS);
62 __entry->partner_type = UCSI_CONSTAT(con, PARTNER_TYPE);
63 __entry->request_data_obj = UCSI_CONSTAT(con, RDO);
64 __entry->bc_status = UCSI_CONSTAT(con, BC_STATUS);
[all …]
/linux/drivers/usb/typec/
H A Dport-mapper.c20 return component_bind_all(dev, &port->con); in typec_aggregate_bind()
27 component_unbind_all(dev, &port->con); in typec_aggregate_unbind()
96 int typec_link_ports(struct typec_port *con) in typec_link_ports()
98 struct each_port_arg arg = { .port = con, .match = NULL }; in typec_link_ports()
100 if (!has_acpi_companion(&con->dev)) in typec_link_ports()
118 return component_master_add_with_match(&con->dev, &typec_aggregate_ops, arg.match);
121 void typec_unlink_ports(struct typec_port *con)
123 if (has_acpi_companion(&con->dev))
124 component_master_del(&con->dev, &typec_aggregate_ops);
79 typec_link_ports(struct typec_port * con) typec_link_ports() argument
104 typec_unlink_ports(struct typec_port * con) typec_unlink_ports() argument
/linux/sound/soc/samsung/
H A Dspdif.c74 * @saved_con: Backup con reg. in suspend.
181 u32 con, clkcon, cstas; in spdif_hw_params()
197 con = readl(regs + CON) & CON_MASK; in spdif_hw_params()
201 con &= ~CON_FIFO_TH_MASK; in spdif_hw_params()
202 con |= (0x7 << CON_FIFO_TH_SHIFT); in spdif_hw_params()
203 con |= CON_USERDATA_23RDBIT; in spdif_hw_params()
204 con |= CON_PCM_DATA; in spdif_hw_params()
206 con &= ~CON_PCM_MASK; in spdif_hw_params()
209 con |= CON_PCM_16BIT; in spdif_hw_params()
226 con in spdif_hw_params()
184 u32 con, clkcon, cstas; spdif_hw_params() local
285 u32 con, clkcon; spdif_shutdown() local
302 u32 con = spdif->saved_con; spdif_suspend() local
[all...]
/linux/arch/um/kernel/
H A Dkmsg_dump.c16 struct console *con; in kmsg_dumper_stdout() local
27 for_each_console_srcu(con) { in kmsg_dumper_stdout()
33 if (strcmp(con->name, "ttynull") != 0 && in kmsg_dumper_stdout()
34 console_is_usable(con, console_srcu_read_flags(con), true)) { in kmsg_dumper_stdout()
39 if (con) in kmsg_dumper_stdout()

123456789