@@ -813,7 +813,7 @@ fn read_common_impl(socket_data: *tcp_socket_data, timeout_msecs: uint)
813
813
log ( debug, "starting tcp::read" ) ;
814
814
let iotask = ( * socket_data) . iotask ;
815
815
let rs_result = read_start_common_impl ( socket_data) ;
816
- if result:: is_failure ( rs_result) {
816
+ if result:: is_err ( rs_result) {
817
817
let err_data = result:: get_err ( rs_result) ;
818
818
result:: err ( err_data)
819
819
}
@@ -1424,7 +1424,7 @@ mod test {
1424
1424
1425
1425
let accept_result = accept ( new_conn) ;
1426
1426
log ( debug, "SERVER: after accept()" ) ;
1427
- if result:: is_failure ( accept_result) {
1427
+ if result:: is_err ( accept_result) {
1428
1428
log ( debug, "SERVER: error accept connection" ) ;
1429
1429
let err_data = result:: get_err ( accept_result) ;
1430
1430
comm:: send ( kill_ch, some ( err_data) ) ;
@@ -1465,7 +1465,7 @@ mod test {
1465
1465
log ( debug, "SERVER: recv'd on cont_ch..leaving listen cb" ) ;
1466
1466
} ) ;
1467
1467
// err check on listen_result
1468
- if result:: is_failure ( listen_result) {
1468
+ if result:: is_err ( listen_result) {
1469
1469
let err_data = result:: get_err ( listen_result) ;
1470
1470
log ( debug, #fmt ( "SERVER: exited abnormally name %s msg %s" ,
1471
1471
err_data. err_name , err_data. err_msg ) ) ;
@@ -1486,7 +1486,7 @@ mod test {
1486
1486
let server_ip_addr = ip:: v4:: parse_addr ( server_ip) ;
1487
1487
let new_listener_result =
1488
1488
new_listener ( server_ip_addr, server_port, 128 u, iotask) ;
1489
- if result:: is_failure ( new_listener_result) {
1489
+ if result:: is_err ( new_listener_result) {
1490
1490
let err_data = result:: get_err ( new_listener_result) ;
1491
1491
log ( debug, #fmt ( "SERVER: exited abnormally name %s msg %s" ,
1492
1492
err_data. err_name , err_data. err_msg ) ) ;
@@ -1498,7 +1498,7 @@ mod test {
1498
1498
// in a loop {}, but we're just going to take a single
1499
1499
// client.. get their req, write a resp and then exit
1500
1500
let new_conn_result = server_port. recv ( ) ;
1501
- if result:: is_failure ( new_conn_result) {
1501
+ if result:: is_err ( new_conn_result) {
1502
1502
let err_data = result:: get_err ( new_conn_result) ;
1503
1503
log ( debug, #fmt ( "SERVER: exited abnormally name %s msg %s" ,
1504
1504
err_data. err_name , err_data. err_msg ) ) ;
@@ -1535,7 +1535,7 @@ mod test {
1535
1535
1536
1536
log ( debug, "CLIENT: starting.." ) ;
1537
1537
let connect_result = connect ( server_ip_addr, server_port, iotask) ;
1538
- if result:: is_failure ( connect_result) {
1538
+ if result:: is_err ( connect_result) {
1539
1539
log ( debug, "CLIENT: failed to connect" ) ;
1540
1540
let err_data = result:: get_err ( connect_result) ;
1541
1541
log ( debug, #fmt ( "CLIENT: connect err name: %s msg: %s" ,
@@ -1547,7 +1547,7 @@ mod test {
1547
1547
let resp_bytes = str:: bytes ( resp) ;
1548
1548
tcp_write_single ( sock, resp_bytes) ;
1549
1549
let read_result = sock. read ( 0 u) ;
1550
- if read_result. is_failure ( ) {
1550
+ if read_result. is_err ( ) {
1551
1551
log ( debug, "CLIENT: failure to read" ) ;
1552
1552
""
1553
1553
}
@@ -1564,7 +1564,7 @@ mod test {
1564
1564
fn tcp_write_single ( sock : tcp_socket , val : [ u8 ] ) {
1565
1565
let write_result_future = sock. write_future ( val) ;
1566
1566
let write_result = write_result_future. get ( ) ;
1567
- if result:: is_failure ( write_result) {
1567
+ if result:: is_err ( write_result) {
1568
1568
log ( debug, "tcp_write_single: write failed!" ) ;
1569
1569
let err_data = result:: get_err ( write_result) ;
1570
1570
log ( debug, #fmt ( "tcp_write_single err name: %s msg: %s" ,
0 commit comments