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
|
/*
* Copyright (C) 2017 ~ 2018 Deepin Technology Co., Ltd.
*
* Author: jouyouyun <jouyouwen717@gmail.com>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package appinfo
import (
"bytes"
"io"
"github.com/linuxdeepin/go-x11-client"
)
type StartupNotifyMessage struct {
Type string
KeyValues map[string]string
}
func (msg *StartupNotifyMessage) fillBuffer() *bytes.Buffer {
var buf bytes.Buffer
buf.WriteString(msg.Type)
buf.WriteByte(':')
for k, v := range msg.KeyValues {
buf.WriteString(k)
buf.WriteString(`="`)
vlen := len(v)
for i := 0; i < vlen; i++ {
b := v[i]
switch b {
case 0, ' ', '"', '\\':
buf.WriteByte('\\')
}
buf.WriteByte(b)
}
buf.WriteString(`" `)
}
buf.WriteByte(0)
return &buf
}
func (msg *StartupNotifyMessage) Broadcast(conn *x.Conn) error {
atomMsgType, err := conn.GetAtom("_NET_STARTUP_INFO")
if err != nil {
return err
}
atomMsgTypeBegin, err := conn.GetAtom("_NET_STARTUP_INFO_BEGIN")
if err != nil {
return err
}
return broadcastXMessage(conn, atomMsgType, atomMsgTypeBegin, msg.fillBuffer())
}
func broadcastXMessage(conn *x.Conn, atomMsgType, atomMsgTypeBegin x.Atom, msgReader io.Reader) error {
// create window
xid, err := conn.AllocID()
if err != nil {
return err
}
defer func() {
_ = conn.FreeID(xid)
}()
win := x.Window(xid)
root := conn.GetDefaultScreen().Root
err = x.CreateWindowChecked(conn, 0, win, root, 0, 0, 1, 1,
0, x.WindowClassInputOnly, x.CopyFromParent,
x.CWOverrideRedirect|x.CWEventMask,
[]uint32{1, x.EventMaskPropertyChange | x.EventMaskStructureNotify}).Check(conn)
if err != nil {
return err
}
// send x message
ev := x.ClientMessageEvent{
Format: 8,
Window: win,
Type: atomMsgTypeBegin,
}
var buf [20]byte
var readDone bool
for !readDone {
n, err := msgReader.Read(buf[:])
if err != nil {
// EOF
readDone = true
}
if n == 0 {
break
}
ev.Data = x.ClientMessageData{}
ev.Data.SetData8(&buf)
w := x.NewWriter()
x.WriteClientMessageEvent(w, &ev)
x.SendEvent(conn, false, root,
x.EventMaskPropertyChange, w.Bytes())
ev.Type = atomMsgType
}
x.DestroyWindow(conn, win)
conn.Flush()
return nil
}
|
