package/go_process_manager
1
0
Fork 0
mirror of https://github.com/lzh-1625/go_process_manager.git synced 2025-10-05 16:06:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

add ui file

Browse Source
This commit is contained in:
liuzhihang1
2024-06-28 21:44:21 +08:00
parent cf22322d31
commit 8889c86e75
41 changed files with 9619 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service/process/process_pty.go
View File

@@ -104,7 +104,7 @@ func (p *ProcessPty) readInit() {
p.bufHanle(buf[:n])
if p.IsUsing.Load() {
p.ws.wsMux.Lock()
p.ws.wsConnect.WriteMessage(websocket.TextMessage, buf[:n])
p.ws.wsConnect.WriteMessage(websocket.BinaryMessage, buf[:n])
p.ws.wsMux.Unlock()
}
}
@@ -113,7 +113,7 @@ func (p *ProcessPty) readInit() {
}
func (p *ProcessPty) ReadCache(ws *websocket.Conn) {
ws.WriteMessage(websocket.TextMessage, p.cacheBytesBuf.Bytes())
ws.WriteMessage(websocket.BinaryMessage, p.cacheBytesBuf.Bytes())
}
func (p *ProcessPty) bufHanle(b []byte) {

4
service/process/process_std.go
View File

@@ -107,7 +107,7 @@ func (p *ProcessStd) pInit() {
func (p *ProcessStd) ReadCache(ws *websocket.Conn) {
for _, line := range p.cacheLine {
ws.WriteMessage(websocket.TextMessage, []byte(line))
ws.WriteMessage(websocket.BinaryMessage, []byte(line))
}
}
@@ -128,7 +128,7 @@ func (p *ProcessStd) readInit() {
output = p.Read()
if p.IsUsing.Load() && output != "" {
p.ws.wsMux.Lock()
p.ws.wsConnect.WriteMessage(websocket.TextMessage, []byte(output))
p.ws.wsConnect.WriteMessage(websocket.BinaryMessage, []byte(output))
p.ws.wsMux.Unlock()
}
}