… | |
… | |
93 | for (msg_buf *buf = msgbuf; buf < msgbuf + MSG_BUF_COUNT; ++buf) |
93 | for (msg_buf *buf = msgbuf; buf < msgbuf + MSG_BUF_COUNT; ++buf) |
94 | { |
94 | { |
95 | if (len == buf->len && !memcmp (msg, buf->msg, len)) |
95 | if (len == buf->len && !memcmp (msg, buf->msg, len)) |
96 | { |
96 | { |
97 | // found matching buf, see if expired |
97 | // found matching buf, see if expired |
98 | if (buf->expire <= pticks || !buf->count) |
98 | if (buf->expire <= server_tick || !buf->count) |
99 | { |
99 | { |
100 | // yes, take over matching buffer, print |
100 | // yes, take over matching buffer, print |
101 | buf->expire = pticks + pl->outputs_sync; |
101 | buf->expire = server_tick + pl->outputs_sync; |
102 | buf->count = pl->outputs_count; |
102 | buf->count = pl->outputs_count; |
103 | |
103 | |
104 | return false; |
104 | return false; |
105 | } |
105 | } |
106 | |
106 | |
… | |
… | |
112 | if (lru->expire > buf->expire) |
112 | if (lru->expire > buf->expire) |
113 | lru = buf; |
113 | lru = buf; |
114 | } |
114 | } |
115 | |
115 | |
116 | // new message, evoke oldest buffer |
116 | // new message, evoke oldest buffer |
117 | lru->expire = pticks + pl->outputs_sync; |
117 | lru->expire = server_tick + pl->outputs_sync; |
118 | lru->count = pl->outputs_count; |
118 | lru->count = pl->outputs_count; |
119 | lru->len = len; |
119 | lru->len = len; |
120 | memcpy (lru->msg, msg, len); |
120 | memcpy (lru->msg, msg, len); |
121 | |
121 | |
122 | return false; |
122 | return false; |