con 28 arch/arm/kernel/early_printk.c static void early_console_write(struct console *con, const char *s, unsigned n) con 206 arch/arm/mach-ep93xx/clock.c #define INIT_CK(dev,con,ck) \ con 207 arch/arm/mach-ep93xx/clock.c { .dev_id = dev, .con_id = con, .clk = ck } con 26 arch/arm/mach-omap1/clock.h #define CLK(dev, con, ck, cp) \ con 31 arch/arm/mach-omap1/clock.h .con_id = con, \ con 49 arch/arm/mach-s3c64xx/irq-pm.c u32 con; con 74 arch/arm/mach-s3c64xx/irq-pm.c grp->con = __raw_readl(S3C64XX_EINT12CON + (i * 4)); con 95 arch/arm/mach-s3c64xx/irq-pm.c __raw_writel(grp->con, S3C64XX_EINT12CON + (i * 4)); con 85 arch/arm/plat-samsung/adc.c unsigned con = readl(adc->regs + S3C2410_ADCCON); con 87 arch/arm/plat-samsung/adc.c con |= S3C2410_ADCCON_ENABLE_START; con 88 arch/arm/plat-samsung/adc.c writel(con, adc->regs + S3C2410_ADCCON); con 94 arch/arm/plat-samsung/adc.c unsigned con = readl(adc->regs + S3C2410_ADCCON); con 100 arch/arm/plat-samsung/adc.c con &= ~S3C2410_ADCCON_MUXMASK; con 101 arch/arm/plat-samsung/adc.c con &= ~S3C2410_ADCCON_STDBM; con 102 arch/arm/plat-samsung/adc.c con &= ~S3C2410_ADCCON_STARTMASK; con 111 arch/arm/plat-samsung/adc.c con |= S3C2410_ADCCON_SELMUX(client->channel); con 114 arch/arm/plat-samsung/adc.c writel(con, adc->regs + S3C2410_ADCCON); con 419 arch/arm/plat-samsung/adc.c u32 con; con 423 arch/arm/plat-samsung/adc.c con = readl(adc->regs + S3C2410_ADCCON); con 424 arch/arm/plat-samsung/adc.c con |= S3C2410_ADCCON_STDBM; con 425 arch/arm/plat-samsung/adc.c writel(con, adc->regs + S3C2410_ADCCON); con 180 arch/arm/plat-samsung/gpio-samsung.c u32 con; con 190 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(reg); con 191 arch/arm/plat-samsung/gpio-samsung.c con &= ~(0x3 << shift); con 192 arch/arm/plat-samsung/gpio-samsung.c con |= cfg; con 193 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, reg); con 211 arch/arm/plat-samsung/gpio-samsung.c u32 con; con 213 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(chip->base); con 214 arch/arm/plat-samsung/gpio-samsung.c con >>= off * 2; con 215 arch/arm/plat-samsung/gpio-samsung.c con &= 3; con 218 arch/arm/plat-samsung/gpio-samsung.c return S3C_GPIO_SPECIAL(con); con 243 arch/arm/plat-samsung/gpio-samsung.c u32 con; con 253 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(reg); con 254 arch/arm/plat-samsung/gpio-samsung.c con &= ~(0xf << shift); con 255 arch/arm/plat-samsung/gpio-samsung.c con |= cfg; con 256 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, reg); con 278 arch/arm/plat-samsung/gpio-samsung.c u32 con; con 283 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(reg); con 284 arch/arm/plat-samsung/gpio-samsung.c con >>= shift; con 285 arch/arm/plat-samsung/gpio-samsung.c con &= 0xf; con 288 arch/arm/plat-samsung/gpio-samsung.c return S3C_GPIO_SPECIAL(con); con 308 arch/arm/plat-samsung/gpio-samsung.c u32 con; con 321 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(reg); con 322 arch/arm/plat-samsung/gpio-samsung.c con &= ~(0x1 << shift); con 323 arch/arm/plat-samsung/gpio-samsung.c con |= cfg; con 324 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, reg); con 344 arch/arm/plat-samsung/gpio-samsung.c u32 con; con 346 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(chip->base); con 347 arch/arm/plat-samsung/gpio-samsung.c con >>= off; con 348 arch/arm/plat-samsung/gpio-samsung.c con &= 1; con 349 arch/arm/plat-samsung/gpio-samsung.c con++; con 351 arch/arm/plat-samsung/gpio-samsung.c return S3C_GPIO_SFN(con); con 433 arch/arm/plat-samsung/gpio-samsung.c unsigned long con; con 437 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(base + 0x00); con 438 arch/arm/plat-samsung/gpio-samsung.c con &= ~(3 << (offset * 2)); con 440 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, base + 0x00); con 453 arch/arm/plat-samsung/gpio-samsung.c unsigned long con; con 463 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(base + 0x00); con 464 arch/arm/plat-samsung/gpio-samsung.c con &= ~(3 << (offset * 2)); con 465 arch/arm/plat-samsung/gpio-samsung.c con |= 1 << (offset * 2); con 467 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, base + 0x00); con 495 arch/arm/plat-samsung/gpio-samsung.c unsigned long con; con 497 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(base + GPIOCON_OFF); con 499 arch/arm/plat-samsung/gpio-samsung.c con |= 0xf << con_4bit_shift(offset); con 501 arch/arm/plat-samsung/gpio-samsung.c con &= ~(0xf << con_4bit_shift(offset)); con 502 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, base + GPIOCON_OFF); con 504 arch/arm/plat-samsung/gpio-samsung.c pr_debug("%s: %p: CON now %08lx\n", __func__, base, con); con 514 arch/arm/plat-samsung/gpio-samsung.c unsigned long con; con 517 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(base + GPIOCON_OFF); con 518 arch/arm/plat-samsung/gpio-samsung.c con &= ~(0xf << con_4bit_shift(offset)); con 519 arch/arm/plat-samsung/gpio-samsung.c con |= 0x1 << con_4bit_shift(offset); con 529 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, base + GPIOCON_OFF); con 532 arch/arm/plat-samsung/gpio-samsung.c pr_debug("%s: %p: CON %08lx, DAT %08lx\n", __func__, base, con, dat); con 565 arch/arm/plat-samsung/gpio-samsung.c unsigned long con; con 572 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(regcon); con 573 arch/arm/plat-samsung/gpio-samsung.c con &= ~(0xf << con_4bit_shift(offset)); con 574 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, regcon); con 576 arch/arm/plat-samsung/gpio-samsung.c pr_debug("%s: %p: CON %08lx\n", __func__, base, con); con 587 arch/arm/plat-samsung/gpio-samsung.c unsigned long con; con 596 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(regcon); con 597 arch/arm/plat-samsung/gpio-samsung.c con &= ~(0xf << con_4bit_shift(con_offset)); con 598 arch/arm/plat-samsung/gpio-samsung.c con |= 0x1 << con_4bit_shift(con_offset); con 608 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, regcon); con 611 arch/arm/plat-samsung/gpio-samsung.c pr_debug("%s: %p: CON %08lx, DAT %08lx\n", __func__, base, con, dat); con 631 arch/arm/plat-samsung/gpio-samsung.c unsigned long con; con 635 arch/arm/plat-samsung/gpio-samsung.c con = __raw_readl(base + 0x00); con 644 arch/arm/plat-samsung/gpio-samsung.c con &= ~(1 << offset); con 646 arch/arm/plat-samsung/gpio-samsung.c __raw_writel(con, base + 0x00); con 74 arch/arm/plat-samsung/pm-gpio.c static inline int is_sfn(unsigned long con) con 76 arch/arm/plat-samsung/pm-gpio.c return con >= 2; con 81 arch/arm/plat-samsung/pm-gpio.c static inline int is_in(unsigned long con) con 83 arch/arm/plat-samsung/pm-gpio.c return con == 0; con 88 arch/arm/plat-samsung/pm-gpio.c static inline int is_out(unsigned long con) con 90 arch/arm/plat-samsung/pm-gpio.c return con == 1; con 243 arch/arm/plat-samsung/pm-gpio.c void __iomem *con = chip->base + (index * 4); con 244 arch/arm/plat-samsung/pm-gpio.c u32 old_gpcon = __raw_readl(con); con 253 arch/arm/plat-samsung/pm-gpio.c __raw_writel(gpcon, con); con 121 arch/c6x/include/asm/clock.h #define CLK(dev, con, ck) \ con 124 arch/c6x/include/asm/clock.h .con_id = con, \ con 14 arch/h8300/kernel/sim-console.c static void sim_write(struct console *con, const char *s, unsigned n) con 27 arch/h8300/kernel/sim-console.c device->con->write = sim_write; con 43 arch/m68k/emu/nfcon.c static void nfcon_write(struct console *con, const char *str, con 49 arch/m68k/emu/nfcon.c static struct tty_driver *nfcon_device(struct console *con, int *index) con 52 arch/m68k/emu/nfcon.c return (con->flags & CON_ENABLED) ? nfcon_tty_driver : NULL; con 14 arch/mips/dec/prom/console.c static void __init prom_console_write(struct console *con, const char *s, con 17 arch/mips/kernel/early_printk.c static void early_console_write(struct console *con, const char *s, unsigned n) con 120 arch/mips/lantiq/xway/gptu.c static inline void clkdev_add_gptu(struct device *dev, const char *con, con 126 arch/mips/lantiq/xway/gptu.c clk->cl.con_id = con; con 309 arch/mips/lantiq/xway/sysctrl.c static void clkdev_add_pmu(const char *dev, const char *con, bool deactivate, con 315 arch/mips/lantiq/xway/sysctrl.c clk->cl.con_id = con; con 332 arch/mips/lantiq/xway/sysctrl.c static void clkdev_add_cgu(const char *dev, const char *con, con 338 arch/mips/lantiq/xway/sysctrl.c clk->cl.con_id = con; con 91 arch/mips/sgi-ip32/ip32-setup.c char* con = ArcGetEnvironmentVariable("console"); con 92 arch/mips/sgi-ip32/ip32-setup.c if (con && *con == 'd') { con 97 arch/mips/sgi-ip32/ip32-setup.c add_preferred_console("ttyS", *(con + 1) == '2' ? 1 : 0, con 141 arch/powerpc/kernel/udbg.c static void udbg_console_write(struct console *con, const char *s, con 11 arch/s390/kernel/early_printk.c static void sclp_early_write(struct console *con, const char *s, unsigned int len) con 297 arch/sparc/kernel/btext.c static void btext_console_write(struct console *con, const char *s, con 112 arch/sparc/kernel/setup_32.c prom_console_write(struct console *con, const char *s, unsigned int n) con 85 arch/sparc/kernel/setup_64.c prom_console_write(struct console *con, const char *s, unsigned int n) con 11 arch/um/kernel/early_printk.c static void early_console_write(struct console *con, const char *s, unsigned int n) con 16 arch/unicore32/kernel/early_printk.c static void early_ocd_write(struct console *con, const char *s, unsigned n) con 243 arch/x86/include/asm/inst.h .byte \rcon con 32 arch/x86/kernel/early_printk.c static void early_vga_write(struct console *con, const char *str, unsigned n) con 123 arch/x86/kernel/early_printk.c static void early_serial_write(struct console *con, const char *s, unsigned n) con 330 arch/x86/kernel/early_printk.c static void early_console_register(struct console *con, int keep_early) con 332 arch/x86/kernel/early_printk.c if (con->index != -1) { con 334 arch/x86/kernel/early_printk.c con->name); con 337 arch/x86/kernel/early_printk.c early_console = con; con 440 crypto/af_alg.c static int af_alg_cmsg_send(struct msghdr *msg, struct af_alg_control *con) con 452 crypto/af_alg.c if (cmsg->cmsg_len < CMSG_LEN(sizeof(*con->iv))) con 454 crypto/af_alg.c con->iv = (void *)CMSG_DATA(cmsg); con 455 crypto/af_alg.c if (cmsg->cmsg_len < CMSG_LEN(con->iv->ivlen + con 456 crypto/af_alg.c sizeof(*con->iv))) con 463 crypto/af_alg.c con->op = *(u32 *)CMSG_DATA(cmsg); con 469 crypto/af_alg.c con->aead_assoclen = *(u32 *)CMSG_DATA(cmsg); con 822 crypto/af_alg.c struct af_alg_control con = {}; con 829 crypto/af_alg.c err = af_alg_cmsg_send(msg, &con); con 834 crypto/af_alg.c switch (con.op) { con 845 crypto/af_alg.c if (con.iv && con.iv->ivlen != ivsize) con 857 crypto/af_alg.c if (con.iv) con 858 crypto/af_alg.c memcpy(ctx->iv, con.iv->iv, ivsize); con 860 crypto/af_alg.c ctx->aead_assoclen = con.aead_assoclen; con 19 drivers/base/devcon.c struct device_connection con = { .id = con_id }; con 24 drivers/base/devcon.c con.fwnode = fwnode_graph_get_remote_port_parent(ep); con 25 drivers/base/devcon.c if (!fwnode_device_is_available(con.fwnode)) con 28 drivers/base/devcon.c ret = match(&con, -1, data); con 29 drivers/base/devcon.c fwnode_handle_put(con.fwnode); con 42 drivers/base/devcon.c struct device_connection con = { }; con 47 drivers/base/devcon.c con.fwnode = fwnode_find_reference(fwnode, con_id, i); con 48 drivers/base/devcon.c if (IS_ERR(con.fwnode)) con 51 drivers/base/devcon.c ret = match(&con, -1, data); con 52 drivers/base/devcon.c fwnode_handle_put(con.fwnode); con 104 drivers/base/devcon.c struct device_connection *con; con 117 drivers/base/devcon.c list_for_each_entry(con, &devcon_list, list) { con 118 drivers/base/devcon.c ep = match_string(con->endpoint, 2, devname); con 122 drivers/base/devcon.c if (con_id && strcmp(con->id, con_id)) con 125 drivers/base/devcon.c ret = match(con, !ep, data); con 155 drivers/base/devcon.c static void *device_connection_fwnode_match(struct device_connection *con) con 161 drivers/base/devcon.c dev = bus_find_device_by_fwnode(bus, con->fwnode); con 162 drivers/base/devcon.c if (dev && !strncmp(dev_name(dev), con->id, strlen(con->id))) con 171 drivers/base/devcon.c static void *generic_match(struct device_connection *con, int ep, void *data) con 176 drivers/base/devcon.c if (con->fwnode) con 177 drivers/base/devcon.c return device_connection_fwnode_match(con); con 180 drivers/base/devcon.c dev = bus_find_device_by_name(bus, NULL, con->endpoint[ep]); con 213 drivers/base/devcon.c void device_connection_add(struct device_connection *con) con 216 drivers/base/devcon.c list_add_tail(&con->list, &devcon_list); con 225 drivers/base/devcon.c void device_connection_remove(struct device_connection *con) con 228 drivers/base/devcon.c list_del(&con->list); con 75 drivers/block/paride/pseudo.h void (*con)(void); con 80 drivers/block/paride/pseudo.h con = ps_continuation; con 83 drivers/block/paride/pseudo.h if (!con) { con 90 drivers/block/paride/pseudo.h con(); con 477 drivers/clk/ti/clk.c int ti_clk_add_alias(struct device *dev, struct clk *clk, const char *con) con 493 drivers/clk/ti/clk.c cl->con_id = con; con 512 drivers/clk/ti/clk.c const char *con) con 521 drivers/clk/ti/clk.c ret = ti_clk_add_alias(dev, clk, con); con 542 drivers/clk/ti/clk.c const char *con) con 547 drivers/clk/ti/clk.c clk = ti_clk_register(dev, hw, con); con 93 drivers/clk/ti/clock.h #define CLK(dev, con, ck) \ con 97 drivers/clk/ti/clock.h .con_id = con, \ con 157 drivers/clk/ti/clock.h #define DT_CLK(dev, con, name) \ con 161 drivers/clk/ti/clock.h .con_id = con, \ con 212 drivers/clk/ti/clock.h const char *con); con 214 drivers/clk/ti/clock.h const char *con); con 215 drivers/clk/ti/clock.h int ti_clk_add_alias(struct device *dev, struct clk *clk, const char *con); con 133 drivers/firmware/efi/earlycon.c efi_earlycon_write(struct console *con, const char *str, unsigned int num) con 240 drivers/firmware/efi/earlycon.c device->con->write = efi_earlycon_write; con 241 drivers/firmware/efi/earlycon.c earlycon_console = device->con; con 328 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 331 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 337 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c obj = &con->objs[head->block]; con 344 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c list_add(&obj->node, &con->head); con 354 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 358 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 365 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c obj = &con->objs[head->block]; con 373 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c obj = &con->objs[i]; con 389 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 391 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c return con->hw_supported & BIT(head->block); con 397 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 399 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c return con->features & BIT(head->block); con 409 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 432 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->features |= BIT(head->block); con 435 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->features &= ~BIT(head->block); con 447 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 451 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 493 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 496 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 499 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (con->flags & AMDGPU_RAS_FLAG_INIT_BY_VBIOS) { con 535 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 538 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c list_for_each_entry_safe(obj, tmp, &con->head, node) { con 551 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c return con->features; con 557 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 583 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c return con->features; con 688 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 692 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 695 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c list_for_each_entry(obj, &con->head, node) { con 757 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = con 759 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_device *adev = con->adev; con 788 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = con 791 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c return scnprintf(buf, PAGE_SIZE, "feature mask: 0x%x\n", con->features); con 796 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 798 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c &con->features_attr.attr, con 802 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c &con->badpages_attr, con 811 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->features_attr = (struct device_attribute) { con 819 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->badpages_attr = (struct bin_attribute) { con 837 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 839 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c &con->features_attr.attr, con 843 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c &con->badpages_attr, con 911 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 914 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c list_for_each_entry_safe(obj, tmp, &con->head, node) { con 927 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 930 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->dir = debugfs_create_dir("ras", minor->debugfs_root); con 931 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->ent = debugfs_create_file("ras_ctrl", S_IWUGO | S_IRUGO, con->dir, con 938 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 951 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c S_IWUGO | S_IRUGO, con->dir, obj, con 970 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 973 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c list_for_each_entry_safe(obj, tmp, &con->head, node) { con 977 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c debugfs_remove(con->ent); con 978 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c debugfs_remove(con->dir); con 979 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->dir = NULL; con 980 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->ent = NULL; con 1140 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1143 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c list_for_each_entry_safe(obj, tmp, &con->head, node) { con 1162 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1167 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con || !con->eh_data || !bps || !count) con 1170 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_lock(&con->recovery_lock); con 1171 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c data = con->eh_data; con 1198 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_unlock(&con->recovery_lock); con 1238 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1243 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con || !con->eh_data || !bps || pages <= 0) con 1246 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_lock(&con->recovery_lock); con 1247 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c data = con->eh_data; con 1262 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_unlock(&con->recovery_lock); con 1270 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1276 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con || !con->eh_data) con 1279 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_lock(&con->recovery_lock); con 1280 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c data = con->eh_data; con 1297 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_unlock(&con->recovery_lock); con 1304 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1309 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con || !con->eh_data) con 1312 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_lock(&con->recovery_lock); con 1313 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c data = con->eh_data; con 1326 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_unlock(&con->recovery_lock); con 1348 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1349 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct ras_err_handler_data **data = &con->eh_data; con 1356 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_init(&con->recovery_lock); con 1357 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c INIT_WORK(&con->recovery_work, amdgpu_ras_do_recovery); con 1358 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c atomic_set(&con->in_recovery, 0); con 1359 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->adev = adev; con 1369 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1370 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct ras_err_handler_data *data = con->eh_data; con 1372 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c cancel_work_sync(&con->recovery_work); con 1376 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_lock(&con->recovery_lock); con 1377 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->eh_data = NULL; con 1380 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c mutex_unlock(&con->recovery_lock); con 1429 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1431 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (con) con 1434 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con = kmalloc(sizeof(struct amdgpu_ras) + con 1437 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 1440 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->objs = (struct ras_manager *)(con + 1); con 1442 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c amdgpu_ras_set_context(adev, con); con 1444 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c amdgpu_ras_check_supported(adev, &con->hw_supported, con 1445 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c &con->supported); con 1446 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con->hw_supported) { con 1448 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c kfree(con); con 1452 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->features = 0; con 1453 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c INIT_LIST_HEAD(&con->head); con 1455 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->flags = RAS_DEFAULT_FLAGS; con 1471 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->hw_supported, con->supported); con 1477 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c kfree(con); con 1487 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1490 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 1493 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (con->flags & AMDGPU_RAS_FLAG_INIT_BY_VBIOS) { con 1505 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c list_for_each_entry_safe(obj, tmp, &con->head, node) { con 1514 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (con->flags & AMDGPU_RAS_FLAG_INIT_NEED_RESET) { con 1515 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c con->flags &= ~AMDGPU_RAS_FLAG_INIT_NEED_RESET; con 1530 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1532 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 1537 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (con->features) con 1544 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1546 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 1557 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c struct amdgpu_ras *con = amdgpu_ras_get_context(adev); con 1559 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (!con) con 1565 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c WARN(con->features, "Feature mask is not cleared"); con 1567 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c if (con->features) con 1571 drivers/gpu/drm/amd/amdgpu/amdgpu_ras.c kfree(con); con 227 drivers/gpu/drm/bridge/sii902x.c static inline struct sii902x *connector_to_sii902x(struct drm_connector *con) con 229 drivers/gpu/drm/bridge/sii902x.c return container_of(con, struct sii902x, connector); con 84 drivers/gpu/drm/fsl-dcu/fsl_dcu_drm_crtc.c struct drm_connector *con = &fsl_dev->connector.base; con 94 drivers/gpu/drm/fsl-dcu/fsl_dcu_drm_crtc.c if (!(con->display_info.bus_flags & DRM_BUS_FLAG_PIXDATA_DRIVE_POSEDGE)) con 18 drivers/gpu/drm/fsl-dcu/fsl_dcu_drm_output.h to_fsl_dcu_connector(struct drm_connector *con) con 20 drivers/gpu/drm/fsl-dcu/fsl_dcu_drm_output.h return con ? container_of(con, struct fsl_dcu_drm_connector, base) con 151 drivers/gpu/drm/imx/dw_hdmi-imx.c imx6q_hdmi_mode_valid(struct drm_connector *con, con 164 drivers/gpu/drm/imx/dw_hdmi-imx.c imx6dl_hdmi_mode_valid(struct drm_connector *con, con 201 drivers/gpu/drm/mediatek/mtk_disp_ovl.c unsigned int con; con 206 drivers/gpu/drm/mediatek/mtk_disp_ovl.c con = ovl_fmt_convert(ovl, fmt); con 208 drivers/gpu/drm/mediatek/mtk_disp_ovl.c con |= OVL_CON_AEN | OVL_CON_ALPHA; con 210 drivers/gpu/drm/mediatek/mtk_disp_ovl.c writel_relaxed(con, comp->regs + DISP_REG_OVL_CON(idx)); con 200 drivers/gpu/drm/mediatek/mtk_disp_rdma.c unsigned int con; con 202 drivers/gpu/drm/mediatek/mtk_disp_rdma.c con = rdma_fmt_convert(rdma, fmt); con 203 drivers/gpu/drm/mediatek/mtk_disp_rdma.c writel_relaxed(con, comp->regs + DISP_RDMA_MEM_CON); con 130 drivers/gpu/drm/nouveau/nouveau_connector.h struct drm_connector *con) con 132 drivers/gpu/drm/nouveau/nouveau_connector.h return container_of(con, struct nouveau_connector, base); con 68 drivers/gpu/drm/vmwgfx/vmwgfx_fb.c struct drm_connector *con; con 478 drivers/gpu/drm/vmwgfx/vmwgfx_fb.c set.connectors = &par->con; con 602 drivers/gpu/drm/vmwgfx/vmwgfx_fb.c set.connectors = &par->con; con 675 drivers/gpu/drm/vmwgfx/vmwgfx_fb.c par->max_height, &par->con, con 2026 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c struct drm_connector *con; con 2048 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c drm_for_each_connector_iter(con, &conn_iter) { con 2049 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c du = vmw_connector_to_du(con); con 2066 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c list_for_each_entry(con, &dev->mode_config.connector_list, head) { con 2067 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c du = vmw_connector_to_du(con); con 2070 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c (&con->base, dev->mode_config.suggested_x_property, con 2073 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c (&con->base, dev->mode_config.suggested_y_property, con 2077 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c (&con->base, dev->mode_config.suggested_x_property, con 2080 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c (&con->base, dev->mode_config.suggested_y_property, con 2083 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c con->status = vmw_du_connector_detect(con, true); con 2654 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c struct drm_connector *con; con 2661 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c list_for_each_entry(con, &dev_priv->dev->mode_config.connector_list, con 2675 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c if (list_empty(&con->modes)) con 2676 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c (void) vmw_du_connector_fill_modes(con, max_width, max_height); con 2678 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c if (list_empty(&con->modes)) { con 2684 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c du = vmw_connector_to_du(con); con 2685 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c *p_con = con; con 2688 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c list_for_each_entry(mode, &con->modes, head) { con 2697 drivers/gpu/drm/vmwgfx/vmwgfx_kms.c *p_mode = list_first_entry(&con->modes, con 31 drivers/hwtracing/stm/console.c stm_console_write(struct console *con, const char *buf, unsigned len) con 33 drivers/hwtracing/stm/console.c struct stm_console *sc = container_of(con, struct stm_console, console); con 720 drivers/i2c/busses/i2c-omap.c u16 con = omap_i2c_read_reg(omap, OMAP_I2C_CON_REG); con 721 drivers/i2c/busses/i2c-omap.c while (con & OMAP_I2C_CON_STT) { con 722 drivers/i2c/busses/i2c-omap.c con = omap_i2c_read_reg(omap, OMAP_I2C_CON_REG); con 305 drivers/i2c/busses/i2c-rk3x.c u32 con; con 307 drivers/i2c/busses/i2c-rk3x.c con = i2c_readl(i2c, REG_CON); con 315 drivers/i2c/busses/i2c-rk3x.c con &= ~REG_CON_LASTACK; con 317 drivers/i2c/busses/i2c-rk3x.c con |= REG_CON_LASTACK; con 322 drivers/i2c/busses/i2c-rk3x.c con &= ~REG_CON_MOD_MASK; con 323 drivers/i2c/busses/i2c-rk3x.c con |= REG_CON_MOD(REG_CON_MOD_RX); con 326 drivers/i2c/busses/i2c-rk3x.c i2c_writel(i2c, con, REG_CON); con 450 drivers/i2c/busses/i2c-rk3x.c unsigned int con; con 463 drivers/i2c/busses/i2c-rk3x.c con = i2c_readl(i2c, REG_CON); con 464 drivers/i2c/busses/i2c-rk3x.c con &= ~REG_CON_STOP; con 465 drivers/i2c/busses/i2c-rk3x.c i2c_writel(i2c, con, REG_CON); con 236 drivers/iio/adc/exynos_adc.c u32 con; con 241 drivers/iio/adc/exynos_adc.c con = readl(ADC_V1_CON(info->regs)); con 242 drivers/iio/adc/exynos_adc.c con |= ADC_V1_CON_STANDBY; con 243 drivers/iio/adc/exynos_adc.c writel(con, ADC_V1_CON(info->regs)); con 394 drivers/iio/adc/exynos_adc.c u32 con; con 399 drivers/iio/adc/exynos_adc.c con = readl(ADC_V2_CON1(info->regs)); con 400 drivers/iio/adc/exynos_adc.c con &= ~ADC_CON_EN_START; con 401 drivers/iio/adc/exynos_adc.c writel(con, ADC_V2_CON1(info->regs)); con 57 drivers/media/pci/bt8xx/bttv-audio-hook.c unsigned int con; con 74 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x000; con 77 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x300; con 80 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x200; con 83 drivers/media/pci/bt8xx/bttv-audio-hook.c gpio_bits(0x300, con); con 88 drivers/media/pci/bt8xx/bttv-audio-hook.c unsigned int val, con; con 97 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x300; con 100 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x100; con 103 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x000; con 106 drivers/media/pci/bt8xx/bttv-audio-hook.c if (con != (val & 0x300)) { con 107 drivers/media/pci/bt8xx/bttv-audio-hook.c gpio_bits(0x300, con); con 261 drivers/media/pci/bt8xx/bttv-audio-hook.c unsigned int con = 0; con 277 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x080000; con 280 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x180000; con 283 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0; con 286 drivers/media/pci/bt8xx/bttv-audio-hook.c gpio_bits(0x180000, con); con 453 drivers/media/pci/bt8xx/bttv-audio-hook.c unsigned int con = 0xffffff; con 471 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x00000000; con 474 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x00180000; con 477 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x00000000; con 480 drivers/media/pci/bt8xx/bttv-audio-hook.c con = 0x00060000; con 486 drivers/media/pci/bt8xx/bttv-audio-hook.c gpio_bits(0x1e0000, con); con 390 drivers/media/pci/ddbridge/ddbridge-core.c static void calc_con(struct ddb_output *output, u32 *con, u32 *con2, u32 flags) con 396 drivers/media/pci/ddbridge/ddbridge-core.c *con = 0x1c; con 403 drivers/media/pci/ddbridge/ddbridge-core.c *con = 0x10c; con 411 drivers/media/pci/ddbridge/ddbridge-core.c *con |= 0x800; con 413 drivers/media/pci/ddbridge/ddbridge-core.c *con |= 0x1000; con 420 drivers/media/pci/ddbridge/ddbridge-core.c *con |= 0x1810; con 434 drivers/media/pci/ddbridge/ddbridge-core.c *con |= 0x810; /* 96 MBit/s and gap */ con 437 drivers/media/pci/ddbridge/ddbridge-core.c *con |= 0x10; /* enable gap */ con 447 drivers/media/pci/ddbridge/ddbridge-core.c *con &= ~0x10; /* Disable gap */ con 460 drivers/media/pci/ddbridge/ddbridge-core.c u32 con = 0x11c, con2 = 0; con 469 drivers/media/pci/ddbridge/ddbridge-core.c con = (1UL << 13) | 0x14; con 471 drivers/media/pci/ddbridge/ddbridge-core.c calc_con(output, &con, &con2, 0); con 476 drivers/media/pci/ddbridge/ddbridge-core.c ddbwritel(dev, con, TS_CONTROL(output)); con 485 drivers/media/pci/ddbridge/ddbridge-core.c ddbwritel(dev, con | 1, TS_CONTROL(output)); con 188 drivers/mmc/host/omap_hsmmc.c u32 con; con 586 drivers/mmc/host/omap_hsmmc.c u32 con; con 588 drivers/mmc/host/omap_hsmmc.c con = OMAP_HSMMC_READ(host->base, CON); con 591 drivers/mmc/host/omap_hsmmc.c con |= DDR; /* configure in DDR mode */ con 593 drivers/mmc/host/omap_hsmmc.c con &= ~DDR; con 596 drivers/mmc/host/omap_hsmmc.c OMAP_HSMMC_WRITE(host->base, CON, con | DW8); con 599 drivers/mmc/host/omap_hsmmc.c OMAP_HSMMC_WRITE(host->base, CON, con & ~DW8); con 604 drivers/mmc/host/omap_hsmmc.c OMAP_HSMMC_WRITE(host->base, CON, con & ~DW8); con 614 drivers/mmc/host/omap_hsmmc.c u32 con; con 616 drivers/mmc/host/omap_hsmmc.c con = OMAP_HSMMC_READ(host->base, CON); con 618 drivers/mmc/host/omap_hsmmc.c OMAP_HSMMC_WRITE(host->base, CON, con | OD); con 620 drivers/mmc/host/omap_hsmmc.c OMAP_HSMMC_WRITE(host->base, CON, con & ~OD); con 635 drivers/mmc/host/omap_hsmmc.c if (host->con == OMAP_HSMMC_READ(host->base, CON) && con 697 drivers/mmc/host/omap_hsmmc.c host->con = OMAP_HSMMC_READ(host->base, CON); con 1550 drivers/mmc/host/omap_hsmmc.c u32 irq_mask, con; con 1555 drivers/mmc/host/omap_hsmmc.c con = OMAP_HSMMC_READ(host->base, CON); con 1560 drivers/mmc/host/omap_hsmmc.c con |= CTPL | CLKEXTFREE; con 1564 drivers/mmc/host/omap_hsmmc.c con &= ~(CTPL | CLKEXTFREE); con 1566 drivers/mmc/host/omap_hsmmc.c OMAP_HSMMC_WRITE(host->base, CON, con); con 153 drivers/mmc/host/s3cmci.c u32 con, pre, cmdarg, cmdcon, cmdsta, r0, r1, r2, r3, timer, bsize; con 156 drivers/mmc/host/s3cmci.c con = readl(host->base + S3C2410_SDICON); con 174 drivers/mmc/host/s3cmci.c prefix, con, pre, timer); con 1266 drivers/mmc/host/s3cmci.c u32 con = readl(host->base + S3C2410_SDICON); con 1268 drivers/mmc/host/s3cmci.c con |= S3C2440_SDICON_SDRESET; con 1269 drivers/mmc/host/s3cmci.c writel(con, host->base + S3C2410_SDICON); con 1276 drivers/mmc/host/s3cmci.c u32 con; con 1280 drivers/mmc/host/s3cmci.c con = readl(host->base + S3C2410_SDICON); con 1287 drivers/mmc/host/s3cmci.c con |= S3C2410_SDICON_SDIOIRQ; con 1296 drivers/mmc/host/s3cmci.c con &= ~S3C2410_SDICON_SDIOIRQ; con 1304 drivers/mmc/host/s3cmci.c writel(con, host->base + S3C2410_SDICON); con 742 drivers/net/ethernet/qlogic/qed/qed_fcoe.c struct qed_fcoe_conn *con; con 783 drivers/net/ethernet/qlogic/qed/qed_fcoe.c if (hash_con->con->icid == handle) con 787 drivers/net/ethernet/qlogic/qed/qed_fcoe.c if (!hash_con || (hash_con->con->icid != handle)) con 888 drivers/net/ethernet/qlogic/qed/qed_fcoe.c &hash_con->con); con 896 drivers/net/ethernet/qlogic/qed/qed_fcoe.c *handle = hash_con->con->icid; con 897 drivers/net/ethernet/qlogic/qed/qed_fcoe.c *fw_cid = hash_con->con->fw_cid; con 919 drivers/net/ethernet/qlogic/qed/qed_fcoe.c qed_fcoe_release_connection(QED_AFFIN_HWFN(cdev), hash_con->con); con 930 drivers/net/ethernet/qlogic/qed/qed_fcoe.c struct qed_fcoe_conn *con; con 940 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con = hash_con->con; con 942 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->sq_pbl_addr = conn_info->sq_pbl_addr; con 943 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->sq_curr_page_addr = conn_info->sq_curr_page_addr; con 944 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->sq_next_page_addr = conn_info->sq_next_page_addr; con 945 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->tx_max_fc_pay_len = conn_info->tx_max_fc_pay_len; con 946 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->e_d_tov_timer_val = conn_info->e_d_tov_timer_val; con 947 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->rec_tov_timer_val = conn_info->rec_tov_timer_val; con 948 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->rx_max_fc_pay_len = conn_info->rx_max_fc_pay_len; con 949 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->vlan_tag = conn_info->vlan_tag; con 950 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->max_conc_seqs_c3 = conn_info->max_conc_seqs_c3; con 951 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->flags = conn_info->flags; con 952 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->def_q_idx = conn_info->def_q_idx; con 954 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->src_mac_addr_hi = (conn_info->src_mac[5] << 8) | con 956 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->src_mac_addr_mid = (conn_info->src_mac[3] << 8) | con 958 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->src_mac_addr_lo = (conn_info->src_mac[1] << 8) | con 960 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->dst_mac_addr_hi = (conn_info->dst_mac[5] << 8) | con 962 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->dst_mac_addr_mid = (conn_info->dst_mac[3] << 8) | con 964 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->dst_mac_addr_lo = (conn_info->dst_mac[1] << 8) | con 967 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->s_id.addr_hi = conn_info->s_id.addr_hi; con 968 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->s_id.addr_mid = conn_info->s_id.addr_mid; con 969 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->s_id.addr_lo = conn_info->s_id.addr_lo; con 970 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->d_id.addr_hi = conn_info->d_id.addr_hi; con 971 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->d_id.addr_mid = conn_info->d_id.addr_mid; con 972 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->d_id.addr_lo = conn_info->d_id.addr_lo; con 974 drivers/net/ethernet/qlogic/qed/qed_fcoe.c return qed_sp_fcoe_conn_offload(QED_AFFIN_HWFN(cdev), con, con 982 drivers/net/ethernet/qlogic/qed/qed_fcoe.c struct qed_fcoe_conn *con; con 992 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con = hash_con->con; con 993 drivers/net/ethernet/qlogic/qed/qed_fcoe.c con->terminate_params = terminate_params; con 995 drivers/net/ethernet/qlogic/qed/qed_fcoe.c return qed_sp_fcoe_conn_destroy(QED_AFFIN_HWFN(cdev), con, con 1079 drivers/net/ethernet/qlogic/qed/qed_iscsi.c struct qed_iscsi_conn *con; con 1118 drivers/net/ethernet/qlogic/qed/qed_iscsi.c if (hash_con->con->icid == handle) con 1122 drivers/net/ethernet/qlogic/qed/qed_iscsi.c if (!hash_con || (hash_con->con->icid != handle)) con 1217 drivers/net/ethernet/qlogic/qed/qed_iscsi.c &hash_con->con); con 1225 drivers/net/ethernet/qlogic/qed/qed_iscsi.c *handle = hash_con->con->icid; con 1226 drivers/net/ethernet/qlogic/qed/qed_iscsi.c *fw_cid = hash_con->con->fw_cid; con 1248 drivers/net/ethernet/qlogic/qed/qed_iscsi.c qed_iscsi_release_connection(QED_AFFIN_HWFN(cdev), hash_con->con); con 1259 drivers/net/ethernet/qlogic/qed/qed_iscsi.c struct qed_iscsi_conn *con; con 1269 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con = hash_con->con; con 1271 drivers/net/ethernet/qlogic/qed/qed_iscsi.c ether_addr_copy(con->local_mac, conn_info->src.mac); con 1272 drivers/net/ethernet/qlogic/qed/qed_iscsi.c ether_addr_copy(con->remote_mac, conn_info->dst.mac); con 1273 drivers/net/ethernet/qlogic/qed/qed_iscsi.c memcpy(con->local_ip, conn_info->src.ip, sizeof(con->local_ip)); con 1274 drivers/net/ethernet/qlogic/qed/qed_iscsi.c memcpy(con->remote_ip, conn_info->dst.ip, sizeof(con->remote_ip)); con 1275 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->local_port = conn_info->src.port; con 1276 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->remote_port = conn_info->dst.port; con 1278 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->layer_code = conn_info->layer_code; con 1279 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->sq_pbl_addr = conn_info->sq_pbl_addr; con 1280 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->initial_ack = conn_info->initial_ack; con 1281 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->vlan_id = conn_info->vlan_id; con 1282 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->tcp_flags = conn_info->tcp_flags; con 1283 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ip_version = conn_info->ip_version; con 1284 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->default_cq = conn_info->default_cq; con 1285 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ka_max_probe_cnt = conn_info->ka_max_probe_cnt; con 1286 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->dup_ack_theshold = conn_info->dup_ack_theshold; con 1287 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->rcv_next = conn_info->rcv_next; con 1288 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->snd_una = conn_info->snd_una; con 1289 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->snd_next = conn_info->snd_next; con 1290 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->snd_max = conn_info->snd_max; con 1291 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->snd_wnd = conn_info->snd_wnd; con 1292 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->rcv_wnd = conn_info->rcv_wnd; con 1293 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->snd_wl1 = conn_info->snd_wl1; con 1294 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->cwnd = conn_info->cwnd; con 1295 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ss_thresh = conn_info->ss_thresh; con 1296 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->srtt = conn_info->srtt; con 1297 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->rtt_var = conn_info->rtt_var; con 1298 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ts_recent = conn_info->ts_recent; con 1299 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ts_recent_age = conn_info->ts_recent_age; con 1300 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->total_rt = conn_info->total_rt; con 1301 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ka_timeout_delta = conn_info->ka_timeout_delta; con 1302 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->rt_timeout_delta = conn_info->rt_timeout_delta; con 1303 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->dup_ack_cnt = conn_info->dup_ack_cnt; con 1304 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->snd_wnd_probe_cnt = conn_info->snd_wnd_probe_cnt; con 1305 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ka_probe_cnt = conn_info->ka_probe_cnt; con 1306 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->rt_cnt = conn_info->rt_cnt; con 1307 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->flow_label = conn_info->flow_label; con 1308 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ka_timeout = conn_info->ka_timeout; con 1309 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ka_interval = conn_info->ka_interval; con 1310 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->max_rt_time = conn_info->max_rt_time; con 1311 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->initial_rcv_wnd = conn_info->initial_rcv_wnd; con 1312 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ttl = conn_info->ttl; con 1313 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->tos_or_tc = conn_info->tos_or_tc; con 1314 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->remote_port = conn_info->remote_port; con 1315 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->local_port = conn_info->local_port; con 1316 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->mss = conn_info->mss; con 1317 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->snd_wnd_scale = conn_info->snd_wnd_scale; con 1318 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->rcv_wnd_scale = conn_info->rcv_wnd_scale; con 1319 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->da_timeout_value = conn_info->da_timeout_value; con 1320 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->ack_frequency = conn_info->ack_frequency; con 1323 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->offl_flags = 0x1; con 1325 drivers/net/ethernet/qlogic/qed/qed_iscsi.c return qed_sp_iscsi_conn_offload(QED_AFFIN_HWFN(cdev), con, con 1334 drivers/net/ethernet/qlogic/qed/qed_iscsi.c struct qed_iscsi_conn *con; con 1344 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con = hash_con->con; con 1345 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->update_flag = conn_info->update_flag; con 1346 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->max_seq_size = conn_info->max_seq_size; con 1347 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->max_recv_pdu_length = conn_info->max_recv_pdu_length; con 1348 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->max_send_pdu_length = conn_info->max_send_pdu_length; con 1349 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->first_seq_length = conn_info->first_seq_length; con 1350 drivers/net/ethernet/qlogic/qed/qed_iscsi.c con->exp_stat_sn = conn_info->exp_stat_sn; con 1352 drivers/net/ethernet/qlogic/qed/qed_iscsi.c return qed_sp_iscsi_conn_update(QED_AFFIN_HWFN(cdev), con, con 1367 drivers/net/ethernet/qlogic/qed/qed_iscsi.c return qed_sp_iscsi_conn_clear_sq(QED_AFFIN_HWFN(cdev), hash_con->con, con 1383 drivers/net/ethernet/qlogic/qed/qed_iscsi.c hash_con->con->abortive_dsconnect = abrt_conn; con 1385 drivers/net/ethernet/qlogic/qed/qed_iscsi.c return qed_sp_iscsi_conn_terminate(QED_AFFIN_HWFN(cdev), hash_con->con, con 1406 drivers/net/ethernet/qlogic/qed/qed_iscsi.c return qed_sp_iscsi_mac_update(QED_AFFIN_HWFN(cdev), hash_con->con, con 819 drivers/net/netconsole.c static void write_ext_msg(struct console *con, const char *msg, con 835 drivers/net/netconsole.c static void write_msg(struct console *con, const char *msg, unsigned int len) con 113 drivers/pinctrl/samsung/pinctrl-exynos.c unsigned int con, trig_type; con 142 drivers/pinctrl/samsung/pinctrl-exynos.c con = readl(bank->eint_base + reg_con); con 143 drivers/pinctrl/samsung/pinctrl-exynos.c con &= ~(EXYNOS_EINT_CON_MASK << shift); con 144 drivers/pinctrl/samsung/pinctrl-exynos.c con |= trig_type << shift; con 145 drivers/pinctrl/samsung/pinctrl-exynos.c writel(con, bank->eint_base + reg_con); con 155 drivers/pinctrl/samsung/pinctrl-exynos.c unsigned int shift, mask, con; con 172 drivers/pinctrl/samsung/pinctrl-exynos.c con = readl(bank->pctl_base + reg_con); con 173 drivers/pinctrl/samsung/pinctrl-exynos.c con &= ~(mask << shift); con 174 drivers/pinctrl/samsung/pinctrl-exynos.c con |= EXYNOS_PIN_FUNC_EINT << shift; con 175 drivers/pinctrl/samsung/pinctrl-exynos.c writel(con, bank->pctl_base + reg_con); con 187 drivers/pinctrl/samsung/pinctrl-exynos.c unsigned int shift, mask, con; con 195 drivers/pinctrl/samsung/pinctrl-exynos.c con = readl(bank->pctl_base + reg_con); con 196 drivers/pinctrl/samsung/pinctrl-exynos.c con &= ~(mask << shift); con 197 drivers/pinctrl/samsung/pinctrl-exynos.c con |= EXYNOS_PIN_FUNC_INPUT << shift; con 198 drivers/pinctrl/samsung/pinctrl-exynos.c writel(con, bank->pctl_base + reg_con); con 379 drivers/rtc/rtc-s3c.c unsigned int con, tmp; con 381 drivers/rtc/rtc-s3c.c con = readw(info->base + S3C2410_RTCCON); con 383 drivers/rtc/rtc-s3c.c if ((con & S3C2410_RTCCON_RTCEN) == 0) { con 390 drivers/rtc/rtc-s3c.c if (con & S3C2410_RTCCON_CNTSEL) { con 398 drivers/rtc/rtc-s3c.c if (con & S3C2410_RTCCON_CLKRST) { con 409 drivers/rtc/rtc-s3c.c unsigned int con; con 411 drivers/rtc/rtc-s3c.c con = readw(info->base + S3C2410_RTCCON); con 412 drivers/rtc/rtc-s3c.c con &= ~S3C2410_RTCCON_RTCEN; con 413 drivers/rtc/rtc-s3c.c writew(con, info->base + S3C2410_RTCCON); con 415 drivers/rtc/rtc-s3c.c con = readb(info->base + S3C2410_TICNT); con 416 drivers/rtc/rtc-s3c.c con &= ~S3C2410_TICNT_ENABLE; con 417 drivers/rtc/rtc-s3c.c writeb(con, info->base + S3C2410_TICNT); con 422 drivers/rtc/rtc-s3c.c unsigned int con; con 424 drivers/rtc/rtc-s3c.c con = readw(info->base + S3C2410_RTCCON); con 425 drivers/rtc/rtc-s3c.c con &= ~S3C64XX_RTCCON_TICEN; con 426 drivers/rtc/rtc-s3c.c con &= ~S3C2410_RTCCON_RTCEN; con 427 drivers/rtc/rtc-s3c.c writew(con, info->base + S3C2410_RTCCON); con 709 drivers/rtc/rtc-s3c.c unsigned int con; con 711 drivers/rtc/rtc-s3c.c con = readw(info->base + S3C2410_RTCCON); con 712 drivers/rtc/rtc-s3c.c con |= S3C2443_RTCCON_TICSEL; con 713 drivers/rtc/rtc-s3c.c writew(con, info->base + S3C2410_RTCCON); con 745 drivers/rtc/rtc-s3c.c unsigned int con; con 749 drivers/rtc/rtc-s3c.c con = readw(info->base + S3C2410_RTCCON); con 750 drivers/rtc/rtc-s3c.c writew(con | info->ticnt_en_save, info->base + S3C2410_RTCCON); con 841 drivers/s390/char/sclp_vt220.c sclp_vt220_con_write(struct console *con, const char *buf, unsigned int count) con 446 drivers/scsi/aic94xx/aic94xx_seq.c u8 con = asd_read_reg_byte(asd_ha, CCONEXIST); con 447 drivers/scsi/aic94xx/aic94xx_seq.c u8 val = hweight8(con); con 1074 drivers/scsi/qla2xxx/qla_target.c struct qlt_plogi_ack_t *con = con 1080 drivers/scsi/qla2xxx/qla_target.c if (con) { con 1081 drivers/scsi/qla2xxx/qla_target.c iocb = &con->iocb; con 1088 drivers/scsi/qla2xxx/qla_target.c iocb->u.isp24.port_name, con->ref_count); con 1089 drivers/scsi/qla2xxx/qla_target.c qlt_plogi_ack_unref(vha, con); con 434 drivers/spi/spi-lantiq-ssc.c u32 con; con 448 drivers/spi/spi-lantiq-ssc.c con = lantiq_ssc_readl(spi, LTQ_SPI_CON); con 450 drivers/spi/spi-lantiq-ssc.c con &= ~LTQ_SPI_CON_TXOFF; con 452 drivers/spi/spi-lantiq-ssc.c con |= LTQ_SPI_CON_TXOFF; con 455 drivers/spi/spi-lantiq-ssc.c con &= ~LTQ_SPI_CON_RXOFF; con 457 drivers/spi/spi-lantiq-ssc.c con |= LTQ_SPI_CON_RXOFF; con 459 drivers/spi/spi-lantiq-ssc.c lantiq_ssc_writel(spi, con, LTQ_SPI_CON); con 329 drivers/thermal/samsung/exynos_tmu.c static u32 get_con_reg(struct exynos_tmu_data *data, u32 con) con 333 drivers/thermal/samsung/exynos_tmu.c con |= (EXYNOS4412_MUX_ADDR_VALUE << EXYNOS4412_MUX_ADDR_SHIFT); con 335 drivers/thermal/samsung/exynos_tmu.c con &= ~(EXYNOS_TMU_REF_VOLTAGE_MASK << EXYNOS_TMU_REF_VOLTAGE_SHIFT); con 336 drivers/thermal/samsung/exynos_tmu.c con |= data->reference_voltage << EXYNOS_TMU_REF_VOLTAGE_SHIFT; con 338 drivers/thermal/samsung/exynos_tmu.c con &= ~(EXYNOS_TMU_BUF_SLOPE_SEL_MASK << EXYNOS_TMU_BUF_SLOPE_SEL_SHIFT); con 339 drivers/thermal/samsung/exynos_tmu.c con |= (data->gain << EXYNOS_TMU_BUF_SLOPE_SEL_SHIFT); con 341 drivers/thermal/samsung/exynos_tmu.c con &= ~(EXYNOS_TMU_TRIP_MODE_MASK << EXYNOS_TMU_TRIP_MODE_SHIFT); con 342 drivers/thermal/samsung/exynos_tmu.c con |= (EXYNOS_NOISE_CANCEL_MODE << EXYNOS_TMU_TRIP_MODE_SHIFT); con 344 drivers/thermal/samsung/exynos_tmu.c return con; con 393 drivers/thermal/samsung/exynos_tmu.c u32 th, con; con 401 drivers/thermal/samsung/exynos_tmu.c con = readl(data->base + EXYNOS_TMU_REG_CONTROL); con 402 drivers/thermal/samsung/exynos_tmu.c con |= (1 << EXYNOS_TMU_THERM_TRIP_EN_SHIFT); con 403 drivers/thermal/samsung/exynos_tmu.c writel(con, data->base + EXYNOS_TMU_REG_CONTROL); con 562 drivers/thermal/samsung/exynos_tmu.c unsigned int con, interrupt_en = 0, i; con 564 drivers/thermal/samsung/exynos_tmu.c con = get_con_reg(data, readl(data->base + EXYNOS_TMU_REG_CONTROL)); con 579 drivers/thermal/samsung/exynos_tmu.c con |= (1 << EXYNOS_TMU_CORE_EN_SHIFT); con 581 drivers/thermal/samsung/exynos_tmu.c con &= ~(1 << EXYNOS_TMU_CORE_EN_SHIFT); con 585 drivers/thermal/samsung/exynos_tmu.c writel(con, data->base + EXYNOS_TMU_REG_CONTROL); con 592 drivers/thermal/samsung/exynos_tmu.c unsigned int con, interrupt_en = 0, pd_det_en, i; con 594 drivers/thermal/samsung/exynos_tmu.c con = get_con_reg(data, readl(data->base + EXYNOS_TMU_REG_CONTROL)); con 608 drivers/thermal/samsung/exynos_tmu.c con |= (1 << EXYNOS_TMU_CORE_EN_SHIFT); con 610 drivers/thermal/samsung/exynos_tmu.c con &= ~(1 << EXYNOS_TMU_CORE_EN_SHIFT); con 616 drivers/thermal/samsung/exynos_tmu.c writel(con, data->base + EXYNOS_TMU_REG_CONTROL); con 623 drivers/thermal/samsung/exynos_tmu.c unsigned int con, interrupt_en = 0, i; con 625 drivers/thermal/samsung/exynos_tmu.c con = get_con_reg(data, readl(data->base + EXYNOS_TMU_REG_CONTROL)); con 639 drivers/thermal/samsung/exynos_tmu.c con |= (1 << EXYNOS_TMU_CORE_EN_SHIFT); con 640 drivers/thermal/samsung/exynos_tmu.c con |= (1 << EXYNOS7_PD_DET_EN_SHIFT); con 642 drivers/thermal/samsung/exynos_tmu.c con &= ~(1 << EXYNOS_TMU_CORE_EN_SHIFT); con 643 drivers/thermal/samsung/exynos_tmu.c con &= ~(1 << EXYNOS7_PD_DET_EN_SHIFT); con 647 drivers/thermal/samsung/exynos_tmu.c writel(con, data->base + EXYNOS_TMU_REG_CONTROL); con 444 drivers/tty/goldfish.c static void gf_early_write(struct console *con, const char *s, unsigned int n) con 446 drivers/tty/goldfish.c struct earlycon_device *dev = con->data; con 457 drivers/tty/goldfish.c device->con->write = gf_early_write; con 691 drivers/tty/hvc/hvc_xen.c device->con->write = xenboot_earlycon_write; con 151 drivers/tty/serial/8250/8250_early.c device->con->write = early_serial8250_write; con 172 drivers/tty/serial/8250/8250_early.c device->con->write = early_serial8250_write; con 192 drivers/tty/serial/8250/8250_early.c dev->con->write = early_serial8250_write; con 127 drivers/tty/serial/8250/8250_ingenic.c dev->con->write = ingenic_early_console_write; con 396 drivers/tty/serial/altera_jtaguart.c dev->con->write = altera_jtaguart_earlycon_write; con 528 drivers/tty/serial/altera_uart.c dev->con->write = altera_uart_earlycon_write; con 2423 drivers/tty/serial/amba-pl011.c static void qdf2400_e44_early_write(struct console *con, const char *s, unsigned n) con 2425 drivers/tty/serial/amba-pl011.c struct earlycon_device *dev = con->data; con 2442 drivers/tty/serial/amba-pl011.c static void pl011_early_write(struct console *con, const char *s, unsigned n) con 2444 drivers/tty/serial/amba-pl011.c struct earlycon_device *dev = con->data; con 2467 drivers/tty/serial/amba-pl011.c device->con->write = pl011_early_write; con 2491 drivers/tty/serial/amba-pl011.c device->con->write = qdf2400_e44_early_write; con 549 drivers/tty/serial/arc_uart.c static void arc_early_serial_write(struct console *con, const char *s, con 552 drivers/tty/serial/arc_uart.c struct earlycon_device *dev = con->data; con 573 drivers/tty/serial/arc_uart.c dev->con->write = arc_early_serial_write; con 773 drivers/tty/serial/bcm63xx_uart.c static void bcm_early_write(struct console *con, const char *s, unsigned n) con 775 drivers/tty/serial/bcm63xx_uart.c struct earlycon_device *dev = con->data; con 787 drivers/tty/serial/bcm63xx_uart.c device->con->write = bcm_early_write; con 39 drivers/tty/serial/earlycon-arm-semihost.c static void smh_write(struct console *con, const char *s, unsigned n) con 41 drivers/tty/serial/earlycon-arm-semihost.c struct earlycon_device *dev = con->data; con 48 drivers/tty/serial/earlycon-arm-semihost.c device->con->write = smh_write; con 18 drivers/tty/serial/earlycon-riscv-sbi.c static void sbi_console_write(struct console *con, con 21 drivers/tty/serial/earlycon-riscv-sbi.c struct earlycon_device *dev = con->data; con 28 drivers/tty/serial/earlycon-riscv-sbi.c device->con->write = sbi_console_write; con 36 drivers/tty/serial/earlycon.c .con = &early_con, con 58 drivers/tty/serial/earlycon.c struct console *earlycon = device->con; con 145 drivers/tty/serial/earlycon.c if (!early_console_dev.con->write) con 148 drivers/tty/serial/earlycon.c register_console(early_console_dev.con); con 296 drivers/tty/serial/earlycon.c if (!early_console_dev.con->write) con 300 drivers/tty/serial/earlycon.c register_console(early_console_dev.con); con 791 drivers/tty/serial/fsl_linflexuart.c static void linflex_earlycon_write(struct console *con, const char *s, con 794 drivers/tty/serial/fsl_linflexuart.c struct earlycon_device *dev = con->data; con 805 drivers/tty/serial/fsl_linflexuart.c device->con->write = linflex_earlycon_write; con 2303 drivers/tty/serial/fsl_lpuart.c static void lpuart_early_write(struct console *con, const char *s, unsigned n) con 2305 drivers/tty/serial/fsl_lpuart.c struct earlycon_device *dev = con->data; con 2310 drivers/tty/serial/fsl_lpuart.c static void lpuart32_early_write(struct console *con, const char *s, unsigned n) con 2312 drivers/tty/serial/fsl_lpuart.c struct earlycon_device *dev = con->data; con 2323 drivers/tty/serial/fsl_lpuart.c device->con->write = lpuart_early_write; con 2334 drivers/tty/serial/fsl_lpuart.c device->con->write = lpuart32_early_write; con 2346 drivers/tty/serial/fsl_lpuart.c device->con->write = lpuart32_early_write; con 2125 drivers/tty/serial/imx.c static void imx_uart_console_early_write(struct console *con, const char *s, con 2128 drivers/tty/serial/imx.c struct earlycon_device *dev = con->data; con 2139 drivers/tty/serial/imx.c dev->con->write = imx_uart_console_early_write; con 1020 drivers/tty/serial/ip22zilog.c ip22zilog_console_write(struct console *con, const char *s, unsigned int count) con 1022 drivers/tty/serial/ip22zilog.c struct uart_ip22zilog_port *up = &ip22zilog_port_table[con->index]; con 1031 drivers/tty/serial/ip22zilog.c static int __init ip22zilog_console_setup(struct console *con, char *options) con 1033 drivers/tty/serial/ip22zilog.c struct uart_ip22zilog_port *up = &ip22zilog_port_table[con->index]; con 1041 drivers/tty/serial/ip22zilog.c printk(KERN_INFO "Console: ttyS%d (IP22-Zilog)\n", con->index); con 1053 drivers/tty/serial/ip22zilog.c return uart_set_options(&up->port, con, baud, parity, bits, flow); con 417 drivers/tty/serial/lantiq.c unsigned int con = 0; con 426 drivers/tty/serial/lantiq.c con = ASCCON_M_7ASYNC; con 434 drivers/tty/serial/lantiq.c con = ASCCON_M_8ASYNC; con 441 drivers/tty/serial/lantiq.c con |= ASCCON_STP; con 445 drivers/tty/serial/lantiq.c con &= ~ASCCON_ODD; con 447 drivers/tty/serial/lantiq.c con |= ASCCON_ODD; con 471 drivers/tty/serial/lantiq.c con |= ASCCON_FEN | ASCCON_TOEN | ASCCON_ROEN; con 476 drivers/tty/serial/lantiq.c asc_update_bits(0, con, port->membase + LTQ_ASC_CON); con 703 drivers/tty/serial/lantiq.c device->con->write = lqasc_serial_early_console_write; con 564 drivers/tty/serial/meson_uart.c device->con->write = meson_serial_early_console_write; con 481 drivers/tty/serial/milbeaut_usio.c device->con->write = mlb_usio_early_console_write; con 495 drivers/tty/serial/mps2-uart.c static void mps2_early_write(struct console *con, const char *s, unsigned int n) con 497 drivers/tty/serial/mps2-uart.c struct earlycon_device *dev = con->data; con 508 drivers/tty/serial/mps2-uart.c device->con->write = mps2_early_write; con 1684 drivers/tty/serial/msm_serial.c msm_serial_early_write(struct console *con, const char *s, unsigned n) con 1686 drivers/tty/serial/msm_serial.c struct earlycon_device *dev = con->data; con 1697 drivers/tty/serial/msm_serial.c device->con->write = msm_serial_early_write; con 1704 drivers/tty/serial/msm_serial.c msm_serial_early_write_dm(struct console *con, const char *s, unsigned n) con 1706 drivers/tty/serial/msm_serial.c struct earlycon_device *dev = con->data; con 1718 drivers/tty/serial/msm_serial.c device->con->write = msm_serial_early_write_dm; con 618 drivers/tty/serial/mvebu-uart.c static void mvebu_uart_putc_early_write(struct console *con, con 622 drivers/tty/serial/mvebu-uart.c struct earlycon_device *dev = con->data; con 634 drivers/tty/serial/mvebu-uart.c device->con->write = mvebu_uart_putc_early_write; con 1278 drivers/tty/serial/omap-serial.c device->con->write = early_omap_serial_write; con 603 drivers/tty/serial/owl-uart.c device->con->write = owl_uart_early_console_write; con 1799 drivers/tty/serial/pmac_zilog.c static void pmz_console_write(struct console *con, const char *s, unsigned int count); con 1956 drivers/tty/serial/pmac_zilog.c static void pmz_console_write(struct console *con, const char *s, unsigned int count) con 1958 drivers/tty/serial/pmac_zilog.c struct uart_pmac_port *uap = &pmz_ports[con->index]; con 1102 drivers/tty/serial/qcom_geni_serial.c static void qcom_geni_serial_earlycon_write(struct console *con, con 1105 drivers/tty/serial/qcom_geni_serial.c struct earlycon_device *dev = con->data; con 1154 drivers/tty/serial/qcom_geni_serial.c dev->con->write = qcom_geni_serial_earlycon_write; con 1155 drivers/tty/serial/qcom_geni_serial.c dev->con->setup = NULL; con 690 drivers/tty/serial/rda-uart.c device->con->write = rda_uart_early_console_write; con 2526 drivers/tty/serial/samsung.c static void samsung_early_write(struct console *con, const char *s, unsigned n) con 2528 drivers/tty/serial/samsung.c struct earlycon_device *dev = con->data; con 2539 drivers/tty/serial/samsung.c device->con->write = samsung_early_write; con 3448 drivers/tty/serial/sh-sci.c device->con->write = serial_console_write; con 726 drivers/tty/serial/sifive.c static void early_sifive_serial_write(struct console *con, const char *s, con 729 drivers/tty/serial/sifive.c struct earlycon_device *dev = con->data; con 743 drivers/tty/serial/sifive.c dev->con->write = early_sifive_serial_write; con 1043 drivers/tty/serial/sprd_serial.c static void sprd_early_write(struct console *con, const char *s, unsigned int n) con 1045 drivers/tty/serial/sprd_serial.c struct earlycon_device *dev = con->data; con 1056 drivers/tty/serial/sprd_serial.c device->con->write = sprd_early_write; con 55 drivers/tty/serial/suncore.c int sunserial_console_match(struct console *con, struct device_node *dp, con 58 drivers/tty/serial/suncore.c if (!con) con 61 drivers/tty/serial/suncore.c drv->cons = con; con 78 drivers/tty/serial/suncore.c con->index = line; con 79 drivers/tty/serial/suncore.c add_preferred_console(con->name, line, NULL); con 85 drivers/tty/serial/suncore.c void sunserial_console_termios(struct console *con, struct device_node *uart_dp) con 167 drivers/tty/serial/suncore.c con->cflag = cflag; con 439 drivers/tty/serial/sunhv.c static void sunhv_console_write_paged(struct console *con, const char *s, unsigned n) con 494 drivers/tty/serial/sunhv.c static void sunhv_console_write_bychar(struct console *con, const char *s, unsigned n) con 862 drivers/tty/serial/sunsab.c static void sunsab_console_write(struct console *con, const char *s, unsigned n) con 864 drivers/tty/serial/sunsab.c struct uart_sunsab_port *up = &sunsab_ports[con->index]; con 880 drivers/tty/serial/sunsab.c static int sunsab_console_setup(struct console *con, char *options) con 882 drivers/tty/serial/sunsab.c struct uart_sunsab_port *up = &sunsab_ports[con->index]; con 896 drivers/tty/serial/sunsab.c (sunsab_reg.minor - 64) + con->index); con 898 drivers/tty/serial/sunsab.c sunserial_console_termios(con, up->port.dev->of_node); con 900 drivers/tty/serial/sunsab.c switch (con->cflag & CBAUD) { con 941 drivers/tty/serial/sunsab.c sunsab_convert_to_sab(up, con->cflag, 0, baud, quot); con 1203 drivers/tty/serial/sunzilog.c sunzilog_console_write(struct console *con, const char *s, unsigned int count) con 1205 drivers/tty/serial/sunzilog.c struct uart_sunzilog_port *up = &sunzilog_port_table[con->index]; con 1221 drivers/tty/serial/sunzilog.c static int __init sunzilog_console_setup(struct console *con, char *options) con 1223 drivers/tty/serial/sunzilog.c struct uart_sunzilog_port *up = &sunzilog_port_table[con->index]; con 1231 drivers/tty/serial/sunzilog.c (sunzilog_reg.minor - 64) + con->index, con->index); con 1234 drivers/tty/serial/sunzilog.c sunserial_console_termios(con, up->port.dev->of_node); con 1239 drivers/tty/serial/sunzilog.c switch (con->cflag & CBAUD) { con 1256 drivers/tty/serial/sunzilog.c sunzilog_convert_to_zs(up, con->cflag, 0, brg); con 584 drivers/tty/serial/uartlite.c device->con->write = early_uartlite_write; con 756 drivers/tty/serial/vr41xx_siu.c static void siu_console_write(struct console *con, const char *s, unsigned count) con 761 drivers/tty/serial/vr41xx_siu.c port = &siu_uart_ports[con->index]; con 772 drivers/tty/serial/vr41xx_siu.c static int __init siu_console_setup(struct console *con, char *options) con 780 drivers/tty/serial/vr41xx_siu.c if (con->index >= SIU_PORTS_MAX) con 781 drivers/tty/serial/vr41xx_siu.c con->index = 0; con 783 drivers/tty/serial/vr41xx_siu.c port = &siu_uart_ports[con->index]; con 796 drivers/tty/serial/vr41xx_siu.c return uart_set_options(port, con, baud, parity, bits, flow); con 1137 drivers/tty/serial/xilinx_uartps.c static void cdns_early_write(struct console *con, const char *s, con 1140 drivers/tty/serial/xilinx_uartps.c struct earlycon_device *dev = con->data; con 1176 drivers/tty/serial/xilinx_uartps.c device->con->write = cdns_early_write; con 118 drivers/tty/vt/vt.c const struct consw *con; con 3376 drivers/tty/vt/vt.c if (con_driver->con == NULL) { con 3377 drivers/tty/vt/vt.c con_driver->con = conswitchp; con 3521 drivers/tty/vt/vt.c if (con_driver->con == csw) { con 3624 drivers/tty/vt/vt.c if (con_driver->con == csw && con 3640 drivers/tty/vt/vt.c if (con_back->con && con_back->con != csw) { con 3641 drivers/tty/vt/vt.c defcsw = con_back->con; con 3687 drivers/tty/vt/vt.c static int vt_bind(struct con_driver *con) con 3692 drivers/tty/vt/vt.c if (!con->con || !(con->flag & CON_DRIVER_FLAG_MODULE)) con 3695 drivers/tty/vt/vt.c csw = con->con; con 3698 drivers/tty/vt/vt.c struct con_driver *con = ®istered_con_driver[i]; con 3700 drivers/tty/vt/vt.c if (con->con && !(con->flag & CON_DRIVER_FLAG_MODULE)) { con 3701 drivers/tty/vt/vt.c defcsw = con->con; con 3712 drivers/tty/vt/vt.c for (i = con->first; i <= con->last; i++) { con 3737 drivers/tty/vt/vt.c static int vt_unbind(struct con_driver *con) con 3743 drivers/tty/vt/vt.c if (!con->con || !(con->flag & CON_DRIVER_FLAG_MODULE)) con 3746 drivers/tty/vt/vt.c csw = con->con; con 3751 drivers/tty/vt/vt.c for (i = con->first; i <= con->last; i++) { con 3779 drivers/tty/vt/vt.c static inline int vt_bind(struct con_driver *con) con 3783 drivers/tty/vt/vt.c static inline int vt_unbind(struct con_driver *con) con 3792 drivers/tty/vt/vt.c struct con_driver *con = dev_get_drvdata(dev); con 3798 drivers/tty/vt/vt.c vt_bind(con); con 3800 drivers/tty/vt/vt.c vt_unbind(con); con 3810 drivers/tty/vt/vt.c struct con_driver *con = dev_get_drvdata(dev); con 3814 drivers/tty/vt/vt.c bind = con_is_bound(con->con); con 3823 drivers/tty/vt/vt.c struct con_driver *con = dev_get_drvdata(dev); con 3826 drivers/tty/vt/vt.c (con->flag & CON_DRIVER_FLAG_MODULE) ? "(M)" : "(S)", con 3827 drivers/tty/vt/vt.c con->desc); con 3842 drivers/tty/vt/vt.c static int vtconsole_init_device(struct con_driver *con) con 3844 drivers/tty/vt/vt.c con->flag |= CON_DRIVER_FLAG_ATTR; con 3848 drivers/tty/vt/vt.c static void vtconsole_deinit_device(struct con_driver *con) con 3850 drivers/tty/vt/vt.c con->flag &= ~CON_DRIVER_FLAG_ATTR; con 3996 drivers/tty/vt/vt.c if (con_driver->con == csw) { con 4013 drivers/tty/vt/vt.c if (con_driver->con == NULL && con 4015 drivers/tty/vt/vt.c con_driver->con = csw; con 4074 drivers/tty/vt/vt.c if (con_driver->con == csw) { con 4085 drivers/tty/vt/vt.c con_driver->con = NULL; con 4116 drivers/tty/vt/vt.c if (WARN_ON_ONCE(con_driver->con)) con 4117 drivers/tty/vt/vt.c con_driver->con = NULL; con 4181 drivers/tty/vt/vt.c struct con_driver *con = ®istered_con_driver[i]; con 4183 drivers/tty/vt/vt.c if (con->con && !con->dev) { con 4184 drivers/tty/vt/vt.c con->dev = con 4186 drivers/tty/vt/vt.c MKDEV(0, con->node), con 4187 drivers/tty/vt/vt.c con, con_dev_groups, con 4188 drivers/tty/vt/vt.c "vtcon%i", con->node); con 4190 drivers/tty/vt/vt.c if (IS_ERR(con->dev)) { con 4192 drivers/tty/vt/vt.c con->desc, PTR_ERR(con->dev)); con 4193 drivers/tty/vt/vt.c con->dev = NULL; con 4195 drivers/tty/vt/vt.c vtconsole_init_device(con); con 4617 drivers/tty/vt/vt.c int con = op->height; con 4626 drivers/tty/vt/vt.c else if (con < 0 || !vc_cons_allocated(con)) con 4628 drivers/tty/vt/vt.c else if (con == vc->vc_num) /* nothing to do */ con 4631 drivers/tty/vt/vt.c rc = vc->vc_sw->con_font_copy(vc, con); con 913 drivers/usb/early/ehci-dbgp.c static void early_dbgp_write(struct console *con, const char *str, u32 n) con 871 drivers/usb/early/xhci-dbc.c static void early_xdbc_write(struct console *con, const char *str, u32 n) con 17 drivers/usb/gadget/function/f_uac1_legacy.c static int generic_set_cmd(struct usb_audio_control *con, u8 cmd, int value); con 18 drivers/usb/gadget/function/f_uac1_legacy.c static int generic_get_cmd(struct usb_audio_control *con, u8 cmd); con 394 drivers/usb/gadget/function/f_uac1_legacy.c struct usb_audio_control *con; con 401 drivers/usb/gadget/function/f_uac1_legacy.c list_for_each_entry(con, &cs->control, list) { con 402 drivers/usb/gadget/function/f_uac1_legacy.c if (con->type == con_sel) { con 403 drivers/usb/gadget/function/f_uac1_legacy.c audio->set_con = con; con 431 drivers/usb/gadget/function/f_uac1_legacy.c struct usb_audio_control *con; con 438 drivers/usb/gadget/function/f_uac1_legacy.c list_for_each_entry(con, &cs->control, list) { con 439 drivers/usb/gadget/function/f_uac1_legacy.c if (con->type == con_sel && con->get) { con 440 drivers/usb/gadget/function/f_uac1_legacy.c value = con->get(con, cmd); con 771 drivers/usb/gadget/function/f_uac1_legacy.c static int generic_set_cmd(struct usb_audio_control *con, u8 cmd, int value) con 773 drivers/usb/gadget/function/f_uac1_legacy.c con->data[cmd] = value; con 778 drivers/usb/gadget/function/f_uac1_legacy.c static int generic_get_cmd(struct usb_audio_control *con, u8 cmd) con 780 drivers/usb/gadget/function/f_uac1_legacy.c return con->data[cmd]; con 1360 drivers/usb/misc/sisusbvga/sisusb_con.c static int sisusbdummycon_font_copy(struct vc_data *vc, int con) con 88 drivers/usb/roles/class.c static void *usb_role_switch_match(struct device_connection *con, int ep, con 93 drivers/usb/roles/class.c if (con->fwnode) { con 94 drivers/usb/roles/class.c if (con->id && !fwnode_property_present(con->fwnode, con->id)) con 97 drivers/usb/roles/class.c dev = class_find_device_by_fwnode(role_class, con->fwnode); con 99 drivers/usb/roles/class.c dev = class_find_device_by_name(role_class, con->endpoint[ep]); con 74 drivers/usb/typec/altmodes/displayport.c static int dp_altmode_configure(struct dp_altmode *dp, u8 con) con 79 drivers/usb/typec/altmodes/displayport.c switch (con) { con 120 drivers/usb/typec/altmodes/displayport.c u8 con = DP_STATUS_CONNECTION(dp->data.status); con 128 drivers/usb/typec/altmodes/displayport.c } else if (!(con & DP_CONF_CURRENTLY(dp->data.conf))) { con 129 drivers/usb/typec/altmodes/displayport.c ret = dp_altmode_configure(dp, con); con 331 drivers/usb/typec/altmodes/displayport.c int con; con 334 drivers/usb/typec/altmodes/displayport.c con = sysfs_match_string(configurations, buf); con 335 drivers/usb/typec/altmodes/displayport.c if (con < 0) con 336 drivers/usb/typec/altmodes/displayport.c return con; con 347 drivers/usb/typec/altmodes/displayport.c if ((con == DP_CONF_DFP_D && !(cap & DP_CAP_DFP_D)) || con 348 drivers/usb/typec/altmodes/displayport.c (con == DP_CONF_UFP_D && !(cap & DP_CAP_UFP_D))) { con 354 drivers/usb/typec/altmodes/displayport.c conf |= con; con 208 drivers/usb/typec/class.c static void *typec_port_match(struct device_connection *con, int ep, void *data) con 216 drivers/usb/typec/class.c if (con->fwnode) con 217 drivers/usb/typec/class.c return class_find_device_by_fwnode(typec_class, con->fwnode); con 219 drivers/usb/typec/class.c dev = class_find_device_by_name(typec_class, con->endpoint[ep]); con 42 drivers/usb/typec/mux.c static void *typec_switch_match(struct device_connection *con, int ep, con 47 drivers/usb/typec/mux.c if (con->fwnode) { con 48 drivers/usb/typec/mux.c if (con->id && !fwnode_property_present(con->fwnode, con->id)) con 51 drivers/usb/typec/mux.c dev = class_find_device(&typec_mux_class, NULL, con->fwnode, con 55 drivers/usb/typec/mux.c con->endpoint[ep], name_match); con 185 drivers/usb/typec/mux.c static void *typec_mux_match(struct device_connection *con, int ep, void *data) con 194 drivers/usb/typec/mux.c if (!con->fwnode) { con 196 drivers/usb/typec/mux.c con->endpoint[ep], name_match); con 205 drivers/usb/typec/mux.c match = !con->id; con 211 drivers/usb/typec/mux.c match = fwnode_property_present(con->fwnode, "accessory"); con 218 drivers/usb/typec/mux.c nval = fwnode_property_count_u16(con->fwnode, "svid"); con 226 drivers/usb/typec/mux.c nval = fwnode_property_read_u16_array(con->fwnode, "svid", val, nval); con 243 drivers/usb/typec/mux.c dev = class_find_device(&typec_mux_class, NULL, con->fwnode, con 20 drivers/usb/typec/ucsi/displayport.c struct ucsi_connector *con; con 55 drivers/usb/typec/ucsi/displayport.c mutex_lock(&dp->con->lock); con 62 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 66 drivers/usb/typec/ucsi/displayport.c UCSI_CMD_GET_CURRENT_CAM(ctrl, dp->con->num); con 67 drivers/usb/typec/ucsi/displayport.c ret = ucsi_send_command(dp->con->ucsi, &ctrl, &cur, sizeof(cur)); con 69 drivers/usb/typec/ucsi/displayport.c if (dp->con->ucsi->ppm->data->version > 0x0100) { con 70 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 77 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 78 drivers/usb/typec/ucsi/displayport.c if (dp->con->port_altmode[cur] == alt) con 98 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 109 drivers/usb/typec/ucsi/displayport.c mutex_lock(&dp->con->lock); con 120 drivers/usb/typec/ucsi/displayport.c ctrl.raw_cmd = UCSI_CMD_SET_NEW_CAM(dp->con->num, 0, dp->offset, 0); con 121 drivers/usb/typec/ucsi/displayport.c ret = ucsi_send_command(dp->con->ucsi, &ctrl, NULL, 0); con 135 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 180 drivers/usb/typec/ucsi/displayport.c ctrl.raw_cmd = UCSI_CMD_SET_NEW_CAM(dp->con->num, 1, dp->offset, pins); con 182 drivers/usb/typec/ucsi/displayport.c return ucsi_send_command(dp->con->ucsi, &ctrl, NULL, 0); con 192 drivers/usb/typec/ucsi/displayport.c mutex_lock(&dp->con->lock); con 199 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 222 drivers/usb/typec/ucsi/displayport.c ucsi_altmode_update_active(dp->con); con 238 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 254 drivers/usb/typec/ucsi/displayport.c mutex_lock(&dp->con->lock); con 265 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&dp->con->lock); con 284 drivers/usb/typec/ucsi/displayport.c struct typec_altmode *ucsi_register_displayport(struct ucsi_connector *con, con 293 drivers/usb/typec/ucsi/displayport.c mutex_lock(&con->lock); con 302 drivers/usb/typec/ucsi/displayport.c alt = typec_port_register_altmode(con->port, desc); con 304 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&con->lock); con 311 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&con->lock); con 318 drivers/usb/typec/ucsi/displayport.c dp->con = con; con 324 drivers/usb/typec/ucsi/displayport.c mutex_unlock(&con->lock); con 222 drivers/usb/typec/ucsi/ucsi.c void ucsi_altmode_update_active(struct ucsi_connector *con) con 230 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_GET_CURRENT_CAM(ctrl, con->num); con 231 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_run_command(con->ucsi, &ctrl, &cur, sizeof(cur)); con 233 drivers/usb/typec/ucsi/ucsi.c if (con->ucsi->ppm->data->version > 0x0100) { con 234 drivers/usb/typec/ucsi/ucsi.c dev_err(con->ucsi->dev, con 242 drivers/usb/typec/ucsi/ucsi.c altmode = typec_altmode_get_partner(con->port_altmode[cur]); con 244 drivers/usb/typec/ucsi/ucsi.c for (i = 0; con->partner_altmode[i]; i++) con 245 drivers/usb/typec/ucsi/ucsi.c typec_altmode_update_active(con->partner_altmode[i], con 246 drivers/usb/typec/ucsi/ucsi.c con->partner_altmode[i] == altmode); con 272 drivers/usb/typec/ucsi/ucsi.c static int ucsi_register_altmode(struct ucsi_connector *con, con 281 drivers/usb/typec/ucsi/ucsi.c override = !!(con->ucsi->cap.features & UCSI_CAP_ALT_MODE_OVERRIDE); con 285 drivers/usb/typec/ucsi/ucsi.c i = ucsi_next_altmode(con->port_altmode); con 291 drivers/usb/typec/ucsi/ucsi.c desc->mode = ucsi_altmode_next_mode(con->port_altmode, con 297 drivers/usb/typec/ucsi/ucsi.c alt = ucsi_register_displayport(con, override, i, desc); con 300 drivers/usb/typec/ucsi/ucsi.c alt = typec_port_register_altmode(con->port, desc); con 309 drivers/usb/typec/ucsi/ucsi.c con->port_altmode[i] = alt; con 312 drivers/usb/typec/ucsi/ucsi.c i = ucsi_next_altmode(con->partner_altmode); con 318 drivers/usb/typec/ucsi/ucsi.c desc->mode = ucsi_altmode_next_mode(con->partner_altmode, con 321 drivers/usb/typec/ucsi/ucsi.c alt = typec_partner_register_altmode(con->partner, desc); con 327 drivers/usb/typec/ucsi/ucsi.c con->partner_altmode[i] = alt; con 338 drivers/usb/typec/ucsi/ucsi.c dev_err(con->ucsi->dev, "failed to registers svid 0x%04x mode %d\n", con 344 drivers/usb/typec/ucsi/ucsi.c static int ucsi_register_altmodes(struct ucsi_connector *con, u8 recipient) con 356 drivers/usb/typec/ucsi/ucsi.c if (!(con->ucsi->cap.features & UCSI_CAP_ALT_MODE_DETAILS)) con 359 drivers/usb/typec/ucsi/ucsi.c if (recipient == UCSI_RECIPIENT_SOP && con->partner_altmode[0]) con 363 drivers/usb/typec/ucsi/ucsi.c max_altmodes = con->ucsi->cap.num_alt_modes; con 367 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_GET_ALTERNATE_MODES(ctrl, recipient, con->num, i, 1); con 368 drivers/usb/typec/ucsi/ucsi.c len = ucsi_run_command(con->ucsi, &ctrl, alt, sizeof(alt)); con 390 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_register_altmode(con, &desc, recipient); con 399 drivers/usb/typec/ucsi/ucsi.c static void ucsi_unregister_altmodes(struct ucsi_connector *con, u8 recipient) con 407 drivers/usb/typec/ucsi/ucsi.c adev = con->port_altmode; con 410 drivers/usb/typec/ucsi/ucsi.c adev = con->partner_altmode; con 428 drivers/usb/typec/ucsi/ucsi.c static void ucsi_pwr_opmode_change(struct ucsi_connector *con) con 430 drivers/usb/typec/ucsi/ucsi.c switch (con->status.pwr_op_mode) { con 432 drivers/usb/typec/ucsi/ucsi.c typec_set_pwr_opmode(con->port, TYPEC_PWR_MODE_PD); con 435 drivers/usb/typec/ucsi/ucsi.c typec_set_pwr_opmode(con->port, TYPEC_PWR_MODE_1_5A); con 438 drivers/usb/typec/ucsi/ucsi.c typec_set_pwr_opmode(con->port, TYPEC_PWR_MODE_3_0A); con 441 drivers/usb/typec/ucsi/ucsi.c typec_set_pwr_opmode(con->port, TYPEC_PWR_MODE_USB); con 446 drivers/usb/typec/ucsi/ucsi.c static int ucsi_register_partner(struct ucsi_connector *con) con 451 drivers/usb/typec/ucsi/ucsi.c if (con->partner) con 456 drivers/usb/typec/ucsi/ucsi.c switch (con->status.partner_type) { con 467 drivers/usb/typec/ucsi/ucsi.c desc.usb_pd = con->status.pwr_op_mode == UCSI_CONSTAT_PWR_OPMODE_PD; con 469 drivers/usb/typec/ucsi/ucsi.c partner = typec_register_partner(con->port, &desc); con 471 drivers/usb/typec/ucsi/ucsi.c dev_err(con->ucsi->dev, con 472 drivers/usb/typec/ucsi/ucsi.c "con%d: failed to register partner (%ld)\n", con->num, con 477 drivers/usb/typec/ucsi/ucsi.c con->partner = partner; con 482 drivers/usb/typec/ucsi/ucsi.c static void ucsi_unregister_partner(struct ucsi_connector *con) con 484 drivers/usb/typec/ucsi/ucsi.c if (!con->partner) con 487 drivers/usb/typec/ucsi/ucsi.c ucsi_unregister_altmodes(con, UCSI_RECIPIENT_SOP); con 488 drivers/usb/typec/ucsi/ucsi.c typec_unregister_partner(con->partner); con 489 drivers/usb/typec/ucsi/ucsi.c con->partner = NULL; con 492 drivers/usb/typec/ucsi/ucsi.c static void ucsi_partner_change(struct ucsi_connector *con) con 496 drivers/usb/typec/ucsi/ucsi.c if (!con->partner) con 499 drivers/usb/typec/ucsi/ucsi.c switch (con->status.partner_type) { con 501 drivers/usb/typec/ucsi/ucsi.c typec_set_data_role(con->port, TYPEC_HOST); con 504 drivers/usb/typec/ucsi/ucsi.c typec_set_data_role(con->port, TYPEC_DEVICE); con 511 drivers/usb/typec/ucsi/ucsi.c if (!completion_done(&con->complete)) con 512 drivers/usb/typec/ucsi/ucsi.c complete(&con->complete); con 515 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_register_altmodes(con, UCSI_RECIPIENT_SOP); con 517 drivers/usb/typec/ucsi/ucsi.c dev_err(con->ucsi->dev, con 519 drivers/usb/typec/ucsi/ucsi.c con->num); con 521 drivers/usb/typec/ucsi/ucsi.c ucsi_altmode_update_active(con); con 526 drivers/usb/typec/ucsi/ucsi.c struct ucsi_connector *con = container_of(work, struct ucsi_connector, con 528 drivers/usb/typec/ucsi/ucsi.c struct ucsi *ucsi = con->ucsi; con 532 drivers/usb/typec/ucsi/ucsi.c mutex_lock(&con->lock); con 534 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_GET_CONNECTOR_STATUS(ctrl, con->num); con 535 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_send_command(ucsi, &ctrl, &con->status, sizeof(con->status)); con 542 drivers/usb/typec/ucsi/ucsi.c if (con->status.change & UCSI_CONSTAT_POWER_OPMODE_CHANGE) con 543 drivers/usb/typec/ucsi/ucsi.c ucsi_pwr_opmode_change(con); con 545 drivers/usb/typec/ucsi/ucsi.c if (con->status.change & UCSI_CONSTAT_POWER_DIR_CHANGE) { con 546 drivers/usb/typec/ucsi/ucsi.c typec_set_pwr_role(con->port, con->status.pwr_dir); con 549 drivers/usb/typec/ucsi/ucsi.c if (!completion_done(&con->complete)) con 550 drivers/usb/typec/ucsi/ucsi.c complete(&con->complete); con 553 drivers/usb/typec/ucsi/ucsi.c if (con->status.change & UCSI_CONSTAT_CONNECT_CHANGE) { con 554 drivers/usb/typec/ucsi/ucsi.c typec_set_pwr_role(con->port, con->status.pwr_dir); con 556 drivers/usb/typec/ucsi/ucsi.c switch (con->status.partner_type) { con 558 drivers/usb/typec/ucsi/ucsi.c typec_set_data_role(con->port, TYPEC_HOST); con 561 drivers/usb/typec/ucsi/ucsi.c typec_set_data_role(con->port, TYPEC_DEVICE); con 567 drivers/usb/typec/ucsi/ucsi.c if (con->status.connected) con 568 drivers/usb/typec/ucsi/ucsi.c ucsi_register_partner(con); con 570 drivers/usb/typec/ucsi/ucsi.c ucsi_unregister_partner(con); con 573 drivers/usb/typec/ucsi/ucsi.c if (con->status.change & UCSI_CONSTAT_CAM_CHANGE) { con 579 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_GET_CAM_SUPPORTED(ctrl, con->num); con 580 drivers/usb/typec/ucsi/ucsi.c ucsi_run_command(con->ucsi, &ctrl, NULL, 0); con 583 drivers/usb/typec/ucsi/ucsi.c if (con->status.change & UCSI_CONSTAT_PARTNER_CHANGE) con 584 drivers/usb/typec/ucsi/ucsi.c ucsi_partner_change(con); con 590 drivers/usb/typec/ucsi/ucsi.c trace_ucsi_connector_change(con->num, &con->status); con 594 drivers/usb/typec/ucsi/ucsi.c mutex_unlock(&con->lock); con 624 drivers/usb/typec/ucsi/ucsi.c struct ucsi_connector *con; con 626 drivers/usb/typec/ucsi/ucsi.c con = &ucsi->connector[cci->connector_change - 1]; con 629 drivers/usb/typec/ucsi/ucsi.c schedule_work(&con->work); con 638 drivers/usb/typec/ucsi/ucsi.c static int ucsi_reset_connector(struct ucsi_connector *con, bool hard) con 642 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_CONNECTOR_RESET(ctrl, con, hard); con 644 drivers/usb/typec/ucsi/ucsi.c return ucsi_send_command(con->ucsi, &ctrl, NULL, 0); con 694 drivers/usb/typec/ucsi/ucsi.c static int ucsi_role_cmd(struct ucsi_connector *con, struct ucsi_control *ctrl) con 698 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_send_command(con->ucsi, ctrl, NULL, 0); con 703 drivers/usb/typec/ucsi/ucsi.c mutex_lock(&con->ucsi->ppm_lock); con 704 drivers/usb/typec/ucsi/ucsi.c ucsi_reset_ppm(con->ucsi); con 705 drivers/usb/typec/ucsi/ucsi.c mutex_unlock(&con->ucsi->ppm_lock); con 708 drivers/usb/typec/ucsi/ucsi.c ucsi_send_command(con->ucsi, &c, NULL, 0); con 710 drivers/usb/typec/ucsi/ucsi.c ucsi_reset_connector(con, true); con 719 drivers/usb/typec/ucsi/ucsi.c struct ucsi_connector *con = to_ucsi_connector(cap); con 723 drivers/usb/typec/ucsi/ucsi.c mutex_lock(&con->lock); con 725 drivers/usb/typec/ucsi/ucsi.c if (!con->partner) { con 730 drivers/usb/typec/ucsi/ucsi.c if ((con->status.partner_type == UCSI_CONSTAT_PARTNER_TYPE_DFP && con 732 drivers/usb/typec/ucsi/ucsi.c (con->status.partner_type == UCSI_CONSTAT_PARTNER_TYPE_UFP && con 736 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_SET_UOR(ctrl, con, role); con 737 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_role_cmd(con, &ctrl); con 741 drivers/usb/typec/ucsi/ucsi.c if (!wait_for_completion_timeout(&con->complete, con 746 drivers/usb/typec/ucsi/ucsi.c mutex_unlock(&con->lock); con 754 drivers/usb/typec/ucsi/ucsi.c struct ucsi_connector *con = to_ucsi_connector(cap); con 758 drivers/usb/typec/ucsi/ucsi.c mutex_lock(&con->lock); con 760 drivers/usb/typec/ucsi/ucsi.c if (!con->partner) { con 765 drivers/usb/typec/ucsi/ucsi.c if (con->status.pwr_dir == role) con 768 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_SET_PDR(ctrl, con, role); con 769 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_role_cmd(con, &ctrl); con 773 drivers/usb/typec/ucsi/ucsi.c if (!wait_for_completion_timeout(&con->complete, con 780 drivers/usb/typec/ucsi/ucsi.c if (con->status.pwr_op_mode != UCSI_CONSTAT_PWR_OPMODE_PD) { con 781 drivers/usb/typec/ucsi/ucsi.c ucsi_reset_connector(con, true); con 786 drivers/usb/typec/ucsi/ucsi.c mutex_unlock(&con->lock); con 791 drivers/usb/typec/ucsi/ucsi.c static struct fwnode_handle *ucsi_find_fwnode(struct ucsi_connector *con) con 796 drivers/usb/typec/ucsi/ucsi.c device_for_each_child_node(con->ucsi->dev, fwnode) con 797 drivers/usb/typec/ucsi/ucsi.c if (i++ == con->num) con 804 drivers/usb/typec/ucsi/ucsi.c struct ucsi_connector *con = &ucsi->connector[index]; con 805 drivers/usb/typec/ucsi/ucsi.c struct typec_capability *cap = &con->typec_cap; con 810 drivers/usb/typec/ucsi/ucsi.c INIT_WORK(&con->work, ucsi_connector_change); con 811 drivers/usb/typec/ucsi/ucsi.c init_completion(&con->complete); con 812 drivers/usb/typec/ucsi/ucsi.c mutex_init(&con->lock); con 813 drivers/usb/typec/ucsi/ucsi.c con->num = index + 1; con 814 drivers/usb/typec/ucsi/ucsi.c con->ucsi = ucsi; con 817 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_GET_CONNECTOR_CAPABILITY(ctrl, con->num); con 818 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_run_command(ucsi, &ctrl, &con->cap, sizeof(con->cap)); con 822 drivers/usb/typec/ucsi/ucsi.c if (con->cap.op_mode & UCSI_CONCAP_OPMODE_DRP) con 824 drivers/usb/typec/ucsi/ucsi.c else if (con->cap.op_mode & UCSI_CONCAP_OPMODE_DFP) con 826 drivers/usb/typec/ucsi/ucsi.c else if (con->cap.op_mode & UCSI_CONCAP_OPMODE_UFP) con 829 drivers/usb/typec/ucsi/ucsi.c if (con->cap.provider && con->cap.consumer) con 831 drivers/usb/typec/ucsi/ucsi.c else if (con->cap.provider) con 833 drivers/usb/typec/ucsi/ucsi.c else if (con->cap.consumer) con 840 drivers/usb/typec/ucsi/ucsi.c if (con->cap.op_mode & UCSI_CONCAP_OPMODE_AUDIO_ACCESSORY) con 842 drivers/usb/typec/ucsi/ucsi.c if (con->cap.op_mode & UCSI_CONCAP_OPMODE_DEBUG_ACCESSORY) con 845 drivers/usb/typec/ucsi/ucsi.c cap->fwnode = ucsi_find_fwnode(con); con 850 drivers/usb/typec/ucsi/ucsi.c con->port = typec_register_port(ucsi->dev, cap); con 851 drivers/usb/typec/ucsi/ucsi.c if (IS_ERR(con->port)) con 852 drivers/usb/typec/ucsi/ucsi.c return PTR_ERR(con->port); con 855 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_register_altmodes(con, UCSI_RECIPIENT_CON); con 858 drivers/usb/typec/ucsi/ucsi.c con->num); con 861 drivers/usb/typec/ucsi/ucsi.c UCSI_CMD_GET_CONNECTOR_STATUS(ctrl, con->num); con 862 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_run_command(ucsi, &ctrl, &con->status, sizeof(con->status)); con 864 drivers/usb/typec/ucsi/ucsi.c dev_err(ucsi->dev, "con%d: failed to get status\n", con->num); con 868 drivers/usb/typec/ucsi/ucsi.c ucsi_pwr_opmode_change(con); con 869 drivers/usb/typec/ucsi/ucsi.c typec_set_pwr_role(con->port, con->status.pwr_dir); con 871 drivers/usb/typec/ucsi/ucsi.c switch (con->status.partner_type) { con 873 drivers/usb/typec/ucsi/ucsi.c typec_set_data_role(con->port, TYPEC_HOST); con 876 drivers/usb/typec/ucsi/ucsi.c typec_set_data_role(con->port, TYPEC_DEVICE); con 883 drivers/usb/typec/ucsi/ucsi.c if (con->status.connected) con 884 drivers/usb/typec/ucsi/ucsi.c ucsi_register_partner(con); con 886 drivers/usb/typec/ucsi/ucsi.c if (con->partner) { con 887 drivers/usb/typec/ucsi/ucsi.c ret = ucsi_register_altmodes(con, UCSI_RECIPIENT_SOP); con 891 drivers/usb/typec/ucsi/ucsi.c con->num); con 893 drivers/usb/typec/ucsi/ucsi.c ucsi_altmode_update_active(con); con 896 drivers/usb/typec/ucsi/ucsi.c trace_ucsi_register_port(con->num, &con->status); con 904 drivers/usb/typec/ucsi/ucsi.c struct ucsi_connector *con; con 962 drivers/usb/typec/ucsi/ucsi.c for (con = ucsi->connector; con->port; con++) { con 963 drivers/usb/typec/ucsi/ucsi.c ucsi_unregister_partner(con); con 964 drivers/usb/typec/ucsi/ucsi.c ucsi_unregister_altmodes(con, UCSI_RECIPIENT_CON); con 965 drivers/usb/typec/ucsi/ucsi.c typec_unregister_port(con->port); con 966 drivers/usb/typec/ucsi/ucsi.c con->port = NULL; con 432 drivers/usb/typec/ucsi/ucsi.h void ucsi_altmode_update_active(struct ucsi_connector *con); con 437 drivers/usb/typec/ucsi/ucsi.h ucsi_register_displayport(struct ucsi_connector *con, con 445 drivers/usb/typec/ucsi/ucsi.h ucsi_register_displayport(struct ucsi_connector *con, con 139 drivers/video/console/dummycon.c static int dummycon_font_copy(struct vc_data *vc, int con) con 2616 drivers/video/fbdev/core/fbcon.c static int fbcon_copy_font(struct vc_data *vc, int con) con 2618 drivers/video/fbdev/core/fbcon.c struct fbcon_display *od = &fb_display[con]; con 480 drivers/video/fbdev/sa1100fb.c sa1100fb_set_cmap(struct fb_cmap *cmap, int kspc, int con, con 491 drivers/video/fbdev/sa1100fb.c return gen_set_cmap(cmap, kspc, con, info); con 63 drivers/video/fbdev/sis/sis_main.c static int sisfb_get_fix(struct fb_fix_screeninfo *fix, int con, con 1869 drivers/video/fbdev/sis/sis_main.c sisfb_get_fix(struct fb_fix_screeninfo *fix, int con, struct fb_info *info) con 4598 fs/ceph/mds_client.c static struct ceph_connection *con_get(struct ceph_connection *con) con 4600 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4604 fs/ceph/mds_client.c return con; con 4610 fs/ceph/mds_client.c static void con_put(struct ceph_connection *con) con 4612 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4622 fs/ceph/mds_client.c static void peer_reset(struct ceph_connection *con) con 4624 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4631 fs/ceph/mds_client.c static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) con 4633 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4689 fs/ceph/mds_client.c static struct ceph_auth_handshake *get_authorizer(struct ceph_connection *con, con 4692 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4717 fs/ceph/mds_client.c static int add_authorizer_challenge(struct ceph_connection *con, con 4720 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4728 fs/ceph/mds_client.c static int verify_authorizer_reply(struct ceph_connection *con) con 4730 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4737 fs/ceph/mds_client.c static int invalidate_authorizer(struct ceph_connection *con) con 4739 fs/ceph/mds_client.c struct ceph_mds_session *s = con->private; con 4748 fs/ceph/mds_client.c static struct ceph_msg *mds_alloc_msg(struct ceph_connection *con, con 4755 fs/ceph/mds_client.c if (con->in_msg) con 4756 fs/ceph/mds_client.c return con->in_msg; con 4771 fs/ceph/mds_client.c struct ceph_mds_session *s = msg->con->private; con 4779 fs/ceph/mds_client.c struct ceph_mds_session *s = msg->con->private; con 157 fs/cifs/asn1.c unsigned int *cls, unsigned int *con, unsigned int *tag) con 165 fs/cifs/asn1.c *con = (ch & 0x20) >> 5; con 214 fs/cifs/asn1.c unsigned int *cls, unsigned int *con, unsigned int *tag) con 219 fs/cifs/asn1.c if (!asn1_id_decode(ctx, cls, con, tag)) con 226 fs/cifs/asn1.c if (*con == ASN1_PRI && !def) con 490 fs/cifs/asn1.c unsigned int cls, con, tag, oidlen, rc; con 497 fs/cifs/asn1.c if (asn1_header_decode(&ctx, &end, &cls, &con, &tag) == 0) { con 500 fs/cifs/asn1.c } else if ((cls != ASN1_APL) || (con != ASN1_CON) con 502 fs/cifs/asn1.c cifs_dbg(FYI, "cls = %d con = %d tag = %d\n", cls, con, tag); con 507 fs/cifs/asn1.c rc = asn1_header_decode(&ctx, &end, &cls, &con, &tag); con 509 fs/cifs/asn1.c if ((tag == ASN1_OJI) && (con == ASN1_PRI) && con 528 fs/cifs/asn1.c if (asn1_header_decode(&ctx, &end, &cls, &con, &tag) == 0) { con 531 fs/cifs/asn1.c } else if ((cls != ASN1_CTX) || (con != ASN1_CON) con 534 fs/cifs/asn1.c cls, con, tag, end, *end); con 539 fs/cifs/asn1.c if (asn1_header_decode(&ctx, &end, &cls, &con, &tag) == 0) { con 542 fs/cifs/asn1.c } else if ((cls != ASN1_UNI) || (con != ASN1_CON) con 545 fs/cifs/asn1.c cls, con, tag, end, *end); con 550 fs/cifs/asn1.c if (asn1_header_decode(&ctx, &end, &cls, &con, &tag) == 0) { con 553 fs/cifs/asn1.c } else if ((cls != ASN1_CTX) || (con != ASN1_CON) con 556 fs/cifs/asn1.c cls, con, tag, end, *end); con 562 fs/cifs/asn1.c (&ctx, &sequence_end, &cls, &con, &tag) == 0) { con 565 fs/cifs/asn1.c } else if ((cls != ASN1_UNI) || (con != ASN1_CON) con 568 fs/cifs/asn1.c cls, con, tag, end, *end); con 574 fs/cifs/asn1.c rc = asn1_header_decode(&ctx, &end, &cls, &con, &tag); con 579 fs/cifs/asn1.c if ((tag == ASN1_OJI) && (con == ASN1_PRI)) { con 136 fs/dlm/lowcomms.c struct connection *con; con 184 fs/dlm/lowcomms.c struct connection *con; con 188 fs/dlm/lowcomms.c hlist_for_each_entry(con, &connection_hash[r], list) { con 189 fs/dlm/lowcomms.c if (con->nodeid == nodeid) con 190 fs/dlm/lowcomms.c return con; con 201 fs/dlm/lowcomms.c struct connection *con = NULL; con 204 fs/dlm/lowcomms.c con = __find_con(nodeid); con 205 fs/dlm/lowcomms.c if (con || !alloc) con 206 fs/dlm/lowcomms.c return con; con 208 fs/dlm/lowcomms.c con = kmem_cache_zalloc(con_cache, alloc); con 209 fs/dlm/lowcomms.c if (!con) con 213 fs/dlm/lowcomms.c hlist_add_head(&con->list, &connection_hash[r]); con 215 fs/dlm/lowcomms.c con->nodeid = nodeid; con 216 fs/dlm/lowcomms.c mutex_init(&con->sock_mutex); con 217 fs/dlm/lowcomms.c INIT_LIST_HEAD(&con->writequeue); con 218 fs/dlm/lowcomms.c spin_lock_init(&con->writequeue_lock); con 219 fs/dlm/lowcomms.c INIT_WORK(&con->swork, process_send_sockets); con 220 fs/dlm/lowcomms.c INIT_WORK(&con->rwork, process_recv_sockets); con 223 fs/dlm/lowcomms.c if (con->nodeid) { con 226 fs/dlm/lowcomms.c con->connect_action = zerocon->connect_action; con 227 fs/dlm/lowcomms.c if (!con->rx_action) con 228 fs/dlm/lowcomms.c con->rx_action = zerocon->rx_action; con 231 fs/dlm/lowcomms.c return con; con 239 fs/dlm/lowcomms.c struct connection *con; con 242 fs/dlm/lowcomms.c hlist_for_each_entry_safe(con, n, &connection_hash[i], list) con 243 fs/dlm/lowcomms.c conn_func(con); con 249 fs/dlm/lowcomms.c struct connection *con; con 252 fs/dlm/lowcomms.c con = __nodeid2con(nodeid, allocation); con 255 fs/dlm/lowcomms.c return con; con 412 fs/dlm/lowcomms.c struct connection *con; con 415 fs/dlm/lowcomms.c con = sock2con(sk); con 416 fs/dlm/lowcomms.c if (con && !test_and_set_bit(CF_READ_PENDING, &con->flags)) con 417 fs/dlm/lowcomms.c queue_work(recv_workqueue, &con->rwork); con 423 fs/dlm/lowcomms.c struct connection *con; con 426 fs/dlm/lowcomms.c con = sock2con(sk); con 427 fs/dlm/lowcomms.c if (!con) con 430 fs/dlm/lowcomms.c clear_bit(SOCK_NOSPACE, &con->sock->flags); con 432 fs/dlm/lowcomms.c if (test_and_clear_bit(CF_APP_LIMITED, &con->flags)) { con 433 fs/dlm/lowcomms.c con->sock->sk->sk_write_pending--; con 434 fs/dlm/lowcomms.c clear_bit(SOCKWQ_ASYNC_NOSPACE, &con->sock->flags); con 437 fs/dlm/lowcomms.c queue_work(send_workqueue, &con->swork); con 442 fs/dlm/lowcomms.c static inline void lowcomms_connect_sock(struct connection *con) con 444 fs/dlm/lowcomms.c if (test_bit(CF_CLOSE, &con->flags)) con 446 fs/dlm/lowcomms.c queue_work(send_workqueue, &con->swork); con 467 fs/dlm/lowcomms.c struct connection *con; con 472 fs/dlm/lowcomms.c con = nodeid2con(nodeid, GFP_NOFS); con 473 fs/dlm/lowcomms.c if (!con) con 475 fs/dlm/lowcomms.c lowcomms_connect_sock(con); con 481 fs/dlm/lowcomms.c struct connection *con; con 486 fs/dlm/lowcomms.c con = sock2con(sk); con 487 fs/dlm/lowcomms.c if (con == NULL) con 491 fs/dlm/lowcomms.c if (con->sock == NULL || con 492 fs/dlm/lowcomms.c kernel_getpeername(con->sock, (struct sockaddr *)&saddr) < 0) { con 496 fs/dlm/lowcomms.c con->nodeid, dlm_config.ci_tcp_port, con 504 fs/dlm/lowcomms.c con->nodeid, &sin4->sin_addr.s_addr, con 513 fs/dlm/lowcomms.c con->nodeid, sin6->sin6_addr.s6_addr32[0], con 551 fs/dlm/lowcomms.c static void add_sock(struct socket *sock, struct connection *con) con 556 fs/dlm/lowcomms.c con->sock = sock; con 558 fs/dlm/lowcomms.c sk->sk_user_data = con; con 588 fs/dlm/lowcomms.c static void close_connection(struct connection *con, bool and_other, con 591 fs/dlm/lowcomms.c bool closing = test_and_set_bit(CF_CLOSING, &con->flags); con 593 fs/dlm/lowcomms.c if (tx && !closing && cancel_work_sync(&con->swork)) { con 594 fs/dlm/lowcomms.c log_print("canceled swork for node %d", con->nodeid); con 595 fs/dlm/lowcomms.c clear_bit(CF_WRITE_PENDING, &con->flags); con 597 fs/dlm/lowcomms.c if (rx && !closing && cancel_work_sync(&con->rwork)) { con 598 fs/dlm/lowcomms.c log_print("canceled rwork for node %d", con->nodeid); con 599 fs/dlm/lowcomms.c clear_bit(CF_READ_PENDING, &con->flags); con 602 fs/dlm/lowcomms.c mutex_lock(&con->sock_mutex); con 603 fs/dlm/lowcomms.c if (con->sock) { con 604 fs/dlm/lowcomms.c restore_callbacks(con->sock); con 605 fs/dlm/lowcomms.c sock_release(con->sock); con 606 fs/dlm/lowcomms.c con->sock = NULL; con 608 fs/dlm/lowcomms.c if (con->othercon && and_other) { con 610 fs/dlm/lowcomms.c close_connection(con->othercon, false, true, true); con 612 fs/dlm/lowcomms.c if (con->rx_page) { con 613 fs/dlm/lowcomms.c __free_page(con->rx_page); con 614 fs/dlm/lowcomms.c con->rx_page = NULL; con 617 fs/dlm/lowcomms.c con->retries = 0; con 618 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 619 fs/dlm/lowcomms.c clear_bit(CF_CLOSING, &con->flags); con 623 fs/dlm/lowcomms.c static int receive_from_sock(struct connection *con) con 633 fs/dlm/lowcomms.c mutex_lock(&con->sock_mutex); con 635 fs/dlm/lowcomms.c if (con->sock == NULL) { con 639 fs/dlm/lowcomms.c if (con->nodeid == 0) { con 644 fs/dlm/lowcomms.c if (con->rx_page == NULL) { con 649 fs/dlm/lowcomms.c con->rx_page = alloc_page(GFP_ATOMIC); con 650 fs/dlm/lowcomms.c if (con->rx_page == NULL) con 652 fs/dlm/lowcomms.c cbuf_init(&con->cb, PAGE_SIZE); con 659 fs/dlm/lowcomms.c iov[0].iov_len = con->cb.base - cbuf_data(&con->cb); con 660 fs/dlm/lowcomms.c iov[0].iov_base = page_address(con->rx_page) + cbuf_data(&con->cb); con 668 fs/dlm/lowcomms.c if (cbuf_data(&con->cb) >= con->cb.base) { con 669 fs/dlm/lowcomms.c iov[0].iov_len = PAGE_SIZE - cbuf_data(&con->cb); con 670 fs/dlm/lowcomms.c iov[1].iov_len = con->cb.base; con 671 fs/dlm/lowcomms.c iov[1].iov_base = page_address(con->rx_page); con 677 fs/dlm/lowcomms.c r = ret = sock_recvmsg(con->sock, &msg, MSG_DONTWAIT | MSG_NOSIGNAL); con 683 fs/dlm/lowcomms.c cbuf_add(&con->cb, ret); con 684 fs/dlm/lowcomms.c ret = dlm_process_incoming_buffer(con->nodeid, con 685 fs/dlm/lowcomms.c page_address(con->rx_page), con 686 fs/dlm/lowcomms.c con->cb.base, con->cb.len, con 690 fs/dlm/lowcomms.c page_address(con->rx_page), con->cb.base, con 691 fs/dlm/lowcomms.c con->cb.len, r); con 695 fs/dlm/lowcomms.c cbuf_eat(&con->cb, ret); con 697 fs/dlm/lowcomms.c if (cbuf_empty(&con->cb) && !call_again_soon) { con 698 fs/dlm/lowcomms.c __free_page(con->rx_page); con 699 fs/dlm/lowcomms.c con->rx_page = NULL; con 704 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 708 fs/dlm/lowcomms.c if (!test_and_set_bit(CF_READ_PENDING, &con->flags)) con 709 fs/dlm/lowcomms.c queue_work(recv_workqueue, &con->rwork); con 710 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 714 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 716 fs/dlm/lowcomms.c close_connection(con, true, true, false); con 727 fs/dlm/lowcomms.c static int tcp_accept_from_sock(struct connection *con) con 744 fs/dlm/lowcomms.c mutex_lock_nested(&con->sock_mutex, 0); con 746 fs/dlm/lowcomms.c if (!con->sock) { con 747 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 751 fs/dlm/lowcomms.c result = kernel_accept(con->sock, &newsock, O_NONBLOCK); con 771 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 841 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 846 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 855 fs/dlm/lowcomms.c static int sctp_accept_from_sock(struct connection *con) con 873 fs/dlm/lowcomms.c mutex_lock_nested(&con->sock_mutex, 0); con 875 fs/dlm/lowcomms.c ret = kernel_accept(con->sock, &newsock, O_NONBLOCK); con 958 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 963 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 999 fs/dlm/lowcomms.c static int sctp_bind_addrs(struct connection *con, uint16_t port) con 1009 fs/dlm/lowcomms.c result = kernel_bind(con->sock, con 1013 fs/dlm/lowcomms.c result = kernel_setsockopt(con->sock, SOL_SCTP, con 1031 fs/dlm/lowcomms.c static void sctp_connect_to_sock(struct connection *con) con 1040 fs/dlm/lowcomms.c if (con->nodeid == 0) { con 1045 fs/dlm/lowcomms.c mutex_lock(&con->sock_mutex); con 1048 fs/dlm/lowcomms.c if (con->retries++ > MAX_CONNECT_RETRIES) con 1051 fs/dlm/lowcomms.c if (con->sock) { con 1052 fs/dlm/lowcomms.c log_print("node %d already connected.", con->nodeid); con 1057 fs/dlm/lowcomms.c result = nodeid_to_addr(con->nodeid, &daddr, NULL, true); con 1059 fs/dlm/lowcomms.c log_print("no address for nodeid %d", con->nodeid); con 1069 fs/dlm/lowcomms.c con->rx_action = receive_from_sock; con 1070 fs/dlm/lowcomms.c con->connect_action = sctp_connect_to_sock; con 1071 fs/dlm/lowcomms.c add_sock(sock, con); con 1074 fs/dlm/lowcomms.c if (sctp_bind_addrs(con, 0)) con 1079 fs/dlm/lowcomms.c log_print("connecting to %d", con->nodeid); con 1104 fs/dlm/lowcomms.c con->sock = NULL; con 1117 fs/dlm/lowcomms.c log_print("connect %d try %d error %d", con->nodeid, con 1118 fs/dlm/lowcomms.c con->retries, result); con 1119 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1121 fs/dlm/lowcomms.c lowcomms_connect_sock(con); con 1126 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1130 fs/dlm/lowcomms.c static void tcp_connect_to_sock(struct connection *con) con 1138 fs/dlm/lowcomms.c if (con->nodeid == 0) { con 1143 fs/dlm/lowcomms.c mutex_lock(&con->sock_mutex); con 1144 fs/dlm/lowcomms.c if (con->retries++ > MAX_CONNECT_RETRIES) con 1148 fs/dlm/lowcomms.c if (con->sock) con 1158 fs/dlm/lowcomms.c result = nodeid_to_addr(con->nodeid, &saddr, NULL, false); con 1160 fs/dlm/lowcomms.c log_print("no address for nodeid %d", con->nodeid); con 1164 fs/dlm/lowcomms.c con->rx_action = receive_from_sock; con 1165 fs/dlm/lowcomms.c con->connect_action = tcp_connect_to_sock; con 1166 fs/dlm/lowcomms.c add_sock(sock, con); con 1181 fs/dlm/lowcomms.c log_print("connecting to %d", con->nodeid); con 1195 fs/dlm/lowcomms.c if (con->sock) { con 1196 fs/dlm/lowcomms.c sock_release(con->sock); con 1197 fs/dlm/lowcomms.c con->sock = NULL; con 1210 fs/dlm/lowcomms.c log_print("connect %d try %d error %d", con->nodeid, con 1211 fs/dlm/lowcomms.c con->retries, result); con 1212 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1214 fs/dlm/lowcomms.c lowcomms_connect_sock(con); con 1218 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1222 fs/dlm/lowcomms.c static struct socket *tcp_create_listen_sock(struct connection *con, con 1254 fs/dlm/lowcomms.c sock->sk->sk_user_data = con; con 1256 fs/dlm/lowcomms.c con->rx_action = tcp_accept_from_sock; con 1257 fs/dlm/lowcomms.c con->connect_action = tcp_connect_to_sock; con 1267 fs/dlm/lowcomms.c con->sock = NULL; con 1311 fs/dlm/lowcomms.c struct connection *con = nodeid2con(0, GFP_NOFS); con 1315 fs/dlm/lowcomms.c if (!con) con 1339 fs/dlm/lowcomms.c sock->sk->sk_user_data = con; con 1341 fs/dlm/lowcomms.c con->sock = sock; con 1342 fs/dlm/lowcomms.c con->sock->sk->sk_data_ready = lowcomms_data_ready; con 1343 fs/dlm/lowcomms.c con->rx_action = sctp_accept_from_sock; con 1344 fs/dlm/lowcomms.c con->connect_action = sctp_connect_to_sock; con 1349 fs/dlm/lowcomms.c if (sctp_bind_addrs(con, dlm_config.ci_tcp_port)) con 1362 fs/dlm/lowcomms.c con->sock = NULL; con 1370 fs/dlm/lowcomms.c struct connection *con = nodeid2con(0, GFP_NOFS); con 1373 fs/dlm/lowcomms.c if (!con) con 1385 fs/dlm/lowcomms.c sock = tcp_create_listen_sock(con, dlm_local_addr[0]); con 1387 fs/dlm/lowcomms.c add_sock(sock, con); con 1399 fs/dlm/lowcomms.c static struct writequeue_entry *new_writequeue_entry(struct connection *con, con 1418 fs/dlm/lowcomms.c entry->con = con; con 1425 fs/dlm/lowcomms.c struct connection *con; con 1429 fs/dlm/lowcomms.c con = nodeid2con(nodeid, allocation); con 1430 fs/dlm/lowcomms.c if (!con) con 1433 fs/dlm/lowcomms.c spin_lock(&con->writequeue_lock); con 1434 fs/dlm/lowcomms.c e = list_entry(con->writequeue.prev, struct writequeue_entry, list); con 1435 fs/dlm/lowcomms.c if ((&e->list == &con->writequeue) || con 1443 fs/dlm/lowcomms.c spin_unlock(&con->writequeue_lock); con 1451 fs/dlm/lowcomms.c e = new_writequeue_entry(con, allocation); con 1453 fs/dlm/lowcomms.c spin_lock(&con->writequeue_lock); con 1457 fs/dlm/lowcomms.c list_add_tail(&e->list, &con->writequeue); con 1458 fs/dlm/lowcomms.c spin_unlock(&con->writequeue_lock); con 1467 fs/dlm/lowcomms.c struct connection *con = e->con; con 1470 fs/dlm/lowcomms.c spin_lock(&con->writequeue_lock); con 1475 fs/dlm/lowcomms.c spin_unlock(&con->writequeue_lock); con 1477 fs/dlm/lowcomms.c queue_work(send_workqueue, &con->swork); con 1481 fs/dlm/lowcomms.c spin_unlock(&con->writequeue_lock); con 1486 fs/dlm/lowcomms.c static void send_to_sock(struct connection *con) con 1494 fs/dlm/lowcomms.c mutex_lock(&con->sock_mutex); con 1495 fs/dlm/lowcomms.c if (con->sock == NULL) con 1498 fs/dlm/lowcomms.c spin_lock(&con->writequeue_lock); con 1500 fs/dlm/lowcomms.c e = list_entry(con->writequeue.next, struct writequeue_entry, con 1502 fs/dlm/lowcomms.c if ((struct list_head *) e == &con->writequeue) con 1508 fs/dlm/lowcomms.c spin_unlock(&con->writequeue_lock); con 1512 fs/dlm/lowcomms.c ret = kernel_sendpage(con->sock, e->page, offset, len, con 1516 fs/dlm/lowcomms.c test_bit(SOCKWQ_ASYNC_NOSPACE, &con->sock->flags) && con 1517 fs/dlm/lowcomms.c !test_and_set_bit(CF_APP_LIMITED, &con->flags)) { con 1521 fs/dlm/lowcomms.c set_bit(SOCK_NOSPACE, &con->sock->flags); con 1522 fs/dlm/lowcomms.c con->sock->sk->sk_write_pending++; con 1536 fs/dlm/lowcomms.c spin_lock(&con->writequeue_lock); con 1539 fs/dlm/lowcomms.c spin_unlock(&con->writequeue_lock); con 1541 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1545 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1546 fs/dlm/lowcomms.c close_connection(con, true, false, true); con 1549 fs/dlm/lowcomms.c queue_work(send_workqueue, &con->swork); con 1553 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1554 fs/dlm/lowcomms.c queue_work(send_workqueue, &con->swork); con 1558 fs/dlm/lowcomms.c static void clean_one_writequeue(struct connection *con) con 1562 fs/dlm/lowcomms.c spin_lock(&con->writequeue_lock); con 1563 fs/dlm/lowcomms.c list_for_each_entry_safe(e, safe, &con->writequeue, list) { con 1567 fs/dlm/lowcomms.c spin_unlock(&con->writequeue_lock); con 1574 fs/dlm/lowcomms.c struct connection *con; con 1578 fs/dlm/lowcomms.c con = nodeid2con(nodeid, 0); con 1579 fs/dlm/lowcomms.c if (con) { con 1580 fs/dlm/lowcomms.c set_bit(CF_CLOSE, &con->flags); con 1581 fs/dlm/lowcomms.c close_connection(con, true, true, true); con 1582 fs/dlm/lowcomms.c clean_one_writequeue(con); con 1601 fs/dlm/lowcomms.c struct connection *con = container_of(work, struct connection, rwork); con 1604 fs/dlm/lowcomms.c clear_bit(CF_READ_PENDING, &con->flags); con 1606 fs/dlm/lowcomms.c err = con->rx_action(con); con 1613 fs/dlm/lowcomms.c struct connection *con = container_of(work, struct connection, swork); con 1615 fs/dlm/lowcomms.c clear_bit(CF_WRITE_PENDING, &con->flags); con 1616 fs/dlm/lowcomms.c if (con->sock == NULL) /* not mutex protected so check it inside too */ con 1617 fs/dlm/lowcomms.c con->connect_action(con); con 1618 fs/dlm/lowcomms.c if (!list_empty(&con->writequeue)) con 1619 fs/dlm/lowcomms.c send_to_sock(con); con 1657 fs/dlm/lowcomms.c static void _stop_conn(struct connection *con, bool and_other) con 1659 fs/dlm/lowcomms.c mutex_lock(&con->sock_mutex); con 1660 fs/dlm/lowcomms.c set_bit(CF_CLOSE, &con->flags); con 1661 fs/dlm/lowcomms.c set_bit(CF_READ_PENDING, &con->flags); con 1662 fs/dlm/lowcomms.c set_bit(CF_WRITE_PENDING, &con->flags); con 1663 fs/dlm/lowcomms.c if (con->sock && con->sock->sk) { con 1664 fs/dlm/lowcomms.c write_lock_bh(&con->sock->sk->sk_callback_lock); con 1665 fs/dlm/lowcomms.c con->sock->sk->sk_user_data = NULL; con 1666 fs/dlm/lowcomms.c write_unlock_bh(&con->sock->sk->sk_callback_lock); con 1668 fs/dlm/lowcomms.c if (con->othercon && and_other) con 1669 fs/dlm/lowcomms.c _stop_conn(con->othercon, false); con 1670 fs/dlm/lowcomms.c mutex_unlock(&con->sock_mutex); con 1673 fs/dlm/lowcomms.c static void stop_conn(struct connection *con) con 1675 fs/dlm/lowcomms.c _stop_conn(con, true); con 1678 fs/dlm/lowcomms.c static void free_conn(struct connection *con) con 1680 fs/dlm/lowcomms.c close_connection(con, true, true, true); con 1681 fs/dlm/lowcomms.c if (con->othercon) con 1682 fs/dlm/lowcomms.c kmem_cache_free(con_cache, con->othercon); con 1683 fs/dlm/lowcomms.c hlist_del(&con->list); con 1684 fs/dlm/lowcomms.c kmem_cache_free(con_cache, con); con 1692 fs/dlm/lowcomms.c struct connection *con; con 1706 fs/dlm/lowcomms.c hlist_for_each_entry_safe(con, n, con 1708 fs/dlm/lowcomms.c ok &= test_bit(CF_READ_PENDING, &con->flags); con 1709 fs/dlm/lowcomms.c ok &= test_bit(CF_WRITE_PENDING, &con->flags); con 1710 fs/dlm/lowcomms.c if (con->othercon) { con 1712 fs/dlm/lowcomms.c &con->othercon->flags); con 1714 fs/dlm/lowcomms.c &con->othercon->flags); con 1740 fs/dlm/lowcomms.c struct connection *con; con 1778 fs/dlm/lowcomms.c con = nodeid2con(0,0); con 1779 fs/dlm/lowcomms.c if (con) { con 1780 fs/dlm/lowcomms.c close_connection(con, false, true, true); con 1781 fs/dlm/lowcomms.c kmem_cache_free(con_cache, con); con 29 fs/proc/consoles.c struct console *con = v; con 33 fs/proc/consoles.c if (con->device) { con 36 fs/proc/consoles.c driver = con->device(con, &index); con 44 fs/proc/consoles.c flags[a] = (con->flags & con_flags[a].flag) ? con 49 fs/proc/consoles.c seq_printf(m, "%s%d", con->name, con->index); con 51 fs/proc/consoles.c seq_printf(m, "%c%c%c (%s)", con->read ? 'R' : '-', con 52 fs/proc/consoles.c con->write ? 'W' : '-', con->unblank ? 'U' : '-', con 63 fs/proc/consoles.c struct console *con; con 67 fs/proc/consoles.c for_each_console(con) con 71 fs/proc/consoles.c return con; con 76 fs/proc/consoles.c struct console *con = v; con 78 fs/proc/consoles.c return con->next; con 490 fs/pstore/platform.c static void pstore_console_write(struct console *con, const char *s, unsigned c) con 28 include/linux/ceph/messenger.h void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m); con 32 include/linux/ceph/messenger.h struct ceph_connection *con, con 34 include/linux/ceph/messenger.h int (*add_authorizer_challenge)(struct ceph_connection *con, con 37 include/linux/ceph/messenger.h int (*verify_authorizer_reply) (struct ceph_connection *con); con 38 include/linux/ceph/messenger.h int (*invalidate_authorizer)(struct ceph_connection *con); con 41 include/linux/ceph/messenger.h void (*fault) (struct ceph_connection *con); con 45 include/linux/ceph/messenger.h void (*peer_reset) (struct ceph_connection *con); con 47 include/linux/ceph/messenger.h struct ceph_msg * (*alloc_msg) (struct ceph_connection *con, con 231 include/linux/ceph/messenger.h struct ceph_connection *con; con 343 include/linux/ceph/messenger.h extern void ceph_con_init(struct ceph_connection *con, void *private, con 346 include/linux/ceph/messenger.h extern void ceph_con_open(struct ceph_connection *con, con 349 include/linux/ceph/messenger.h extern bool ceph_con_opened(struct ceph_connection *con); con 350 include/linux/ceph/messenger.h extern void ceph_con_close(struct ceph_connection *con); con 351 include/linux/ceph/messenger.h extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg); con 356 include/linux/ceph/messenger.h extern void ceph_con_keepalive(struct ceph_connection *con); con 357 include/linux/ceph/messenger.h extern bool ceph_con_keepalive_expired(struct ceph_connection *con, con 85 include/linux/ceph/mon_client.h struct ceph_connection con; con 69 include/linux/console.h int (*con_font_copy)(struct vc_data *vc, int con); con 163 include/linux/console.h #define for_each_console(con) \ con 164 include/linux/console.h for (con = console_drivers; con != NULL; con = con->next) con 1017 include/linux/device.h typedef void *(*devcon_match_fn_t)(struct device_connection *con, int ep, con 1028 include/linux/device.h void device_connection_add(struct device_connection *con); con 1029 include/linux/device.h void device_connection_remove(struct device_connection *con); con 344 include/linux/serial_core.h struct console *con; con 32 include/linux/usb/audio.h int (*set)(struct usb_audio_control *con, u8 cmd, int value); con 33 include/linux/usb/audio.h int (*get)(struct usb_audio_control *con, u8 cmd); con 781 kernel/events/uprobes.c struct uprobe_consumer **con; con 785 kernel/events/uprobes.c for (con = &uprobe->consumers; *con; con = &(*con)->next) { con 786 kernel/events/uprobes.c if (*con == uc) { con 787 kernel/events/uprobes.c *con = uc->next; con 1226 kernel/events/uprobes.c struct uprobe_consumer *con; con 1234 kernel/events/uprobes.c for (con = uprobe->consumers; con && con != uc ; con = con->next) con 1236 kernel/events/uprobes.c if (con) con 1799 kernel/printk/printk.c struct console *con; con 1806 kernel/printk/printk.c for_each_console(con) { con 1807 kernel/printk/printk.c if (exclusive_console && con != exclusive_console) con 1809 kernel/printk/printk.c if (!(con->flags & CON_ENABLED)) con 1811 kernel/printk/printk.c if (!con->write) con 1814 kernel/printk/printk.c !(con->flags & CON_ANYTIME)) con 1816 kernel/printk/printk.c if (con->flags & CON_EXTENDED) con 1817 kernel/printk/printk.c con->write(con, ext_text, ext_len); con 1819 kernel/printk/printk.c con->write(con, text, len); con 2359 kernel/printk/printk.c struct console *con; con 2361 kernel/printk/printk.c for_each_console(con) con 2362 kernel/printk/printk.c if ((con->flags & CON_ENABLED) && con 2363 kernel/printk/printk.c (con->flags & CON_ANYTIME)) con 2934 kernel/printk/printk.c struct console *con; con 2937 kernel/printk/printk.c for_each_console(con) { con 2938 kernel/printk/printk.c if (!(con->flags & CON_BOOT)) con 2942 kernel/printk/printk.c if (init_section_intersects(con, sizeof(*con)) || con 2943 kernel/printk/printk.c init_section_contains(con->write, 0) || con 2944 kernel/printk/printk.c init_section_contains(con->read, 0) || con 2945 kernel/printk/printk.c init_section_contains(con->device, 0) || con 2946 kernel/printk/printk.c init_section_contains(con->unblank, 0) || con 2947 kernel/printk/printk.c init_section_contains(con->data, 0)) { con 2953 kernel/printk/printk.c con->name, con->index); con 2954 kernel/printk/printk.c unregister_console(con); con 98 kernel/trace/trace_uprobe.c static int uprobe_dispatcher(struct uprobe_consumer *con, struct pt_regs *regs); con 99 kernel/trace/trace_uprobe.c static int uretprobe_dispatcher(struct uprobe_consumer *con, con 1455 kernel/trace/trace_uprobe.c static int uprobe_dispatcher(struct uprobe_consumer *con, struct pt_regs *regs) con 1464 kernel/trace/trace_uprobe.c tu = container_of(con, struct trace_uprobe, consumer); con 1492 kernel/trace/trace_uprobe.c static int uretprobe_dispatcher(struct uprobe_consumer *con, con 1500 kernel/trace/trace_uprobe.c tu = container_of(con, struct trace_uprobe, consumer); con 811 net/ceph/auth_x.c if (!CEPH_HAVE_FEATURE(msg->con->peer_features, CEPHX_V2)) { con 876 net/ceph/auth_x.c if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) con 895 net/ceph/auth_x.c if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) con 119 net/ceph/messenger.c static void con_flag_clear(struct ceph_connection *con, unsigned long con_flag) con 123 net/ceph/messenger.c clear_bit(con_flag, &con->flags); con 126 net/ceph/messenger.c static void con_flag_set(struct ceph_connection *con, unsigned long con_flag) con 130 net/ceph/messenger.c set_bit(con_flag, &con->flags); con 133 net/ceph/messenger.c static bool con_flag_test(struct ceph_connection *con, unsigned long con_flag) con 137 net/ceph/messenger.c return test_bit(con_flag, &con->flags); con 140 net/ceph/messenger.c static bool con_flag_test_and_clear(struct ceph_connection *con, con 145 net/ceph/messenger.c return test_and_clear_bit(con_flag, &con->flags); con 148 net/ceph/messenger.c static bool con_flag_test_and_set(struct ceph_connection *con, con 153 net/ceph/messenger.c return test_and_set_bit(con_flag, &con->flags); con 170 net/ceph/messenger.c static void queue_con(struct ceph_connection *con); con 171 net/ceph/messenger.c static void cancel_con(struct ceph_connection *con); con 173 net/ceph/messenger.c static void con_fault(struct ceph_connection *con); con 302 net/ceph/messenger.c static void con_sock_state_init(struct ceph_connection *con) con 306 net/ceph/messenger.c old_state = atomic_xchg(&con->sock_state, CON_SOCK_STATE_CLOSED); con 309 net/ceph/messenger.c dout("%s con %p sock %d -> %d\n", __func__, con, old_state, con 313 net/ceph/messenger.c static void con_sock_state_connecting(struct ceph_connection *con) con 317 net/ceph/messenger.c old_state = atomic_xchg(&con->sock_state, CON_SOCK_STATE_CONNECTING); con 320 net/ceph/messenger.c dout("%s con %p sock %d -> %d\n", __func__, con, old_state, con 324 net/ceph/messenger.c static void con_sock_state_connected(struct ceph_connection *con) con 328 net/ceph/messenger.c old_state = atomic_xchg(&con->sock_state, CON_SOCK_STATE_CONNECTED); con 331 net/ceph/messenger.c dout("%s con %p sock %d -> %d\n", __func__, con, old_state, con 335 net/ceph/messenger.c static void con_sock_state_closing(struct ceph_connection *con) con 339 net/ceph/messenger.c old_state = atomic_xchg(&con->sock_state, CON_SOCK_STATE_CLOSING); con 344 net/ceph/messenger.c dout("%s con %p sock %d -> %d\n", __func__, con, old_state, con 348 net/ceph/messenger.c static void con_sock_state_closed(struct ceph_connection *con) con 352 net/ceph/messenger.c old_state = atomic_xchg(&con->sock_state, CON_SOCK_STATE_CLOSED); con 358 net/ceph/messenger.c dout("%s con %p sock %d -> %d\n", __func__, con, old_state, con 369 net/ceph/messenger.c struct ceph_connection *con = sk->sk_user_data; con 370 net/ceph/messenger.c if (atomic_read(&con->msgr->stopping)) { con 376 net/ceph/messenger.c con, con->state); con 377 net/ceph/messenger.c queue_con(con); con 384 net/ceph/messenger.c struct ceph_connection *con = sk->sk_user_data; con 393 net/ceph/messenger.c if (con_flag_test(con, CON_FLAG_WRITE_PENDING)) { con 395 net/ceph/messenger.c dout("%s %p queueing write work\n", __func__, con); con 397 net/ceph/messenger.c queue_con(con); con 400 net/ceph/messenger.c dout("%s %p nothing to write\n", __func__, con); con 407 net/ceph/messenger.c struct ceph_connection *con = sk->sk_user_data; con 410 net/ceph/messenger.c con, con->state, sk->sk_state); con 418 net/ceph/messenger.c con_sock_state_closing(con); con 419 net/ceph/messenger.c con_flag_set(con, CON_FLAG_SOCK_CLOSED); con 420 net/ceph/messenger.c queue_con(con); con 424 net/ceph/messenger.c con_sock_state_connected(con); con 425 net/ceph/messenger.c queue_con(con); con 436 net/ceph/messenger.c struct ceph_connection *con) con 439 net/ceph/messenger.c sk->sk_user_data = con; con 453 net/ceph/messenger.c static int ceph_tcp_connect(struct ceph_connection *con) con 455 net/ceph/messenger.c struct sockaddr_storage ss = con->peer_addr.in_addr; /* align */ con 460 net/ceph/messenger.c BUG_ON(con->sock); con 464 net/ceph/messenger.c ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family, con 475 net/ceph/messenger.c set_sock_callbacks(sock, con); con 477 net/ceph/messenger.c dout("connect %s\n", ceph_pr_addr(&con->peer_addr)); con 479 net/ceph/messenger.c con_sock_state_connecting(con); con 484 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), con 488 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), ret); con 493 net/ceph/messenger.c if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY)) { con 503 net/ceph/messenger.c con->sock = sock; con 600 net/ceph/messenger.c static int con_close_socket(struct ceph_connection *con) con 604 net/ceph/messenger.c dout("con_close_socket on %p sock %p\n", con, con->sock); con 605 net/ceph/messenger.c if (con->sock) { con 606 net/ceph/messenger.c rc = con->sock->ops->shutdown(con->sock, SHUT_RDWR); con 607 net/ceph/messenger.c sock_release(con->sock); con 608 net/ceph/messenger.c con->sock = NULL; con 617 net/ceph/messenger.c con_flag_clear(con, CON_FLAG_SOCK_CLOSED); con 619 net/ceph/messenger.c con_sock_state_closed(con); con 642 net/ceph/messenger.c static void reset_connection(struct ceph_connection *con) con 646 net/ceph/messenger.c dout("reset_connection %p\n", con); con 647 net/ceph/messenger.c ceph_msg_remove_list(&con->out_queue); con 648 net/ceph/messenger.c ceph_msg_remove_list(&con->out_sent); con 650 net/ceph/messenger.c if (con->in_msg) { con 651 net/ceph/messenger.c BUG_ON(con->in_msg->con != con); con 652 net/ceph/messenger.c ceph_msg_put(con->in_msg); con 653 net/ceph/messenger.c con->in_msg = NULL; con 656 net/ceph/messenger.c con->connect_seq = 0; con 657 net/ceph/messenger.c con->out_seq = 0; con 658 net/ceph/messenger.c if (con->out_msg) { con 659 net/ceph/messenger.c BUG_ON(con->out_msg->con != con); con 660 net/ceph/messenger.c ceph_msg_put(con->out_msg); con 661 net/ceph/messenger.c con->out_msg = NULL; con 663 net/ceph/messenger.c con->in_seq = 0; con 664 net/ceph/messenger.c con->in_seq_acked = 0; con 666 net/ceph/messenger.c con->out_skip = 0; con 672 net/ceph/messenger.c void ceph_con_close(struct ceph_connection *con) con 674 net/ceph/messenger.c mutex_lock(&con->mutex); con 675 net/ceph/messenger.c dout("con_close %p peer %s\n", con, ceph_pr_addr(&con->peer_addr)); con 676 net/ceph/messenger.c con->state = CON_STATE_CLOSED; con 678 net/ceph/messenger.c con_flag_clear(con, CON_FLAG_LOSSYTX); /* so we retry next connect */ con 679 net/ceph/messenger.c con_flag_clear(con, CON_FLAG_KEEPALIVE_PENDING); con 680 net/ceph/messenger.c con_flag_clear(con, CON_FLAG_WRITE_PENDING); con 681 net/ceph/messenger.c con_flag_clear(con, CON_FLAG_BACKOFF); con 683 net/ceph/messenger.c reset_connection(con); con 684 net/ceph/messenger.c con->peer_global_seq = 0; con 685 net/ceph/messenger.c cancel_con(con); con 686 net/ceph/messenger.c con_close_socket(con); con 687 net/ceph/messenger.c mutex_unlock(&con->mutex); con 694 net/ceph/messenger.c void ceph_con_open(struct ceph_connection *con, con 698 net/ceph/messenger.c mutex_lock(&con->mutex); con 699 net/ceph/messenger.c dout("con_open %p %s\n", con, ceph_pr_addr(addr)); con 701 net/ceph/messenger.c WARN_ON(con->state != CON_STATE_CLOSED); con 702 net/ceph/messenger.c con->state = CON_STATE_PREOPEN; con 704 net/ceph/messenger.c con->peer_name.type = (__u8) entity_type; con 705 net/ceph/messenger.c con->peer_name.num = cpu_to_le64(entity_num); con 707 net/ceph/messenger.c memcpy(&con->peer_addr, addr, sizeof(*addr)); con 708 net/ceph/messenger.c con->delay = 0; /* reset backoff memory */ con 709 net/ceph/messenger.c mutex_unlock(&con->mutex); con 710 net/ceph/messenger.c queue_con(con); con 717 net/ceph/messenger.c bool ceph_con_opened(struct ceph_connection *con) con 719 net/ceph/messenger.c return con->connect_seq > 0; con 725 net/ceph/messenger.c void ceph_con_init(struct ceph_connection *con, void *private, con 729 net/ceph/messenger.c dout("con_init %p\n", con); con 730 net/ceph/messenger.c memset(con, 0, sizeof(*con)); con 731 net/ceph/messenger.c con->private = private; con 732 net/ceph/messenger.c con->ops = ops; con 733 net/ceph/messenger.c con->msgr = msgr; con 735 net/ceph/messenger.c con_sock_state_init(con); con 737 net/ceph/messenger.c mutex_init(&con->mutex); con 738 net/ceph/messenger.c INIT_LIST_HEAD(&con->out_queue); con 739 net/ceph/messenger.c INIT_LIST_HEAD(&con->out_sent); con 740 net/ceph/messenger.c INIT_DELAYED_WORK(&con->work, ceph_con_workfn); con 742 net/ceph/messenger.c con->state = CON_STATE_CLOSED; con 763 net/ceph/messenger.c static void con_out_kvec_reset(struct ceph_connection *con) con 765 net/ceph/messenger.c BUG_ON(con->out_skip); con 767 net/ceph/messenger.c con->out_kvec_left = 0; con 768 net/ceph/messenger.c con->out_kvec_bytes = 0; con 769 net/ceph/messenger.c con->out_kvec_cur = &con->out_kvec[0]; con 772 net/ceph/messenger.c static void con_out_kvec_add(struct ceph_connection *con, con 775 net/ceph/messenger.c int index = con->out_kvec_left; con 777 net/ceph/messenger.c BUG_ON(con->out_skip); con 778 net/ceph/messenger.c BUG_ON(index >= ARRAY_SIZE(con->out_kvec)); con 780 net/ceph/messenger.c con->out_kvec[index].iov_len = size; con 781 net/ceph/messenger.c con->out_kvec[index].iov_base = data; con 782 net/ceph/messenger.c con->out_kvec_left++; con 783 net/ceph/messenger.c con->out_kvec_bytes += size; con 791 net/ceph/messenger.c static int con_out_kvec_skip(struct ceph_connection *con) con 793 net/ceph/messenger.c int off = con->out_kvec_cur - con->out_kvec; con 796 net/ceph/messenger.c if (con->out_kvec_bytes > 0) { con 797 net/ceph/messenger.c skip = con->out_kvec[off + con->out_kvec_left - 1].iov_len; con 798 net/ceph/messenger.c BUG_ON(con->out_kvec_bytes < skip); con 799 net/ceph/messenger.c BUG_ON(!con->out_kvec_left); con 800 net/ceph/messenger.c con->out_kvec_bytes -= skip; con 801 net/ceph/messenger.c con->out_kvec_left--; con 1220 net/ceph/messenger.c static size_t sizeof_footer(struct ceph_connection *con) con 1222 net/ceph/messenger.c return (con->peer_features & CEPH_FEATURE_MSG_AUTH) ? con 1238 net/ceph/messenger.c static void prepare_write_message_footer(struct ceph_connection *con) con 1240 net/ceph/messenger.c struct ceph_msg *m = con->out_msg; con 1244 net/ceph/messenger.c dout("prepare_write_message_footer %p\n", con); con 1245 net/ceph/messenger.c con_out_kvec_add(con, sizeof_footer(con), &m->footer); con 1246 net/ceph/messenger.c if (con->peer_features & CEPH_FEATURE_MSG_AUTH) { con 1247 net/ceph/messenger.c if (con->ops->sign_message) con 1248 net/ceph/messenger.c con->ops->sign_message(m); con 1254 net/ceph/messenger.c con->out_more = m->more_to_follow; con 1255 net/ceph/messenger.c con->out_msg_done = true; con 1261 net/ceph/messenger.c static void prepare_write_message(struct ceph_connection *con) con 1266 net/ceph/messenger.c con_out_kvec_reset(con); con 1267 net/ceph/messenger.c con->out_msg_done = false; con 1271 net/ceph/messenger.c if (con->in_seq > con->in_seq_acked) { con 1272 net/ceph/messenger.c con->in_seq_acked = con->in_seq; con 1273 net/ceph/messenger.c con_out_kvec_add(con, sizeof (tag_ack), &tag_ack); con 1274 net/ceph/messenger.c con->out_temp_ack = cpu_to_le64(con->in_seq_acked); con 1275 net/ceph/messenger.c con_out_kvec_add(con, sizeof (con->out_temp_ack), con 1276 net/ceph/messenger.c &con->out_temp_ack); con 1279 net/ceph/messenger.c BUG_ON(list_empty(&con->out_queue)); con 1280 net/ceph/messenger.c m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); con 1281 net/ceph/messenger.c con->out_msg = m; con 1282 net/ceph/messenger.c BUG_ON(m->con != con); con 1286 net/ceph/messenger.c list_move_tail(&m->list_head, &con->out_sent); con 1293 net/ceph/messenger.c m->hdr.seq = cpu_to_le64(++con->out_seq); con 1296 net/ceph/messenger.c if (con->ops->reencode_message) con 1297 net/ceph/messenger.c con->ops->reencode_message(m); con 1301 net/ceph/messenger.c m, con->out_seq, le16_to_cpu(m->hdr.type), con 1308 net/ceph/messenger.c con_out_kvec_add(con, sizeof (tag_msg), &tag_msg); con 1309 net/ceph/messenger.c con_out_kvec_add(con, sizeof(con->out_hdr), &con->out_hdr); con 1310 net/ceph/messenger.c con_out_kvec_add(con, m->front.iov_len, m->front.iov_base); con 1313 net/ceph/messenger.c con_out_kvec_add(con, m->middle->vec.iov_len, con 1318 net/ceph/messenger.c con->out_msg->hdr.crc = cpu_to_le32(crc); con 1319 net/ceph/messenger.c memcpy(&con->out_hdr, &con->out_msg->hdr, sizeof(con->out_hdr)); con 1323 net/ceph/messenger.c con->out_msg->footer.front_crc = cpu_to_le32(crc); con 1327 net/ceph/messenger.c con->out_msg->footer.middle_crc = cpu_to_le32(crc); con 1329 net/ceph/messenger.c con->out_msg->footer.middle_crc = 0; con 1331 net/ceph/messenger.c le32_to_cpu(con->out_msg->footer.front_crc), con 1332 net/ceph/messenger.c le32_to_cpu(con->out_msg->footer.middle_crc)); con 1333 net/ceph/messenger.c con->out_msg->footer.flags = 0; con 1336 net/ceph/messenger.c con->out_msg->footer.data_crc = 0; con 1338 net/ceph/messenger.c prepare_message_data(con->out_msg, m->data_length); con 1339 net/ceph/messenger.c con->out_more = 1; /* data + footer will follow */ con 1342 net/ceph/messenger.c prepare_write_message_footer(con); con 1345 net/ceph/messenger.c con_flag_set(con, CON_FLAG_WRITE_PENDING); con 1351 net/ceph/messenger.c static void prepare_write_ack(struct ceph_connection *con) con 1353 net/ceph/messenger.c dout("prepare_write_ack %p %llu -> %llu\n", con, con 1354 net/ceph/messenger.c con->in_seq_acked, con->in_seq); con 1355 net/ceph/messenger.c con->in_seq_acked = con->in_seq; con 1357 net/ceph/messenger.c con_out_kvec_reset(con); con 1359 net/ceph/messenger.c con_out_kvec_add(con, sizeof (tag_ack), &tag_ack); con 1361 net/ceph/messenger.c con->out_temp_ack = cpu_to_le64(con->in_seq_acked); con 1362 net/ceph/messenger.c con_out_kvec_add(con, sizeof (con->out_temp_ack), con 1363 net/ceph/messenger.c &con->out_temp_ack); con 1365 net/ceph/messenger.c con->out_more = 1; /* more will follow.. eventually.. */ con 1366 net/ceph/messenger.c con_flag_set(con, CON_FLAG_WRITE_PENDING); con 1372 net/ceph/messenger.c static void prepare_write_seq(struct ceph_connection *con) con 1374 net/ceph/messenger.c dout("prepare_write_seq %p %llu -> %llu\n", con, con 1375 net/ceph/messenger.c con->in_seq_acked, con->in_seq); con 1376 net/ceph/messenger.c con->in_seq_acked = con->in_seq; con 1378 net/ceph/messenger.c con_out_kvec_reset(con); con 1380 net/ceph/messenger.c con->out_temp_ack = cpu_to_le64(con->in_seq_acked); con 1381 net/ceph/messenger.c con_out_kvec_add(con, sizeof (con->out_temp_ack), con 1382 net/ceph/messenger.c &con->out_temp_ack); con 1384 net/ceph/messenger.c con_flag_set(con, CON_FLAG_WRITE_PENDING); con 1390 net/ceph/messenger.c static void prepare_write_keepalive(struct ceph_connection *con) con 1392 net/ceph/messenger.c dout("prepare_write_keepalive %p\n", con); con 1393 net/ceph/messenger.c con_out_kvec_reset(con); con 1394 net/ceph/messenger.c if (con->peer_features & CEPH_FEATURE_MSGR_KEEPALIVE2) { con 1398 net/ceph/messenger.c con_out_kvec_add(con, sizeof(tag_keepalive2), &tag_keepalive2); con 1399 net/ceph/messenger.c ceph_encode_timespec64(&con->out_temp_keepalive2, &now); con 1400 net/ceph/messenger.c con_out_kvec_add(con, sizeof(con->out_temp_keepalive2), con 1401 net/ceph/messenger.c &con->out_temp_keepalive2); con 1403 net/ceph/messenger.c con_out_kvec_add(con, sizeof(tag_keepalive), &tag_keepalive); con 1405 net/ceph/messenger.c con_flag_set(con, CON_FLAG_WRITE_PENDING); con 1412 net/ceph/messenger.c static int get_connect_authorizer(struct ceph_connection *con) con 1417 net/ceph/messenger.c if (!con->ops->get_authorizer) { con 1418 net/ceph/messenger.c con->auth = NULL; con 1419 net/ceph/messenger.c con->out_connect.authorizer_protocol = CEPH_AUTH_UNKNOWN; con 1420 net/ceph/messenger.c con->out_connect.authorizer_len = 0; con 1424 net/ceph/messenger.c auth = con->ops->get_authorizer(con, &auth_proto, con->auth_retry); con 1428 net/ceph/messenger.c con->auth = auth; con 1429 net/ceph/messenger.c con->out_connect.authorizer_protocol = cpu_to_le32(auth_proto); con 1430 net/ceph/messenger.c con->out_connect.authorizer_len = cpu_to_le32(auth->authorizer_buf_len); con 1437 net/ceph/messenger.c static void prepare_write_banner(struct ceph_connection *con) con 1439 net/ceph/messenger.c con_out_kvec_add(con, strlen(CEPH_BANNER), CEPH_BANNER); con 1440 net/ceph/messenger.c con_out_kvec_add(con, sizeof (con->msgr->my_enc_addr), con 1441 net/ceph/messenger.c &con->msgr->my_enc_addr); con 1443 net/ceph/messenger.c con->out_more = 0; con 1444 net/ceph/messenger.c con_flag_set(con, CON_FLAG_WRITE_PENDING); con 1447 net/ceph/messenger.c static void __prepare_write_connect(struct ceph_connection *con) con 1449 net/ceph/messenger.c con_out_kvec_add(con, sizeof(con->out_connect), &con->out_connect); con 1450 net/ceph/messenger.c if (con->auth) con 1451 net/ceph/messenger.c con_out_kvec_add(con, con->auth->authorizer_buf_len, con 1452 net/ceph/messenger.c con->auth->authorizer_buf); con 1454 net/ceph/messenger.c con->out_more = 0; con 1455 net/ceph/messenger.c con_flag_set(con, CON_FLAG_WRITE_PENDING); con 1458 net/ceph/messenger.c static int prepare_write_connect(struct ceph_connection *con) con 1460 net/ceph/messenger.c unsigned int global_seq = get_global_seq(con->msgr, 0); con 1464 net/ceph/messenger.c switch (con->peer_name.type) { con 1478 net/ceph/messenger.c dout("prepare_write_connect %p cseq=%d gseq=%d proto=%d\n", con, con 1479 net/ceph/messenger.c con->connect_seq, global_seq, proto); con 1481 net/ceph/messenger.c con->out_connect.features = con 1482 net/ceph/messenger.c cpu_to_le64(from_msgr(con->msgr)->supported_features); con 1483 net/ceph/messenger.c con->out_connect.host_type = cpu_to_le32(CEPH_ENTITY_TYPE_CLIENT); con 1484 net/ceph/messenger.c con->out_connect.connect_seq = cpu_to_le32(con->connect_seq); con 1485 net/ceph/messenger.c con->out_connect.global_seq = cpu_to_le32(global_seq); con 1486 net/ceph/messenger.c con->out_connect.protocol_version = cpu_to_le32(proto); con 1487 net/ceph/messenger.c con->out_connect.flags = 0; con 1489 net/ceph/messenger.c ret = get_connect_authorizer(con); con 1493 net/ceph/messenger.c __prepare_write_connect(con); con 1503 net/ceph/messenger.c static int write_partial_kvec(struct ceph_connection *con) con 1507 net/ceph/messenger.c dout("write_partial_kvec %p %d left\n", con, con->out_kvec_bytes); con 1508 net/ceph/messenger.c while (con->out_kvec_bytes > 0) { con 1509 net/ceph/messenger.c ret = ceph_tcp_sendmsg(con->sock, con->out_kvec_cur, con 1510 net/ceph/messenger.c con->out_kvec_left, con->out_kvec_bytes, con 1511 net/ceph/messenger.c con->out_more); con 1514 net/ceph/messenger.c con->out_kvec_bytes -= ret; con 1515 net/ceph/messenger.c if (con->out_kvec_bytes == 0) con 1519 net/ceph/messenger.c while (ret >= con->out_kvec_cur->iov_len) { con 1520 net/ceph/messenger.c BUG_ON(!con->out_kvec_left); con 1521 net/ceph/messenger.c ret -= con->out_kvec_cur->iov_len; con 1522 net/ceph/messenger.c con->out_kvec_cur++; con 1523 net/ceph/messenger.c con->out_kvec_left--; con 1527 net/ceph/messenger.c con->out_kvec_cur->iov_len -= ret; con 1528 net/ceph/messenger.c con->out_kvec_cur->iov_base += ret; con 1531 net/ceph/messenger.c con->out_kvec_left = 0; con 1534 net/ceph/messenger.c dout("write_partial_kvec %p %d left in %d kvecs ret = %d\n", con, con 1535 net/ceph/messenger.c con->out_kvec_bytes, con->out_kvec_left, ret); con 1559 net/ceph/messenger.c static int write_partial_message_data(struct ceph_connection *con) con 1561 net/ceph/messenger.c struct ceph_msg *msg = con->out_msg; con 1563 net/ceph/messenger.c bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); con 1567 net/ceph/messenger.c dout("%s %p msg %p\n", __func__, con, msg); con 1595 net/ceph/messenger.c ret = ceph_tcp_sendpage(con->sock, page, page_offset, length, con 1608 net/ceph/messenger.c dout("%s %p msg %p done\n", __func__, con, msg); con 1615 net/ceph/messenger.c con_out_kvec_reset(con); con 1616 net/ceph/messenger.c prepare_write_message_footer(con); con 1624 net/ceph/messenger.c static int write_partial_skip(struct ceph_connection *con) con 1629 net/ceph/messenger.c dout("%s %p %d left\n", __func__, con, con->out_skip); con 1630 net/ceph/messenger.c while (con->out_skip > 0) { con 1631 net/ceph/messenger.c size_t size = min(con->out_skip, (int) PAGE_SIZE); con 1633 net/ceph/messenger.c if (size == con->out_skip) con 1635 net/ceph/messenger.c ret = ceph_tcp_sendpage(con->sock, zero_page, 0, size, more); con 1638 net/ceph/messenger.c con->out_skip -= ret; con 1648 net/ceph/messenger.c static void prepare_read_banner(struct ceph_connection *con) con 1650 net/ceph/messenger.c dout("prepare_read_banner %p\n", con); con 1651 net/ceph/messenger.c con->in_base_pos = 0; con 1654 net/ceph/messenger.c static void prepare_read_connect(struct ceph_connection *con) con 1656 net/ceph/messenger.c dout("prepare_read_connect %p\n", con); con 1657 net/ceph/messenger.c con->in_base_pos = 0; con 1660 net/ceph/messenger.c static void prepare_read_ack(struct ceph_connection *con) con 1662 net/ceph/messenger.c dout("prepare_read_ack %p\n", con); con 1663 net/ceph/messenger.c con->in_base_pos = 0; con 1666 net/ceph/messenger.c static void prepare_read_seq(struct ceph_connection *con) con 1668 net/ceph/messenger.c dout("prepare_read_seq %p\n", con); con 1669 net/ceph/messenger.c con->in_base_pos = 0; con 1670 net/ceph/messenger.c con->in_tag = CEPH_MSGR_TAG_SEQ; con 1673 net/ceph/messenger.c static void prepare_read_tag(struct ceph_connection *con) con 1675 net/ceph/messenger.c dout("prepare_read_tag %p\n", con); con 1676 net/ceph/messenger.c con->in_base_pos = 0; con 1677 net/ceph/messenger.c con->in_tag = CEPH_MSGR_TAG_READY; con 1680 net/ceph/messenger.c static void prepare_read_keepalive_ack(struct ceph_connection *con) con 1682 net/ceph/messenger.c dout("prepare_read_keepalive_ack %p\n", con); con 1683 net/ceph/messenger.c con->in_base_pos = 0; con 1689 net/ceph/messenger.c static int prepare_read_message(struct ceph_connection *con) con 1691 net/ceph/messenger.c dout("prepare_read_message %p\n", con); con 1692 net/ceph/messenger.c BUG_ON(con->in_msg != NULL); con 1693 net/ceph/messenger.c con->in_base_pos = 0; con 1694 net/ceph/messenger.c con->in_front_crc = con->in_middle_crc = con->in_data_crc = 0; con 1699 net/ceph/messenger.c static int read_partial(struct ceph_connection *con, con 1702 net/ceph/messenger.c while (con->in_base_pos < end) { con 1703 net/ceph/messenger.c int left = end - con->in_base_pos; con 1705 net/ceph/messenger.c int ret = ceph_tcp_recvmsg(con->sock, object + have, left); con 1708 net/ceph/messenger.c con->in_base_pos += ret; con 1717 net/ceph/messenger.c static int read_partial_banner(struct ceph_connection *con) con 1723 net/ceph/messenger.c dout("read_partial_banner %p at %d\n", con, con->in_base_pos); con 1728 net/ceph/messenger.c ret = read_partial(con, end, size, con->in_banner); con 1732 net/ceph/messenger.c size = sizeof (con->actual_peer_addr); con 1734 net/ceph/messenger.c ret = read_partial(con, end, size, &con->actual_peer_addr); con 1737 net/ceph/messenger.c ceph_decode_banner_addr(&con->actual_peer_addr); con 1739 net/ceph/messenger.c size = sizeof (con->peer_addr_for_me); con 1741 net/ceph/messenger.c ret = read_partial(con, end, size, &con->peer_addr_for_me); con 1744 net/ceph/messenger.c ceph_decode_banner_addr(&con->peer_addr_for_me); con 1750 net/ceph/messenger.c static int read_partial_connect(struct ceph_connection *con) con 1756 net/ceph/messenger.c dout("read_partial_connect %p at %d\n", con, con->in_base_pos); con 1758 net/ceph/messenger.c size = sizeof (con->in_reply); con 1760 net/ceph/messenger.c ret = read_partial(con, end, size, &con->in_reply); con 1764 net/ceph/messenger.c if (con->auth) { con 1765 net/ceph/messenger.c size = le32_to_cpu(con->in_reply.authorizer_len); con 1766 net/ceph/messenger.c if (size > con->auth->authorizer_reply_buf_len) { con 1768 net/ceph/messenger.c con->auth->authorizer_reply_buf_len); con 1774 net/ceph/messenger.c ret = read_partial(con, end, size, con 1775 net/ceph/messenger.c con->auth->authorizer_reply_buf); con 1781 net/ceph/messenger.c con, (int)con->in_reply.tag, con 1782 net/ceph/messenger.c le32_to_cpu(con->in_reply.connect_seq), con 1783 net/ceph/messenger.c le32_to_cpu(con->in_reply.global_seq)); con 1791 net/ceph/messenger.c static int verify_hello(struct ceph_connection *con) con 1793 net/ceph/messenger.c if (memcmp(con->in_banner, CEPH_BANNER, strlen(CEPH_BANNER))) { con 1795 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr)); con 1796 net/ceph/messenger.c con->error_msg = "protocol error, bad banner"; con 2012 net/ceph/messenger.c static int process_banner(struct ceph_connection *con) con 2014 net/ceph/messenger.c dout("process_banner on %p\n", con); con 2016 net/ceph/messenger.c if (verify_hello(con) < 0) con 2024 net/ceph/messenger.c if (memcmp(&con->peer_addr, &con->actual_peer_addr, con 2025 net/ceph/messenger.c sizeof(con->peer_addr)) != 0 && con 2026 net/ceph/messenger.c !(addr_is_blank(&con->actual_peer_addr) && con 2027 net/ceph/messenger.c con->actual_peer_addr.nonce == con->peer_addr.nonce)) { con 2029 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), con 2030 net/ceph/messenger.c (int)le32_to_cpu(con->peer_addr.nonce), con 2031 net/ceph/messenger.c ceph_pr_addr(&con->actual_peer_addr), con 2032 net/ceph/messenger.c (int)le32_to_cpu(con->actual_peer_addr.nonce)); con 2033 net/ceph/messenger.c con->error_msg = "wrong peer at address"; con 2040 net/ceph/messenger.c if (addr_is_blank(&con->msgr->inst.addr)) { con 2041 net/ceph/messenger.c int port = addr_port(&con->msgr->inst.addr); con 2043 net/ceph/messenger.c memcpy(&con->msgr->inst.addr.in_addr, con 2044 net/ceph/messenger.c &con->peer_addr_for_me.in_addr, con 2045 net/ceph/messenger.c sizeof(con->peer_addr_for_me.in_addr)); con 2046 net/ceph/messenger.c addr_set_port(&con->msgr->inst.addr, port); con 2047 net/ceph/messenger.c encode_my_addr(con->msgr); con 2049 net/ceph/messenger.c ceph_pr_addr(&con->msgr->inst.addr)); con 2055 net/ceph/messenger.c static int process_connect(struct ceph_connection *con) con 2057 net/ceph/messenger.c u64 sup_feat = from_msgr(con->msgr)->supported_features; con 2058 net/ceph/messenger.c u64 req_feat = from_msgr(con->msgr)->required_features; con 2059 net/ceph/messenger.c u64 server_feat = le64_to_cpu(con->in_reply.features); con 2062 net/ceph/messenger.c dout("process_connect on %p tag %d\n", con, (int)con->in_tag); con 2064 net/ceph/messenger.c if (con->auth) { con 2065 net/ceph/messenger.c int len = le32_to_cpu(con->in_reply.authorizer_len); con 2074 net/ceph/messenger.c if (con->in_reply.tag == CEPH_MSGR_TAG_CHALLENGE_AUTHORIZER) { con 2075 net/ceph/messenger.c ret = con->ops->add_authorizer_challenge( con 2076 net/ceph/messenger.c con, con->auth->authorizer_reply_buf, len); con 2080 net/ceph/messenger.c con_out_kvec_reset(con); con 2081 net/ceph/messenger.c __prepare_write_connect(con); con 2082 net/ceph/messenger.c prepare_read_connect(con); con 2087 net/ceph/messenger.c ret = con->ops->verify_authorizer_reply(con); con 2089 net/ceph/messenger.c con->error_msg = "bad authorize reply"; con 2095 net/ceph/messenger.c switch (con->in_reply.tag) { con 2099 net/ceph/messenger.c ENTITY_NAME(con->peer_name), con 2100 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), con 2102 net/ceph/messenger.c con->error_msg = "missing required protocol features"; con 2103 net/ceph/messenger.c reset_connection(con); con 2109 net/ceph/messenger.c ENTITY_NAME(con->peer_name), con 2110 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), con 2111 net/ceph/messenger.c le32_to_cpu(con->out_connect.protocol_version), con 2112 net/ceph/messenger.c le32_to_cpu(con->in_reply.protocol_version)); con 2113 net/ceph/messenger.c con->error_msg = "protocol version mismatch"; con 2114 net/ceph/messenger.c reset_connection(con); con 2118 net/ceph/messenger.c con->auth_retry++; con 2119 net/ceph/messenger.c dout("process_connect %p got BADAUTHORIZER attempt %d\n", con, con 2120 net/ceph/messenger.c con->auth_retry); con 2121 net/ceph/messenger.c if (con->auth_retry == 2) { con 2122 net/ceph/messenger.c con->error_msg = "connect authorization failure"; con 2125 net/ceph/messenger.c con_out_kvec_reset(con); con 2126 net/ceph/messenger.c ret = prepare_write_connect(con); con 2129 net/ceph/messenger.c prepare_read_connect(con); con 2141 net/ceph/messenger.c le32_to_cpu(con->in_reply.connect_seq)); con 2143 net/ceph/messenger.c ENTITY_NAME(con->peer_name), con 2144 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr)); con 2145 net/ceph/messenger.c reset_connection(con); con 2146 net/ceph/messenger.c con_out_kvec_reset(con); con 2147 net/ceph/messenger.c ret = prepare_write_connect(con); con 2150 net/ceph/messenger.c prepare_read_connect(con); con 2153 net/ceph/messenger.c mutex_unlock(&con->mutex); con 2154 net/ceph/messenger.c pr_info("reset on %s%lld\n", ENTITY_NAME(con->peer_name)); con 2155 net/ceph/messenger.c if (con->ops->peer_reset) con 2156 net/ceph/messenger.c con->ops->peer_reset(con); con 2157 net/ceph/messenger.c mutex_lock(&con->mutex); con 2158 net/ceph/messenger.c if (con->state != CON_STATE_NEGOTIATING) con 2168 net/ceph/messenger.c le32_to_cpu(con->out_connect.connect_seq), con 2169 net/ceph/messenger.c le32_to_cpu(con->in_reply.connect_seq)); con 2170 net/ceph/messenger.c con->connect_seq = le32_to_cpu(con->in_reply.connect_seq); con 2171 net/ceph/messenger.c con_out_kvec_reset(con); con 2172 net/ceph/messenger.c ret = prepare_write_connect(con); con 2175 net/ceph/messenger.c prepare_read_connect(con); con 2184 net/ceph/messenger.c con->peer_global_seq, con 2185 net/ceph/messenger.c le32_to_cpu(con->in_reply.global_seq)); con 2186 net/ceph/messenger.c get_global_seq(con->msgr, con 2187 net/ceph/messenger.c le32_to_cpu(con->in_reply.global_seq)); con 2188 net/ceph/messenger.c con_out_kvec_reset(con); con 2189 net/ceph/messenger.c ret = prepare_write_connect(con); con 2192 net/ceph/messenger.c prepare_read_connect(con); con 2200 net/ceph/messenger.c ENTITY_NAME(con->peer_name), con 2201 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), con 2203 net/ceph/messenger.c con->error_msg = "missing required protocol features"; con 2204 net/ceph/messenger.c reset_connection(con); con 2208 net/ceph/messenger.c WARN_ON(con->state != CON_STATE_NEGOTIATING); con 2209 net/ceph/messenger.c con->state = CON_STATE_OPEN; con 2210 net/ceph/messenger.c con->auth_retry = 0; /* we authenticated; clear flag */ con 2211 net/ceph/messenger.c con->peer_global_seq = le32_to_cpu(con->in_reply.global_seq); con 2212 net/ceph/messenger.c con->connect_seq++; con 2213 net/ceph/messenger.c con->peer_features = server_feat; con 2215 net/ceph/messenger.c con->peer_global_seq, con 2216 net/ceph/messenger.c le32_to_cpu(con->in_reply.connect_seq), con 2217 net/ceph/messenger.c con->connect_seq); con 2218 net/ceph/messenger.c WARN_ON(con->connect_seq != con 2219 net/ceph/messenger.c le32_to_cpu(con->in_reply.connect_seq)); con 2221 net/ceph/messenger.c if (con->in_reply.flags & CEPH_MSG_CONNECT_LOSSY) con 2222 net/ceph/messenger.c con_flag_set(con, CON_FLAG_LOSSYTX); con 2224 net/ceph/messenger.c con->delay = 0; /* reset backoff memory */ con 2226 net/ceph/messenger.c if (con->in_reply.tag == CEPH_MSGR_TAG_SEQ) { con 2227 net/ceph/messenger.c prepare_write_seq(con); con 2228 net/ceph/messenger.c prepare_read_seq(con); con 2230 net/ceph/messenger.c prepare_read_tag(con); con 2241 net/ceph/messenger.c con->error_msg = "protocol error, got WAIT as client"; con 2245 net/ceph/messenger.c con->error_msg = "protocol error, garbage tag during connect"; con 2255 net/ceph/messenger.c static int read_partial_ack(struct ceph_connection *con) con 2257 net/ceph/messenger.c int size = sizeof (con->in_temp_ack); con 2260 net/ceph/messenger.c return read_partial(con, end, size, &con->in_temp_ack); con 2266 net/ceph/messenger.c static void process_ack(struct ceph_connection *con) con 2269 net/ceph/messenger.c u64 ack = le64_to_cpu(con->in_temp_ack); con 2271 net/ceph/messenger.c bool reconnect = (con->in_tag == CEPH_MSGR_TAG_SEQ); con 2272 net/ceph/messenger.c struct list_head *list = reconnect ? &con->out_queue : &con->out_sent; con 2292 net/ceph/messenger.c prepare_read_tag(con); con 2296 net/ceph/messenger.c static int read_partial_message_section(struct ceph_connection *con, con 2307 net/ceph/messenger.c ret = ceph_tcp_recvmsg(con->sock, (char *)section->iov_base + con 2319 net/ceph/messenger.c static int read_partial_msg_data(struct ceph_connection *con) con 2321 net/ceph/messenger.c struct ceph_msg *msg = con->in_msg; con 2323 net/ceph/messenger.c bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); con 2334 net/ceph/messenger.c crc = con->in_data_crc; con 2342 net/ceph/messenger.c ret = ceph_tcp_recvpage(con->sock, page, page_offset, length); con 2345 net/ceph/messenger.c con->in_data_crc = crc; con 2355 net/ceph/messenger.c con->in_data_crc = crc; con 2363 net/ceph/messenger.c static int ceph_con_in_msg_alloc(struct ceph_connection *con, int *skip); con 2365 net/ceph/messenger.c static int read_partial_message(struct ceph_connection *con) con 2367 net/ceph/messenger.c struct ceph_msg *m = con->in_msg; con 2372 net/ceph/messenger.c bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); con 2373 net/ceph/messenger.c bool need_sign = (con->peer_features & CEPH_FEATURE_MSG_AUTH); con 2377 net/ceph/messenger.c dout("read_partial_message con %p msg %p\n", con, m); con 2380 net/ceph/messenger.c size = sizeof (con->in_hdr); con 2382 net/ceph/messenger.c ret = read_partial(con, end, size, &con->in_hdr); con 2386 net/ceph/messenger.c crc = crc32c(0, &con->in_hdr, offsetof(struct ceph_msg_header, crc)); con 2387 net/ceph/messenger.c if (cpu_to_le32(crc) != con->in_hdr.crc) { con 2389 net/ceph/messenger.c crc, con->in_hdr.crc); con 2393 net/ceph/messenger.c front_len = le32_to_cpu(con->in_hdr.front_len); con 2396 net/ceph/messenger.c middle_len = le32_to_cpu(con->in_hdr.middle_len); con 2399 net/ceph/messenger.c data_len = le32_to_cpu(con->in_hdr.data_len); con 2404 net/ceph/messenger.c seq = le64_to_cpu(con->in_hdr.seq); con 2405 net/ceph/messenger.c if ((s64)seq - (s64)con->in_seq < 1) { con 2407 net/ceph/messenger.c ENTITY_NAME(con->peer_name), con 2408 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), con 2409 net/ceph/messenger.c seq, con->in_seq + 1); con 2410 net/ceph/messenger.c con->in_base_pos = -front_len - middle_len - data_len - con 2411 net/ceph/messenger.c sizeof_footer(con); con 2412 net/ceph/messenger.c con->in_tag = CEPH_MSGR_TAG_READY; con 2414 net/ceph/messenger.c } else if ((s64)seq - (s64)con->in_seq > 1) { con 2416 net/ceph/messenger.c seq, con->in_seq + 1); con 2417 net/ceph/messenger.c con->error_msg = "bad message sequence # for incoming message"; con 2422 net/ceph/messenger.c if (!con->in_msg) { con 2425 net/ceph/messenger.c dout("got hdr type %d front %d data %d\n", con->in_hdr.type, con 2427 net/ceph/messenger.c ret = ceph_con_in_msg_alloc(con, &skip); con 2431 net/ceph/messenger.c BUG_ON(!con->in_msg ^ skip); con 2435 net/ceph/messenger.c con->in_base_pos = -front_len - middle_len - data_len - con 2436 net/ceph/messenger.c sizeof_footer(con); con 2437 net/ceph/messenger.c con->in_tag = CEPH_MSGR_TAG_READY; con 2438 net/ceph/messenger.c con->in_seq++; con 2442 net/ceph/messenger.c BUG_ON(!con->in_msg); con 2443 net/ceph/messenger.c BUG_ON(con->in_msg->con != con); con 2444 net/ceph/messenger.c m = con->in_msg; con 2452 net/ceph/messenger.c prepare_message_data(con->in_msg, data_len); con 2456 net/ceph/messenger.c ret = read_partial_message_section(con, &m->front, front_len, con 2457 net/ceph/messenger.c &con->in_front_crc); con 2463 net/ceph/messenger.c ret = read_partial_message_section(con, &m->middle->vec, con 2465 net/ceph/messenger.c &con->in_middle_crc); con 2472 net/ceph/messenger.c ret = read_partial_msg_data(con); con 2478 net/ceph/messenger.c size = sizeof_footer(con); con 2480 net/ceph/messenger.c ret = read_partial(con, end, size, &m->footer); con 2494 net/ceph/messenger.c if (con->in_front_crc != le32_to_cpu(m->footer.front_crc)) { con 2496 net/ceph/messenger.c m, con->in_front_crc, m->footer.front_crc); con 2499 net/ceph/messenger.c if (con->in_middle_crc != le32_to_cpu(m->footer.middle_crc)) { con 2501 net/ceph/messenger.c m, con->in_middle_crc, m->footer.middle_crc); con 2506 net/ceph/messenger.c con->in_data_crc != le32_to_cpu(m->footer.data_crc)) { con 2508 net/ceph/messenger.c con->in_data_crc, le32_to_cpu(m->footer.data_crc)); con 2512 net/ceph/messenger.c if (need_sign && con->ops->check_message_signature && con 2513 net/ceph/messenger.c con->ops->check_message_signature(m)) { con 2526 net/ceph/messenger.c static void process_message(struct ceph_connection *con) con 2528 net/ceph/messenger.c struct ceph_msg *msg = con->in_msg; con 2530 net/ceph/messenger.c BUG_ON(con->in_msg->con != con); con 2531 net/ceph/messenger.c con->in_msg = NULL; con 2534 net/ceph/messenger.c if (con->peer_name.type == 0) con 2535 net/ceph/messenger.c con->peer_name = msg->hdr.src; con 2537 net/ceph/messenger.c con->in_seq++; con 2538 net/ceph/messenger.c mutex_unlock(&con->mutex); con 2547 net/ceph/messenger.c con->in_front_crc, con->in_middle_crc, con->in_data_crc); con 2548 net/ceph/messenger.c con->ops->dispatch(con, msg); con 2550 net/ceph/messenger.c mutex_lock(&con->mutex); con 2553 net/ceph/messenger.c static int read_keepalive_ack(struct ceph_connection *con) con 2557 net/ceph/messenger.c int ret = read_partial(con, size, size, &ceph_ts); con 2560 net/ceph/messenger.c ceph_decode_timespec64(&con->last_keepalive_ack, &ceph_ts); con 2561 net/ceph/messenger.c prepare_read_tag(con); con 2569 net/ceph/messenger.c static int try_write(struct ceph_connection *con) con 2573 net/ceph/messenger.c dout("try_write start %p state %lu\n", con, con->state); con 2574 net/ceph/messenger.c if (con->state != CON_STATE_PREOPEN && con 2575 net/ceph/messenger.c con->state != CON_STATE_CONNECTING && con 2576 net/ceph/messenger.c con->state != CON_STATE_NEGOTIATING && con 2577 net/ceph/messenger.c con->state != CON_STATE_OPEN) con 2581 net/ceph/messenger.c if (con->state == CON_STATE_PREOPEN) { con 2582 net/ceph/messenger.c BUG_ON(con->sock); con 2583 net/ceph/messenger.c con->state = CON_STATE_CONNECTING; con 2585 net/ceph/messenger.c con_out_kvec_reset(con); con 2586 net/ceph/messenger.c prepare_write_banner(con); con 2587 net/ceph/messenger.c prepare_read_banner(con); con 2589 net/ceph/messenger.c BUG_ON(con->in_msg); con 2590 net/ceph/messenger.c con->in_tag = CEPH_MSGR_TAG_READY; con 2592 net/ceph/messenger.c con, con->state); con 2593 net/ceph/messenger.c ret = ceph_tcp_connect(con); con 2595 net/ceph/messenger.c con->error_msg = "connect error"; con 2601 net/ceph/messenger.c dout("try_write out_kvec_bytes %d\n", con->out_kvec_bytes); con 2602 net/ceph/messenger.c BUG_ON(!con->sock); con 2605 net/ceph/messenger.c if (con->out_kvec_left) { con 2606 net/ceph/messenger.c ret = write_partial_kvec(con); con 2610 net/ceph/messenger.c if (con->out_skip) { con 2611 net/ceph/messenger.c ret = write_partial_skip(con); con 2617 net/ceph/messenger.c if (con->out_msg) { con 2618 net/ceph/messenger.c if (con->out_msg_done) { con 2619 net/ceph/messenger.c ceph_msg_put(con->out_msg); con 2620 net/ceph/messenger.c con->out_msg = NULL; /* we're done with this one */ con 2624 net/ceph/messenger.c ret = write_partial_message_data(con); con 2637 net/ceph/messenger.c if (con->state == CON_STATE_OPEN) { con 2638 net/ceph/messenger.c if (con_flag_test_and_clear(con, CON_FLAG_KEEPALIVE_PENDING)) { con 2639 net/ceph/messenger.c prepare_write_keepalive(con); con 2643 net/ceph/messenger.c if (!list_empty(&con->out_queue)) { con 2644 net/ceph/messenger.c prepare_write_message(con); con 2647 net/ceph/messenger.c if (con->in_seq > con->in_seq_acked) { con 2648 net/ceph/messenger.c prepare_write_ack(con); con 2654 net/ceph/messenger.c con_flag_clear(con, CON_FLAG_WRITE_PENDING); con 2658 net/ceph/messenger.c dout("try_write done on %p ret %d\n", con, ret); con 2665 net/ceph/messenger.c static int try_read(struct ceph_connection *con) con 2670 net/ceph/messenger.c dout("try_read start on %p state %lu\n", con, con->state); con 2671 net/ceph/messenger.c if (con->state != CON_STATE_CONNECTING && con 2672 net/ceph/messenger.c con->state != CON_STATE_NEGOTIATING && con 2673 net/ceph/messenger.c con->state != CON_STATE_OPEN) con 2676 net/ceph/messenger.c BUG_ON(!con->sock); con 2678 net/ceph/messenger.c dout("try_read tag %d in_base_pos %d\n", (int)con->in_tag, con 2679 net/ceph/messenger.c con->in_base_pos); con 2681 net/ceph/messenger.c if (con->state == CON_STATE_CONNECTING) { con 2683 net/ceph/messenger.c ret = read_partial_banner(con); con 2686 net/ceph/messenger.c ret = process_banner(con); con 2690 net/ceph/messenger.c con->state = CON_STATE_NEGOTIATING; con 2697 net/ceph/messenger.c ret = prepare_write_connect(con); con 2700 net/ceph/messenger.c prepare_read_connect(con); con 2706 net/ceph/messenger.c if (con->state == CON_STATE_NEGOTIATING) { con 2708 net/ceph/messenger.c ret = read_partial_connect(con); con 2711 net/ceph/messenger.c ret = process_connect(con); con 2717 net/ceph/messenger.c WARN_ON(con->state != CON_STATE_OPEN); con 2719 net/ceph/messenger.c if (con->in_base_pos < 0) { con 2723 net/ceph/messenger.c ret = ceph_tcp_recvmsg(con->sock, NULL, -con->in_base_pos); con 2726 net/ceph/messenger.c dout("skipped %d / %d bytes\n", ret, -con->in_base_pos); con 2727 net/ceph/messenger.c con->in_base_pos += ret; con 2728 net/ceph/messenger.c if (con->in_base_pos) con 2731 net/ceph/messenger.c if (con->in_tag == CEPH_MSGR_TAG_READY) { con 2735 net/ceph/messenger.c ret = ceph_tcp_recvmsg(con->sock, &con->in_tag, 1); con 2738 net/ceph/messenger.c dout("try_read got tag %d\n", (int)con->in_tag); con 2739 net/ceph/messenger.c switch (con->in_tag) { con 2741 net/ceph/messenger.c prepare_read_message(con); con 2744 net/ceph/messenger.c prepare_read_ack(con); con 2747 net/ceph/messenger.c prepare_read_keepalive_ack(con); con 2750 net/ceph/messenger.c con_close_socket(con); con 2751 net/ceph/messenger.c con->state = CON_STATE_CLOSED; con 2757 net/ceph/messenger.c if (con->in_tag == CEPH_MSGR_TAG_MSG) { con 2758 net/ceph/messenger.c ret = read_partial_message(con); con 2762 net/ceph/messenger.c con->error_msg = "bad crc/signature"; con 2768 net/ceph/messenger.c con->error_msg = "io error"; con 2773 net/ceph/messenger.c if (con->in_tag == CEPH_MSGR_TAG_READY) con 2775 net/ceph/messenger.c process_message(con); con 2776 net/ceph/messenger.c if (con->state == CON_STATE_OPEN) con 2777 net/ceph/messenger.c prepare_read_tag(con); con 2780 net/ceph/messenger.c if (con->in_tag == CEPH_MSGR_TAG_ACK || con 2781 net/ceph/messenger.c con->in_tag == CEPH_MSGR_TAG_SEQ) { con 2786 net/ceph/messenger.c ret = read_partial_ack(con); con 2789 net/ceph/messenger.c process_ack(con); con 2792 net/ceph/messenger.c if (con->in_tag == CEPH_MSGR_TAG_KEEPALIVE2_ACK) { con 2793 net/ceph/messenger.c ret = read_keepalive_ack(con); con 2800 net/ceph/messenger.c dout("try_read done on %p ret %d\n", con, ret); con 2804 net/ceph/messenger.c pr_err("try_read bad con->in_tag = %d\n", (int)con->in_tag); con 2805 net/ceph/messenger.c con->error_msg = "protocol error, garbage tag"; con 2816 net/ceph/messenger.c static int queue_con_delay(struct ceph_connection *con, unsigned long delay) con 2818 net/ceph/messenger.c if (!con->ops->get(con)) { con 2819 net/ceph/messenger.c dout("%s %p ref count 0\n", __func__, con); con 2823 net/ceph/messenger.c if (!queue_delayed_work(ceph_msgr_wq, &con->work, delay)) { con 2824 net/ceph/messenger.c dout("%s %p - already queued\n", __func__, con); con 2825 net/ceph/messenger.c con->ops->put(con); con 2829 net/ceph/messenger.c dout("%s %p %lu\n", __func__, con, delay); con 2833 net/ceph/messenger.c static void queue_con(struct ceph_connection *con) con 2835 net/ceph/messenger.c (void) queue_con_delay(con, 0); con 2838 net/ceph/messenger.c static void cancel_con(struct ceph_connection *con) con 2840 net/ceph/messenger.c if (cancel_delayed_work(&con->work)) { con 2841 net/ceph/messenger.c dout("%s %p\n", __func__, con); con 2842 net/ceph/messenger.c con->ops->put(con); con 2846 net/ceph/messenger.c static bool con_sock_closed(struct ceph_connection *con) con 2848 net/ceph/messenger.c if (!con_flag_test_and_clear(con, CON_FLAG_SOCK_CLOSED)) con 2853 net/ceph/messenger.c con->error_msg = "socket closed (con state " #x ")"; \ con 2856 net/ceph/messenger.c switch (con->state) { con 2865 net/ceph/messenger.c __func__, con, con->state); con 2866 net/ceph/messenger.c con->error_msg = "unrecognized con state"; con 2875 net/ceph/messenger.c static bool con_backoff(struct ceph_connection *con) con 2879 net/ceph/messenger.c if (!con_flag_test_and_clear(con, CON_FLAG_BACKOFF)) con 2882 net/ceph/messenger.c ret = queue_con_delay(con, round_jiffies_relative(con->delay)); con 2885 net/ceph/messenger.c con, con->delay); con 2887 net/ceph/messenger.c con_flag_set(con, CON_FLAG_BACKOFF); con 2895 net/ceph/messenger.c static void con_fault_finish(struct ceph_connection *con) con 2897 net/ceph/messenger.c dout("%s %p\n", __func__, con); con 2903 net/ceph/messenger.c if (con->auth_retry) { con 2904 net/ceph/messenger.c dout("auth_retry %d, invalidating\n", con->auth_retry); con 2905 net/ceph/messenger.c if (con->ops->invalidate_authorizer) con 2906 net/ceph/messenger.c con->ops->invalidate_authorizer(con); con 2907 net/ceph/messenger.c con->auth_retry = 0; con 2910 net/ceph/messenger.c if (con->ops->fault) con 2911 net/ceph/messenger.c con->ops->fault(con); con 2919 net/ceph/messenger.c struct ceph_connection *con = container_of(work, struct ceph_connection, con 2923 net/ceph/messenger.c mutex_lock(&con->mutex); con 2927 net/ceph/messenger.c if ((fault = con_sock_closed(con))) { con 2928 net/ceph/messenger.c dout("%s: con %p SOCK_CLOSED\n", __func__, con); con 2931 net/ceph/messenger.c if (con_backoff(con)) { con 2932 net/ceph/messenger.c dout("%s: con %p BACKOFF\n", __func__, con); con 2935 net/ceph/messenger.c if (con->state == CON_STATE_STANDBY) { con 2936 net/ceph/messenger.c dout("%s: con %p STANDBY\n", __func__, con); con 2939 net/ceph/messenger.c if (con->state == CON_STATE_CLOSED) { con 2940 net/ceph/messenger.c dout("%s: con %p CLOSED\n", __func__, con); con 2941 net/ceph/messenger.c BUG_ON(con->sock); con 2944 net/ceph/messenger.c if (con->state == CON_STATE_PREOPEN) { con 2945 net/ceph/messenger.c dout("%s: con %p PREOPEN\n", __func__, con); con 2946 net/ceph/messenger.c BUG_ON(con->sock); con 2949 net/ceph/messenger.c ret = try_read(con); con 2953 net/ceph/messenger.c if (!con->error_msg) con 2954 net/ceph/messenger.c con->error_msg = "socket error on read"; con 2959 net/ceph/messenger.c ret = try_write(con); con 2963 net/ceph/messenger.c if (!con->error_msg) con 2964 net/ceph/messenger.c con->error_msg = "socket error on write"; con 2971 net/ceph/messenger.c con_fault(con); con 2972 net/ceph/messenger.c mutex_unlock(&con->mutex); con 2975 net/ceph/messenger.c con_fault_finish(con); con 2977 net/ceph/messenger.c con->ops->put(con); con 2984 net/ceph/messenger.c static void con_fault(struct ceph_connection *con) con 2987 net/ceph/messenger.c con, con->state, ceph_pr_addr(&con->peer_addr)); con 2989 net/ceph/messenger.c pr_warn("%s%lld %s %s\n", ENTITY_NAME(con->peer_name), con 2990 net/ceph/messenger.c ceph_pr_addr(&con->peer_addr), con->error_msg); con 2991 net/ceph/messenger.c con->error_msg = NULL; con 2993 net/ceph/messenger.c WARN_ON(con->state != CON_STATE_CONNECTING && con 2994 net/ceph/messenger.c con->state != CON_STATE_NEGOTIATING && con 2995 net/ceph/messenger.c con->state != CON_STATE_OPEN); con 2997 net/ceph/messenger.c con_close_socket(con); con 2999 net/ceph/messenger.c if (con_flag_test(con, CON_FLAG_LOSSYTX)) { con 3001 net/ceph/messenger.c con->state = CON_STATE_CLOSED; con 3005 net/ceph/messenger.c if (con->in_msg) { con 3006 net/ceph/messenger.c BUG_ON(con->in_msg->con != con); con 3007 net/ceph/messenger.c ceph_msg_put(con->in_msg); con 3008 net/ceph/messenger.c con->in_msg = NULL; con 3012 net/ceph/messenger.c list_splice_init(&con->out_sent, &con->out_queue); con 3016 net/ceph/messenger.c if (list_empty(&con->out_queue) && con 3017 net/ceph/messenger.c !con_flag_test(con, CON_FLAG_KEEPALIVE_PENDING)) { con 3018 net/ceph/messenger.c dout("fault %p setting STANDBY clearing WRITE_PENDING\n", con); con 3019 net/ceph/messenger.c con_flag_clear(con, CON_FLAG_WRITE_PENDING); con 3020 net/ceph/messenger.c con->state = CON_STATE_STANDBY; con 3023 net/ceph/messenger.c con->state = CON_STATE_PREOPEN; con 3024 net/ceph/messenger.c if (con->delay == 0) con 3025 net/ceph/messenger.c con->delay = BASE_DELAY_INTERVAL; con 3026 net/ceph/messenger.c else if (con->delay < MAX_DELAY_INTERVAL) con 3027 net/ceph/messenger.c con->delay *= 2; con 3028 net/ceph/messenger.c con_flag_set(con, CON_FLAG_BACKOFF); con 3029 net/ceph/messenger.c queue_con(con); con 3070 net/ceph/messenger.c static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) con 3072 net/ceph/messenger.c if (msg->con) con 3073 net/ceph/messenger.c msg->con->ops->put(msg->con); con 3075 net/ceph/messenger.c msg->con = con ? con->ops->get(con) : NULL; con 3076 net/ceph/messenger.c BUG_ON(msg->con != con); con 3079 net/ceph/messenger.c static void clear_standby(struct ceph_connection *con) con 3082 net/ceph/messenger.c if (con->state == CON_STATE_STANDBY) { con 3083 net/ceph/messenger.c dout("clear_standby %p and ++connect_seq\n", con); con 3084 net/ceph/messenger.c con->state = CON_STATE_PREOPEN; con 3085 net/ceph/messenger.c con->connect_seq++; con 3086 net/ceph/messenger.c WARN_ON(con_flag_test(con, CON_FLAG_WRITE_PENDING)); con 3087 net/ceph/messenger.c WARN_ON(con_flag_test(con, CON_FLAG_KEEPALIVE_PENDING)); con 3094 net/ceph/messenger.c void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) con 3097 net/ceph/messenger.c msg->hdr.src = con->msgr->inst.name; con 3101 net/ceph/messenger.c mutex_lock(&con->mutex); con 3103 net/ceph/messenger.c if (con->state == CON_STATE_CLOSED) { con 3104 net/ceph/messenger.c dout("con_send %p closed, dropping %p\n", con, msg); con 3106 net/ceph/messenger.c mutex_unlock(&con->mutex); con 3110 net/ceph/messenger.c msg_con_set(msg, con); con 3113 net/ceph/messenger.c list_add_tail(&msg->list_head, &con->out_queue); con 3115 net/ceph/messenger.c ENTITY_NAME(con->peer_name), le16_to_cpu(msg->hdr.type), con 3121 net/ceph/messenger.c clear_standby(con); con 3122 net/ceph/messenger.c mutex_unlock(&con->mutex); con 3126 net/ceph/messenger.c if (con_flag_test_and_set(con, CON_FLAG_WRITE_PENDING) == 0) con 3127 net/ceph/messenger.c queue_con(con); con 3136 net/ceph/messenger.c struct ceph_connection *con = msg->con; con 3138 net/ceph/messenger.c if (!con) { con 3143 net/ceph/messenger.c mutex_lock(&con->mutex); con 3145 net/ceph/messenger.c dout("%s %p msg %p - was on queue\n", __func__, con, msg); con 3151 net/ceph/messenger.c if (con->out_msg == msg) { con 3152 net/ceph/messenger.c BUG_ON(con->out_skip); con 3154 net/ceph/messenger.c if (con->out_msg_done) { con 3155 net/ceph/messenger.c con->out_skip += con_out_kvec_skip(con); con 3158 net/ceph/messenger.c con->out_skip += sizeof_footer(con); con 3162 net/ceph/messenger.c con->out_skip += msg->cursor.total_resid; con 3164 net/ceph/messenger.c con->out_skip += con_out_kvec_skip(con); con 3165 net/ceph/messenger.c con->out_skip += con_out_kvec_skip(con); con 3168 net/ceph/messenger.c __func__, con, msg, con->out_kvec_bytes, con->out_skip); con 3170 net/ceph/messenger.c con->out_msg = NULL; con 3174 net/ceph/messenger.c mutex_unlock(&con->mutex); con 3182 net/ceph/messenger.c struct ceph_connection *con = msg->con; con 3184 net/ceph/messenger.c if (!con) { con 3189 net/ceph/messenger.c mutex_lock(&con->mutex); con 3190 net/ceph/messenger.c if (con->in_msg == msg) { con 3191 net/ceph/messenger.c unsigned int front_len = le32_to_cpu(con->in_hdr.front_len); con 3192 net/ceph/messenger.c unsigned int middle_len = le32_to_cpu(con->in_hdr.middle_len); con 3193 net/ceph/messenger.c unsigned int data_len = le32_to_cpu(con->in_hdr.data_len); con 3196 net/ceph/messenger.c dout("%s %p msg %p revoked\n", __func__, con, msg); con 3197 net/ceph/messenger.c con->in_base_pos = con->in_base_pos - con 3203 net/ceph/messenger.c ceph_msg_put(con->in_msg); con 3204 net/ceph/messenger.c con->in_msg = NULL; con 3205 net/ceph/messenger.c con->in_tag = CEPH_MSGR_TAG_READY; con 3206 net/ceph/messenger.c con->in_seq++; con 3209 net/ceph/messenger.c __func__, con, con->in_msg, msg); con 3211 net/ceph/messenger.c mutex_unlock(&con->mutex); con 3217 net/ceph/messenger.c void ceph_con_keepalive(struct ceph_connection *con) con 3219 net/ceph/messenger.c dout("con_keepalive %p\n", con); con 3220 net/ceph/messenger.c mutex_lock(&con->mutex); con 3221 net/ceph/messenger.c clear_standby(con); con 3222 net/ceph/messenger.c con_flag_set(con, CON_FLAG_KEEPALIVE_PENDING); con 3223 net/ceph/messenger.c mutex_unlock(&con->mutex); con 3225 net/ceph/messenger.c if (con_flag_test_and_set(con, CON_FLAG_WRITE_PENDING) == 0) con 3226 net/ceph/messenger.c queue_con(con); con 3230 net/ceph/messenger.c bool ceph_con_keepalive_expired(struct ceph_connection *con, con 3234 net/ceph/messenger.c (con->peer_features & CEPH_FEATURE_MSGR_KEEPALIVE2)) { con 3239 net/ceph/messenger.c ts = timespec64_add(con->last_keepalive_ack, ts); con 3400 net/ceph/messenger.c static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) con 3431 net/ceph/messenger.c static int ceph_con_in_msg_alloc(struct ceph_connection *con, int *skip) con 3433 net/ceph/messenger.c struct ceph_msg_header *hdr = &con->in_hdr; con 3438 net/ceph/messenger.c BUG_ON(con->in_msg != NULL); con 3439 net/ceph/messenger.c BUG_ON(!con->ops->alloc_msg); con 3441 net/ceph/messenger.c mutex_unlock(&con->mutex); con 3442 net/ceph/messenger.c msg = con->ops->alloc_msg(con, hdr, skip); con 3443 net/ceph/messenger.c mutex_lock(&con->mutex); con 3444 net/ceph/messenger.c if (con->state != CON_STATE_OPEN) { con 3451 net/ceph/messenger.c msg_con_set(msg, con); con 3452 net/ceph/messenger.c con->in_msg = msg; con 3462 net/ceph/messenger.c con->error_msg = "error allocating memory for incoming message"; con 3465 net/ceph/messenger.c memcpy(&con->in_msg->hdr, &con->in_hdr, sizeof(con->in_hdr)); con 3467 net/ceph/messenger.c if (middle_len && !con->in_msg->middle) { con 3468 net/ceph/messenger.c ret = ceph_alloc_middle(con, con->in_msg); con 3470 net/ceph/messenger.c ceph_msg_put(con->in_msg); con 3471 net/ceph/messenger.c con->in_msg = NULL; con 115 net/ceph/mon_client.c ceph_con_send(&monc->con, monc->m_auth); con 128 net/ceph/mon_client.c ceph_con_close(&monc->con); con 189 net/ceph/mon_client.c ceph_con_open(&monc->con, CEPH_ENTITY_TYPE_MON, monc->cur_mon, con 196 net/ceph/mon_client.c ceph_con_keepalive(&monc->con); con 210 net/ceph/mon_client.c monc->cur_mon, ceph_pr_addr(&monc->con.peer_addr)); con 306 net/ceph/mon_client.c ceph_con_send(&monc->con, ceph_msg_get(msg)); con 572 net/ceph/mon_client.c ceph_con_send(&monc->con, ceph_msg_get(req->request)); con 633 net/ceph/mon_client.c static struct ceph_msg *get_generic_reply(struct ceph_connection *con, con 637 net/ceph/mon_client.c struct ceph_mon_client *monc = con->private; con 964 net/ceph/mon_client.c ceph_con_send(&monc->con, ceph_msg_get(req->request)); con 985 net/ceph/mon_client.c if (ceph_con_keepalive_expired(&monc->con, con 993 net/ceph/mon_client.c ceph_con_keepalive(&monc->con); con 999 net/ceph/mon_client.c !(monc->con.peer_features & CEPH_FEATURE_MON_STATEFUL_SUB)) { con 1088 net/ceph/mon_client.c ceph_con_init(&monc->con, monc, &mon_con_ops, con 1193 net/ceph/mon_client.c ceph_pr_addr(&monc->con.peer_addr)); con 1231 net/ceph/mon_client.c static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) con 1233 net/ceph/mon_client.c struct ceph_mon_client *monc = con->private; con 1283 net/ceph/mon_client.c static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, con 1287 net/ceph/mon_client.c struct ceph_mon_client *monc = con->private; con 1300 net/ceph/mon_client.c return get_generic_reply(con, hdr, skip); con 1306 net/ceph/mon_client.c return get_generic_reply(con, hdr, skip); con 1330 net/ceph/mon_client.c (unsigned int)con->peer_name.type, con 1331 net/ceph/mon_client.c le64_to_cpu(con->peer_name.num)); con 1343 net/ceph/mon_client.c static void mon_fault(struct ceph_connection *con) con 1345 net/ceph/mon_client.c struct ceph_mon_client *monc = con->private; con 1366 net/ceph/mon_client.c static struct ceph_connection *con_get(struct ceph_connection *con) con 1368 net/ceph/mon_client.c return con; con 1371 net/ceph/mon_client.c static void con_put(struct ceph_connection *con) con 2124 net/ceph/osd_client.c if (CEPH_HAVE_FEATURE(msg->con->peer_features, RESEND_ON_SPLIT)) { con 2127 net/ceph/osd_client.c ceph_encode_64(&p, msg->con->peer_features); con 4098 net/ceph/osd_client.c static void osd_fault(struct ceph_connection *con) con 4100 net/ceph/osd_client.c struct ceph_osd *osd = con->private; con 5408 net/ceph/osd_client.c static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) con 5410 net/ceph/osd_client.c struct ceph_osd *osd = con->private; con 5441 net/ceph/osd_client.c static struct ceph_msg *get_reply(struct ceph_connection *con, con 5445 net/ceph/osd_client.c struct ceph_osd *osd = con->private; con 5530 net/ceph/osd_client.c static struct ceph_msg *alloc_msg(struct ceph_connection *con, con 5534 net/ceph/osd_client.c struct ceph_osd *osd = con->private; con 5544 net/ceph/osd_client.c return get_reply(con, hdr, skip); con 5556 net/ceph/osd_client.c static struct ceph_connection *get_osd_con(struct ceph_connection *con) con 5558 net/ceph/osd_client.c struct ceph_osd *osd = con->private; con 5560 net/ceph/osd_client.c return con; con 5564 net/ceph/osd_client.c static void put_osd_con(struct ceph_connection *con) con 5566 net/ceph/osd_client.c struct ceph_osd *osd = con->private; con 5577 net/ceph/osd_client.c static struct ceph_auth_handshake *get_authorizer(struct ceph_connection *con, con 5580 net/ceph/osd_client.c struct ceph_osd *o = con->private; con 5605 net/ceph/osd_client.c static int add_authorizer_challenge(struct ceph_connection *con, con 5608 net/ceph/osd_client.c struct ceph_osd *o = con->private; con 5616 net/ceph/osd_client.c static int verify_authorizer_reply(struct ceph_connection *con) con 5618 net/ceph/osd_client.c struct ceph_osd *o = con->private; con 5625 net/ceph/osd_client.c static int invalidate_authorizer(struct ceph_connection *con) con 5627 net/ceph/osd_client.c struct ceph_osd *o = con->private; con 5645 net/ceph/osd_client.c struct ceph_osd *o = msg->con->private; con 5653 net/ceph/osd_client.c struct ceph_osd *o = msg->con->private; con 1029 net/tipc/netlink_compat.c struct nlattr *con[TIPC_NLA_CON_MAX + 1]; con 1031 net/tipc/netlink_compat.c err = nla_parse_nested_deprecated(con, TIPC_NLA_CON_MAX, con 1038 net/tipc/netlink_compat.c node = nla_get_u32(con[TIPC_NLA_CON_NODE]); con 1043 net/tipc/netlink_compat.c nla_get_u32(con[TIPC_NLA_CON_SOCK])); con 1045 net/tipc/netlink_compat.c if (con[TIPC_NLA_CON_FLAG]) con 1047 net/tipc/netlink_compat.c nla_get_u32(con[TIPC_NLA_CON_TYPE]), con 1048 net/tipc/netlink_compat.c nla_get_u32(con[TIPC_NLA_CON_INST])); con 117 net/tipc/topsrv.c static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s); con 119 net/tipc/topsrv.c static bool connected(struct tipc_conn *con) con 121 net/tipc/topsrv.c return con && test_bit(CF_CONNECTED, &con->flags); con 126 net/tipc/topsrv.c struct tipc_conn *con = container_of(kref, struct tipc_conn, kref); con 127 net/tipc/topsrv.c struct tipc_topsrv *s = con->server; con 131 net/tipc/topsrv.c idr_remove(&s->conn_idr, con->conid); con 134 net/tipc/topsrv.c if (con->sock) con 135 net/tipc/topsrv.c sock_release(con->sock); con 137 net/tipc/topsrv.c spin_lock_bh(&con->outqueue_lock); con 138 net/tipc/topsrv.c list_for_each_entry_safe(e, safe, &con->outqueue, list) { con 142 net/tipc/topsrv.c spin_unlock_bh(&con->outqueue_lock); con 143 net/tipc/topsrv.c kfree(con); con 146 net/tipc/topsrv.c static void conn_put(struct tipc_conn *con) con 148 net/tipc/topsrv.c kref_put(&con->kref, tipc_conn_kref_release); con 151 net/tipc/topsrv.c static void conn_get(struct tipc_conn *con) con 153 net/tipc/topsrv.c kref_get(&con->kref); con 156 net/tipc/topsrv.c static void tipc_conn_close(struct tipc_conn *con) con 158 net/tipc/topsrv.c struct sock *sk = con->sock->sk; con 162 net/tipc/topsrv.c disconnect = test_and_clear_bit(CF_CONNECTED, &con->flags); con 166 net/tipc/topsrv.c tipc_conn_delete_sub(con, NULL); con 175 net/tipc/topsrv.c kernel_sock_shutdown(con->sock, SHUT_RDWR); con 177 net/tipc/topsrv.c conn_put(con); con 182 net/tipc/topsrv.c struct tipc_conn *con; con 185 net/tipc/topsrv.c con = kzalloc(sizeof(*con), GFP_ATOMIC); con 186 net/tipc/topsrv.c if (!con) con 189 net/tipc/topsrv.c kref_init(&con->kref); con 190 net/tipc/topsrv.c INIT_LIST_HEAD(&con->outqueue); con 191 net/tipc/topsrv.c INIT_LIST_HEAD(&con->sub_list); con 192 net/tipc/topsrv.c spin_lock_init(&con->outqueue_lock); con 193 net/tipc/topsrv.c spin_lock_init(&con->sub_lock); con 194 net/tipc/topsrv.c INIT_WORK(&con->swork, tipc_conn_send_work); con 195 net/tipc/topsrv.c INIT_WORK(&con->rwork, tipc_conn_recv_work); con 198 net/tipc/topsrv.c ret = idr_alloc(&s->conn_idr, con, 0, 0, GFP_ATOMIC); con 200 net/tipc/topsrv.c kfree(con); con 204 net/tipc/topsrv.c con->conid = ret; con 208 net/tipc/topsrv.c set_bit(CF_CONNECTED, &con->flags); con 209 net/tipc/topsrv.c con->server = s; con 211 net/tipc/topsrv.c return con; con 216 net/tipc/topsrv.c struct tipc_conn *con; con 219 net/tipc/topsrv.c con = idr_find(&s->conn_idr, conid); con 220 net/tipc/topsrv.c if (!connected(con) || !kref_get_unless_zero(&con->kref)) con 221 net/tipc/topsrv.c con = NULL; con 223 net/tipc/topsrv.c return con; con 229 net/tipc/topsrv.c static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s) con 231 net/tipc/topsrv.c struct tipc_net *tn = tipc_net(con->server->net); con 232 net/tipc/topsrv.c struct list_head *sub_list = &con->sub_list; con 235 net/tipc/topsrv.c spin_lock_bh(&con->sub_lock); con 244 net/tipc/topsrv.c spin_unlock_bh(&con->sub_lock); con 247 net/tipc/topsrv.c static void tipc_conn_send_to_sock(struct tipc_conn *con) con 249 net/tipc/topsrv.c struct list_head *queue = &con->outqueue; con 250 net/tipc/topsrv.c struct tipc_topsrv *srv = con->server; con 258 net/tipc/topsrv.c spin_lock_bh(&con->outqueue_lock); con 263 net/tipc/topsrv.c spin_unlock_bh(&con->outqueue_lock); con 266 net/tipc/topsrv.c tipc_conn_delete_sub(con, &evt->s); con 274 net/tipc/topsrv.c if (con->sock) { con 275 net/tipc/topsrv.c ret = kernel_sendmsg(con->sock, &msg, &iov, con 281 net/tipc/topsrv.c return tipc_conn_close(con); con 292 net/tipc/topsrv.c spin_lock_bh(&con->outqueue_lock); con 296 net/tipc/topsrv.c spin_unlock_bh(&con->outqueue_lock); con 301 net/tipc/topsrv.c struct tipc_conn *con = container_of(work, struct tipc_conn, swork); con 303 net/tipc/topsrv.c if (connected(con)) con 304 net/tipc/topsrv.c tipc_conn_send_to_sock(con); con 306 net/tipc/topsrv.c conn_put(con); con 317 net/tipc/topsrv.c struct tipc_conn *con; con 319 net/tipc/topsrv.c con = tipc_conn_lookup(srv, conid); con 320 net/tipc/topsrv.c if (!con) con 323 net/tipc/topsrv.c if (!connected(con)) con 331 net/tipc/topsrv.c spin_lock_bh(&con->outqueue_lock); con 332 net/tipc/topsrv.c list_add_tail(&e->list, &con->outqueue); con 333 net/tipc/topsrv.c spin_unlock_bh(&con->outqueue_lock); con 335 net/tipc/topsrv.c if (queue_work(srv->send_wq, &con->swork)) con 338 net/tipc/topsrv.c conn_put(con); con 347 net/tipc/topsrv.c struct tipc_conn *con; con 350 net/tipc/topsrv.c con = sk->sk_user_data; con 351 net/tipc/topsrv.c if (connected(con)) { con 352 net/tipc/topsrv.c conn_get(con); con 353 net/tipc/topsrv.c if (!queue_work(con->server->send_wq, &con->swork)) con 354 net/tipc/topsrv.c conn_put(con); con 360 net/tipc/topsrv.c struct tipc_conn *con, con 368 net/tipc/topsrv.c tipc_conn_delete_sub(con, s); con 375 net/tipc/topsrv.c sub = tipc_sub_subscribe(srv->net, s, con->conid); con 379 net/tipc/topsrv.c spin_lock_bh(&con->sub_lock); con 380 net/tipc/topsrv.c list_add(&sub->sub_list, &con->sub_list); con 381 net/tipc/topsrv.c spin_unlock_bh(&con->sub_lock); con 385 net/tipc/topsrv.c static int tipc_conn_rcv_from_sock(struct tipc_conn *con) con 387 net/tipc/topsrv.c struct tipc_topsrv *srv = con->server; con 388 net/tipc/topsrv.c struct sock *sk = con->sock->sk; con 398 net/tipc/topsrv.c ret = sock_recvmsg(con->sock, &msg, MSG_DONTWAIT); con 403 net/tipc/topsrv.c ret = tipc_conn_rcv_sub(srv, con, &s); con 409 net/tipc/topsrv.c tipc_conn_close(con); con 415 net/tipc/topsrv.c struct tipc_conn *con = container_of(work, struct tipc_conn, rwork); con 418 net/tipc/topsrv.c while (connected(con)) { con 419 net/tipc/topsrv.c if (tipc_conn_rcv_from_sock(con)) con 428 net/tipc/topsrv.c conn_put(con); con 436 net/tipc/topsrv.c struct tipc_conn *con; con 439 net/tipc/topsrv.c con = sk->sk_user_data; con 440 net/tipc/topsrv.c if (connected(con)) { con 441 net/tipc/topsrv.c conn_get(con); con 442 net/tipc/topsrv.c if (!queue_work(con->server->rcv_wq, &con->rwork)) con 443 net/tipc/topsrv.c conn_put(con); con 453 net/tipc/topsrv.c struct tipc_conn *con; con 461 net/tipc/topsrv.c con = tipc_conn_alloc(srv); con 462 net/tipc/topsrv.c if (IS_ERR(con)) { con 463 net/tipc/topsrv.c ret = PTR_ERR(con); con 472 net/tipc/topsrv.c newsk->sk_user_data = con; con 473 net/tipc/topsrv.c con->sock = newsock; con 561 net/tipc/topsrv.c struct tipc_conn *con; con 571 net/tipc/topsrv.c con = tipc_conn_alloc(tipc_topsrv(net)); con 572 net/tipc/topsrv.c if (IS_ERR(con)) con 575 net/tipc/topsrv.c *conid = con->conid; con 576 net/tipc/topsrv.c con->sock = NULL; con 577 net/tipc/topsrv.c rc = tipc_conn_rcv_sub(tipc_topsrv(net), con, &sub); con 580 net/tipc/topsrv.c conn_put(con); con 586 net/tipc/topsrv.c struct tipc_conn *con; con 588 net/tipc/topsrv.c con = tipc_conn_lookup(tipc_topsrv(net), conid); con 589 net/tipc/topsrv.c if (!con) con 592 net/tipc/topsrv.c test_and_clear_bit(CF_CONNECTED, &con->flags); con 593 net/tipc/topsrv.c tipc_conn_delete_sub(con, NULL); con 594 net/tipc/topsrv.c conn_put(con); con 595 net/tipc/topsrv.c conn_put(con); con 678 net/tipc/topsrv.c struct tipc_conn *con; con 683 net/tipc/topsrv.c con = idr_find(&srv->conn_idr, id); con 684 net/tipc/topsrv.c if (con) { con 686 net/tipc/topsrv.c tipc_conn_close(con); con 1032 security/selinux/selinuxfs.c char *con = NULL, *user = NULL, *ptr; con 1047 security/selinux/selinuxfs.c con = kzalloc(size + 1, GFP_KERNEL); con 1048 security/selinux/selinuxfs.c if (!con) con 1057 security/selinux/selinuxfs.c if (sscanf(buf, "%s %s", con, user) != 2) con 1060 security/selinux/selinuxfs.c length = security_context_str_to_sid(state, con, &sid, GFP_KERNEL); con 1089 security/selinux/selinuxfs.c kfree(con); con 1610 security/selinux/selinuxfs.c char *con; con 1615 security/selinux/selinuxfs.c ret = security_sid_to_context(fsi->state, sid, &con, &len); con 1619 security/selinux/selinuxfs.c ret = simple_read_from_buffer(buf, count, ppos, con, len); con 1620 security/selinux/selinuxfs.c kfree(con); con 396 sound/soc/samsung/i2s.c u32 con = readl(addr + I2SCON); con 400 sound/soc/samsung/i2s.c con |= CON_ACTIVE; con 401 sound/soc/samsung/i2s.c con &= ~CON_TXCH_PAUSE; con 404 sound/soc/samsung/i2s.c con |= CON_TXSDMA_ACTIVE; con 405 sound/soc/samsung/i2s.c con &= ~CON_TXSDMA_PAUSE; con 407 sound/soc/samsung/i2s.c con |= CON_TXDMA_ACTIVE; con 408 sound/soc/samsung/i2s.c con &= ~CON_TXDMA_PAUSE; con 417 sound/soc/samsung/i2s.c con |= CON_TXSDMA_PAUSE; con 418 sound/soc/samsung/i2s.c con &= ~CON_TXSDMA_ACTIVE; con 420 sound/soc/samsung/i2s.c con |= CON_TXDMA_PAUSE; con 421 sound/soc/samsung/i2s.c con &= ~CON_TXDMA_ACTIVE; con 425 sound/soc/samsung/i2s.c writel(con, addr + I2SCON); con 429 sound/soc/samsung/i2s.c con |= CON_TXCH_PAUSE; con 434 sound/soc/samsung/i2s.c con &= ~CON_ACTIVE; con 438 sound/soc/samsung/i2s.c writel(con, addr + I2SCON); con 447 sound/soc/samsung/i2s.c u32 con = readl(addr + I2SCON); con 451 sound/soc/samsung/i2s.c con |= CON_RXDMA_ACTIVE | CON_ACTIVE; con 452 sound/soc/samsung/i2s.c con &= ~(CON_RXDMA_PAUSE | CON_RXCH_PAUSE); con 459 sound/soc/samsung/i2s.c con |= CON_RXDMA_PAUSE | CON_RXCH_PAUSE; con 460 sound/soc/samsung/i2s.c con &= ~CON_RXDMA_ACTIVE; con 465 sound/soc/samsung/i2s.c con &= ~CON_ACTIVE; con 469 sound/soc/samsung/i2s.c writel(con, addr + I2SCON); con 45 sound/soc/samsung/s3c-i2s-v2.c static void dbg_showcon(const char *fn, u32 con) con 48 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_LRINDEX), con 49 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_TXFIFO_EMPTY), con 50 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_RXFIFO_EMPTY), con 51 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_TXFIFO_FULL), con 52 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_RXFIFO_FULL)); con 56 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_TXDMA_PAUSE), con 57 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_RXDMA_PAUSE), con 58 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_TXCH_PAUSE), con 59 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_RXCH_PAUSE)); con 61 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_TXDMA_ACTIVE), con 62 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_RXDMA_ACTIVE), con 63 sound/soc/samsung/s3c-i2s-v2.c bit_set(con, S3C2412_IISCON_IIS_ACTIVE)); con 66 sound/soc/samsung/s3c-i2s-v2.c static inline void dbg_showcon(const char *fn, u32 con) con 75 sound/soc/samsung/s3c-i2s-v2.c u32 fic, con, mod; con 80 sound/soc/samsung/s3c-i2s-v2.c con = readl(regs + S3C2412_IISCON); con 83 sound/soc/samsung/s3c-i2s-v2.c pr_debug("%s: IIS: CON=%x MOD=%x FIC=%x\n", __func__, con, mod, fic); con 86 sound/soc/samsung/s3c-i2s-v2.c con |= S3C2412_IISCON_TXDMA_ACTIVE | S3C2412_IISCON_IIS_ACTIVE; con 87 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_TXDMA_PAUSE; con 88 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_TXCH_PAUSE; con 107 sound/soc/samsung/s3c-i2s-v2.c writel(con, regs + S3C2412_IISCON); con 115 sound/soc/samsung/s3c-i2s-v2.c con |= S3C2412_IISCON_TXDMA_PAUSE; con 116 sound/soc/samsung/s3c-i2s-v2.c con |= S3C2412_IISCON_TXCH_PAUSE; con 117 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_TXDMA_ACTIVE; con 127 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_IIS_ACTIVE; con 137 sound/soc/samsung/s3c-i2s-v2.c writel(con, regs + S3C2412_IISCON); con 141 sound/soc/samsung/s3c-i2s-v2.c dbg_showcon(__func__, con); con 142 sound/soc/samsung/s3c-i2s-v2.c pr_debug("%s: IIS: CON=%x MOD=%x FIC=%x\n", __func__, con, mod, fic); con 148 sound/soc/samsung/s3c-i2s-v2.c u32 fic, con, mod; con 153 sound/soc/samsung/s3c-i2s-v2.c con = readl(regs + S3C2412_IISCON); con 156 sound/soc/samsung/s3c-i2s-v2.c pr_debug("%s: IIS: CON=%x MOD=%x FIC=%x\n", __func__, con, mod, fic); con 159 sound/soc/samsung/s3c-i2s-v2.c con |= S3C2412_IISCON_RXDMA_ACTIVE | S3C2412_IISCON_IIS_ACTIVE; con 160 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_RXDMA_PAUSE; con 161 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_RXCH_PAUSE; con 180 sound/soc/samsung/s3c-i2s-v2.c writel(con, regs + S3C2412_IISCON); con 184 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_RXDMA_ACTIVE; con 185 sound/soc/samsung/s3c-i2s-v2.c con |= S3C2412_IISCON_RXDMA_PAUSE; con 186 sound/soc/samsung/s3c-i2s-v2.c con |= S3C2412_IISCON_RXCH_PAUSE; con 190 sound/soc/samsung/s3c-i2s-v2.c con &= ~S3C2412_IISCON_IIS_ACTIVE; con 204 sound/soc/samsung/s3c-i2s-v2.c writel(con, regs + S3C2412_IISCON); con 209 sound/soc/samsung/s3c-i2s-v2.c pr_debug("%s: IIS: CON=%x MOD=%x FIC=%x\n", __func__, con, mod, fic); con 178 sound/soc/samsung/spdif.c u32 con, clkcon, cstas; con 195 sound/soc/samsung/spdif.c con = readl(regs + CON) & CON_MASK; con 199 sound/soc/samsung/spdif.c con &= ~CON_FIFO_TH_MASK; con 200 sound/soc/samsung/spdif.c con |= (0x7 << CON_FIFO_TH_SHIFT); con 201 sound/soc/samsung/spdif.c con |= CON_USERDATA_23RDBIT; con 202 sound/soc/samsung/spdif.c con |= CON_PCM_DATA; con 204 sound/soc/samsung/spdif.c con &= ~CON_PCM_MASK; con 207 sound/soc/samsung/spdif.c con |= CON_PCM_16BIT; con 224 sound/soc/samsung/spdif.c con &= ~CON_MCLKDIV_MASK; con 227 sound/soc/samsung/spdif.c con |= CON_MCLKDIV_256FS; con 230 sound/soc/samsung/spdif.c con |= CON_MCLKDIV_384FS; con 233 sound/soc/samsung/spdif.c con |= CON_MCLKDIV_512FS; con 261 sound/soc/samsung/spdif.c writel(con, regs + CON); con 279 sound/soc/samsung/spdif.c u32 con, clkcon; con 283 sound/soc/samsung/spdif.c con = readl(regs + CON) & CON_MASK; con 286 sound/soc/samsung/spdif.c writel(con | CON_SW_RESET, regs + CON); con 296 sound/soc/samsung/spdif.c u32 con = spdif->saved_con; con 304 sound/soc/samsung/spdif.c writel(con | CON_SW_RESET, spdif->regs + CON); con 1196 sound/soc/soc-dapm.c int con = 0; con 1230 sound/soc/soc-dapm.c con += fn(path->node[dir], list, custom_stop_condition); con 1235 sound/soc/soc-dapm.c widget->endpoints[dir] = con; con 1237 sound/soc/soc-dapm.c return con; con 902 tools/firewire/nosy-dump.c poptContext con; con 908 tools/firewire/nosy-dump.c con = poptGetContext(NULL, argc, argv, options, 0); con 909 tools/firewire/nosy-dump.c retval = poptGetNextOpt(con); con 911 tools/firewire/nosy-dump.c poptPrintUsage(con, stdout, 0); con 1019 tools/firewire/nosy-dump.c poptFreeContext(con);