mirror/v
1
0
Fork 0
mirror of https://github.com/vlang/v.git synced 2023-08-10 21:13:21 +03:00
Code Issues Projects Releases Wiki Activity

net: format the output of -d trace_tcp output better

Browse Source
This commit is contained in:
Delyan Angelov 2021-04-23 17:02:15 +03:00
parent 42a65e1009
commit e6c4c4de3d
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
vlib/net/tcp.v
View File

@ -29,7 +29,7 @@ pub fn dial_tcp(address string) ?&TcpConn {
pub fn (mut c TcpConn) close() ? { pub fn (mut c TcpConn) close() ? {
$if trace_tcp ? { $if trace_tcp ? {
eprintln(' TcpConn.close | c.sock.handle: $c.sock.handle') eprintln(' TcpConn.close | c.sock.handle: ${c.sock.handle:6}')
} }
c.sock.close() ? c.sock.close() ?
return none return none
@ -38,9 +38,7 @@ pub fn (mut c TcpConn) close() ? {
// write_ptr blocks and attempts to write all data // write_ptr blocks and attempts to write all data
pub fn (mut c TcpConn) write_ptr(b &byte, len int) ?int { pub fn (mut c TcpConn) write_ptr(b &byte, len int) ?int {
$if trace_tcp ? { $if trace_tcp ? {
eprintln( eprintln('>>> TcpConn.write_ptr | c.sock.handle: ${c.sock.handle:6} | b: ${ptr_str(b)} len: ${len:6}')
'>>> TcpConn.write_ptr | c.sock.handle: $c.sock.handle | b: ${ptr_str(b)} len: $len |\n' +
unsafe { b.vstring_with_len(len) })
} }
$if trace_tcp_data_write ? { $if trace_tcp_data_write ? {
eprintln('>>> TcpConn.write_ptr | data.len: ${len:6} | data: ' + eprintln('>>> TcpConn.write_ptr | data.len: ${len:6} | data: ' +
@ -90,7 +88,7 @@ pub fn (mut c TcpConn) write_string(s string) ?int {
pub fn (mut c TcpConn) read_ptr(buf_ptr &byte, len int) ?int { pub fn (mut c TcpConn) read_ptr(buf_ptr &byte, len int) ?int {
mut res := wrap_read_result(C.recv(c.sock.handle, buf_ptr, len, 0)) ? mut res := wrap_read_result(C.recv(c.sock.handle, buf_ptr, len, 0)) ?
$if trace_tcp ? { $if trace_tcp ? {
eprintln('<<< TcpConn.read_ptr | c.sock.handle: $c.sock.handle | buf_ptr: ${ptr_str(buf_ptr)} len: $len | res: $res') eprintln('<<< TcpConn.read_ptr | c.sock.handle: ${c.sock.handle:6} | buf_ptr: ${ptr_str(buf_ptr):8} len: ${len:6} | res: ${res:6}')
} }
if res > 0 { if res > 0 {
$if trace_tcp_data_read ? { $if trace_tcp_data_read ? {
@ -104,7 +102,7 @@ pub fn (mut c TcpConn) read_ptr(buf_ptr &byte, len int) ?int {
c.wait_for_read() ? c.wait_for_read() ?
res = wrap_read_result(C.recv(c.sock.handle, buf_ptr, len, 0)) ? res = wrap_read_result(C.recv(c.sock.handle, buf_ptr, len, 0)) ?
$if trace_tcp ? { $if trace_tcp ? {
eprintln('<<< TcpConn.read_ptr | c.sock.handle: $c.sock.handle | buf_ptr: ${ptr_str(buf_ptr)} len: $len | res: $res') eprintln('<<< TcpConn.read_ptr | c.sock.handle: ${c.sock.handle:6} | buf_ptr: ${ptr_str(buf_ptr):8} len: ${len:6} | res: ${res:6}')
} }
$if trace_tcp_data_read ? { $if trace_tcp_data_read ? {
if res > 0 { if res > 0 {
@ -225,7 +223,7 @@ pub fn listen_tcp(port int) ?&TcpListener {
pub fn (mut l TcpListener) accept() ?&TcpConn { pub fn (mut l TcpListener) accept() ?&TcpConn {
$if trace_tcp ? { $if trace_tcp ? {
eprintln(' TcpListener.accept | l.sock.handle: $l.sock.handle') eprintln(' TcpListener.accept | l.sock.handle: ${l.sock.handle:6}')
} }
addr := C.sockaddr_storage{} addr := C.sockaddr_storage{}
unsafe { C.memset(&addr, 0, sizeof(C.sockaddr_storage)) } unsafe { C.memset(&addr, 0, sizeof(C.sockaddr_storage)) }
@ -242,7 +240,7 @@ pub fn (mut l TcpListener) accept() ?&TcpConn {
} }
new_sock := tcp_socket_from_handle(new_handle) ? new_sock := tcp_socket_from_handle(new_handle) ?
$if trace_tcp ? { $if trace_tcp ? {
eprintln(' TcpListener.accept | << new_sock: $new_sock') eprintln(' TcpListener.accept | << new_sock.handle: ${new_sock.handle:6}')
} }
return &TcpConn{ return &TcpConn{
sock: new_sock sock: new_sock
@ -276,7 +274,7 @@ pub fn (mut c TcpListener) wait_for_accept() ? {
pub fn (mut c TcpListener) close() ? { pub fn (mut c TcpListener) close() ? {
$if trace_tcp ? { $if trace_tcp ? {
eprintln(' TcpListener.close | c.sock.handle: $c.sock.handle') eprintln(' TcpListener.close | c.sock.handle: ${c.sock.handle:6}')
} }
c.sock.close() ? c.sock.close() ?
return none return none
@ -348,7 +346,7 @@ pub fn (mut s TcpSocket) set_option_int(opt SocketOption, value int) ? {
fn (mut s TcpSocket) close() ? { fn (mut s TcpSocket) close() ? {
$if trace_tcp ? { $if trace_tcp ? {
eprintln(' TcpSocket.close | s.handle: $s.handle') eprintln(' TcpSocket.close | s.handle: ${s.handle:6}')
} }
return shutdown(s.handle) return shutdown(s.handle)
} }
@ -363,7 +361,7 @@ const (
fn (mut s TcpSocket) connect(a string) ? { fn (mut s TcpSocket) connect(a string) ? {
$if trace_tcp ? { $if trace_tcp ? {
eprintln(' TcpSocket.connect | s.handle: $s.handle | a: $a') eprintln(' TcpSocket.connect | s.handle: ${s.handle:6} | a: $a')
} }
addr := resolve_addr(a, .inet, .tcp) ? addr := resolve_addr(a, .inet, .tcp) ?
res := C.connect(s.handle, &addr.addr, addr.len) res := C.connect(s.handle, &addr.addr, addr.len)