egor3f/kittenipc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add checks

Browse Source
This commit is contained in:
Egor Aristov 2025-12-30 21:13:16 +03:00
parent 4f8e3adc6d
commit e89e436236
Signed by: egor3f
GPG Key ID: 40482A264AAEC85F
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/golang/lib.go
View File

@ -222,6 +222,10 @@ func (ipc *ipcCommon) handleResponse(msg Message) {
} }
func (ipc *ipcCommon) Call(method string, params ...any) (Vals, error) { func (ipc *ipcCommon) Call(method string, params ...any) (Vals, error) {
if ipc.conn == nil {
return nil, fmt.Errorf("ipc is not connected to remote process socket")
}
if ipc.stopRequested.Load() { if ipc.stopRequested.Load() {
return nil, fmt.Errorf("ipc is stopping") return nil, fmt.Errorf("ipc is stopping")
} }
@ -494,6 +498,9 @@ func mergeErr(errs ...error) (ret error) {
func mapTypeNames(types []any) map[string]any { func mapTypeNames(types []any) map[string]any {
result := make(map[string]any) result := make(map[string]any)
for _, t := range types { for _, t := range types {
if reflect.TypeOf(t).Kind() != reflect.Pointer {
panic(fmt.Sprintf("LocalAPI argument must be pointer"))
}
typeName := reflect.TypeOf(t).Elem().Name() typeName := reflect.TypeOf(t).Elem().Name()
result[typeName] = t result[typeName] = t
} }