aboutsummaryrefslogtreecommitdiff
path: root/examples/http-server/connection-queue.tm
diff options
context:
space:
mode:
authorBruce Hill <bruce@bruce-hill.com>2025-04-06 14:20:18 -0400
committerBruce Hill <bruce@bruce-hill.com>2025-04-06 14:20:18 -0400
commit2bb2ff871fa1761478442bec5f6a32c9428360a1 (patch)
tree9b73df7a0c50c02353ae7bca7c2cd54788ef0077 /examples/http-server/connection-queue.tm
parent59845e610f2c90474f34079d27b5f1e07071ded4 (diff)
Change method calls to use `foo.baz()` instead of `foo:baz()`
Diffstat (limited to 'examples/http-server/connection-queue.tm')
-rw-r--r--examples/http-server/connection-queue.tm18
1 files changed, 9 insertions, 9 deletions
diff --git a/examples/http-server/connection-queue.tm b/examples/http-server/connection-queue.tm
index 84f92362..3c8058d5 100644
--- a/examples/http-server/connection-queue.tm
+++ b/examples/http-server/connection-queue.tm
@@ -5,21 +5,21 @@ func _assert_success(name:Text, val:Int32; inline):
struct ConnectionQueue(_connections:@[Int32]=@[], _mutex=pthread_mutex_t.new(), _cond=pthread_cond_t.new()):
func enqueue(queue:ConnectionQueue, connection:Int32):
- queue._mutex:lock()
- queue._connections:insert(connection)
- queue._mutex:unlock()
- queue._cond:signal()
+ queue._mutex.lock()
+ queue._connections.insert(connection)
+ queue._mutex.unlock()
+ queue._cond.signal()
func dequeue(queue:ConnectionQueue -> Int32):
conn : Int32? = none
- queue._mutex:lock()
+ queue._mutex.lock()
while queue._connections.length == 0:
- queue._cond:wait(queue._mutex)
+ queue._cond.wait(queue._mutex)
- conn = queue._connections:pop(1)
- queue._mutex:unlock()
- queue._cond:signal()
+ conn = queue._connections.pop(1)
+ queue._mutex.unlock()
+ queue._cond.signal()
return conn!