123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543 |
- package zend
- /*
- #include <stdlib.h>
- #include "array.h"
- */
- import "C"
- import "reflect"
- import "unsafe"
- import "log"
- ////
- //export goapi_array_new
- func goapi_array_new(kind int, retpp *unsafe.Pointer) {
- sty := FROMCIP(goapi_type_r(kind)).(reflect.Type)
- log.Println(sty.Kind().String(), sty)
- arrval := reflect.MakeSlice(reflect.SliceOf(sty), 0, 0)
- *retpp = TOCIP(arrval.Interface())
- }
- //export goapi_array_push
- func goapi_array_push(arrp unsafe.Pointer, elm unsafe.Pointer, retpp *unsafe.Pointer) {
- // *arr = append(*arr, s)
- arr := FROMCIP(arrp)
- vty := reflect.TypeOf(arr)
- if vty != nil {
- }
- switch vty.Elem().Kind() {
- case reflect.Int64:
- elmval := (int64)(C.int64_t(uintptr(elm)))
- narr := append(arr.([]int64), elmval)
- *retpp = TOCIP(narr)
- case reflect.String:
- // only support string element
- elmval := C.GoString((*C.char)(elm))
- narr := append(arr.([]string), elmval)
- *retpp = TOCIP(narr)
- }
- return
- }
- //export goapi_map_new
- func goapi_map_new(retpp *unsafe.Pointer) {
- // m := make(map[string]string, 0)
- kty := FROMCIP(goapi_type_r(int(reflect.String))).(reflect.Type)
- vty := FROMCIP(goapi_type_r(int(reflect.String))).(reflect.Type)
- mv := reflect.MakeMap(reflect.MapOf(kty, vty))
- m := mv.Interface().(map[string]string)
- *retpp = TOCIP(m)
- }
- //export goapi_map_add
- func goapi_map_add(mp unsafe.Pointer, keyp unsafe.Pointer, valuep unsafe.Pointer) {
- m := FROMCIP(mp).(map[string]string)
- key := C.GoString((*C.char)(keyp))
- value := C.GoString((*C.char)(valuep))
- m[key] = value
- }
- //export goapi_map_get
- func goapi_map_get(mp unsafe.Pointer, keyp unsafe.Pointer, retpp *unsafe.Pointer) {
- m := FROMCIP(mp).(map[string]string)
- key := C.GoString((*C.char)(keyp))
- if _, has := m[key]; has {
- v := m[key]
- *retpp = unsafe.Pointer(C.CString(v))
- }
- return
- }
- //export goapi_map_del
- func goapi_map_del(mp unsafe.Pointer, keyp unsafe.Pointer) {
- m := FROMCIP(mp).(map[string]string)
- key := C.GoString((*C.char)(keyp))
- if _, has := m[key]; has {
- delete(m, key)
- }
- }
- //export goapi_map_has
- func goapi_map_has(mp unsafe.Pointer, keyp unsafe.Pointer) bool {
- m := FROMCIP(mp).(map[string]string)
- key := C.GoString((*C.char)(keyp))
- if _, has := m[key]; has {
- return true
- }
- return false
- }
- //export goapi_chan_new
- func goapi_chan_new(kind int, buffer int, retpp *unsafe.Pointer) {
- cty := FROMCIP(goapi_type_r(kind)).(reflect.Type)
- chval := reflect.MakeChan(cty, buffer)
- *retpp = TOCIP(chval.Interface())
- }
- // TODO
- //export goapi_chan_read
- func goapi_chan_read(chp unsafe.Pointer, retpp *unsafe.Pointer) {
- ch := FROMCIP(chp)
- chv := reflect.ValueOf(ch)
- rv, ok := chv.Recv()
- if ok {
- *retpp = TOCIP(rv.Interface())
- }
- }
- // TODO
- //export goapi_chan_write
- func goapi_chan_write(chp unsafe.Pointer, elm unsafe.Pointer) {
- ch := FROMCIP(chp)
- chv := reflect.ValueOf(ch)
- chv.Send(reflect.ValueOf(FROMCIP(elm)))
- }
- // TODO
- //export goapi_chan_close
- func goapi_chan_close(chp unsafe.Pointer) {
- ch := FROMCIP(chp)
- chv := reflect.ValueOf(ch)
- chv.Close()
- }
- func goapi_type_r(kind int) unsafe.Pointer {
- var retpp unsafe.Pointer
- goapi_type(kind, &retpp)
- return retpp
- }
- //export goapi_type
- func goapi_type(kind int, retpp *unsafe.Pointer) {
- wkind := (reflect.Kind)(kind)
- var refty reflect.Type
- switch wkind {
- case reflect.Invalid:
- case reflect.Bool:
- refty = reflect.TypeOf(true)
- case reflect.Int:
- refty = reflect.TypeOf(int(0))
- case reflect.Int8:
- refty = reflect.TypeOf(int8(0))
- case reflect.Int16:
- refty = reflect.TypeOf(int16(0))
- case reflect.Int32:
- refty = reflect.TypeOf(int32(0))
- case reflect.Int64:
- refty = reflect.TypeOf(int64(0))
- case reflect.Uint:
- refty = reflect.TypeOf(uint(0))
- case reflect.Uint8:
- refty = reflect.TypeOf(uint8(0))
- case reflect.Uint16:
- refty = reflect.TypeOf(uint16(0))
- case reflect.Uint32:
- refty = reflect.TypeOf(uint32(0))
- case reflect.Uint64:
- refty = reflect.TypeOf(uint64(0))
- case reflect.Uintptr:
- refty = reflect.TypeOf(uintptr(0))
- case reflect.Float32:
- refty = reflect.TypeOf(float32(1.0))
- case reflect.Float64:
- refty = reflect.TypeOf(float64(1.0))
- case reflect.Complex64:
- case reflect.Complex128:
- case reflect.Array:
- refty = reflect.TypeOf([]interface{}{})
- case reflect.Chan:
- case reflect.Func:
- case reflect.Interface:
- case reflect.Map:
- refty = reflect.TypeOf(map[interface{}]interface{}{})
- case reflect.Ptr:
- case reflect.Slice:
- case reflect.String:
- refty = reflect.TypeOf("")
- case reflect.Struct:
- case reflect.UnsafePointer:
- refty = reflect.TypeOf(unsafe.Pointer(uintptr(0)))
- }
- *retpp = TOCIP(refty)
- }
- //export goapi_typeof
- func goapi_typeof(v unsafe.Pointer, retpp *unsafe.Pointer) {
- gv := FROMCIP(v)
- *retpp = TOCIP(reflect.TypeOf(gv))
- }
- //export goapi_typeid
- func goapi_typeid(v unsafe.Pointer) int {
- gv := FROMCIP(v)
- return int(reflect.TypeOf(gv).Kind())
- }
- //export goapi_new
- func goapi_new(kind int, retpp *unsafe.Pointer) {
- refty := goapi_type_r(kind)
- refval := reflect.New(FROMCIP(refty).(reflect.Type))
- *retpp = TOCIP(refval)
- }
- func goapi_new_kind(kind reflect.Kind, retpp *unsafe.Pointer) {
- goapi_new(int(kind), retpp)
- }
- func goapi_new_type(kty reflect.Type, retpp *unsafe.Pointer) {
- goapi_new_kind(kty.Kind(), retpp)
- }
- //export goapi_new_value
- func goapi_new_value(kind int, v uintptr, retpp *unsafe.Pointer) {
- wkind := reflect.Kind(kind)
- var refval interface{}
- switch wkind {
- case reflect.Invalid:
- case reflect.Bool:
- if v == 0 {
- refval = false
- } else {
- refval = true
- }
- case reflect.Int:
- refval = int(v)
- case reflect.Int8:
- refval = int8(v)
- case reflect.Int16:
- refval = int16(v)
- case reflect.Int32:
- refval = int32(v)
- case reflect.Int64:
- refval = int64(v)
- case reflect.Uint:
- refval = uint(v)
- case reflect.Uint8:
- refval = uint8(v)
- case reflect.Uint16:
- refval = uint16(v)
- case reflect.Uint32:
- refval = uint32(v)
- case reflect.Uint64:
- refval = uint64(v)
- case reflect.Uintptr:
- refval = v
- case reflect.Float32:
- refval = float32(*(*C.float)(unsafe.Pointer(v)))
- C.free(unsafe.Pointer(v))
- case reflect.Float64:
- refval = float64(*(*C.double)(unsafe.Pointer(v)))
- C.free(unsafe.Pointer(v))
- case reflect.Complex64:
- case reflect.Complex128:
- case reflect.Array:
- case reflect.Chan:
- case reflect.Func:
- case reflect.Interface:
- case reflect.Map:
- case reflect.Ptr:
- case reflect.Slice:
- case reflect.String:
- refval = C.GoString((*C.char)(unsafe.Pointer(v)))
- case reflect.Struct:
- case reflect.UnsafePointer:
- refval = unsafe.Pointer(v)
- }
- *retpp = TOCIP(refval)
- }
- //export goapi_set_value
- func goapi_set_value(gv unsafe.Pointer, v uintptr, retpp *unsafe.Pointer) {
- giv := FROMCIP(gv)
- gvty := reflect.TypeOf(giv)
- var nv unsafe.Pointer
- goapi_new_value(int(gvty.Kind()), v, &nv)
- reflect.ValueOf(giv).Set(reflect.ValueOf(FROMCIP(nv)))
- if *retpp != gv {
- *retpp = gv
- }
- }
- //export goapi_set_php_array
- func goapi_set_php_array(rp unsafe.Pointer, arr *unsafe.Pointer) {
- ru := reflect.ValueOf(FROMCIP(rp))
- set_php_array(ru, arr)
- }
- func set_php_array(ru reflect.Value, rv *unsafe.Pointer) {
- switch ru.Kind() {
- case reflect.Array, reflect.Slice:
- n := ru.Len()
- if n == 0 {
- break
- }
- for i := 0; i < n; i++ {
- son := ru.Index(i)
- switch son.Kind() {
- case reflect.Array, reflect.Slice, reflect.Map:
- temp := unsafe.Pointer(C.php_array_create_zval())
- //php7 zval处理为栈内存
- if nil == temp {
- var tm C.zval
- tmp := &tm
- C.php7_array_init(tmp)
- temp = unsafe.Pointer(tmp)
- }
- sonup := &temp
- push_php_array(son, sonup, int64(i), 1)
- C.php_array_add_next_index_zval(*rv, *sonup)
- default:
- push_php_array(son, rv, int64(i), 1)
- }
- }
- case reflect.Map:
- t := ru.MapKeys()
- if len(t) == 0 {
- break
- }
- mk := t[0]
- mapKeyType := 0
- switch mk.Kind() {
- case reflect.String:
- mapKeyType = 2
- case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32,
- reflect.Int64, reflect.Uint, reflect.Uint8, reflect.Uint16,
- reflect.Uint32, reflect.Uint64:
- mapKeyType = 1
- default:
- return
- }
- for _, v := range t {
- son := ru.MapIndex(v)
- switch son.Kind() {
- case reflect.Array, reflect.Slice, reflect.Map:
- temp := unsafe.Pointer(C.php_array_create_zval())
- if nil == temp {
- var tm C.zval
- tmp := &tm
- C.php7_array_init(tmp)
- temp = unsafe.Pointer(tmp)
- }
- sonup := &temp
- if 1 == mapKeyType {
- ik := v.Int()
- push_php_array(son, sonup, ik, mapKeyType)
- C.php_array_add_index_zval(*rv, C.ulong(ik), *sonup)
- } else {
- ik := v.String()
- push_php_array(son, sonup, ik, mapKeyType)
- C.php_array_add_assoc_zval(*rv, C.CString(ik), *sonup)
- }
- default:
- if 1 == mapKeyType {
- push_php_array(son, rv, v.Int(), mapKeyType)
- } else {
- push_php_array(son, rv, v.String(), mapKeyType)
- }
- }
- }
- default:
- panic("wft")
- }
- }
- func push_php_array(ru reflect.Value, rv *unsafe.Pointer, key interface{}, at int) {
- if rv == nil {
- return
- }
- var stringKey string
- var numberKey int64
- if at == 1 {
- numberKey = key.(int64)
- } else {
- stringKey = key.(string)
- }
- switch ru.Kind() {
- case reflect.Array, reflect.Slice, reflect.Map:
- set_php_array(ru, rv)
- case reflect.Int64:
- fallthrough
- case reflect.Int8:
- fallthrough
- case reflect.Int32:
- fallthrough
- case reflect.Int:
- fallthrough
- case reflect.Int16:
- if 1 == at {
- C.php_array_add_index_long(*rv, C.ulong(numberKey), C.long(ru.Int()))
- } else {
- C.php_array_add_assoc_long(*rv, C.CString(stringKey), C.long(ru.Int()))
- }
- case reflect.Uint:
- fallthrough
- case reflect.Uint64:
- fallthrough
- case reflect.Uint32:
- fallthrough
- case reflect.Uint16:
- fallthrough
- case reflect.Uint8:
- if 1 == at {
- C.php_array_add_index_long(*rv, C.ulong(numberKey), C.long(ru.Uint()))
- } else {
- C.php_array_add_assoc_long(*rv, C.CString(stringKey), C.long(ru.Uint()))
- }
- case reflect.Float64:
- fallthrough
- case reflect.Float32:
- if 1 == at {
- C.php_array_add_index_double(*rv, C.ulong(numberKey), C.double(ru.Float()))
- } else {
- C.php_array_add_assoc_double(*rv, C.CString(stringKey), C.double(ru.Float()))
- }
- case reflect.String:
- if 1 == at {
- C.php_array_add_index_string(*rv, C.ulong(numberKey), C.CString(ru.String()))
- } else {
- C.php_array_add_assoc_string(*rv, C.CString(stringKey), C.CString(ru.String()))
- }
- }
- }
- //export goapi_get_value
- func goapi_get_value(gv unsafe.Pointer, gvt unsafe.Pointer) uintptr {
- giv := FROMCIP(gv)
- gvty := reflect.TypeOf(giv)
- if gvty == nil {
- return 0
- }
- rvt := 0
-
- var rv uintptr
- switch gvty.Kind() {
- case reflect.Invalid:
- case reflect.Bool:
- if giv.(bool) {
- rv = 1
- } else {
- rv = 0
- }
- rvt = PHPTY_IS_BOOL
- case reflect.Int:
- rv = (uintptr)(giv.(int))
- rvt = PHPTY_IS_LONG
- case reflect.Int8:
- rv = (uintptr)(giv.(int8))
- rvt = PHPTY_IS_LONG
- case reflect.Int16:
- rv = (uintptr)(giv.(int16))
- rvt = PHPTY_IS_LONG
- case reflect.Int32:
- rv = (uintptr)(giv.(int32))
- rvt = PHPTY_IS_LONG
- case reflect.Int64:
- rv = (uintptr)(giv.(int64))
- rvt = PHPTY_IS_LONG
- case reflect.Uint:
- rv = (uintptr)(giv.(uint))
- rvt = PHPTY_IS_LONG
- case reflect.Uint8:
- rv = (uintptr)(giv.(uint8))
- rvt = PHPTY_IS_LONG
- case reflect.Uint16:
- rv = (uintptr)(giv.(uint16))
- rvt = PHPTY_IS_LONG
- case reflect.Uint32:
- rv = (uintptr)(giv.(uint32))
- rvt = PHPTY_IS_LONG
- case reflect.Uint64:
- rv = (uintptr)(giv.(uint64))
- rvt = PHPTY_IS_LONG
- case reflect.Uintptr:
- rv = giv.(uintptr)
- case reflect.Float32:
- var drv *C.double = (*C.double)(C.malloc(8))
- *drv = (C.double)(giv.(float32))
- rv = uintptr(unsafe.Pointer(drv))
- rvt = PHPTY_IS_DOUBLE
- case reflect.Float64:
- var drv *C.double = (*C.double)(C.malloc(8))
- *drv = (C.double)(giv.(float64))
- rv = uintptr(unsafe.Pointer(drv))
- rvt = PHPTY_IS_DOUBLE
- case reflect.Complex64:
- case reflect.Complex128:
- case reflect.Chan:
- case reflect.Func:
- case reflect.Interface:
- case reflect.Ptr:
- case reflect.String:
- rv = uintptr(unsafe.Pointer(C.CString(giv.(string))))
- rvt = PHPTY_IS_STRING
- case reflect.Map:
- rvt = PHPTY_IS_ARRAY
- case reflect.Slice:
- rvt = PHPTY_IS_ARRAY
- case reflect.Array:
- rvt = PHPTY_IS_ARRAY
- case reflect.Struct:
- case reflect.UnsafePointer:
- rv = (uintptr)(giv.(unsafe.Pointer))
- }
- // 简洁方式
- /*rvty := FROMCIP(goapi_type_r(int(reflect.Uintptr))).(reflect.Type)
- log.Println(rvty)
- log.Println(goapi_type_r(int(reflect.Uintptr)))
- if gvty.ConvertibleTo(rvty) {
- rv = reflect.ValueOf(giv).Convert(rvty).Interface().(uintptr)
- } else {
- switch gvty.Kind() {
- case reflect.Ptr:
- rv = reflect.ValueOf(giv).Pointer()
- default:
- log.Panicln("can not convert:", giv, gvty.Kind(), gvty, rvty)
- }
- }*/
-
- *(*C.int)(gvt) = C.int(rvt)
- return rv
- }
|