svr.sun_family = AF_UNIX;
strcpy(svr.sun_path, mynname);
len = strlen(svr.sun_path) + sizeof(svr.sun_family);
+ fprintf(stderr, "logint: Binding to socket: %s\n", svr.sun_path);
bind(sock, (struct sockaddr*)&svr, len);
listen(sock, 5);
strcpy(svr.sun_path, argv[1]);
strcpy(mykname, argv[1]);
len = strlen(svr.sun_path) + sizeof(svr.sun_family);
+ fprintf(stderr, "logint: Connecting to socket: %s\n", svr.sun_path);
i = connect(internal_sock, (struct sockaddr*)&svr, len);
if (i==0) {
fcntl(internal_sock,F_SETFL, O_NONBLOCK |
fcntl(internal_sock,F_GETFL,0));
}
- else
+ else {
while (i!=0) {
close(internal_sock);
internal_sock = socket(AF_UNIX, SOCK_STREAM, 0);
fcntl(internal_sock, F_GETFL, 0));
i = connect(internal_sock, (struct sockaddr*)&svr, len);
}
+ }
on = 1;
setsockopt(internal_sock, IPPROTO_TCP, TCP_NODELAY, (char*)&on,
sizeof(on));
close(sock);
/* load code and prototypes */
- if (filename != NULL)
+ if (filename != NULL) {
+ fprintf(stderr, "logint: loading code: %s\n", filename);
load(filename);
- else
+ }
+ else {
usage();
+ }
}
/**
*/
int main(int argc, char **argv)
{
+ fprintf(stderr, "logint: initializing\n");
/* initialize executor */
initiate(argc, argv);
/* initialize running system */
+ fprintf(stderr, "logint: runsys\n");
runsys();
+ fprintf(stderr, "logint: initializing scheduler\n");
init_scheduler();
+ fprintf(stderr, "logint: acquiring GRAPH resource\n");
GraphRes = get_graph_res();
- if (GraphRes < 0)
+ if (GraphRes < 0) {
+ fprintf(stderr, "logint: > acquiring GRAPH resource failed\n");
exit(12);
+ }
request_id();
if (remote)