mirrors/v
1
0
Fork 0
mirror of https://github.com/vlang/v.git synced 2025-09-16 16:02:29 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions 13

vweb2 (#19997)

Browse source
This commit is contained in:
Casper Küthe 2023-12-09 06:07:51 +01:00 • committed by GitHub
parent 2768de1fc7
commit 08189d649c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
27 changed files with 4001 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

33
vlib/picoev/picoev.v
View file

@ -1,17 +1,24 @@
module picoev
import net
import picohttpparser
import time
pub const max_fds = 1024
pub const max_queue = 4096
// events
pub const picoev_read = 1
pub const picoev_write = 2
pub const picoev_timeout = 4
pub const picoev_add = 0x40000000
pub const picoev_del = 0x20000000
pub const picoev_readwrite = 3
// Target is a data representation of everything that needs to be associated with a single
@ -31,19 +38,21 @@ pub:
port int = 8080
cb fn (voidptr, picohttpparser.Request, mut picohttpparser.Response) = unsafe { nil }
err_cb fn (voidptr, picohttpparser.Request, mut picohttpparser.Response, IError) = default_err_cb
raw_cb fn (mut Picoev, int) = unsafe { nil }
user_data voidptr = unsafe { nil }
timeout_secs int = 8
max_headers int = 100
max_read int = 4096
max_write int = 8192
raw_cb fn (mut Picoev, int, int) = unsafe { nil }
user_data voidptr = unsafe { nil }
timeout_secs int = 8
max_headers int = 100
max_read int = 4096
max_write int = 8192
family net.AddrFamily = .ip
host string = 'localhost'
}
@[heap]
pub struct Picoev {
cb fn (voidptr, picohttpparser.Request, mut picohttpparser.Response) = unsafe { nil }
err_cb fn (voidptr, picohttpparser.Request, mut picohttpparser.Response, IError) = default_err_cb
raw_cb fn (mut Picoev, int) = unsafe { nil }
raw_cb fn (mut Picoev, int, int) = unsafe { nil }
timeout_secs int
max_headers int = 100
@ -98,7 +107,7 @@ pub fn (mut pv Picoev) add(fd int, events int, timeout int, cb voidptr) int {
// del removes a file descriptor from the loop
@[direct_array_access]
fn (mut pv Picoev) del(fd int) int {
pub fn (mut pv Picoev) del(fd int) int {
assert fd < picoev.max_fds
mut target := pv.file_descriptors[fd]
@ -212,7 +221,7 @@ fn raw_callback(fd int, events int, context voidptr) {
} else if events & picoev.picoev_read != 0 {
pv.set_timeout(fd, pv.timeout_secs)
if !isnil(pv.raw_cb) {
pv.raw_cb(mut pv, fd)
pv.raw_cb(mut pv, fd, events)
return
}
@ -272,6 +281,12 @@ fn raw_callback(fd int, events int, context voidptr) {
// Callback (should call .end() itself)
pv.cb(pv.user_data, req, mut &res)
} else if events & picoev.picoev_write != 0 {
pv.set_timeout(fd, pv.timeout_secs)
if !isnil(pv.raw_cb) {
pv.raw_cb(mut pv, fd, events)
return
}
}
}