aboutsummaryrefslogtreecommitdiff
path: root/src/http/websocket.zig
diff options
context:
space:
mode:
Diffstat (limited to 'src/http/websocket.zig')
-rw-r--r--src/http/websocket.zig22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/http/websocket.zig b/src/http/websocket.zig
index 48a4cebf5..2fdd28451 100644
--- a/src/http/websocket.zig
+++ b/src/http/websocket.zig
@@ -53,20 +53,20 @@ pub const WebsocketHeader = packed struct {
if (comptime Environment.allow_assert) {
var buf_ = [2]u8{ 0, 0 };
var stream = std.io.fixedBufferStream(&buf_);
- stream.writer().writeIntBig(u16, @bitCast(u16, header)) catch unreachable;
+ stream.writer().writeIntBig(u16, @as(u16, @bitCast(header))) catch unreachable;
stream.pos = 0;
const casted = stream.reader().readIntBig(u16) catch unreachable;
- std.debug.assert(casted == @bitCast(u16, header));
- std.debug.assert(std.meta.eql(@bitCast(WebsocketHeader, casted), header));
+ std.debug.assert(casted == @as(u16, @bitCast(header)));
+ std.debug.assert(std.meta.eql(@as(WebsocketHeader, @bitCast(casted)), header));
}
- try writer.writeIntBig(u16, @bitCast(u16, header));
+ try writer.writeIntBig(u16, @as(u16, @bitCast(header)));
std.debug.assert(header.len == packLength(n));
}
pub fn packLength(length: usize) u7 {
return switch (length) {
- 0...125 => @truncate(u7, length),
+ 0...125 => @as(u7, @truncate(length)),
126...0xFFFF => 126,
else => 127,
};
@@ -156,7 +156,7 @@ pub const Websocket = struct {
var socket = Websocket{
.read_stream = undefined,
.reader = undefined,
- .stream = std.net.Stream{ .handle = @intCast(std.os.socket_t, fd) },
+ .stream = std.net.Stream{ .handle = @as(std.os.socket_t, @intCast(fd)) },
.flags = flags,
};
@@ -185,7 +185,7 @@ pub const Websocket = struct {
// Close and send the status
pub fn close(self: *Websocket, code: u16) !void {
const c = if (native_endian == .Big) code else @byteSwap(code);
- const data = @bitCast([2]u8, c);
+ const data = @as([2]u8, @bitCast(c));
_ = try self.writeMessage(.Close, &data);
}
@@ -230,13 +230,13 @@ pub const Websocket = struct {
if (!dataframe.isValid()) return error.InvalidMessage;
- try stream.writeIntBig(u16, @bitCast(u16, dataframe.header));
+ try stream.writeIntBig(u16, @as(u16, @bitCast(dataframe.header)));
// Write extended length if needed
const n = dataframe.data.len;
switch (n) {
0...126 => {}, // Included in header
- 127...0xFFFF => try stream.writeIntBig(u16, @truncate(u16, n)),
+ 127...0xFFFF => try stream.writeIntBig(u16, @as(u16, @truncate(n))),
else => try stream.writeIntBig(u64, n),
}
@@ -292,9 +292,9 @@ pub const Websocket = struct {
// header.rsv1 = header_bytes[0] & 0x40 == 0x40;
// header.rsv2 = header_bytes[0] & 0x20;
// header.rsv3 = header_bytes[0] & 0x10;
- header.opcode = @enumFromInt(Opcode, @truncate(u4, header_bytes[0]));
+ header.opcode = @as(Opcode, @enumFromInt(@as(u4, @truncate(header_bytes[0]))));
header.mask = header_bytes[1] & 0x80 == 0x80;
- header.len = @truncate(u7, header_bytes[1]);
+ header.len = @as(u7, @truncate(header_bytes[1]));
// Decode length
var length: u64 = header.len;