Test

crypto777/nanosrc/aio/worker_posix.c

@@ -103,7 +103,7 @@ int nn_worker_init(struct nn_worker *self)
 {
     int32_t rc;
     PNACL_message("nn_worker_init %p\n",self);
-    sleep(1);
+    //sleep(1);
     rc = nn_efd_init(&self->efd);
     PNACL_message("efd init: rc.%d\n",rc);
     if ( rc < 0 )

crypto777/nanosrc/core/global.c

@@ -240,7 +240,7 @@ PNACL_message("list init\n");
     // Initialise other parts of the global state.
     nn_list_init(&SELF.transports);
     nn_list_init(&SELF.socktypes);
-    sleep(1);
+    //sleep(1);
 PNACL_message("transports init\n");
     //  Plug in individual transports.
     //nn_global_add_transport(nn_ipc);
@@ -248,36 +248,36 @@ PNACL_message("transports init\n");
     //nn_global_add_transport(nn_inproc);
     //nn_global_add_transport(nn_ws);
     //nn_global_add_transport(nn_tcpmux);
-    sleep(1);
+    //sleep(1);
 PNACL_message("socktypes init\n");
     // Plug in individual socktypes
     nn_global_add_socktype(nn_pair_socktype);
-    sleep(1);
+    //sleep(1);
     PNACL_message("nn_xpair_socktype init\n");
     nn_global_add_socktype(nn_xpair_socktype);
     PNACL_message("did nn_xpair_socktype init\n");
-    //nn_global_add_socktype(nn_rep_socktype);
-    //nn_global_add_socktype(nn_req_socktype);
-    //nn_global_add_socktype(nn_xrep_socktype);
-    //nn_global_add_socktype(nn_xreq_socktype);
-    //nn_global_add_socktype(nn_respondent_socktype);
-    //nn_global_add_socktype(nn_surveyor_socktype);
-    //nn_global_add_socktype(nn_xrespondent_socktype);
-    //nn_global_add_socktype(nn_xsurveyor_socktype);
-    //nn_global_add_socktype(nn_pub_socktype);
-    //nn_global_add_socktype(nn_sub_socktype);
-    //nn_global_add_socktype(nn_xpub_socktype);
-    //nn_global_add_socktype(nn_xsub_socktype);
-    //nn_global_add_socktype(nn_push_socktype);
-    //nn_global_add_socktype(nn_xpush_socktype);
-    //nn_global_add_socktype(nn_pull_socktype);
-    //nn_global_add_socktype(nn_xpull_socktype);
-    //nn_global_add_socktype(nn_bus_socktype);
-    //nn_global_add_socktype(nn_xbus_socktype);
-    sleep(1);
+    nn_global_add_socktype(nn_rep_socktype);
+    nn_global_add_socktype(nn_req_socktype);
+    nn_global_add_socktype(nn_xrep_socktype);
+    nn_global_add_socktype(nn_xreq_socktype);
+    nn_global_add_socktype(nn_respondent_socktype);
+    nn_global_add_socktype(nn_surveyor_socktype);
+    nn_global_add_socktype(nn_xrespondent_socktype);
+    nn_global_add_socktype(nn_xsurveyor_socktype);
+    nn_global_add_socktype(nn_pub_socktype);
+    nn_global_add_socktype(nn_sub_socktype);
+    nn_global_add_socktype(nn_xpub_socktype);
+    nn_global_add_socktype(nn_xsub_socktype);
+    nn_global_add_socktype(nn_push_socktype);
+    nn_global_add_socktype(nn_xpush_socktype);
+    nn_global_add_socktype(nn_pull_socktype);
+    nn_global_add_socktype(nn_xpull_socktype);
+    nn_global_add_socktype(nn_bus_socktype);
+    nn_global_add_socktype(nn_xbus_socktype);
+    //sleep(1);
 PNACL_message("do pool init\n");
     nn_pool_init(&SELF.pool); // Start the worker threads
-    sleep(1);
+    //sleep(1);
 PNACL_message("do FSM init\n");
     nn_fsm_init_root(&SELF.fsm,nn_global_handler,nn_global_shutdown,&SELF.ctx); // Start FSM
     SELF.state = NN_GLOBAL_STATE_IDLE;

crypto777/nanosrc/utils/efd_pipe.c

@@ -34,14 +34,14 @@ int nn_efd_init(struct nn_efd *self)
 {
     int rc,flags,p[2];
     PNACL_message("inside efd_init: pipe\n");
-    sleep(1);
+    //sleep(1);
 #if defined NN_HAVE_PIPE2
     rc = pipe2(p, O_NONBLOCK | O_CLOEXEC);
 #else
     rc = pipe(p);
 #endif
     PNACL_message("rc efd_init: %d\n",rc);
-    sleep(1);
+    //sleep(1);
     if (rc != 0 && (errno == EMFILE || errno == ENFILE))
         return -EMFILE;
     errno_assert (rc == 0);