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
128
129
130
131
132
|
# -*- coding: utf-8 -*-
module Diva::Model::PhotoInterface
GdkPixbufCache = Struct.new(:pixbuf, :width, :height, :read_count, :reserver)
# ローカルファイルシステム上のものなら真
def local?
uri.scheme == 'file'.freeze
end
# 特定のサイズのPixbufを作成するDeferredを返す
def download_pixbuf(width:, height:)
increase_read_count
cache_get_defer(width: width, height: height).trap do |err|
error err if err
gen_pixbuf_from_raw_data(width: width, height: height)
end
end
# download_pixbuf と似ているが、すぐさまキャッシュされているGdkPixbuf::Pixbufを返す。
# 取得に失敗した場合は ifnone を返す。
# もしキャッシュされた GdkPixbuf::Pixbuf が存在しない場合、ロード中を示すPixbufを返し、
# GdkPixbuf::Pixbuf の作成を開始する。
# 作成が完了したら、その Pixbuf を引数に _&complete_callback_ が呼び出される。
# ==== Args
# [width:] 取得する Pixbuf の幅(px)
# [height:] 取得する Pixbuf の高さ(px)
# [ifnone:] Pixbuf が存在しなかった時に _&complete_callback_ に渡す値
# [&complete_callback] このメソッドによって画像のダウンロードが行われた場合、ダウンロード完了時に呼ばれる
# ==== Return
# [GdkPixbuf::Pixbuf] pixbuf
def load_pixbuf(width:, height:, ifnone: Skin['notfound.png'].pixbuf(width: width, height: height), &complete_callback)
result = pixbuf(width: width, height: height) rescue ifnone
if result
result
else
download_pixbuf(width: width, height: height).next(&complete_callback).trap{
complete_callback.(ifnone)
}
Skin['loading.png'].pixbuf(width: width, height: height)
end
end
# 引数の寸法の GdkPixbuf::Pixbuf を、Pixbufキャッシュから返す。
# Pixbufキャッシュに存在しない場合は nil を返す。
# ただし、ロファイルシステム上に見つかった場合は、その場でそれを読み込んで返す。
# つまり、ファイルシステムのファイルを示している場合は、このメソッドはnilを返さず、常に GdkPixbuf::Pixbuf を返す。
# ==== Args
# [width:] Pixbufの幅(px)
# [height:] Pixbufの高さ(px)
# ==== Return
# [GdkPixbuf::Pixbuf] メモリキャッシュやファイルシステムから画像が見つかった場合
# [nil] 画像がローカルにキャッシュされていない場合
def pixbuf(width:, height:)
result = pixbuf_cache[[width, height].hash]
if result
result.read_count += 1
result.reserver.cancel if result.reserver
result.reserver = pixbuf_forget(width, height, result.read_count)
result.pixbuf
elsif local?
pixbuf_cache_set(GdkPixbuf::Pixbuf.new(file: uri.path, width: width, height: height), width: width, height: height)
end
end
private
def gen_pixbuf_from_raw_data(width:, height:)
download(width: width, height: height).next{|photo|
pb = pixbuf(width: width, height: height)
if pb
pb
else
loader = GdkPixbuf::PixbufLoader.new
loader.write photo.blob
loader.close
pb = loader.pixbuf
pixbuf_cache_set(pb.scale(*calc_fitclop(pb, Gdk::Rectangle.new(0, 0, width, height))),
width: width,
height: height)
end
}
end
def cache_get_defer(width:, height:)
Deferred.new.next do
result = pixbuf(width: width, height: height)
if result
result
else
Deferred.fail(result)
end
end
end
def pixbuf_cache_set(pixbuf, width:, height:)
if pixbuf_cache[[width, height].hash]
error "cache already exists for #{uri} #{width}*#{height}"
pixbuf(width: width, height: height)
else
key = [width, height].hash
pixbuf_cache[key] =
GdkPixbufCache.new(pixbuf, width, height, 0, pixbuf_forget(width, height, 0))
pixbuf
end
end
def pixbuf_cache
@pixbuf_cache ||= Hash.new
end
def pixbuf_forget(width, height, gen)
Reserver.new([300, 60 * gen ** 2].max, thread: SerialThread) do
pixbuf_cache.delete([width, height].hash)
end
end
# _src_ が _rect_ にアスペクト比を維持した状態で内接するように縮小した場合のサイズを返す
# ==== Args
# [src] 元の寸法(Gtk::Rectangle)
# [dst] 収めたい枠の寸法(Gtk::Rectangle)
# ==== Return
# 幅(px), 高さ(px)
def calc_fitclop(src, dst)
if (dst.width * src.height) > (dst.height * src.width)
return src.width * dst.height / src.height, dst.height
else
return dst.width, src.height * dst.width / src.width
end
end
end
|
