define socket api

Author: jkingstonc

example/test.gila

@@ -8,6 +8,11 @@ dll = load_gila_abi_dll("./gila_socket/target/debug/gila_socket.dll")
 
 
 
+socket = dll.create_socket(80)
+dll.listen_socket(socket)
+conn = dll.accept_socket(socket)
 
-res = dll.create_socket(12)
-print(res)
+
+
+
+print(socket)

gila_socket/src/socket.rs

@@ -12,3 +12,47 @@ pub extern "C" fn create_socket(
     println!("create_socket port={:?}", port);
     return Object::I64(12);
 }
+
+#[no_mangle]
+pub extern "C" fn listen_socket(
+    shared_execution_context: &mut SharedExecutionContext,
+    execution_context: &mut ProcessContext,
+    args: Vec<Object>,
+) -> Object {
+    let port = &args[0];
+    println!("listen_socket port={:?}", port);
+    return Object::I64(12);
+}
+
+#[no_mangle]
+pub extern "C" fn accept_socket(
+    shared_execution_context: &mut SharedExecutionContext,
+    execution_context: &mut ProcessContext,
+    args: Vec<Object>,
+) -> Object {
+    let socket = &args[0];
+    println!("accept_socket socket={:?}", socket);
+    return Object::I64(12);
+}
+
+#[no_mangle]
+pub extern "C" fn send_socket(
+    shared_execution_context: &mut SharedExecutionContext,
+    execution_context: &mut ProcessContext,
+    args: Vec<Object>,
+) -> Object {
+    let socket = &args[0];
+    println!("send_socket socket={:?}", socket);
+    return Object::I64(12);
+}
+
+#[no_mangle]
+pub extern "C" fn close_socket(
+    shared_execution_context: &mut SharedExecutionContext,
+    execution_context: &mut ProcessContext,
+    args: Vec<Object>,
+) -> Object {
+    let socket = &args[0];
+    println!("closing socket={:?}", socket);
+    return Object::I64(12);
+}

src/codegen.rs

@@ -347,6 +347,14 @@ impl BytecodeGenerator<'_> {
                 load_gila_abi_dll_perm_slot,
             );
 
+        let load_c_abi_dll_perm_slot = alloc_perm_slot!(self);
+        self.codegen_context.chunks[self.codegen_context.current_chunk_pointer]
+            .variable_map
+            .insert(
+                Type::IDENTIFIER(Rc::new("load_c_abi_dll".to_string())),
+                load_c_abi_dll_perm_slot,
+            );
+
         let __platform___reg = alloc_perm_slot!(self);
         self.codegen_context.chunks[self.codegen_context.current_chunk_pointer]
             .variable_map

src/execution.rs

@@ -776,6 +776,16 @@ fn native_open_windows(
     return Object::I64(0);
 }
 
+fn native_load_c_abi_dll(
+    shared_execution_context: &mut SharedExecutionContext,
+    execution_context: &mut ProcessContext,
+    args: Vec<Object>,
+) -> Object {
+    let path = args[0].as_string(shared_execution_context);
+    let dll = shared_execution_context.load_gila_abi_dll(path.s.to_string());
+    Object::GILA_ABI_DLL(dll)
+}
+
 pub struct ExecutionEngine<'a> {
     pub config: &'a Config,
     pub running: bool,
@@ -844,6 +854,20 @@ impl<'a> ExecutionEngine<'a> {
         self.environment.stack_frames[self.environment.stack_frame_pointer].stack[2] =
             Object::GC_REF(alloc);
 
+        let alloc_res = self.shared_execution_context.heap.alloc(
+            GCRefData::GILA_ABI_FUNCTION_OBJECT(GilaABIFunctionObject::RUST_CALL_CONVENTION(
+                native_load_c_abi_dll,
+            )),
+            config,
+        );
+        if alloc_res.is_err() {
+            return Err(alloc_res.err().unwrap());
+        }
+        let alloc = alloc_res.unwrap();
+        self.environment.stack_frames[self.environment.stack_frame_pointer].stack[3] =
+            Object::GC_REF(alloc);
+
+        ///
         let alloc_res = self.shared_execution_context.heap.alloc(
             GCRefData::STRING(StringObject {
                 s: Rc::new(env::consts::OS.to_owned()),
@@ -854,7 +878,7 @@ impl<'a> ExecutionEngine<'a> {
             return Err(alloc_res.err().unwrap());
         }
         let alloc = alloc_res.unwrap();
-        self.environment.stack_frames[self.environment.stack_frame_pointer].stack[3] =
+        self.environment.stack_frames[self.environment.stack_frame_pointer].stack[4] =
             Object::GC_REF(alloc);
 
         Ok(())
@@ -1456,6 +1480,7 @@ impl<'a> ExecutionEngine<'a> {
                 let result = unsafe {
                     native_fn.invoke(self.shared_execution_context, self.environment, args)
                 };
+                println!("got result {:?}", result);
                 stack_set!(self, destination, result);
                 increment_ip!(self);
             }