/openbmc/linux/net/ceph/ |
H A D | messenger_v1.c | 110 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 D | messenger_v2.c | 109 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv() argument 113 dout("%s con %p %s %zu\n", __func__, con, in ceph_tcp_recv() 114 iov_iter_is_discard(&con->v2.in_iter) ? "discard" : "need", in ceph_tcp_recv() 115 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv() 116 ret = do_recvmsg(con->sock, &con->v2.in_iter); in ceph_tcp_recv() 117 dout("%s con %p ret %d left %zu\n", __func__, con, ret, in ceph_tcp_recv() 118 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv() 196 static int ceph_tcp_send(struct ceph_connection *con) in ceph_tcp_send() argument 200 dout("%s con %p have %zu try_sendpage %d\n", __func__, con, in ceph_tcp_send() 201 iov_iter_count(&con->v2.out_iter), con->v2.out_iter_sendpage); in ceph_tcp_send() [all …]
|
H A D | messenger.c | 100 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 …]
|
/openbmc/linux/drivers/usb/typec/ucsi/ |
H A D | ucsi.c | 218 struct ucsi_connector *con; member 225 struct ucsi_connector *con = uwork->con; in ucsi_poll_worker() local 228 mutex_lock(&con->lock); in ucsi_poll_worker() 230 if (!con->partner) { in ucsi_poll_worker() 232 mutex_unlock(&con->lock); in ucsi_poll_worker() 237 ret = uwork->cb(con); in ucsi_poll_worker() 240 queue_delayed_work(con->wq, &uwork->work, uwork->delay); in ucsi_poll_worker() 246 mutex_unlock(&con->lock); in ucsi_poll_worker() 249 static int ucsi_partner_task(struct ucsi_connector *con, in ucsi_partner_task() argument 255 if (!con->partner) in ucsi_partner_task() [all …]
|
H A D | psy.c | 33 static int ucsi_psy_get_scope(struct ucsi_connector *con, in ucsi_psy_get_scope() argument 37 struct device *dev = con->ucsi->dev; in ucsi_psy_get_scope() 44 if (con->ucsi->cap.attributes & mask) in ucsi_psy_get_scope() 53 static int ucsi_psy_get_online(struct ucsi_connector *con, in ucsi_psy_get_online() argument 57 if (con->status.flags & UCSI_CONSTAT_CONNECTED && in ucsi_psy_get_online() 58 (con->status.flags & UCSI_CONSTAT_PWR_DIR) == TYPEC_SINK) in ucsi_psy_get_online() 63 static int ucsi_psy_get_voltage_min(struct ucsi_connector *con, in ucsi_psy_get_voltage_min() argument 68 switch (UCSI_CONSTAT_PWR_OPMODE(con->status.flags)) { in ucsi_psy_get_voltage_min() 70 pdo = con->src_pdos[0]; in ucsi_psy_get_voltage_min() 86 static int ucsi_psy_get_voltage_max(struct ucsi_connector *con, in ucsi_psy_get_voltage_max() argument [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() 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 …]
|
/openbmc/qemu/ui/ |
H A D | console.c | 77 static bool console_compatible_with(QemuConsole *con, 129 void graphic_hw_update_done(QemuConsole *con) in graphic_hw_update_done() argument 131 if (con) { in graphic_hw_update_done() 132 qemu_co_enter_all(&con->dump_queue, NULL); in graphic_hw_update_done() 136 void graphic_hw_update(QemuConsole *con) in graphic_hw_update() argument 139 if (!con) { in graphic_hw_update() 142 if (con->hw_ops->gfx_update) { in graphic_hw_update() 143 con->hw_ops->gfx_update(con->hw); in graphic_hw_update() 144 async = con->hw_ops->gfx_update_async; in graphic_hw_update() 147 graphic_hw_update_done(con); in graphic_hw_update() [all …]
|
H A D | sdl2.c | 214 if (!qemu_input_is_absolute(scon->dcl.con)) { in sdl_hide_cursor() 225 if (!qemu_input_is_absolute(scon->dcl.con)) { in sdl_show_cursor() 230 (gui_grab || qemu_input_is_absolute(scon->dcl.con) || absolute_enabled)) { in sdl_show_cursor() 241 QemuConsole *con = scon ? scon->dcl.con : NULL; in sdl_grab_start() local 243 if (!con || !qemu_console_is_graphic(con)) { in sdl_grab_start() 256 if (!qemu_input_is_absolute(scon->dcl.con) && !absolute_enabled) { in sdl_grab_start() 289 if (qemu_input_is_absolute(sdl2_console[0].dcl.con)) { in sdl_mouse_mode_change() 316 qemu_input_update_buttons(scon->dcl.con, bmap, prev_state, state); in sdl_send_mouse_event() 320 if (qemu_input_is_absolute(scon->dcl.con)) { in sdl_send_mouse_event() 321 qemu_input_queue_abs(scon->dcl.con, INPUT_AXIS_X, in sdl_send_mouse_event() [all …]
|
H A D | dbus-console.c | 204 if (!dpy_ui_info_supported(ddc->dcl.con)) { in dbus_console_set_ui_info() 212 dpy_set_ui_info(ddc->dcl.con, &info, false); in dbus_console_set_ui_info() 379 if (qemu_input_is_absolute(ddc->dcl.con)) { in dbus_mouse_rel_motion() 387 qemu_input_queue_rel(ddc->dcl.con, INPUT_AXIS_X, dx); in dbus_mouse_rel_motion() 388 qemu_input_queue_rel(ddc->dcl.con, INPUT_AXIS_Y, dy); in dbus_mouse_rel_motion() 418 width = qemu_console_get_width(ddc->dcl.con, 0); in dbus_touch_send_event() 419 height = qemu_console_get_height(ddc->dcl.con, 0); in dbus_touch_send_event() 421 console_handle_touch_event(ddc->dcl.con, touch_slots, in dbus_touch_send_event() 446 if (!qemu_input_is_absolute(ddc->dcl.con)) { in dbus_mouse_set_pos() 454 width = qemu_console_get_width(ddc->dcl.con, 0); in dbus_mouse_set_pos() [all …]
|
/openbmc/linux/net/tipc/ |
H A D | topsrv.c | 117 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 …]
|
/openbmc/linux/fs/dlm/ |
H A D | lowcomms.c | 133 struct connection *con; member 163 int (*connect)(struct connection *con, struct socket *sock, 212 static void lowcomms_queue_swork(struct connection *con) in lowcomms_queue_swork() argument 214 assert_spin_locked(&con->writequeue_lock); in lowcomms_queue_swork() 216 if (!test_bit(CF_IO_STOP, &con->flags) && in lowcomms_queue_swork() 217 !test_bit(CF_APP_LIMITED, &con->flags) && in lowcomms_queue_swork() 218 !test_and_set_bit(CF_SEND_PENDING, &con->flags)) in lowcomms_queue_swork() 219 queue_work(io_workqueue, &con->swork); in lowcomms_queue_swork() 222 static void lowcomms_queue_rwork(struct connection *con) in lowcomms_queue_rwork() argument 225 WARN_ON_ONCE(!lockdep_sock_is_held(con->sock->sk)); in lowcomms_queue_rwork() [all …]
|
/openbmc/qemu/hw/char/ |
H A D | xen_console.c | 64 static bool buffer_append(XenConsole *con) in OBJECT_DECLARE_SIMPLE_TYPE() 66 struct buffer *buffer = &con->buffer; in OBJECT_DECLARE_SIMPLE_TYPE() 68 struct xencons_interface *intf = con->sring; in OBJECT_DECLARE_SIMPLE_TYPE() 89 xen_device_notify_event_channel(XEN_DEVICE(con), con->event_channel, NULL); in OBJECT_DECLARE_SIMPLE_TYPE() 117 static int ring_free_bytes(XenConsole *con) in ring_free_bytes() argument 119 struct xencons_interface *intf = con->sring; in ring_free_bytes() 135 XenConsole *con = opaque; in xencons_can_receive() local 136 return ring_free_bytes(con); in xencons_can_receive() 141 XenConsole *con = opaque; in xencons_receive() local 142 struct xencons_interface *intf = con->sring; in xencons_receive() [all …]
|
/openbmc/linux/tools/perf/util/ |
H A D | bpf_lock_contention.c | 20 int lock_contention_prepare(struct lock_contention *con) in lock_contention_prepare() argument 24 struct evlist *evlist = con->evlist; in lock_contention_prepare() 25 struct target *target = con->target; in lock_contention_prepare() 33 bpf_map__set_value_size(skel->maps.stacks, con->max_stack * sizeof(u64)); in lock_contention_prepare() 34 bpf_map__set_max_entries(skel->maps.lock_stat, con->map_nr_entries); in lock_contention_prepare() 35 bpf_map__set_max_entries(skel->maps.tstamp, con->map_nr_entries); in lock_contention_prepare() 37 if (con->aggr_mode == LOCK_AGGR_TASK) in lock_contention_prepare() 38 bpf_map__set_max_entries(skel->maps.task_data, con->map_nr_entries); in lock_contention_prepare() 42 if (con->save_callstack) in lock_contention_prepare() 43 bpf_map__set_max_entries(skel->maps.stacks, con->map_nr_entries); in lock_contention_prepare() [all …]
|
/openbmc/linux/include/linux/ceph/ |
H A D | messenger.h | 30 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m); 34 struct ceph_connection *con, 36 int (*add_authorizer_challenge)(struct ceph_connection *con, 39 int (*verify_authorizer_reply) (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); 49 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con, 59 int (*get_auth_request)(struct ceph_connection *con, 62 int (*handle_auth_reply_more)(struct ceph_connection *con, [all …]
|
/openbmc/qemu/include/ui/ |
H A D | console.h | 121 void console_handle_touch_event(QemuConsole *con, 274 QemuConsole *con; member 311 bool dpy_ui_info_supported(const QemuConsole *con); 312 const QemuUIInfo *dpy_get_ui_info(const QemuConsole *con); 313 int dpy_set_ui_info(QemuConsole *con, QemuUIInfo *info, bool delay); 315 void dpy_gfx_update(QemuConsole *con, int x, int y, int w, int h); 316 void dpy_gfx_update_full(QemuConsole *con); 317 void dpy_gfx_replace_surface(QemuConsole *con, 319 void dpy_text_cursor(QemuConsole *con, int x, int y); 320 void dpy_text_update(QemuConsole *con, int x, int y, int w, int h); [all …]
|
/openbmc/linux/drivers/infiniband/ulp/rtrs/ |
H A D | rtrs.c | 72 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 D | rtrs-clt.c | 188 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(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(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 …]
|
/openbmc/u-boot/test/dm/ |
H A D | video.c | 111 struct udevice *dev, *con; in dm_test_video_text() local 121 ut_assertok(uclass_get_device(UCLASS_VIDEO_CONSOLE, 0, &con)); in dm_test_video_text() 122 vidconsole_putc_xy(con, 0, 0, 'a'); in dm_test_video_text() 125 vidconsole_putc_xy(con, 0, 0, ' '); in dm_test_video_text() 129 vidconsole_putc_xy(con, VID_TO_POS(i * 8), 0, ' ' + i); in dm_test_video_text() 132 vidconsole_set_row(con, 0, WHITE); in dm_test_video_text() 136 vidconsole_putc_xy(con, VID_TO_POS(i * 8), 0, ' ' + i); in dm_test_video_text() 146 struct udevice *dev, *con; in dm_test_video_chars() local 151 ut_assertok(uclass_get_device(UCLASS_VIDEO_CONSOLE, 0, &con)); in dm_test_video_chars() 152 vidconsole_put_string(con, test_string); in dm_test_video_chars() [all …]
|
/openbmc/linux/arch/arm/mach-s3c/ |
H A D | gpio-samsung.c | 73 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 …]
|
/openbmc/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 …]
|
/openbmc/linux/drivers/gpu/drm/amd/amdgpu/ |
H A D | amdgpu_ras.c | 126 static bool amdgpu_ras_check_bad_page_unlock(struct amdgpu_ras *con, 641 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); in amdgpu_ras_create_obj() local 644 if (!adev->ras_enabled || !con) in amdgpu_ras_create_obj() 654 obj = &con->objs[AMDGPU_RAS_BLOCK__LAST + head->sub_block_index]; in amdgpu_ras_create_obj() 656 obj = &con->objs[head->block]; in amdgpu_ras_create_obj() 664 list_add(&obj->node, &con->head); in amdgpu_ras_create_obj() 674 struct amdgpu_ras *con = amdgpu_ras_get_context(adev); in amdgpu_ras_find_obj() local 678 if (!adev->ras_enabled || !con) in amdgpu_ras_find_obj() 689 obj = &con->objs[AMDGPU_RAS_BLOCK__LAST + head->sub_block_index]; in amdgpu_ras_find_obj() 691 obj = &con->objs[head->block]; in amdgpu_ras_find_obj() [all …]
|
/openbmc/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") 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 …]
|
/openbmc/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() 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 …]
|
/openbmc/linux/drivers/net/ethernet/qlogic/qed/ |
H A D | qed_nvmetcp.c | 256 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 …]
|
/openbmc/linux/tools/perf/tests/shell/ |
H A D | lock_contention.sh | 54 if ! perf lock con -b true > /dev/null 2>&1 ; then 60 perf lock con -a -b -E 1 -q -- perf bench sched messaging > /dev/null 2> ${result} 90 if ! perf lock con -b true > /dev/null 2>&1 ; then 95 perf lock con -a -b -t -E 1 -q -- perf bench sched messaging > /dev/null 2> ${result} 113 if ! perf lock con -b true > /dev/null 2>&1 ; then 118 perf lock con -a -b -l -E 1 -q -- perf bench sched messaging > /dev/null 2> ${result} 136 if ! perf lock con -b true > /dev/null 2>&1 ; then 140 perf lock con -a -b -Y spinlock -q -- perf bench sched messaging > /dev/null 2> ${result} 168 if ! perf lock con -b true > /dev/null 2>&1 ; then 172 perf lock con -a -b -L tasklist_lock -q -- perf bench sched messaging > /dev/null 2> ${result} [all …]
|