irc: lock fifo when writing to it · rockorager.dev/comlink@bea1d58

rockorager.dev / comlink

fork atom

an experimental irc client

fork atom

irc: lock fifo when writing to it

rockorager.dev 1 year ago bea1d581 4bfb4bbc

1 changed file

expand all

unified split

src

irc.zig

src/irc.zig

··· 1967 1967 @memcpy(buffer.slice(), buf[i..idx]); 1968 1968 assert(std.mem.eql(u8, buf[idx .. idx + 2], "\r\n")); 1969 1969 log.debug("[<-{s}] {s}", .{ self.config.name orelse self.config.server, buffer.slice() }); 1970 + self.fifo_mutex.lock(); 1971 + defer self.fifo_mutex.unlock(); 1970 1972 try self.fifo.writeItem(.{ .client = self, .msg = buffer }); 1971 1973 } 1972 1974 if (i != n) {