| ... | @@ -3887,7 +3887,7 @@ test "accept_direct" { | ... | @@ -3887,7 +3887,7 @@ test "accept_direct" { |
| 3887 | try testing.expectEqual(@as(u32, 1), try ring.submit()); | 3887 | try testing.expectEqual(@as(u32, 1), try ring.submit()); |
| 3888 | | 3888 | |
| 3889 | // connect | 3889 | // connect |
| 3890 | var client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); | 3890 | const client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); |
| 3891 | try os.connect(client, &address.any, address.getOsSockLen()); | 3891 | try os.connect(client, &address.any, address.getOsSockLen()); |
| 3892 | defer os.closeSocket(client); | 3892 | defer os.closeSocket(client); |
| 3893 | | 3893 | |
| ... | @@ -3921,7 +3921,7 @@ test "accept_direct" { | ... | @@ -3921,7 +3921,7 @@ test "accept_direct" { |
| 3921 | _ = try ring.accept_direct(accept_userdata, listener_socket, null, null, 0); | 3921 | _ = try ring.accept_direct(accept_userdata, listener_socket, null, null, 0); |
| 3922 | try testing.expectEqual(@as(u32, 1), try ring.submit()); | 3922 | try testing.expectEqual(@as(u32, 1), try ring.submit()); |
| 3923 | // connect | 3923 | // connect |
| 3924 | var client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); | 3924 | const client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); |
| 3925 | try os.connect(client, &address.any, address.getOsSockLen()); | 3925 | try os.connect(client, &address.any, address.getOsSockLen()); |
| 3926 | defer os.closeSocket(client); | 3926 | defer os.closeSocket(client); |
| 3927 | // completion with error | 3927 | // completion with error |
| ... | @@ -3963,7 +3963,7 @@ test "accept_multishot_direct" { | ... | @@ -3963,7 +3963,7 @@ test "accept_multishot_direct" { |
| 3963 | | 3963 | |
| 3964 | for (registered_fds) |_| { | 3964 | for (registered_fds) |_| { |
| 3965 | // connect | 3965 | // connect |
| 3966 | var client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); | 3966 | const client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); |
| 3967 | try os.connect(client, &address.any, address.getOsSockLen()); | 3967 | try os.connect(client, &address.any, address.getOsSockLen()); |
| 3968 | defer os.closeSocket(client); | 3968 | defer os.closeSocket(client); |
| 3969 | | 3969 | |
| ... | @@ -3978,7 +3978,7 @@ test "accept_multishot_direct" { | ... | @@ -3978,7 +3978,7 @@ test "accept_multishot_direct" { |
| 3978 | // Multishot is terminated (more flag is not set). | 3978 | // Multishot is terminated (more flag is not set). |
| 3979 | { | 3979 | { |
| 3980 | // connect | 3980 | // connect |
| 3981 | var client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); | 3981 | const client = try os.socket(address.any.family, os.SOCK.STREAM | os.SOCK.CLOEXEC, 0); |
| 3982 | try os.connect(client, &address.any, address.getOsSockLen()); | 3982 | try os.connect(client, &address.any, address.getOsSockLen()); |
| 3983 | defer os.closeSocket(client); | 3983 | defer os.closeSocket(client); |
| 3984 | // completion with error | 3984 | // completion with error |