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
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
package dbusutil
import (
"errors"
"github.com/godbus/dbus"
)
type ServerObject struct {
service *Service
path dbus.ObjectPath
implementers []*implementer
}
func (so *ServerObject) Path() dbus.ObjectPath {
return so.path
}
func (so *ServerObject) Export() error {
s := so.service
conn := s.conn
path := so.path
s.mu.Lock()
defer s.mu.Unlock()
_, ok := s.objMap[path]
if ok {
return errors.New("server object is exported")
}
for _, impl := range so.implementers {
core := impl.core
corePtr := getImplementerPointer(core)
_, ok := s.implObjMap[corePtr]
if ok {
return errors.New("implementer is exported")
}
err := conn.Export(core, so.path, core.GetInterfaceName())
if err != nil {
return err
}
s.implObjMap[corePtr] = so
}
methodTable := make(map[string]interface{}, 3)
methodTable["Introspect"] = so.introspectableIntrospect
err := conn.ExportMethodTable(methodTable, so.path,
orgFreedesktopDBus+".Introspectable")
if err != nil {
return err
}
delete(methodTable, "Introspect")
methodTable["Get"] = so.propertiesGet
methodTable["GetAll"] = so.propertiesGetAll
methodTable["Set"] = so.propertiesSet
err = conn.ExportMethodTable(methodTable, so.path,
orgFreedesktopDBus+".Properties")
if err != nil {
return err
}
s.objMap[so.path] = so
return nil
}
func (so *ServerObject) StopExport() error {
s := so.service
conn := s.conn
path := so.path
s.mu.Lock()
defer s.mu.Unlock()
_, ok := s.objMap[path]
if !ok {
return errors.New("server object is not exported")
}
err := conn.Export(nil, path, orgFreedesktopDBus+".Properties")
if err != nil {
return err
}
err = conn.Export(nil, path, orgFreedesktopDBus+".Introspectable")
if err != nil {
return err
}
for _, impl := range so.implementers {
core := impl.core
err := conn.Export(nil, so.path, core.GetInterfaceName())
if err != nil {
return err
}
corePtr := getImplementerPointer(core)
delete(s.implObjMap, corePtr)
}
delete(s.objMap, path)
return nil
}
func (so *ServerObject) getImplementer(interfaceName string) *implementer {
for _, impl := range so.implementers {
if impl.core.GetInterfaceName() == interfaceName {
return impl
}
}
return nil
}
func (so *ServerObject) SetWriteCallback(v Implementer, propertyName string,
cb PropertyWriteCallback) error {
impl := so.getImplementer(v.GetInterfaceName())
if impl == nil {
return errors.New("not exported")
}
return impl.setWriteCallback(propertyName, cb)
}
func (so *ServerObject) SetReadCallback(v Implementer, propertyName string,
cb PropertyReadCallback) error {
impl := so.getImplementer(v.GetInterfaceName())
if impl == nil {
return errors.New("not exported")
}
return impl.setReadCallback(propertyName, cb)
}
func (so *ServerObject) ConnectChanged(v Implementer, propertyName string,
cb PropertyChangedCallback) error {
impl := so.getImplementer(v.GetInterfaceName())
if impl == nil {
return errors.New("not exported")
}
return impl.connectChanged(propertyName, cb)
}
|
