- MESSAGE m;
- char s[255];
-
-
- m.msg_type = MSG_NET;
- m.param.pword[0] = NET_NODE_EXIST;
- m.param.pword[1] = on;
- m.param.pword[2] = interp->ID;
- write(net_sock,&m,sizeof(MESSAGE));
- bzero(&m,sizeof(MESSAGE));
- while( (m.msg_type!=MSG_NET) && (m.param.pword[0]!=NET_NODE_EXIST) )
- read(net_sock,&m,sizeof(MESSAGE));
-
-if (m.param.pword[1]==1) /* means node exists */
-{
- m.msg_type = MSG_NET;
- m.param.pword[0] = NET_TRANSMIT_CODE;
- m.param.pword[1] = interp->ID;
- m.param.pword[2] = on;
- strcpy(m.param.pstr,interp->fullname);
- write(net_sock,&m,sizeof(MESSAGE));
-
- Net_Notify->setEnabled(FALSE);
- while ( (m.msg_type != MSG_NET) || (m.param.pword[0]!=NET_TRANSMITTED) )
- read(net_sock,&m,sizeof(MESSAGE));
-
-
- m.msg_type = MSG_NET;
- m.param.pword[0] = NET_PROPAGATE;
- m.param.pword[1] = MSG_VLP;
- m.param.pword[2] = NodeNumber;
- m.param.pword[3] = 0;
- m.param.pword[4] = on;
- m.param.pword[5] = 0;
- m.param.pword[6] = VLP_REMOTE_INSTANCE;
- m.param.pword[7] = interp->ID;
- strcpy(m.param.pstr,interp->shortname);
- write(net_sock,&m,sizeof(MESSAGE));
-
- read(net_sock,&m,sizeof(MESSAGE));
- while (1)
- {
- if ( (m.param.pword[0]==NET_PROPAGATE) && (m.param.pword[6] == VLP_REMOTE_INSTANCE_OK))
- {
- interp->RInstances[on] = m.param.pword[7];
- break;
- }
- read(net_sock,&m,sizeof(MESSAGE));
- }
-
- Net_Notify->setEnabled(TRUE);
-
- /*bzero(&m,sizeof(MESSAGE));*/
- m.msg_type = MSG_VLP;
- m.param.pword[0] = VLP_REMOTE_INSTANCE_HERE;
- m.param.pword[1] = interp->RInstances[on];
- write(interp->sock,&m,sizeof(MESSAGE));
-}
- else /* There is no such a node! */
-{
- sprintf(s,"Warning: Node number %d not found!",on);
- WriteMessage(s);
- WriteMessage("Allocating O-process on the local node");
- bzero(&m,sizeof(MESSAGE));
- m.msg_type = MSG_VLP;
- m.param.pword[0] = VLP_REMOTE_INSTANCE_HERE;
- m.param.pword[1] = interp->ID;
- write(interp->sock,&m,sizeof(MESSAGE));
-}
+ MESSAGE m;
+ char s[255];
+
+ m.msg_type = MSG_NET;
+ m.param.pword[0] = NET_NODE_EXIST;
+ m.param.pword[1] = on;
+ m.param.pword[2] = interp->ID;
+ write(net_sock, &m, sizeof(MESSAGE));
+ bzero(&m, sizeof(MESSAGE));
+ while((m.msg_type!=MSG_NET) && (m.param.pword[0]!=NET_NODE_EXIST))
+ read(net_sock, &m, sizeof(MESSAGE));
+
+ /* means node exists */
+ if (m.param.pword[1] == 1) {
+ m.msg_type = MSG_NET;
+ m.param.pword[0] = NET_TRANSMIT_CODE;
+ m.param.pword[1] = interp->ID;
+ m.param.pword[2] = on;
+ strcpy(m.param.pstr, interp->fullname);
+ write(net_sock, &m, sizeof(MESSAGE));
+
+ Net_Notify->setEnabled(FALSE);
+ while ((m.msg_type != MSG_NET) ||
+ (m.param.pword[0] != NET_TRANSMITTED))
+ read(net_sock, &m, sizeof(MESSAGE));
+
+ m.msg_type = MSG_NET;
+ m.param.pword[0] = NET_PROPAGATE;
+ m.param.pword[1] = MSG_VLP;
+ m.param.pword[2] = NodeNumber;
+ m.param.pword[3] = 0;
+ m.param.pword[4] = on;
+ m.param.pword[5] = 0;
+ m.param.pword[6] = VLP_REMOTE_INSTANCE;
+ m.param.pword[7] = interp->ID;
+ strcpy(m.param.pstr, interp->shortname);
+ write(net_sock, &m, sizeof(MESSAGE));
+
+ read(net_sock, &m, sizeof(MESSAGE));
+ while (1) {
+ if ((m.param.pword[0] == NET_PROPAGATE) &&
+ (m.param.pword[6] == VLP_REMOTE_INSTANCE_OK)) {
+ interp->RInstances[on] = m.param.pword[7];
+ break;
+ }
+ read(net_sock, &m, sizeof(MESSAGE));
+ }
+
+ Net_Notify->setEnabled(TRUE);
+
+ /*bzero(&m, sizeof(MESSAGE));*/
+ m.msg_type = MSG_VLP;
+ m.param.pword[0] = VLP_REMOTE_INSTANCE_HERE;
+ m.param.pword[1] = interp->RInstances[on];
+ write(interp->sock, &m, sizeof(MESSAGE));
+ } else { /* There is no such a node! */
+ sprintf(s, "Warning: Node number %d not found!", on);
+ WriteMessage(s);
+ WriteMessage("Allocating O-process on the local node");
+ bzero(&m, sizeof(MESSAGE));
+ m.msg_type = MSG_VLP;
+ m.param.pword[0] = VLP_REMOTE_INSTANCE_HERE;
+ m.param.pword[1] = interp->ID;
+ write(interp->sock, &m, sizeof(MESSAGE));
+ }