1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
#! /usr/bin/env lua
--
-- Sample lgi application for Gio files, streams and usage of
-- Gio.Async It also serves as very crude timing 'benchmark' showing
-- overhead of assorted types operations.
--
local lgi = require 'lgi'
local GLib = lgi.GLib
local Gio = lgi.Gio
local assert = lgi.assert
local app = Gio.Application { application_id = 'org.lgi.samples.giostream' }
local function read_lua(file)
local stream = io.open(file:get_path(), 'r')
local contents = stream:read('*a')
stream:close()
return contents
end
local function write_lua(file, contents)
local stream = io.open(file:get_path(), 'w')
stream:write(contents)
stream:close()
end
local function read_sync(file)
local info = assert(file:query_info('standard::size', 0))
local stream = assert(file:read())
local read_buffers = {}
local remaining = info:get_size()
while remaining > 0 do
local buffer = assert(stream:read_bytes(remaining))
table.insert(read_buffers, buffer.data)
remaining = remaining - #buffer
end
assert(stream:close())
return table.concat(read_buffers)
end
local function read_async(file)
local info = assert(file:async_query_info('standard::size', 'NONE'))
local stream = assert(file:async_read())
local read_buffers = {}
local remaining = info:get_size()
while remaining > 0 do
local buffer = assert(stream:async_read_bytes(remaining))
table.insert(read_buffers, buffer.data)
remaining = remaining - #buffer
end
stream:async_close()
return table.concat(read_buffers)
end
local function write_sync(file, contents)
local stream = assert(file:create('NONE'))
local pos = 1
while pos <= #contents do
local wrote, err = stream:write_bytes(GLib.Bytes(contents:sub(pos)))
assert(wrote >= 0, err)
pos = pos + wrote
end
end
local function write_async(file, contents)
local stream = assert(file:async_create('NONE'))
local pos = 1
while pos <= #contents do
local wrote, err = stream:async_write_bytes(GLib.Bytes(contents:sub(pos)))
assert(wrote >= 0, err)
pos = pos + wrote
end
end
local source_file = Gio.File.new_for_commandline_arg(arg[0])
local function perform(read_op, write_op, target_file)
app:hold()
io.write('+')
local contents = read_op(source_file)
target_file:delete()
write_op(target_file, contents)
local contents_copied = read_op(target_file)
assert(contents == contents_copied)
assert(target_file:delete())
io.write('.')
app:release()
end
local count = 100
local timer = GLib.Timer()
-- Perform sync standard-lua variant of the test.
timer:reset()
for i = 1, count do
perform(read_lua, write_lua, Gio.File.new_for_path('test-lua-' .. i))
end
print((("\n Lua %0.2f secs"):format(timer:elapsed())))
-- Perform sync variant of the test.
timer:reset()
for i = 1, count do
perform(read_sync, write_sync, Gio.File.new_for_path('test-sync-' .. i))
end
print((("\n sync %0.2f secs"):format(timer:elapsed())))
-- Perform async variant of the test.
timer:reset()
for i = 1, count do
Gio.Async.call(perform)(read_async, write_async,
Gio.File.new_for_path('test-async-' .. i))
end
print((("\n async %0.2f secs"):format(timer:elapsed())))
-- Perform parallel variant of the test.
function app:on_activate()
for i = 1, count do
Gio.Async.start(perform)(read_async, write_async,
Gio.File.new_for_path('test-parallel-' .. i))
end
end
timer:reset()
app:run(...)
print((("\n parallel %0.2f secs"):format(timer:elapsed())))
|
