Lines Matching refs:ret
458 int ret;
464 ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family,
467 if (ret)
468 return ret;
480 ret = kernel_connect(sock, (struct sockaddr *)&ss, sizeof(ss),
482 if (ret == -EINPROGRESS) {
486 } else if (ret < 0) {
488 ceph_pr_addr(&con->peer_addr), ret);
490 return ret;
568 int ret;
583 ret = sendpage(sock, page, offset, size, flags);
584 if (ret == -EAGAIN)
585 ret = 0;
587 return ret;
746 u32 ret;
751 ret = ++msgr->global_seq;
753 return ret;
1455 int ret;
1482 ret = get_connect_authorizer(con);
1483 if (ret)
1484 return ret;
1498 int ret;
1502 ret = ceph_tcp_sendmsg(con->sock, con->out_kvec_cur,
1505 if (ret <= 0)
1507 con->out_kvec_bytes -= ret;
1512 while (ret >= con->out_kvec_cur->iov_len) {
1514 ret -= con->out_kvec_cur->iov_len;
1519 if (ret) {
1520 con->out_kvec_cur->iov_len -= ret;
1521 con->out_kvec_cur->iov_base += ret;
1525 ret = 1;
1527 dout("write_partial_kvec %p %d left in %d kvecs ret = %d\n", con,
1528 con->out_kvec_bytes, con->out_kvec_left, ret);
1529 return ret; /* done! */
1578 int ret;
1588 ret = ceph_tcp_sendpage(con->sock, page, page_offset, length,
1590 if (ret <= 0) {
1594 return ret;
1598 ceph_msg_data_advance(cursor, (size_t)ret);
1620 int ret;
1628 ret = ceph_tcp_sendpage(con->sock, zero_page, 0, size, more);
1629 if (ret <= 0)
1631 con->out_skip -= ret;
1633 ret = 1;
1635 return ret;
1698 int ret = ceph_tcp_recvmsg(con->sock, object + have, left);
1699 if (ret <= 0)
1700 return ret;
1701 con->in_base_pos += ret;
1714 int ret;
1721 ret = read_partial(con, end, size, con->in_banner);
1722 if (ret <= 0)
1727 ret = read_partial(con, end, size, &con->actual_peer_addr);
1728 if (ret <= 0)
1734 ret = read_partial(con, end, size, &con->peer_addr_for_me);
1735 if (ret <= 0)
1740 return ret;
1747 int ret;
1753 ret = read_partial(con, end, size, &con->in_reply);
1754 if (ret <= 0)
1762 ret = -EINVAL;
1767 ret = read_partial(con, end, size,
1769 if (ret <= 0)
1778 return ret;
1864 int ip_len, ret;
1890 ret = ceph_pton(ip_addr, ip_len, addr, -1, NULL);
1892 ret = -ESRCH;
1898 pr_info("resolve '%.*s' (ret=%d): %s\n", (int)(end - name), name,
1899 ret, ret ? "failed" : ceph_pr_addr(addr));
1901 return ret;
1918 int ret;
1920 ret = ceph_pton(name, namelen, addr, delim, ipend);
1921 if (ret)
1922 ret = ceph_dns_resolve_name(name, namelen, addr, delim, ipend);
1924 return ret;
1935 int i, ret = -EINVAL;
1949 ret = ceph_parse_server_name(p, end - p, &addr[i], delim, &ipend);
1950 if (ret)
1952 ret = -EINVAL;
2000 return ret;
2051 int ret;
2066 ret = con->ops->add_authorizer_challenge(
2068 if (ret < 0)
2069 return ret;
2078 ret = con->ops->verify_authorizer_reply(con);
2079 if (ret < 0) {
2081 return ret;
2117 ret = prepare_write_connect(con);
2118 if (ret < 0)
2119 return ret;
2138 ret = prepare_write_connect(con);
2139 if (ret < 0)
2140 return ret;
2163 ret = prepare_write_connect(con);
2164 if (ret < 0)
2165 return ret;
2180 ret = prepare_write_connect(con);
2181 if (ret < 0)
2182 return ret;
2291 int ret, left;
2298 ret = ceph_tcp_recvmsg(con->sock, (char *)section->iov_base +
2300 if (ret <= 0)
2301 return ret;
2302 section->iov_len += ret;
2319 int ret;
2333 ret = ceph_tcp_recvpage(con->sock, page, page_offset, length);
2334 if (ret <= 0) {
2338 return ret;
2342 crc = ceph_crc32c_page(crc, page, page_offset, ret);
2343 ceph_msg_data_advance(cursor, (size_t)ret);
2361 int ret;
2373 ret = read_partial(con, end, size, &con->in_hdr);
2374 if (ret <= 0)
2375 return ret;
2418 ret = ceph_con_in_msg_alloc(con, &skip);
2419 if (ret < 0)
2420 return ret;
2447 ret = read_partial_message_section(con, &m->front, front_len,
2449 if (ret <= 0)
2450 return ret;
2454 ret = read_partial_message_section(con, &m->middle->vec,
2457 if (ret <= 0)
2458 return ret;
2463 ret = read_partial_msg_data(con);
2464 if (ret <= 0)
2465 return ret;
2471 ret = read_partial(con, end, size, &m->footer);
2472 if (ret <= 0)
2473 return ret;
2548 int ret = read_partial(con, size, size, &ceph_ts);
2549 if (ret <= 0)
2550 return ret;
2562 int ret = 1;
2584 ret = ceph_tcp_connect(con);
2585 if (ret < 0) {
2597 ret = write_partial_kvec(con);
2598 if (ret <= 0)
2602 ret = write_partial_skip(con);
2603 if (ret <= 0)
2615 ret = write_partial_message_data(con);
2616 if (ret == 1)
2618 if (ret == 0)
2620 if (ret < 0) {
2622 ret);
2647 ret = 0;
2649 dout("try_write done on %p ret %d\n", con, ret);
2650 return ret;
2658 int ret = -1;
2674 ret = read_partial_banner(con);
2675 if (ret <= 0)
2677 ret = process_banner(con);
2678 if (ret < 0)
2688 ret = prepare_write_connect(con);
2689 if (ret < 0)
2699 ret = read_partial_connect(con);
2700 if (ret <= 0)
2702 ret = process_connect(con);
2703 if (ret < 0)
2714 ret = ceph_tcp_recvmsg(con->sock, NULL, -con->in_base_pos);
2715 if (ret <= 0)
2717 dout("skipped %d / %d bytes\n", ret, -con->in_base_pos);
2718 con->in_base_pos += ret;
2726 ret = ceph_tcp_recvmsg(con->sock, &con->in_tag, 1);
2727 if (ret <= 0)
2749 ret = read_partial_message(con);
2750 if (ret <= 0) {
2751 switch (ret) {
2756 ret = -EIO;
2777 ret = read_partial_ack(con);
2778 if (ret <= 0)
2784 ret = read_keepalive_ack(con);
2785 if (ret <= 0)
2791 dout("try_read done on %p ret %d\n", con, ret);
2792 return ret;
2797 ret = -1;
2868 int ret;
2873 ret = queue_con_delay(con, round_jiffies_relative(con->delay));
2874 if (ret) {
2877 BUG_ON(ret == -ENOENT);
2916 int ret;
2940 ret = try_read(con);
2941 if (ret < 0) {
2942 if (ret == -EAGAIN)
2950 ret = try_write(con);
2951 if (ret < 0) {
2952 if (ret == -EAGAIN)
3432 int ret = 0;
3464 ret = ceph_alloc_middle(con, con->in_msg);
3465 if (ret < 0) {
3471 return ret;