spencer/zomq
1
0
Fork 0
mirror of https://github.com/sbrow/zomq.git synced 2026-08-26 19:03:31 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat: Added send_const proc.

Browse Source
This commit is contained in:
Spencer Brower
2026-07-08 15:05:29 -04:00
parent 170182b747
commit 836f1da723
1 changed files with 31 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
zmq/zmq.odin
+31 -3
View File
@@ -27,6 +27,10 @@ foreign lib {
_connect :: proc(s: Socket, addr: cstring) -> c.int ---
@(link_name = "zmq_send")
_send :: proc(s: Socket, buf: rawptr, len: c.size_t, flags: Flags) -> c.int ---
@(link_name = "zmq_send_const")
_send_const :: proc(s: Socket, buf: rawptr, len: c.size_t, flags: Flags) -> c.int ---
@(link_name = "zmq_recv")
_recv :: proc(s: Socket, buf: rawptr, len: c.size_t, flags: Flags) -> c.int ---
@(link_name = "zmq_strerror")
@@ -114,18 +118,42 @@ send :: proc {
send_string,
}
send_bytes :: proc(s: Socket, buf: []u8, flags: Flags = Flags{}) -> (int, Error) {
send_bytes :: proc(s: Socket, buf: []u8, flags: Flags = {}) -> (int, Error) {
n := _send(s, rawptr(&buf[0]), c.size_t(len(buf)), flags)
if n < 0 {
return -1, last_error()
}
return int(n), Error{}
return int(n), nil
}
send_string :: proc(s: Socket, buf: string, flags: Flags = Flags{}) -> (int, Error) {
send_string :: proc(s: Socket, buf: string, flags: Flags = {}) -> (int, Error) {
return send_bytes(s, transmute([]u8)buf, flags)
}
send_const :: proc {
send_const_string,
send_const_bytes,
}
send_const_string :: proc(s: Socket, $str: string, flags: Flags = {}) -> (int, Error) {
n := _send_const(s, rawptr($str), len($str), flags)
if n < 0 {
return -1, last_error()
}
return int(n), nil
}
// buf must have @(rodata) or global lifetime.
send_const_bytes :: proc(s: Socket, buf: []byte, flags: Flags = {}) -> (int, Error) {
n := _send_const(s, rawptr(&buf[0]), len(buf), flags)
if n < 0 {
return -1, last_error()
}
return int(n), nil
}
recv :: proc(s: Socket, buf: []u8, flags: Flags = Flags{}) -> (int, Error) {
n := _recv(s, rawptr(&buf[0]), c.size_t(len(buf)), flags)
if n < 0 {