Changes in uspace/srv/net/nil/nildummy/nildummy.c [6b82009:9934f7d] in mainline

File:

• uspace/srv/net/nil/nildummy/nildummy.c (modified) (16 diffs)

uspace/srv/net/nil/nildummy/nildummy.c

@@ -44 +44 @@
 #include <ipc/net.h>
 #include <ipc/services.h>
+
 #include <net/modules.h>
 #include <net/device.h>
@@ -52 +53 @@
 #include <netif_remote.h>
 #include <nil_skel.h>
+
+// FIXME: remove this header
+#include <kernel/ipc/ipc_methods.h>
+
 #include "nildummy.h"
 
@@ -65 +70 @@
 DEVICE_MAP_IMPLEMENT(nildummy_devices, nildummy_device_t);
 
-int nil_device_state_msg_local(device_id_t device_id, sysarg_t state)
+int nil_device_state_msg_local(int nil_phone, device_id_t device_id, int state)
 {
         fibril_rwlock_read_lock(&nildummy_globals.protos_lock);
-        if (nildummy_globals.proto.sess)
-                il_device_state_msg(nildummy_globals.proto.sess, device_id,
+        if (nildummy_globals.proto.phone)
+                il_device_state_msg(nildummy_globals.proto.phone, device_id,
                     state, nildummy_globals.proto.service);
         fibril_rwlock_read_unlock(&nildummy_globals.protos_lock);
@@ -76 +81 @@
 }
 
-int nil_initialize(async_sess_t *sess)
+int nil_initialize(int net_phone)
 {
         fibril_rwlock_initialize(&nildummy_globals.devices_lock);
@@ -83 +88 @@
         fibril_rwlock_write_lock(&nildummy_globals.protos_lock);
         
-        nildummy_globals.net_sess = sess;
-        nildummy_globals.proto.sess = NULL;
+        nildummy_globals.net_phone = net_phone;
+        nildummy_globals.proto.phone = 0;
         int rc = nildummy_devices_initialize(&nildummy_globals.devices);
         
@@ -97 +102 @@
  * @param[in]     iid   Message identifier.
  * @param[in,out] icall Message parameters.
- * @param[in]     arg    Local argument.
- *
+ * @param[in]     arg   Local argument.
  */
 static void nildummy_receiver(ipc_callid_t iid, ipc_call_t *icall, void *arg)
@@ -108 +112 @@
                 switch (IPC_GET_IMETHOD(*icall)) {
                 case NET_NIL_DEVICE_STATE:
-                        rc = nil_device_state_msg_local(IPC_GET_DEVICE(*icall),
-                            IPC_GET_STATE(*icall));
+                        rc = nil_device_state_msg_local(0,
+                            IPC_GET_DEVICE(*icall), IPC_GET_STATE(*icall));
                         async_answer_0(iid, (sysarg_t) rc);
                         break;
                 
                 case NET_NIL_RECEIVED:
-                        rc = packet_translate_remote(nildummy_globals.net_sess,
+                        rc = packet_translate_remote(nildummy_globals.net_phone,
                             &packet, IPC_GET_PACKET(*icall));
                         if (rc == EOK)
-                                rc = nil_received_msg_local(IPC_GET_DEVICE(*icall),
-                                    packet, 0);
+                                rc = nil_received_msg_local(0,
+                                    IPC_GET_DEVICE(*icall), packet, 0);
                         
                         async_answer_0(iid, (sysarg_t) rc);
@@ -176 +180 @@
                 /* Notify the upper layer module */
                 fibril_rwlock_read_lock(&nildummy_globals.protos_lock);
-                if (nildummy_globals.proto.sess) {
-                        il_mtu_changed_msg(nildummy_globals.proto.sess,
+                if (nildummy_globals.proto.phone) {
+                        il_mtu_changed_msg(nildummy_globals.proto.phone,
                             device->device_id, device->mtu,
                             nildummy_globals.proto.service);
@@ -199 +203 @@
 
         /* Bind the device driver */
-        device->sess = netif_bind_service(device->service, device->device_id,
+        device->phone = netif_bind_service(device->service, device->device_id,
             SERVICE_ETHERNET, nildummy_receiver);
-        if (device->sess == NULL) {
+        if (device->phone < 0) {
                 fibril_rwlock_write_unlock(&nildummy_globals.devices_lock);
                 free(device);
-                return ENOENT;
+                return device->phone;
         }
         
         /* Get hardware address */
-        int rc = netif_get_addr_req(device->sess, device->device_id,
+        int rc = netif_get_addr_req(device->phone, device->device_id,
             &device->addr, &device->addr_data);
         if (rc != EOK) {
@@ -303 +307 @@
 }
 
-int nil_received_msg_local(device_id_t device_id, packet_t *packet,
-    services_t target)
+int nil_received_msg_local(int nil_phone, device_id_t device_id,
+    packet_t *packet, services_t target)
 {
         fibril_rwlock_read_lock(&nildummy_globals.protos_lock);
         
-        if (nildummy_globals.proto.sess) {
+        if (nildummy_globals.proto.phone) {
                 do {
                         packet_t *next = pq_detach(packet);
-                        il_received_msg(nildummy_globals.proto.sess, device_id,
+                        il_received_msg(nildummy_globals.proto.phone, device_id,
                             packet, nildummy_globals.proto.service);
                         packet = next;
@@ -327 +331 @@
  *
  * @param[in] service Module service.
- * @param[in] sess    Service session.
+ * @param[in] phone   Service phone.
  *
  * @return EOK on success.
@@ -334 +338 @@
  *
  */
-static int nildummy_register_message(services_t service, async_sess_t *sess)
+static int nildummy_register_message(services_t service, int phone)
 {
         fibril_rwlock_write_lock(&nildummy_globals.protos_lock);
         nildummy_globals.proto.service = service;
-        nildummy_globals.proto.sess = sess;
-        
-        printf("%s: Protocol registered (service: %d)\n",
-            NAME, nildummy_globals.proto.service);
+        nildummy_globals.proto.phone = phone;
+        
+        printf("%s: Protocol registered (service: %d, phone: %d)\n",
+            NAME, nildummy_globals.proto.service, nildummy_globals.proto.phone);
         
         fibril_rwlock_write_unlock(&nildummy_globals.protos_lock);
@@ -372 +376 @@
         /* Send packet queue */
         if (packet)
-                netif_send_msg(device->sess, device_id, packet,
+                netif_send_msg(device->phone, device_id, packet,
                     SERVICE_NILDUMMY);
         
@@ -396 +400 @@
                 return EOK;
         
-        async_sess_t *callback =
-            async_callback_receive_start(EXCHANGE_SERIALIZE, call);
-        if (callback)
-                return nildummy_register_message(NIL_GET_PROTO(*call), callback);
-        
         switch (IPC_GET_IMETHOD(*call)) {
         case NET_NIL_DEVICE:
@@ -407 +406 @@
         
         case NET_NIL_SEND:
-                rc = packet_translate_remote(nildummy_globals.net_sess,
+                rc = packet_translate_remote(nildummy_globals.net_phone,
                     &packet, IPC_GET_PACKET(*call));
                 if (rc != EOK)
@@ -437 +436 @@
                         return rc;
                 return measured_strings_reply(address, 1);
+        
+        case IPC_M_CONNECT_TO_ME:
+                return nildummy_register_message(NIL_GET_PROTO(*call),
+                    IPC_GET_PHONE(*call));
         }