Lines Matching refs:ret
87 int ret; in ceph_tcp_sendpage() local
103 ret = sock_sendmsg(sock, &msg); in ceph_tcp_sendpage()
104 if (ret == -EAGAIN) in ceph_tcp_sendpage()
105 ret = 0; in ceph_tcp_sendpage()
107 return ret; in ceph_tcp_sendpage()
380 int ret; in prepare_write_connect() local
407 ret = get_connect_authorizer(con); in prepare_write_connect()
408 if (ret) in prepare_write_connect()
409 return ret; in prepare_write_connect()
423 int ret; in write_partial_kvec() local
427 ret = ceph_tcp_sendmsg(con->sock, con->v1.out_kvec_cur, in write_partial_kvec()
431 if (ret <= 0) in write_partial_kvec()
433 con->v1.out_kvec_bytes -= ret; in write_partial_kvec()
438 while (ret >= con->v1.out_kvec_cur->iov_len) { in write_partial_kvec()
440 ret -= con->v1.out_kvec_cur->iov_len; in write_partial_kvec()
445 if (ret) { in write_partial_kvec()
446 con->v1.out_kvec_cur->iov_len -= ret; in write_partial_kvec()
447 con->v1.out_kvec_cur->iov_base += ret; in write_partial_kvec()
451 ret = 1; in write_partial_kvec()
454 con->v1.out_kvec_bytes, con->v1.out_kvec_left, ret); in write_partial_kvec()
455 return ret; /* done! */ in write_partial_kvec()
490 int ret; in write_partial_message_data() local
498 ret = ceph_tcp_sendpage(con->sock, page, page_offset, length, in write_partial_message_data()
500 if (ret <= 0) { in write_partial_message_data()
504 return ret; in write_partial_message_data()
508 ceph_msg_data_advance(cursor, (size_t)ret); in write_partial_message_data()
529 int ret; in write_partial_skip() local
535 ret = ceph_tcp_sendpage(con->sock, ceph_zero_page, 0, size, in write_partial_skip()
537 if (ret <= 0) in write_partial_skip()
539 con->v1.out_skip -= ret; in write_partial_skip()
541 ret = 1; in write_partial_skip()
543 return ret; in write_partial_skip()
605 int ret = ceph_tcp_recvmsg(con->sock, object + have, left); in read_partial() local
606 if (ret <= 0) in read_partial()
607 return ret; in read_partial()
608 con->v1.in_base_pos += ret; in read_partial()
620 int ret; in read_partial_banner() local
627 ret = read_partial(con, end, size, con->v1.in_banner); in read_partial_banner()
628 if (ret <= 0) in read_partial_banner()
633 ret = read_partial(con, end, size, &con->v1.actual_peer_addr); in read_partial_banner()
634 if (ret <= 0) in read_partial_banner()
640 ret = read_partial(con, end, size, &con->v1.peer_addr_for_me); in read_partial_banner()
641 if (ret <= 0) in read_partial_banner()
646 return ret; in read_partial_banner()
653 int ret; in read_partial_connect() local
659 ret = read_partial(con, end, size, &con->v1.in_reply); in read_partial_connect()
660 if (ret <= 0) in read_partial_connect()
668 ret = -EINVAL; in read_partial_connect()
673 ret = read_partial(con, end, size, in read_partial_connect()
675 if (ret <= 0) in read_partial_connect()
684 return ret; in read_partial_connect()
749 int ret; in process_connect() local
765 ret = con->ops->add_authorizer_challenge( in process_connect()
767 if (ret < 0) in process_connect()
768 return ret; in process_connect()
777 ret = con->ops->verify_authorizer_reply(con); in process_connect()
778 if (ret < 0) { in process_connect()
780 return ret; in process_connect()
814 ret = prepare_write_connect(con); in process_connect()
815 if (ret < 0) in process_connect()
816 return ret; in process_connect()
835 ret = prepare_write_connect(con); in process_connect()
836 if (ret < 0) in process_connect()
837 return ret; in process_connect()
859 ret = prepare_write_connect(con); in process_connect()
860 if (ret < 0) in process_connect()
861 return ret; in process_connect()
876 ret = prepare_write_connect(con); in process_connect()
877 if (ret < 0) in process_connect()
878 return ret; in process_connect()
968 int ret, left; in read_partial_message_chunk() local
975 ret = ceph_tcp_recvmsg(con->sock, (char *)section->iov_base + in read_partial_message_chunk()
977 if (ret <= 0) in read_partial_message_chunk()
978 return ret; in read_partial_message_chunk()
979 section->iov_len += ret; in read_partial_message_chunk()
1011 int ret; in read_partial_sparse_msg_extent() local
1018 ret = ceph_tcp_recvpage(con->sock, rpage, (int)off, len); in read_partial_sparse_msg_extent()
1019 if (ret <= 0) in read_partial_sparse_msg_extent()
1020 return ret; in read_partial_sparse_msg_extent()
1021 *crc = ceph_crc32c_page(*crc, rpage, off, ret); in read_partial_sparse_msg_extent()
1022 ceph_msg_data_advance(cursor, (size_t)ret); in read_partial_sparse_msg_extent()
1023 cursor->sr_resid -= ret; in read_partial_sparse_msg_extent()
1025 memcpy_page(page, off, rpage, off, ret); in read_partial_sparse_msg_extent()
1035 int ret = 1; in read_partial_sparse_msg_data() local
1042 ret = read_partial_message_chunk(con, in read_partial_sparse_msg_data()
1047 ret = read_partial_sparse_msg_extent(con, &crc); in read_partial_sparse_msg_data()
1048 if (ret <= 0) in read_partial_sparse_msg_data()
1052 ret = con->ops->sparse_read(con, cursor, in read_partial_sparse_msg_data()
1054 if (ret <= 0) { in read_partial_sparse_msg_data()
1055 ret = ret ? ret : 1; /* must return > 0 to indicate success */ in read_partial_sparse_msg_data()
1058 con->v1.in_sr_len = ret; in read_partial_sparse_msg_data()
1064 return ret; in read_partial_sparse_msg_data()
1075 int ret; in read_partial_msg_data() local
1086 ret = ceph_tcp_recvpage(con->sock, page, page_offset, length); in read_partial_msg_data()
1087 if (ret <= 0) { in read_partial_msg_data()
1091 return ret; in read_partial_msg_data()
1095 crc = ceph_crc32c_page(crc, page, page_offset, ret); in read_partial_msg_data()
1096 ceph_msg_data_advance(cursor, (size_t)ret); in read_partial_msg_data()
1110 int ret; in read_partial_msg_data_bounce() local
1128 ret = ceph_tcp_recvpage(con->sock, con->bounce_page, 0, len); in read_partial_msg_data_bounce()
1129 if (ret <= 0) { in read_partial_msg_data_bounce()
1131 return ret; in read_partial_msg_data_bounce()
1134 crc = crc32c(crc, page_address(con->bounce_page), ret); in read_partial_msg_data_bounce()
1135 memcpy_to_page(page, off, page_address(con->bounce_page), ret); in read_partial_msg_data_bounce()
1137 ceph_msg_data_advance(cursor, ret); in read_partial_msg_data_bounce()
1152 int ret; in read_partial_message() local
1164 ret = read_partial(con, end, size, &con->v1.in_hdr); in read_partial_message()
1165 if (ret <= 0) in read_partial_message()
1166 return ret; in read_partial_message()
1209 ret = ceph_con_in_msg_alloc(con, &con->v1.in_hdr, &skip); in read_partial_message()
1210 if (ret < 0) in read_partial_message()
1211 return ret; in read_partial_message()
1238 ret = read_partial_message_section(con, &m->front, front_len, in read_partial_message()
1240 if (ret <= 0) in read_partial_message()
1241 return ret; in read_partial_message()
1245 ret = read_partial_message_section(con, &m->middle->vec, in read_partial_message()
1248 if (ret <= 0) in read_partial_message()
1249 return ret; in read_partial_message()
1258 ret = read_partial_sparse_msg_data(con); in read_partial_message()
1260 ret = read_partial_msg_data_bounce(con); in read_partial_message()
1262 ret = read_partial_msg_data(con); in read_partial_message()
1263 if (ret <= 0) in read_partial_message()
1264 return ret; in read_partial_message()
1270 ret = read_partial(con, end, size, &m->footer); in read_partial_message()
1271 if (ret <= 0) in read_partial_message()
1272 return ret; in read_partial_message()
1315 int ret = read_partial(con, size, size, &ceph_ts); in read_keepalive_ack() local
1316 if (ret <= 0) in read_keepalive_ack()
1317 return ret; in read_keepalive_ack()
1328 int ret = -1; in ceph_con_v1_try_read() local
1343 ret = read_partial_banner(con); in ceph_con_v1_try_read()
1344 if (ret <= 0) in ceph_con_v1_try_read()
1346 ret = process_banner(con); in ceph_con_v1_try_read()
1347 if (ret < 0) in ceph_con_v1_try_read()
1357 ret = prepare_write_connect(con); in ceph_con_v1_try_read()
1358 if (ret < 0) in ceph_con_v1_try_read()
1367 ret = read_partial_connect(con); in ceph_con_v1_try_read()
1368 if (ret <= 0) in ceph_con_v1_try_read()
1370 ret = process_connect(con); in ceph_con_v1_try_read()
1371 if (ret < 0) in ceph_con_v1_try_read()
1382 ret = ceph_tcp_recvmsg(con->sock, NULL, -con->v1.in_base_pos); in ceph_con_v1_try_read()
1383 if (ret <= 0) in ceph_con_v1_try_read()
1385 dout("skipped %d / %d bytes\n", ret, -con->v1.in_base_pos); in ceph_con_v1_try_read()
1386 con->v1.in_base_pos += ret; in ceph_con_v1_try_read()
1394 ret = ceph_tcp_recvmsg(con->sock, &con->v1.in_tag, 1); in ceph_con_v1_try_read()
1395 if (ret <= 0) in ceph_con_v1_try_read()
1417 ret = read_partial_message(con); in ceph_con_v1_try_read()
1418 if (ret <= 0) { in ceph_con_v1_try_read()
1419 switch (ret) { in ceph_con_v1_try_read()
1424 ret = -EIO; in ceph_con_v1_try_read()
1445 ret = read_partial_ack(con); in ceph_con_v1_try_read()
1446 if (ret <= 0) in ceph_con_v1_try_read()
1452 ret = read_keepalive_ack(con); in ceph_con_v1_try_read()
1453 if (ret <= 0) in ceph_con_v1_try_read()
1459 dout("try_read done on %p ret %d\n", con, ret); in ceph_con_v1_try_read()
1460 return ret; in ceph_con_v1_try_read()
1465 ret = -1; in ceph_con_v1_try_read()
1475 int ret = 1; in ceph_con_v1_try_write() local
1497 ret = ceph_tcp_connect(con); in ceph_con_v1_try_write()
1498 if (ret < 0) { in ceph_con_v1_try_write()
1510 ret = write_partial_kvec(con); in ceph_con_v1_try_write()
1511 if (ret <= 0) in ceph_con_v1_try_write()
1515 ret = write_partial_skip(con); in ceph_con_v1_try_write()
1516 if (ret <= 0) in ceph_con_v1_try_write()
1528 ret = write_partial_message_data(con); in ceph_con_v1_try_write()
1529 if (ret == 1) in ceph_con_v1_try_write()
1531 if (ret == 0) in ceph_con_v1_try_write()
1533 if (ret < 0) { in ceph_con_v1_try_write()
1535 ret); in ceph_con_v1_try_write()
1561 ret = 0; in ceph_con_v1_try_write()
1563 dout("try_write done on %p ret %d\n", con, ret); in ceph_con_v1_try_write()
1564 return ret; in ceph_con_v1_try_write()