Newsgroups: comp.sources.unix From: pleierc@informatik.tu-muenchen.de (Christoph Pleier) Subject: v27i181: distributed-c-2.1 - Distributed C Development Environment, V2.1, Part07/18 References: <1.756634932.28500@gw.home.vix.com> Sender: unix-sources-moderator@gw.home.vix.com Approved: vixie@gw.home.vix.com Submitted-By: pleierc@informatik.tu-muenchen.de (Christoph Pleier) Posting-Number: Volume 27, Issue 181 Archive-Name: distributed-c-2.1/part07 #! /bin/sh # This is a shell archive. Remove anything before this line, then unpack # it by saving it into a file and typing "sh file". To overwrite existing # files, type "sh file -c". You can also feed this as standard input via # unshar, or by typing "sh 'config/debug.c' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * d e b u g . c * X * * X * Package : Configuration Files Parsers * X * Version : 1.0 * X * CreationDate : 26.02.92 * X * LastUpDate : 26.02.92 * X * * X * All routines needed to display additional informations for debugging * X * perpose only. * X * * X * Copyright (C) 1992-1994 by Christoph Pleier * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#include X#include "cfgparsers.h" X X#define DEBUG X X#ifdef DEBUG X X/****************************************************************************** X * DisplaySymbtabel() * X * * X * Displays the components of the symbol table element pointed to by 'symbol'.* X * * X * Return values: none! * X ******************************************************************************/ Xint XDisplaySymbtabel(symbol) XSYMBTABEL *symbol; X{ X TARGETINFO *target; X SYMBTABEL *p_symb; X ACCFSINFO *afs; X IDENTLIST *idl; X FSSPECINFO *fsl; X COMMPINFO *csl; X PATTRINFO *pattrl; X PHOSTLIST *phost; X COSTINFO *costl; X X printf("name : \"%s\"\n", symbol->name); X printf("type : "); X switch(symbol->type) { X case UNDEFINED: X puts("UNDEFINED"); X break; X case S_HOST: X puts("S_HOST"); X printf("installed operating system : %s\n", symbol->info.Host.os->name); X printf(" computer type : %s\n", symbol->info.Host.type->name); X printf(" physical memory : %f MB\n", symbol->info.Host.phys_mem); X printf(" virtual memory : %f MB\n", symbol->info.Host.virt_mem); X printf(" performance index : %f\n", symbol->info.Host.perf_index); X if (symbol->info.Host.multiprocessor) { X printf(" multiprocessor : TRUE\n"); X printf(" number of processors : %d\n", symbol->info.Host.processors); X printf(" memory type : %s memory\n", X (symbol->info.Host.memory_type == SHARED_MEMORY) ? "shared" : "distributed"); X printf("has parallelizing compiler : %s\n", (symbol->info.Host.has_par_compiler) ? "TRUE" : "FALSE"); X } else X printf(" multiprocessor : FALSE\n"); X printf(" is vector computer : %s\n", (symbol->info.Host.is_vector_computer) ? "TRUE" : "FALSE"); X X printf("peripheral devices:\n "); X for(idl = symbol->info.Host.p_devices; idl; idl = idl->next) X printf("%s ", idl->symbol->name); X puts(""); X X printf("accessible filesystems:\n "); X for(afs = symbol->info.Host.f_systems; afs; afs = afs->next) X printf("%s (%f) ", afs->filesystem->name, afs->acc_time); X puts(""); X X printf("compilation information:\n"); X for(target = symbol->info.Host.compinfo; target; target = target->next){ X printf(" target type : \"%s\"\n", target->type); X printf(" target os : \"%s\"\n", target->os); X printf(" cc : \"%s\"\n", target->cc); X printf(" cflags : \"%s\"\n", target->cflags); X printf(" ldflags : \"%s\"\n", target->ldflags); X printf(" libs : \"%s\"\n", target->libs); X } X X printf("cost informations:\n"); X for(costl = symbol->info.Host.costinfo; costl; costl = costl->next) X printf(" -> %15s : %3.2f, %3.2f\n", costl->dest_host->name, costl->crea_val, costl->comm_val); X printf("internal informations:\n"); X printf("prob_load : %f\n", symbol->info.Host.prob_load); X printf(" pcreated : %d\n", symbol->info.Host.pcreated); X break; X case S_COMPUTER_TYPE: X puts("S_COMPUTER_TYPE"); X break; X case S_OPERATING_SYSTEM: X puts("S_OPERATING_SYSTEM"); X break; X case S_FIXED_DISK: X puts("S_FIXED_DISK"); X printf("disk located in host \"%s\"\n", symbol->info.disk.location->name); X printf("disk size = %f MB\n", symbol->info.disk.size); X printf("disk access time = %f ms\n", symbol->info.disk.speed); X break; X case S_PROCESS: X puts("S_PROCESS"); X printf(" intensity index : %f\n", symbol->info.Process.intensity_index); X if (symbol->info.Process.pref_hosts) { X printf(" preferred hosts : "); X for(idl = symbol->info.Process.pref_hosts; idl; idl = idl->next) X printf("%s ", idl->symbol->name); X puts(""); X } X if (symbol->info.Process.rest_hosts) { X printf(" restricted hosts : "); X for(idl = symbol->info.Process.rest_hosts; idl; idl = idl->next) X printf("%s ", idl->symbol->name); X puts(""); X } X if (symbol->info.Process.peri_dev) { X printf("accesses peripheral devices :\n"); X for(idl = symbol->info.Process.peri_dev; idl; idl = idl->next) X printf("%s ", idl->symbol->name); X puts(""); X } X if (symbol->info.Process.filesystems) { X printf("accesses filesystems:\n"); X for(fsl = symbol->info.Process.filesystems; fsl; fsl = fsl->next) X printf(" name: %s, freq: %f, quant: %f\n", X fsl->filesys->name, fsl->frequency, fsl->quantity); X } X if (symbol->info.Process.commps) { X printf("communicates with:\n"); X for(csl = symbol->info.Process.commps; csl; csl = csl->next) X printf(" name: %s, freq: %f, quant: %f\n", X csl->Process->name, csl->frequency, csl->quantity); X } X for(pattrl = symbol->info.Process.others; pattrl; pattrl = pattrl->next) { X switch(pattrl->type) { X case PA_PHYS_MEM: X printf("%s physical memory: %f MB\n", (pattrl->mode == MODE_WISHES) ? "whishes" : "requires", X pattrl->info.phys_mem_size); X break; X case PA_VIRT_MEM: X printf("%s virtual memory: %f MB\n", (pattrl->mode == MODE_WISHES) ? "whishes" : "requires", X pattrl->info.virt_mem_size); X break; X case PA_VECTORIZATION: X printf("%s vectorization\n", (pattrl->mode == MODE_WISHES) ? "whishes" : "requires"); X break; X case PA_PARALLELIZATION: X printf("%s parallelization\n", (pattrl->mode == MODE_WISHES) ? "whishes" : "requires"); X break; X } X } /* for(pattrl) */ X if (symbol->info.Process.phostlist) { X printf("priority hostlist:\n"); X for(phost = symbol->info.Process.phostlist; phost; phost = phost->next) X printf(" host: %10s, pref: %d, w_val: %3d, load: %2.2f, overall: %2.2f\n", X phost->Host->name, phost->preferred, phost->wished_val, X phost->load, phost->overall_index); X } X default: X puts("unknown"); X } /* switch */ X} /* DisplaySymbtabel */ X X/****************************************************************************** X * DisplaySymbolTable() * X * * X * Displays the complete symbol table. * X * * X * Return values: none! * X ******************************************************************************/ Xint XDisplaySymbolTable() X{ X int i; X register SYMBTABEL *symbol; X X puts("Symbol table:"); X puts("=============\n"); X for(symbol = symbtab, i = 1; symbol; symbol = symbol->next, i++) { X printf("Entry %3d:\n", i); X printf("----------\n"); X DisplaySymbtabel(symbol); X puts(""); X } X} /* DisplaySymbolTable */ X X#endif /* DEBUG /**/ END_OF_FILE if test 9082 -ne `wc -c <'config/debug.c'`; then echo shar: \"'config/debug.c'\" unpacked with wrong size! fi # end of 'config/debug.c' fi if test -f 'config/system.y' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'config/system.y'\" else echo shar: Extracting \"'config/system.y'\" \(8845 characters\) sed "s/^X//" >'config/system.y' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * s y s t e m . y * X * * X * Package : Configuration Files Parsers * X * Version : 2.0 * X * CreationDate : 20.11.91 * X * LastUpDate : 20.12.93 * X * * X * The grammar specifying the syntax of the system configuration file. * X * * X * Copyright (C) 1991-1994 by Christoph Pleier * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X%{ X#include X#include X#include X#include "cfgparsers.h" X%} X X/* the type of the value stack */ X%union { X char *y_str; /* a string */ X SYMBTABEL *y_symb; /* a pointer to a symbol table element */ X float y_float; /* a number */ X MULTIINFO *y_multi; X OPTCOMPINFO *y_ocomp; X COMPSPEINFO *y_comsp; X TARGETINFO *y_target; /* a pointer to a target information */ X ACCFSINFO *y_accfs; X IDENTLIST *y_idlist; /* a pointer to an identifier list */ X} X X/* characters */ X%token ',' ';' ':' '.' '+' '-' '*' '/' '%' '~' '!' '&' '|' '^' X%token '=' '<' '>' '{' '}' '[' ']' '(' ')' '\"' '\'' '\\' '@' X X/* special characters X * NOTE: The token definition must be defined exactly like in program.y X */ X%token ACCESSES ACCESSIBLE COMMUNICATES COMPILATION COMPILER COMPUTER COSTS X%token CREATION DEVICES DISKS DISTRIBUTED EXECUTABLES FILESYSTEMS FIXED FOR X%token GENERAL HOST HOSTS HOSTNAMES INDEX INFORMATIONS INTENSITY LISTS LOCATION X%token MEMORY MULTIPROCESSOR OPERATING PARALLELIZING PERFORMANCE PERIPHERAL X%token PHYSICAL PREFERRED PRIORITY PROCESS PROCESSORS REQUIRES RESTRICTED X%token SHARED SIZE SPECIFICATION SPEED STORAGE SYSTEM TARGET TYPE TYPES X%token VARIANTS VECTOR VIRTUAL WISHES WITH X%token VECTORIZATION PARALLELIZATION X%token MS NS KB MB GB X%token CC CFLAGS LD LDFLAGS LIBS X%token IDENT STRING NUMBER X X%type STRING X%type IDENT operating_system_definition X%type NUMBER size_specification time_specification X%type optional_disk_size_definition optional_disk_speed_definition X%type multiprocessor_specification X%type optional_computer_attribute_list optional_computer_attribute X%type computer_specification X%type target_specification target_list compilation_specification X%type filesystem_definition filesystems_list X%type accessible_filesystems_definition X%type ident_list peripheral_devices_definition X X%start system_configuration X X%% X Xsystem_configuration: X declaration_list X ; X Xdeclaration_list: X declaration X | declaration_list declaration X ; X Xdeclaration: X hostnames_definition X | computer_types_definition X | operating_system_variants_definition X | fixed_disks_definition X | host_specification X | compilation_hosts_definition X | costs_definition X ; X Xhostnames_definition: X HOSTNAMES '=' '{' ident_list '}' X {mark_symbols($4, S_HOST);} X ; X Xcomputer_types_definition: X COMPUTER TYPES '=' '{' ident_list '}' X {mark_symbols($5, S_COMPUTER_TYPE);} X ; X Xoperating_system_variants_definition: X OPERATING SYSTEM VARIANTS '=' '{' ident_list '}' X {mark_symbols($6, S_OPERATING_SYSTEM);} X ; X Xfixed_disks_definition: X FIXED DISKS '=' '{' disk_definition_list '}' X ; X Xdisk_definition_list: X disk_definition X | disk_definition_list disk_definition X ; X Xdisk_definition: X IDENT '=' '{' X LOCATION ':' IDENT X optional_disk_size_definition X optional_disk_speed_definition X '}' X {enter_disk_definition($1, $6, $7, $8);} X ; X Xoptional_disk_size_definition: X /* empty */ X {$$ = 0.0;} X | SIZE ':' size_specification X {$$ = $3;} X ; X Xoptional_disk_speed_definition: X /* empty */ X {$$ = 0.0;} X | SPEED ':' time_specification X {$$ = $3;} X ; X Xhost_specification: X HOST ident_list '=' '{' X operating_system_definition X computer_specification X peripheral_devices_definition X compilation_specification X accessible_filesystems_definition X '}' X {enter_host_specification($2, $5, $6, $7, $8, $9);} X ; X Xoperating_system_definition: X OPERATING SYSTEM ':' IDENT X {$$ = $4;} X ; X Xcomputer_specification: X COMPUTER SPECIFICATION '{' X TYPE ':' IDENT X PHYSICAL MEMORY ':' size_specification X VIRTUAL MEMORY ':' size_specification X PERFORMANCE INDEX ':' NUMBER X STORAGE FOR EXECUTABLES ':' IDENT X '}' X {$$ = generate_comp_spec_info($6, $10, $14, $18, NULL, $23);} X | COMPUTER SPECIFICATION '{' X TYPE ':' IDENT X PHYSICAL MEMORY ':' size_specification X VIRTUAL MEMORY ':' size_specification X PERFORMANCE INDEX ':' NUMBER X optional_computer_attribute_list X STORAGE FOR EXECUTABLES ':' IDENT X '}' X {$$ = generate_comp_spec_info($6, $10, $14, $18, $19, $24);} X ; X Xoptional_computer_attribute_list: X optional_computer_attribute X | optional_computer_attribute_list optional_computer_attribute X {$$ = add_opt_comp_attr_info($1, $2);} X ; X Xoptional_computer_attribute: X multiprocessor_specification X {$$ = generate_opt_comp_attr_info($1, 0);} X | VECTOR COMPUTER X {$$ = generate_opt_comp_attr_info(NULL, VECTOR_COMPUTER);} X | PARALLELIZING COMPILER X {$$ = generate_opt_comp_attr_info(NULL, PAR_COMPILER);} X ; X Xmultiprocessor_specification: X MULTIPROCESSOR SYSTEM ':' NUMBER PROCESSORS ',' SHARED MEMORY X {$$ = generate_multi_info($4, SHARED_MEMORY);} X | MULTIPROCESSOR SYSTEM ':' NUMBER PROCESSORS ',' DISTRIBUTED MEMORY X {$$ = generate_multi_info($4, DISTRIBUTED_MEMORY);} X ; X Xperipheral_devices_definition: X /* empty */ X {$$ = NULL;} X | PERIPHERAL DEVICES '=' '{' ident_list '}' X {$$ = $5;} X ; X Xcompilation_specification: X COMPILATION '{' target_list '}' X {$$ = $3;} X ; X Xtarget_list: X target_specification X | target_list target_specification X {$$ = chain_targetinfos($1, $2);} X ; X Xtarget_specification: X TARGET ':' IDENT '(' IDENT ')' '{' X CC '=' STRING X CFLAGS '=' STRING X LDFLAGS '=' STRING X LIBS '=' STRING X '}' X {$$ = generate_targetinfo($3, $5, $10, $13, $16, $19);} X ; X Xaccessible_filesystems_definition: X /* empty */ X {$$ = NULL;} X | ACCESSIBLE FILESYSTEMS '=' '{' filesystems_list '}' X {$$ = $5;} X ; X Xfilesystems_list: X filesystem_definition X | filesystems_list ',' filesystem_definition X {$$ = chain_accfs_infos($1, $3);} X ; X Xfilesystem_definition: X IDENT '(' time_specification ')' X {$$ = generate_accfs_info($1, $3);} X ; X Xcompilation_hosts_definition: X COMPILATION HOSTS PRIORITY LISTS '{' X compilation_hosts_priority_list X '}' X ; X Xcompilation_hosts_priority_list: X /* empty */ X | compilation_hosts_specification_list X | GENERAL ':' ident_list X ; X Xcompilation_hosts_specification_list: X IDENT ':' ident_list X | compilation_hosts_specification_list IDENT ':' ident_list X ; X Xcosts_definition: X COSTS INFORMATIONS '{' costs_definition_list '}' X ; X Xcosts_definition_list: X cost_definition X | costs_definition_list cost_definition X ; X Xcost_definition: X IDENT '-' '>' IDENT ':' NUMBER ',' NUMBER X {enter_cost_definition($1, $4, $6, $8);} X ; X Xident_list: X IDENT X {$$ = store_ident_in_list($1);} X | ident_list ',' IDENT X {$$ = chain_ident_lists($1, store_ident_in_list($3));} X ; X Xsize_specification: X NUMBER MB X | NUMBER GB X {$$ = $1 * 1024;} X ; X Xtime_specification: X NUMBER MS X ; X X%% END_OF_FILE if test 8845 -ne `wc -c <'config/system.y'`; then echo shar: \"'config/system.y'\" unpacked with wrong size! fi # end of 'config/system.y' fi if test -f 'dcadmin/Status.c' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'dcadmin/Status.c'\" else echo shar: Extracting \"'dcadmin/Status.c'\" \(7800 characters\) sed "s/^X//" >'dcadmin/Status.c' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * S t a t u s . c * X * * X * Package : Administration Process * X * Version : 1.0 * X * CreationDate : 16.09.90 * X * LastUpDate : 06.12.93 * X * * X * All routines needed for storing new process states and for displaying * X * them. * X * * X * Copyright (C) 1990-1994 by Christoph Pleier * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#include X#include X#ifdef HETEROGENEOUS X# include X#endif X#include X#include X#ifndef UNICOS X# include X#endif X#include X#ifdef BSD X# include X#endif /* BSD /**/ X#include "ipc.h" X#include "dcc.h" X#include "timeout.h" X#include "dcadmin.h" X X#define EXIT(v) fprintf(stderr, "dcadmin: Terminating!\n"); \ X exit(v) X X/****************************************************************************** X * ChangeProcessStatus() * X * * X * Change the state of a process to 'accept or terminate' or 'running'. * X * * X * Return values: OK upon success / ERROR upon error * X ******************************************************************************/ Xint XChangeProcessStatus(state) Xint state; X{ X PROCESSDATA p_data; X register struct pdat_list *aptr; X X /* Receive the process information of the process */ X if (_receive_process_data(&p_data)) { X error("dcadmin: receiving process data"); X EXIT(ERROR); X } X /* Search entry in list and change the state if there is one. X * Otherwise return an error. X */ X for(aptr = pdat_first; aptr; aptr = aptr->next) { X if (!strcmp(aptr->p_descr.processname, p_data.processname) X#ifdef iPSC X && aptr->p_descr.port.node == p_data.port.node X && aptr->p_descr.port.pid == p_data.port.pid) { X#else X# ifdef SINGLE X && aptr->p_descr.pid == p_data.pid) { X# else /* HOMOGENEOUS || HETEROGENEOUS */ X && !strcmp(aptr->p_descr.port.hostname, p_data.port.hostname) X && aptr->p_descr.port.portnum == p_data.port.portnum) { X# endif /* SINGLE /**/ X#endif /* iPSC /**/ X aptr->status = (state == NOTIFY_ACCORTER_ON) ? ACCORTER : RUNNING; X#ifdef ADMINDEBUG X fprintf(dfile, "[dbg] %s state of process %s with pid %d modified to %s\n", X _processprefix, aptr->p_descr.processname, aptr->p_descr.pid, X (state == NOTIFY_ACCORTER_ON) ? "accept or terminate" : X "running"); X if (_debugflush) X fflush(dfile); X#endif /* ADMINDEBUG /**/ X if (state == NOTIFY_ACCORTER_ON) X CheckAcceptOrTerminate(); X return(OK); X } X } /* for */ X error("Process to change state not found in process data list"); X return(ERROR); X} /* ChangeProcessStatus */ X X/****************************************************************************** X * DisplayStatus() * X * * X * Displays the status of all processes of the 'process data list'. * X * * X * Return values: OK upon success / ERROR upon error * X ******************************************************************************/ Xint XDisplayStatus() X{ X register struct pdat_list *ptr; X X#ifdef DO_NOT_COMPILE X switch(fork()) { X case -1: X error("dcadmin: fork()"); X EXIT(ERROR); X /* break; */ X case 0: X /* child! */ X printf("\n%-20s |", "PROCESSNAME"); X#ifdef iPSC X printf(" %-15s |", "NODE"); X#else X# ifndef SINGLE X printf(" %-20s |", "HOST"); X# endif /* !SINGLE /**/ X#endif /* iPSC /**/ X printf(" %-10s | %-15s\n", "PID", "STATUS"); X for(ptr = pdat_first; ptr; ptr = ptr->next) { X printf("%-20s |", ptr->p_descr.processname); X#ifdef iPSC X printf(" %-15ld |", ptr->p_descr.port.node); X#else X# ifndef SINGLE X printf(" %-20s |", ptr->p_descr.port.hostname); X# endif /* !SINGLE /**/ X#endif /* iPSC /**/ X printf(" %-10d | ", ptr->p_descr.pid); X switch(ptr->status) { X case RUNNING: X printf("%-15s\n", "running"); X break; X case ACCORTER: X printf("%-15s\n", "accept or terminate"); X break; X default: X printf("%-15s\n", "UNKNOWN"); X break; X } /* switch */ X } /* for */ X exit(OK); X break; X default: X /* parent! */ X Intr = 1; X signal(SIGTERM, DisplayStatus); X } /* switch */ X#endif X return(OK); X} /* DisplayStatus */ X X/****************************************************************************** X * GetChildStatus() * X * * X * Get status of terminating children to avoid zombies! * X * * X * Return values: none * X ******************************************************************************/ Xint XGetChildStatus() X{ X int pid, X status; X struct pid_list *pptr, X *lptr; X#ifdef SYSTEM_V X pid = wait(&status); X#else /* BSD */ X union wait wstatus; X X pid = wait3(&wstatus, WNOHANG, NULL); X status = wstatus.w_status; X#endif /* SYSTEM_V /**/ X#ifdef DO_NOT_COMPILE X if (status == 0xB1) { X fputs(": process was stopped!\n", pfile); X } else { X if (!(status & 0xFF)) X fprintf(pfile, " by exit call. Exit code = %d\n", X (status & 0xFF00) >> 8); X else X fprintf(pfile, " by signal %d\n", status); X } X fflush(pfile); X } X#endif X /* set signal again */ X /* signal(SIGCLD, GetChildStatus); */ X Intr = 1; X} /* GetChildStatus */ X END_OF_FILE if test 7800 -ne `wc -c <'dcadmin/Status.c'`; then echo shar: \"'dcadmin/Status.c'\" unpacked with wrong size! fi # end of 'dcadmin/Status.c' fi if test -f 'dcinstall/Compile.c' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'dcinstall/Compile.c'\" else echo shar: Extracting \"'dcinstall/Compile.c'\" \(8377 characters\) sed "s/^X//" >'dcinstall/Compile.c' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * C o m p i l e . c * X * * X * Package : Installer Program * X * Version : 1.0 * X * CreationDate : 20.11.91 * X * LastUpDate : 03.12.93 * X * * X * The routine 'CompileFiles' which performs the complete compilation, * X * linking and loading of programs. * X * * X * Copyright (C) 1991-1994 by Christoph Pleier * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#include X#include X#include "cfgparsers.h" X#include "dcinstall.h" X X/****************************************************************************** X * CompileFiles() * X * * X * Compiles, links and loads the files from the local host 'src' specified as * X * command line arguments on the destination host 'dest'. * X * NOTE: For local compilation 'src' equals 'dest'. * X * * X * Return values: OK upon success / ERROR upon error * X ******************************************************************************/ Xint XCompileFiles(src, dest) XSYMBTABEL *src; /* source host */ XSYMBTABEL *dest; /* destination host */ X{ X int mounted; /* src and dest share one filesystem or not */ X static char cmd[1000]; /* to store the command */ X FILENAMELIST *fptr; /* pointer for file list (xxx.c) */ X OPTIONLIST *optr; /* pointer for option list */ X SYMBTABEL *symbol; /* loop pointer for symbol table elements */ X SYMBTABEL *symbol2; /* loop pointer for symbol table elements */ X SYMBTABEL *class; /* destination compilation class */ X TARGETINFO *targets; /* all targets the local system can build */ X X if (!c_flag && !o_flag) X return(OK); X X#ifndef DEBUG X printf(" Compiling files on %s (%s)\n", X dest->name, dest->info.Host.ex_storage->name); X#endif /* Not DEBUG /**/ X X /* Determine access mode: X * If source-host equals destination host or source and dest host X * share one disk the access mode is mounted. Otherwise if dest is X * accessed via network, it is not mounted! X */ X if (src == dest || src->info.Host.ex_storage->info.disk.location == dest->info.Host.ex_storage->info.disk.location) X mounted = TRUE; X else X mounted = FALSE; X X if (mounted) X sprintf(cmd, "cd %s/dcc/compile ;", gethomedir(getLogin())); X else X sprintf(cmd, "%s %s cd dcc/compile \";\"", RSH, dest->name); X X for(targets = dest->info.Host.compinfo; targets; targets = targets->next) X if (!strcmp(targets->type, dest->info.Host.type->name) X && !strcmp(targets->os, dest->info.Host.os->name)) X break; X X if (!targets) { X fprintf(stderr, "Error: target specification for computer type \"%s\" of operating", X dest->info.Host.type->name); X fprintf(stderr, " system \"%s\" of host \"%s\" not found \n", X dest->info.Host.os->name, dest->name); X fprintf(stderr, " in system configuration file \"%s\"\n", X cfgfilename); X exit(ERROR); X } X X strcat(cmd, " "); X strcat(cmd, targets->cc); X strcat(cmd, " -I. -I../include "); X strcat(cmd, targets->cflags); X strcat(cmd, " "); X X if (o_flag) { X strcat(cmd, "-o "); X strcat(cmd, targetname); X strcat(cmd, " "); X } X X if (c_flag) { X strcat(cmd, "-c "); X strcat(cmd, " "); X } X X for(fptr = first_file; fptr; fptr = fptr->next) { X strcat(cmd, fptr->name); X strcat(cmd, " "); X } X X for(optr = first_opt; optr; optr = optr->next) { X strcat(cmd, optr->option); X strcat(cmd, " "); X } X X if (o_flag) { X strcat(cmd, " ../lib/"); X strcat(cmd, dest->info.Host.type->name); X strcat(cmd, "/dcc.a "); X } X X strcat(cmd, targets->libs); X X if (o_flag) { X if (mounted) X strcat(cmd, " ; mv "); X else X strcat(cmd, " \";\" mv "); X strcat(cmd, targetname); X strcat(cmd, " "); X strcat(cmd, "../bin/"); X strcat(cmd, dest->info.Host.type->name); X strcat(cmd, "/"); X strcat(cmd, targetname); X } X X if (verbose) X printf(" Compilation command: %s\n", cmd); X X if (!noexecute) X if (system(cmd)) { X fprintf(stderr, "\nError compiling the files for host \"%s\"\n", X dest->name); X fprintf(stderr, "The following command caused the error:\n"); X fprintf(stderr, "\"%s\"\n", cmd); X exit(ERROR); X } X X dest->info.Host.wasmade = TRUE; X X /* check the remainding hosts */ X for(symbol = symbtab; symbol; symbol = symbol->next) { X X if (symbol->type == S_HOST X && symbol->info.Host.type == dest->info.Host.type X && symbol->info.Host.os == dest->info.Host.os) { X X if (!symbol->info.Host.istarget || symbol->info.Host.wasmade) X continue; X X if (symbol->info.Host.ex_storage == dest->info.Host.ex_storage) { X /* Host shares files with compilation host => nothing to do! */ X symbol->info.Host.wasmade = TRUE; X } else { X /* Host has own filesystem => distribute generated executables X */ X if (o_flag) { X#ifndef DEBUG X printf(" Distributing files %s (%s) -> %s (%s)\n", X dest->name, dest->info.Host.ex_storage->info.disk.location->name, X symbol->name, symbol->info.Host.ex_storage->info.disk.location->name); X#endif /* Not DEBUG /**/ X sprintf(cmd, "rcp %s/dcc/bin/%s/%s %s@%s:dcc/bin/%s/%s", X gethomedir(getLogin()), dest->info.Host.type->name, X targetname, getLogin(), symbol->name, X dest->info.Host.type->name, targetname); X if (verbose) X printf("Distribution command: %s\n", cmd); X if (!noexecute) X if (system(cmd)) { X fprintf(stderr, "\nError distributing the files to host \"%s\"\n", X symbol->name); X fprintf(stderr, "The following command caused the error:\n"); X fprintf(stderr, "\"%s\"\n", cmd); X exit(ERROR); X } X } X /* all hosts of this filesystem and the same class are also X * marked X */ X for(symbol2 = symbtab; symbol2; symbol2 = symbol2->next) { X if (symbol2->type == S_HOST X && symbol2->info.Host.type == symbol->info.Host.type X && symbol2->info.Host.os == symbol->info.Host.os X && symbol2->info.Host.ex_storage == symbol->info.Host.ex_storage) { X symbol2->info.Host.wasmade = TRUE; X } X } /* for */ X } X } X X } /* for(symbol) */ X X return(OK); X X} /* CompileFiles */ END_OF_FILE if test 8377 -ne `wc -c <'dcinstall/Compile.c'`; then echo shar: \"'dcinstall/Compile.c'\" unpacked with wrong size! fi # end of 'dcinstall/Compile.c' fi if test -f 'dcinstall/ParseOptions.c' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'dcinstall/ParseOptions.c'\" else echo shar: Extracting \"'dcinstall/ParseOptions.c'\" \(8792 characters\) sed "s/^X//" >'dcinstall/ParseOptions.c' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * P a r s e O p t i o n s . c * X * * X * Package : Installer Program * X * Version : 1.1 * X * CreationDate : 20.11.91 * X * LastUpDate : 25.02.92 * X * * X * Parses and interprets the command line options. * X * * X * Copyright (C) 1991-1994 by Christoph Pleier * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#include X#include X#include X#include "cfgparsers.h" X#include "dcinstall.h" X X/****************************************************************************** X * ParseOptions() * X * * X * Parses and interprets the command line options. * X * * X * Return values: OK upon success / ERROR upon error * X ******************************************************************************/ Xint XParseOptions(argc, argv) Xint argc; Xchar *argv[]; X{ X int i; X int length; X char *suffix; X char localhostname[MAXHOSTNAMELEN]; X char input[80]; X FILENAMELIST *fptr; X OPTIONLIST *optr; X SYMBTABEL *symbol; X X for(i = 1; i < argc; i++) { X X if (!strcmp(argv[i], "-f")) { X /* this option was already managed! */ X ++i; X continue; X } X X if (!strcmp(argv[i], "-c")) { X /* Option: "-c" */ X if (o_flag) { X fputs("Error: Option '-o' and '-c' combined\n", stderr); X exit(ERROR); X } X c_flag = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-c\"\n"); X#endif /* DEBUG /**/ X continue; X } X X if (!strcmp(argv[i], "-o")) { X /* Option: "-o" */ X if (c_flag) { X fputs("Error: Option '-c' and '-o' combined\n", stderr); X exit(ERROR); X } X o_flag = TRUE; X targetname = argv[++i]; X#ifdef DEBUG X printf("Option recognized: \"-o %s\"\n", targetname); X#endif /* DEBUG /**/ X continue; X } X X if (!strcmp(argv[i], "-target")) { X if (!strcmp(argv[++i], "all")) { X /* Option: "-target all" */ X alltargets = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-target all\"\n"); X#endif /* DEBUG /**/ X for(symbol = symbtab; symbol; symbol = symbol->next) { X if (symbol->type == S_HOST) X symbol->info.Host.istarget = TRUE; X } X continue; X } else { X /* Option: "-target local" or "-target hostname" */ X if (!strcmp(argv[i], "local")) { X localtarget = TRUE; X if (gethostname(localhostname, MAXHOSTNAMELEN)) { X fputs("Error: can't determine name of local host\n", stderr); X exit(ERROR); X } X symbol = lookup_symbtabel(localhostname); X } else { X symbol = lookup_symbtabel(argv[i]); X } X if (symbol == NULL) { X fprintf(stderr, "Error: target system for hostname \"%s\" is not defined in\n", X (localtarget) ? localhostname : argv[i]); X fprintf(stderr, " system configuration file \"%s\"\n", X cfgfilename); X exit(ERROR); X } X if (symbol->type != S_HOST) { X fprintf(stderr, "Error: target system for hostname \"%s\" is not defined as\n", X argv[i]); X fprintf(stderr, " hostname in system configuration file \"%s\"\n", X cfgfilename); X exit(ERROR); X } X symbol->info.Host.istarget = TRUE; X } X#ifdef DEBUG X printf("Option recognized: \"-target %s\"\n", argv[i]); X#endif /* DEBUG /**/ X continue; X } X X if (!strcmp(argv[i], "-prepare")) { X /* Option: "-prepare" */ X prepare = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-prepare\"\n"); X#endif /* DEBUG /**/ X if (!noexecute) { X puts("WARNING: The option \"-prepare\" causes the destruction of all data"); X puts(" in the directory \"dcc\" including all subdirectories at"); X puts(" all specified hosts!"); X printf("Do you really want to continue? (y/n) "); X scanf("%s", input); X if (input[0] != 'y' && input[0] != 'Y') X exit(OK); X } X continue; X } X X if (!strcmp(argv[i], "-clean")) { X /* Option: "-clean" */ X clean = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-clean\"\n"); X#endif /* DEBUG /**/ X continue; X } X X if (!strcmp(argv[i], "-crosscompile")) { X /* Option: "-crosscompile" */ X crosscompile = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-crosscompile\"\n"); X#endif /* DEBUG /**/ X fputs("Error: Option 'crosscompile' not yet implemented\n", stderr); X fputs("This will be done in a future release.\n", stderr); X exit(ERROR); X continue; X } X X if (!strcmp(argv[i], "-checktargets")) { X /* Option: "-checktargets" */ X checktargets = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-checktargets\"\n"); X#endif /* DEBUG /**/ X fputs("Error: Option 'checktargets' not yet implemented\n", stderr); X fputs("This will be done in a future release.\n", stderr); X exit(ERROR); X continue; X } X X if (!strcmp(argv[i], "-verbose")) { X /* Option: "-verbose" */ X verbose = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-verbose\"\n"); X#endif /* DEBUG /**/ X continue; X } X X if (!strcmp(argv[i], "-noexecute")) { X /* Option: "-noexecute" */ X noexecute = TRUE; X#ifdef DEBUG X printf("Option recognized: \"-noexecute\"\n"); X#endif /* DEBUG /**/ X continue; X } X X#ifdef YYDEBUG X if (!strcmp(argv[i], "-yydebug")) { X /* Option: "-yydebug" */ X# ifdef DEBUG X printf("Option recognized: \"-yydebug\"\n"); X# endif /* DEBUG /**/ X yydebug = 1; X continue; X } X#endif /* YYDEBUG /**/ X X length = strlen(argv[i]); X suffix = argv[i] + length - 2; X X if (!strncmp(suffix, ".c", 2)) { X /* Option: ".c" */ X#ifdef DEBUG X printf("Option recognized: filename \"%s\"\n", argv[i]); X#endif /* DEBUG /**/ X /* store filename in filename list */ X fptr = (FILENAMELIST *) Malloc(sizeof(FILENAMELIST)); X fptr->name = argv[i]; X fptr->next = NULL; X if (first_file == NULL) X first_file = last_file = fptr; X else { X last_file->next = fptr; X last_file = fptr; X } X continue; X } X X if (!strncmp(suffix, ".h", 2)) { X /* Option: ".h" */ X#ifdef DEBUG X printf("Option recognized: include filename \"%s\"\n", argv[i]); X#endif /* DEBUG /**/ X /* store include filename in include filename list */ X fptr = (FILENAMELIST *) Malloc(sizeof(FILENAMELIST)); X fptr->name = argv[i]; X fptr->next = NULL; X if (first_incl_file == NULL) X first_incl_file = last_incl_file = fptr; X else { X last_incl_file->next = fptr; X last_incl_file = fptr; X } X continue; X } X X#ifdef DEBUG X printf("Storing unknown Option: \"%s\"\n", argv[i]); X#endif /* DEBUG /**/ X /* store option in option list */ X optr = (OPTIONLIST *) Malloc(sizeof(OPTIONLIST)); X optr->option = argv[i]; X optr->next = NULL; X if (first_opt == NULL) X first_opt = last_opt = optr; X else { X last_opt->next = optr; X last_opt = optr; X } X X } /* for(i) */ X X return(OK); X} /* ParseOptions */ END_OF_FILE if test 8792 -ne `wc -c <'dcinstall/ParseOptions.c'`; then echo shar: \"'dcinstall/ParseOptions.c'\" unpacked with wrong size! fi # end of 'dcinstall/ParseOptions.c' fi if test -f 'dcinstall/main.c' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'dcinstall/main.c'\" else echo shar: Extracting \"'dcinstall/main.c'\" \(7420 characters\) sed "s/^X//" >'dcinstall/main.c' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * m a i n . c * X * * X * Package : Installer Program * X * Version : 1.1 * X * CreationDate : 20.11.91 * X * LastUpDate : 25.02.92 * X * * X * The routine 'main' and the global variables. * X * * X * Copyright (C) 1991-1994 by Christoph Pleier * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#include X#include "cfgparsers.h" X#include "dcinstall.h" X#include "version.h" X X/* X * global variables X */ X Xint alltargets; /* perform actions for all targets */ Xint checkfile; /* check configuration file only or not */ Xint checktargets; /* check targets or not */ Xint c_flag; /* option '-c' or not */ Xint clean; /* clean targets' remote compilation dirs */ Xint crosscompile; /* use cross compilation if possible or not */ Xint localtarget; /* perform actions for local host only */ Xint noexecute; /* execute commands or not */ Xint o_flag; /* option '-o' or not */ Xint prepare; /* install runtime library or not */ Xint verbose; /* print commands or not */ Xchar cfgfilename[MAXPATHNAMELEN]; /* name of configuration file */ Xchar *targetname; /* name of compilation target */ XFILENAMELIST *first_file; /* pointer to beginning of file list (xxx.c) */ XFILENAMELIST *last_file; /* pointer to end of file list (xxx.c) */ XFILENAMELIST *first_incl_file; /* pointer to beginning of file list (xxx.h) */ XFILENAMELIST *last_incl_file; /* pointer to end of file list (xxx.h) */ XOPTIONLIST *first_opt; /* pointer to beginning of option list */ XOPTIONLIST *last_opt; /* pointer to end of option list */ XSYMBTABEL *symbtab; /* pointer to beginning of symbol table */ XSYMBTABEL *last_symb; /* pointer to end of symbol table */ X#ifdef LINUX Xint yylineno; X#endif X X/****************************************************************************** X * main() * X * * X * The function main. * X * * X * Return values: OK upon success / ERROR upon error * X ******************************************************************************/ Xmain(argc, argv) Xint argc; Xchar *argv[]; X{ X int i; X char localhostname[MAXHOSTNAMELEN]; X SYMBTABEL *local_host, *dummy, *class, *symbol, X *acthost, *actfsys, *cc_host; X char *descr; X X /* some initializations */ X prepare = clean = o_flag = c_flag = alltargets = FALSE; X crosscompile = checkfile = checktargets = FALSE; X localtarget = noexecute = verbose = FALSE; X symbtab = NULL; X targetname = NULL; X first_incl_file = last_incl_file = NULL; X cfgfilename[0] = 0; X X /* is there any job? */ X if (argc == 1) { X fprintf(stderr, "%s\n%s\n%s\n\n", progname, version, copyright); X fputs("Error: nothing to do\n\n", stderr); X DisplayUsage(); X exit(ERROR); X } X X /* check command line for '-f' option */ X for(i = 1; i < argc; i++) { X if (!strcmp(argv[i], "-f")) { X /* Option: "-f filename" */ X strcpy(cfgfilename, argv[++i]); X#ifdef DEBUG X printf("Option recognized: \"-f %s\"\n", cfgfilename); X#endif /* DEBUG /**/ X break; X } X } /* for */ X X /* search default file in home directory */ X if (cfgfilename[0] == 0) X sprintf(cfgfilename, "%s/%s", getenv("HOME"), CFGFILENAME); X X /* interpret system configuration file */ X if (!(yyin = fopen(cfgfilename, "r"))) { X fprintf(stderr, "Error: can't open system configuration file \"%s\"\n", X cfgfilename); X exit(ERROR); X } else { X (void) parse_system(); X (void) close(yyin); X } X X /* parse command line (must follow reading of cfg file!!!) */ X if (ParseOptions(argc, argv)) { X DisplayUsage(); X exit(ERROR); X } X X /* determine hostname of local host */ X if (gethostname(localhostname, MAXHOSTNAMELEN)) { X fputs("Error: can't determine name of local host!\n", stderr); X exit(ERROR); X } X X /* determine host informtion of local host */ X if (!(local_host = lookup_symbtabel(localhostname))) { X fputs("Error: local hostname is not defined in configuration file\n", stderr); X exit(ERROR); X } X X if (localtarget) X local_host->info.Host.istarget = TRUE; X X /* prepare all target hosts if specified as command line option */ X if (prepare) { X for(acthost = symbtab; acthost; acthost = acthost->next) { X if (acthost->type != S_HOST || acthost->info.Host.ex_storage->info.disk.wasprepared) X continue; X PrepareTarget(local_host, acthost); X } X } X X /* generate the requested object files or executables for all targets X * specified in the command line X */ X if (c_flag || o_flag || first_file || first_incl_file) { X for(dummy = symbtab; dummy; dummy = dummy->next) { X X if (dummy->type != S_HOST || !dummy->info.Host.istarget || dummy->info.Host.wasmade) X continue; X X TransferFiles(local_host, dummy); X X CompileFiles(local_host, dummy); X X dummy->info.Host.wasmade = TRUE; X X } /* for(dummy) */ X } X X /* clean all target hosts if specified as command line option */ X if (clean) { X for(acthost = symbtab; acthost; acthost = acthost->next) { Xif (acthost->type != S_HOST || acthost->info.Host.ex_storage->info.disk.wasprepared) X if (acthost->type != S_HOST || !acthost->info.Host.istarget X || acthost->info.Host.ex_storage->info.disk.wascleaned) X continue; X CleanTarget(local_host, acthost); X } X } X X exit(OK); X} /* main */ END_OF_FILE if test 7420 -ne `wc -c <'dcinstall/main.c'`; then echo shar: \"'dcinstall/main.c'\" unpacked with wrong size! fi # end of 'dcinstall/main.c' fi if test -f 'include/com_Errno.h' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'include/com_Errno.h'\" else echo shar: Extracting \"'include/com_Errno.h'\" \(7384 characters\) sed "s/^X//" >'include/com_Errno.h' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * c o m _ E r r n o . h * X * * X * Package : Include files * X * Version : 1.0 * X * CreationDate : 10.07.90 * X * LastUpDate : 30.08.91 * X * * X * Error codes of compiler errors. * X * * X * Copyright (C) 1990-1994 by Franz Distler and Christoph Pleier. * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#ifndef __com_Errno_h X#define __com_Errno_h X X/* syntax error */ X#define ESYNTAX 0 X X/* redefinition of an identifier */ X#define EREDEFINITION 1 X X/* definition or creation of not specified process */ X#define ENOTSPECIFIED 2 X X/* redefinition of a process body */ X#define EREDEFINED 3 X X/* creation of not defined process */ X#define ENOTDEFINED 4 X X/* call of not specified transaction */ X#define EILLTRANSCALL 5 X X/* badly placed accept statement */ X#define EBADLYACCEPT 6 X X/* no variable and no parameter */ X#define ENOVARORPAR 7 X X/* error in process specification */ X#define EINPROCSPEC 8 X X/* process parameter expected */ X#define EPROCPAREXP 9 X X/* process parameter expected */ X#define EPROCPAREXP2 10 X X/* error in process parameter declaration */ X#define EINPROCPARAM 11 X X/* process transaction expected */ X#define EPROCTRANSEXP 12 X X/* process transaction expected */ X#define EPROCTRANSEXP2 13 X X/* error in process transaction declaration */ X#define EINTRANSDECL 14 X X/* error in process transaction declaration */ X#define EINTRANSDECL2 15 X X/* error in process transaction declaration */ X#define EINTRANSDECL3 16 X X/* error in process definition */ X#define EINPROCDEF 17 X X/* error in accept statement */ X#define EINACCSTAT 18 X X/* error in accept statement */ X#define EINACCSTAT2 19 X X/* error in accept statement */ X#define EINACCSTAT3 20 X X/* error in accept statement */ X#define EINACCSTAT4 21 X X/* error in select statement */ X#define EINSELSTAT 22 X X/* error in select statement */ X#define EINSELSTAT2 23 X X/* error in select part */ X#define EINSELPART 24 X X/* error in accept alternative */ X#define EINACCALTERN 25 X X/* error in destroy statement */ X#define EINDESTRSTAT 26 X X/* error in timed transaction call */ X#define EINTIMEDTRANS 27 X X/* error in process creation */ X#define EINPROCCREATE 28 X X/* error in process creation */ X#define EINPROCCREATE2 29 X X/* error in process creation */ X#define EINPROCCREATE3 30 X X/* error in process arguments */ X#define EINPROCARGS 31 X X/* error in process location */ X#define EINPROCLOC 32 X X/* error in transaction call */ X#define EINTRANSCALL 33 X X/* error: 'const' is not allowed in structure definitions */ X#define EILLCONST 34 X X/* error: 'volatile' is not allowed in structure definitions */ X#define EILLVOLATILE 35 X X/* error: 'void' is not allowed in structure definitions */ X#define EILLVOID 36 X X/* error: too many type specifiers at 'char' */ X#define EILLCHAR 37 X X/* error: too many type specifiers at 'short' */ X#define EILLSHORT 38 X X/* error: too many type specifiers at 'int' */ X#define EILLINT 39 X X/* error: too many type specifiers at 'long' */ X#define EILLLONG 40 X X/* error: too many type specifiers at 'float' */ X#define EILLFLOAT 41 X X/* error: too many type specifiers at 'double' */ X#define EILLDOUBLE 42 X X/* error: too many type specifiers at 'process' */ X#define EILLPROCESS 43 X X/* error: badly placed 'signed' */ X#define EILLSIGNED 44 X X/* error: badly placed 'unsigned' */ X#define EILLUNSIGNED 45 X X/* error: enumerations are not allowed in special used structures */ X#define EILLENUM 46 X X/* error: bitfields are not allowed in special used structures */ X#define EILLBITFIELD 47 X X/* error: illegal pointer */ X#define EILLPOINTER 48 X X/* error: too many pointers in special used structure */ X#define EMANYPOINTER 49 X X/* error: type qualifier in combination with pointer is not allowed here */ X#define EILLPOINTQUAL 50 X X/* error: function definitions are not allowed in special used structures */ X#define EILLFUNCTION 51 X X/* error: arrays are not allowed in special used structures */ X#define EILLARRAY 52 X X/* error: unknown array size */ X#define EARRAYSIZE 53 X X/* error: braces '(' ')' are not allowed in combination with arrays */ X#define EILLARRBRACES 54 X X/* error: function definitions are not allowed before arrays */ X#define EILLARRFUNCT 55 X X/* error: multiple dimensional arrays are not allowed here */ X#define EMULTIARRAY 56 X X/* error: braces '(' ')' are not allowed in special used structures */ X#define EILLBRACES 57 X X/* error: typedef names are not allowed in special used structures */ X#define EILLTYPENAME 58 X X/* error: 'auto' is not allowed in special used typedefs */ X#define EILLAUTO 59 X X/* error: 'register' is not allowed in special used typedefs */ X#define EILLREGISTER 60 X X/* error: 'static' is not allowed in special used typedefs */ X#define EILLSTATIC 61 X X/* error: 'extern' is not allowed in special used typedefs */ X#define EILLEXTERN 62 X X/* error: illegal typedef */ X#define EILLTYPEDEF 63 X X/* error: 'const' is not allowed in special used typedefs */ X#define EILLCONST2 64 X X/* error: 'volatile' is not allowed in special used typedefs */ X#define EILLVOLATILE2 65 X X/* error: 'void' is not allowed in special used typedefs */ X#define EILLVOID2 66 X X/* error: enumerations are not allowed in special used typedefs */ X#define EILLENUM2 67 X X/* error: structure definition inside of struct definition requires tag name */ X#define EISTRUCTTAG 68 X X/* error: structure definition of type definition requires tag name */ X#define ETSTRUCTTAG 69 X X/* fatal error: cannot recover from errors */ X#define FCANTRECOVER 70 X X/* warning, too few arguments for process creation */ X#define WPROCESSARGS 71 X X/* warning, too few arguments for transaction call */ X#define WTRANSARGS 72 X X#endif /* !__com_Errno_h */ END_OF_FILE if test 7384 -ne `wc -c <'include/com_Errno.h'`; then echo shar: \"'include/com_Errno.h'\" unpacked with wrong size! fi # end of 'include/com_Errno.h' fi if test -f 'include/globals.h' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'include/globals.h'\" else echo shar: Extracting \"'include/globals.h'\" \(7825 characters\) sed "s/^X//" >'include/globals.h' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * g l o b a l s . h * X * * X * Package : Include files * X * Version : 1.0 * X * CreationDate : 14.08.90 * X * LastUpDate : 06.12.93 * X * * X * Global variables and tables. * X * * X * Copyright (C) 1990-1994 by Franz Distler and Christoph Pleier. * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X/* the symbol table */ XSYMBTAB symbtab; X X/* the global variable to store the actual error */ Xint Errno = -1; X X/* the flag controlling error handling. X * while errflag is set, the semantical functions are not executed! X */ Xshort errflag = FALSE; X X/* the flag indicating an error during a process specification */ Xshort specerr = FALSE; X X/* the flag controlling creation of code. X * while outcodeflag is set, the creation of code is stopped! X */ Xshort outcodeflag = FALSE; X X/* the flag indicating parsing of a process body or not */ Xshort bodyflag = FALSE; X X/* the flag indicating function main() was declared or not */ Xshort mainflag = FALSE; X X/* this flag controls code generation in include files. X * while sysinclflag is set, no code will be stored using Strcat(), X * Strcatmany() * or strmalloc()! X */ Xshort sysinclflag = FALSE; X X/* the functions are collected in a special function file. The appropriate X * file header may only be written once to this file. funcflag is used to X * indicate if the header has already be written or not. X */ Xshort funcflag = FALSE; X X/* the functions to create processes and to perform transactions are collected X * in a special file. The appropriate file header may only be written once to X * this file. specflag is used to indicate if the header has already be written X * or not. X */ Xshort specflag = FALSE; X X#if defined(HETEROGENEOUS) || defined(CHECK_XDR) X/* the xdr routines to encode and decode data are collected in a special file. X * The appropriate file header may only be written once to this file. xdrflag X * is used to indicate if the header has already be written or not. X */ Xshort xdrflag = FALSE; X#endif /* HETEROGENEOUS /**/ X X/* this flags control the various passes */ Xshort allflag = FALSE, /* compile and link files or not */ X beautyflag = FALSE, /* beautify generated files or not */ X infoflag = FALSE, /* display infos about internal actions */ X cppflag = FALSE; /* preprocess source files only or not */ X X#ifndef YYDEBUG X/* the flag indicating output of additional parsing information. If yydebug X * equals 1 additional information will be displayed. X */ X# ifdef UNICOS Xlong yydebug = 0; X# else Xint yydebug = 0; X# endif /* UNICOS /**/ X#endif /* YYDEBUG /**/ X X/* the actual line number in the parsed file */ X#ifdef LINUX Xint yylineno; X#endif /* LINUX /**/ X X#ifdef HETEROGENEOUS X/* the flag indicating if code shall be generated to determine the buffer size X * of the encode/decode buffer or to use a fixed value. X */ Xshort determine_dcc_buf_size = TRUE; X X/* the size specified as command line option */ Xchar *encode_decode_buf_size = NULL; X X/* print warning only one times */ Xshort encode_warning = FALSE; X#endif /* HETEROGENEOUS /**/ X X/* files */ XFILE *yyerrfile = NULL, /* for error messages */ X *outfile = NULL, /* for main program */ X *inclfile = NULL, /* for dynamic includefile */ X *funcfile = NULL, /* for functions */ X *creatfile = NULL, /* for specific process creation routines */ X#if defined(HETEROGENEOUS) || defined(CHECK_XDR) X *xdrfile = NULL, /* for xdr routines */ X#endif X *makefile = NULL, /* for makefile */ X *debugfile = NULL; /* for debug messages */ X X/* filenames */ Xchar *inputfilename, X *yyerrfilename, X outputfilename[MAXFILENAMELEN], X funcfilename[MAXFILENAMELEN], X inclfilename[MAXFILENAMELEN], X creatfilename[MAXFILENAMELEN], X#if defined(HETEROGENEOUS) || defined(CHECK_XDR) X xdrfilename[MAXFILENAMELEN], X#endif X makefilename[MAXFILENAMELEN], X filenameprefix[MAXFILENAMELEN]; X X/* strings to store special data temporary */ Xchar *crextstr, /* the extern declarations of the creation routines */ X *trextstr, /* the declarations of the transaction call routines */ X#if defined(HETEROGENEOUS) || defined(CHECK_XDR) X *xdrextstr, /* the extern declarations of the xdr routines */ X#endif X *fnextstr, /* the extern declarations of functions */ X *errormesg; /* error message utility */ X X/* string to store specified makefile options to pass to the generated X * makefile X */ Xchar *libsstr = "", /* libraries */ X *cflagsstr = "", /* compiler flags */ X *lflagsstr = ""; /* loader flags */ X X/* counters */ Xint phase = 0, /* compiler phase */ X blknum = 0, /* block depth counter */ X processnum = 0, /* process counter */ X transnum = 0, /* transaction counter */ X yynwarns = 0, /* compiler warnings */ X translabel = 0; /* transaction labels */ X X/* during parsing of the declaration of process variables processptr points to X * the symbol table entry containing the corresponding process declaration. X */ XSYMBTABEL *processptr; X X/* buffer to store the result of convert attribute to string routines */ Xchar *convert_buffer; X X/* prefix for displaying informations about internal actions */ Xchar *infoprefix = "***"; X X/* the include files for processes and the main program */ Xchar *includefiles[] = X { "\"/usr/include/stdio.h\"", X "\"/usr/include/sys/types.h\"", X "" X }; X X/* anchors of process list */ Xstruct process_list *first_processname = NULL, X *last_processname = NULL; X X/* anchors of include list */ Xstruct include_list *first_includename = NULL, X *last_includename = NULL; X X/* anchors of additional include paths */ Xstruct include_path_list *first_inclpathname = NULL, X *last_inclpathname = NULL; X X/* anchors of additional preprocessor definitions */ Xstruct cpp_def_list *first_cppdef = NULL, X *last_cppdef = NULL; X X/* anchors of list of symbol table entries of structure and type definitions */ Xstruct struct_type_list *first_structtype = NULL, X *last_structtype = NULL; END_OF_FILE if test 7825 -ne `wc -c <'include/globals.h'`; then echo shar: \"'include/globals.h'\" unpacked with wrong size! fi # end of 'include/globals.h' fi if test -f 'include/run_errlist.h' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'include/run_errlist.h'\" else echo shar: Extracting \"'include/run_errlist.h'\" \(7317 characters\) sed "s/^X//" >'include/run_errlist.h' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A compiler for distributed programming with C * X * * X * r u n _ e r r l i s t . h * X * * X * Package : Include files * X * Version : 1.0 * X * CreationDate : 14.08.90 * X * LastUpDate : 12.03.92 * X * * X * The table containing the runtime error messages. * X * * X * Copyright (C) 1990-1994 by Franz Distler and Christoph Pleier. * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#ifndef __run_errlist_h X#define __run_errlist_h X X/* the names in braces mean: X * AP - Administration Process X * CP - Creator Process X * NP - New created Process X * TC - Transaction Caller X * TA - Transaction Acceptor X * TAS - Transaction Acceptor during Select X * P - any Process X */ X Xchar *runtime_errlist[] = { X X /* EFATAL */ X "fatal error", X X /* ESYSTEMDPNT */ X "system dependent error", X X /* ECREATEPORT */ X "unable to create a new port", X X /* EDELETEPORT */ X "unable to delete specified port", X X /* EACPTCON */ X "error accepting connection", X X /* EMAKECON */ X "error making connection", X X /* ECLOSECON */ X "error closing connection", X X /* ERECVDATA */ X "error receiving data", X X /* ESENDDATA */ X "error sending data", X X /* ECONREFUSED */ X "connection refused", X X /* ETIMEOUT */ X "operation timed out", X X /* ETCCPTONPACC */ X "Timeout error: (CP) created process doesn't report back", X X /* ETCCPTONPCON */ X "Timeout error: (CP) can't connect to new created process", X X /* ETCCPTONPRCV */ X "Timeout error: (CP) new process doesn't send process data", X X /* ETCCPTONPPAR */ X "Timeout error: (CP) can't send initial parameters to new process", X X /* ETCCPTONPPDAT */ X "Timeout error: (CP) can't send port information to new process", X X /* ETCCPTOAPCON */ X "Timeout error: (CP) can't connect to administration process", X X /* ETCCPTOAPREQ */ X "Timeout error: (CP) can't send location request to administration process", X X /* ETCCPTOAPSND */ X "Timeout error: (CP) can't send processname to administration process", X X /* ETCCPTOAPRCV */ X "Timeout error: (CP) can't get location info from administration process", X X /* ETCNPTOAPCON */ X "Timeout error: (NP) can't connect to administration process", X X /* ETCNPTOAPREQ */ X "Timeout error: (NP) can't send request to administration process", X X /* ETCNPTOAPSND */ X "Timeout error: (NP) can't send process data to administration process", X X /* ETCNPTOCPCON */ X "Timeout error: (NP) can't connect to creator process", X X /* ETCNPTOCPACC */ X "Timeout error: (NP) creator process doesen't request connection", X X /* ETCNPTOCPSND */ X "Timeout error: (NP) can't send process data back to creator", X X /* ETCNPGETPARA */ X "Timeout error: (NP) can't receive parameters from creator process", X X /* ETCNPGETPDAT */ X "Timeout error: (NP) can't receive port information from creator process", X X /* ETTCONTOPROC */ X "Timeout error: (TC) can't connect to called process", X X /* ETTSNDREQUEST */ X "Timeout error: (TC) can't send transaction request message", X X /* ETTRCVREPLY */ X "Timeout error: (TC) called process doesn't send reply message", X X /* ETTSENDARGS */ X "Timeout error: (TC) can't send transaction arguments to called process", X X /* ETTRCVRESULT */ X "Timeout error: (TC) can't receive transaction result", X X /* ETAACCEPTCON */ X "Timeout error: (TA) can't accept transaction request connection", X X /* ETARCVREQUEST */ X "Timeout error: (TA) can't receive transaction request message", X X /* ETASENDREPLY */ X "Timeout error: (TA) can't send transaction reply message", X X /* ETARCVPARAMS */ X "Timeout error: (TA) can't receive transaction parameters", X X /* ETASNDRESULT */ X "Timeout error: (TA) can't send transaction result", X X /* ETSACCEPTCON */ X "Timeout error: (TAS) can't accept transaction request connection", X X /* ETSRCVREQUEST */ X "Timeout error: (TAS) can't receive transaction request message", X X /* ETSSENDREPLY */ X "Timeout error: (TAS) can't send transaction reply message", X X /* ETSRCVPARAMS */ X "Timeout error: (TAS) can't receive transaction parameters", X X /* ETSSNDRESULT */ X "Timeout error: (TAS) can't send transaction result", X X /* ETCAPTOCPCON */ X "Timeout error: (AP) can't connect to creator process", X X /* ETCAPTOCPACC */ X "Timeout error: (AP) can't get connection to receive config filename", X X /* ETCAPTOCPRCV */ X "Timeout error: (AP) can't receive config filename", X X /* ETCADRCVNAME */ X "Timeout error: (AP) can't receive process name to determine location of", X X /* ETCADSNDLOC */ X "Timeout error: (AP) can't send process creation location result", X X /* ETCONNTYPESND */ X "Timeout error: (P) can't send connection type", X X /* ETCONNTYPERCV */ X "Timeout error: (P) can't receive connection type", X X /* EPROCSTOPPED */ X "(TA) called process terminated during transaction execution", X X /* EPROCESSCREAT */ X "(P) can't create new process", X X /* EPROCESSKILL */ X "(P) can't kill process", X X /* EEXECPROCESS */ X "(P) can't transform process using execv", X X /* EHOSTNAME */ X "(P) can't determine hostname by gethostname()", X X /* EMALLOCBUF */ X "error allocating heap space for encode/decode buffer", X X /* EENCODE */ X "(P) error encoding data. Perhaps only '_dcc_buf_size' is too little!", X X /* EENCODESIZE */ X "(P) resulting size of converted data is too large. Resize '_dcc_buf_size'.", X X /* EDECODE */ X "(P) error decoding data. Perhaps only '_dcc_buf_size' is too little!", X X /* EXDRSETPOS */ X "(P) error: xdr_setpos() does not work!" X}; X X#endif /* !__run_errlist_h /**/ END_OF_FILE if test 7317 -ne `wc -c <'include/run_errlist.h'`; then echo shar: \"'include/run_errlist.h'\" unpacked with wrong size! fi # end of 'include/run_errlist.h' fi if test -f 'ipc/p1.c' -a "${1}" != "-c" ; then echo shar: Will not clobber existing file \"'ipc/p1.c'\" else echo shar: Extracting \"'ipc/p1.c'\" \(8046 characters\) sed "s/^X//" >'ipc/p1.c' <<'END_OF_FILE' X/*************************************************************************** X * * X * @@@@ @@@ @@@@@ @@@@@ @@@@@ @@@ @@@@ @ @ @@@@@ @@@@@ @@@@ @@@ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @ @ @ @@@@@ @ @@@@@ @ @@@@@ @ @ @ @@@@@ @ @ @ * X * @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ * X * @@@@ @@@ @@@@@ @ @ @ @@@ @@@@ @@@@@ @ @@@@@ @@@@ @@@ * X * * X * A precompiler for distributed programming with C * X * * X * p 1 . c * X * * X * Version 1.0 CreationDate: 15.07.90 * X * LastUpDate: 24.09.90 * X * * X * Process 1 for testing the communication primitives. * X * * X * Copyright (C) 1990 by Franz Distler and Christoph Pleier. * X * All rights reserved! * X ***************************************************************************/ X X/* X * This file is part of the Distributed C Development Environment (DCDE). X * DCDE is free software; you can redistribute it and/or modify X * it under the terms written in the README-file. X * DCDE is distributed in the hope that it will be useful, X * but WITHOUT ANY WARRANTY; without even the implied warranty of X * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. X * See the file README for more details. X */ X X#include X#include X#include "run_Errno.h" X#include "ipc.h" X X#ifdef SYSTEM_V X# define u_short int X#endif /* SYSTEM_V /**/ X X#define DELAY 10 X#define MSGNUM 100 X Xint Errno; XPORTDESCR own_port1, X own_port2, X P2_port; XCONNECTIONDESCR con_port1, X con_port2; X X/* global variables needed for the library functions! */ Xchar *_programname = "p1", X *_processname = "P1"; XPORTDESCR _own_port, X _creator_port, /* unused, but needed! */ X _admin_port; /* unused, but needed! */ XCONNECTIONDESCR _con_port; X Xmain() X{ X int i, res; X char buffer[100], buffer2[100]; X X puts("dcc - distributed c compiler"); X puts("Copyright (C) 1990 by Franz Distler and Christoph Pleier\n"); X puts("Process p1 used for testing the communication primitives"); X puts("Remark: the starting order is: p1, p2, p3"); X if (_create_port(&own_port1)) X _RuntimeError("P1: Error creating own port 1"); X#ifndef iPSC X _display_port_info("P1: port 1", own_port1); X#endif /* iPSC /**/ X X#ifdef iPSC X P2_port.node = 6; X P2_port.pid = 101; X#else X puts("P1: Enter port information of port 1 of process P2:"); X _input_port_info(&P2_port); X#endif /* iPSC /**/ X X puts("\nP1: Testing Rendezvous"); X puts("P1: Test 1a: accept_connection(...,'P1',0)"); X if (_accept_connection(&con_port1, own_port1, 0)) X _RuntimeError("P1: Error accepting connection"); X puts("P1: Test 1a: receiving 2 messages"); X if (_recv_data(con_port1, buffer, 18, 0) < 0) X _RuntimeError("P1: Error in recv_data 1"); X if (strcmp(buffer, "Test 1: Message 1")) { X puts("P1: Error: wrong message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X if (_recv_data(con_port1, buffer, 18, 0) < 0) X _RuntimeError("P1: Error in recv_data 2"); X if (strcmp(buffer, "Test 1: Message 2")) { X puts("P1: Error: wrong message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X puts("P1: Test 1a: sending 1 message"); X strcpy(buffer, "Test 1: Message 3"); X if (_send_data(con_port1, buffer, 18, 10) < 0) X _RuntimeError("P1: Error in send_data 1"); X puts("P1: Test 1a: receiving 1 message"); X if (_recv_data(con_port1, buffer, 18, 10) < 0) X _RuntimeError("P1: Error in recv_data 3"); X if (strcmp(buffer, "Test 1: Message 4")) { X puts("P1: Error: wrong message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X if (_close_connection(con_port1)) X _RuntimeError("P1: Error closing connection"); X puts("P1: Test 1b: make_connection(...,'P1','P2',0)"); X if (_make_connection(&con_port1, own_port1, P2_port, 0)) X _RuntimeError("P1: Error making connection"); X puts("P1: Test 1b: receiving 2 messages"); X if (_recv_data(con_port1, buffer, 18, 0) < 0) X _RuntimeError("P1: Error in recv_data 1"); X if (strcmp(buffer, "Test 1: Message 1")) { X puts("P1: Error: wrong message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X if (_recv_data(con_port1, buffer, 18, 0) < 0) X _RuntimeError("P1: Error in recv_data 2"); X if (strcmp(buffer, "Test 1: Message 2")) { X puts("P1: Error: wrong message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X puts("P1: Test 1b: sending 1 message"); X strcpy(buffer, "Test 1: Message 3"); X if (_send_data(con_port1, buffer, 18, 10) < 0) X _RuntimeError("P1: Error in send_data 1"); X puts("P1: Test 1b: receiving 1 message"); X if (_recv_data(con_port1, buffer, 18, 10) < 0) X _RuntimeError("P1: Error in recv_data 3"); X if (strcmp(buffer, "Test 1: Message 4")) { X puts("P1: Error: wrong message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X if (_close_connection(con_port1)) X _RuntimeError("P1: Error closing connection"); X puts("P1: Rendezvous is OK"); X X puts("\nP1: Testing timeouts"); X puts("P1: Test 2a: accept_connection(...,'P1',5)"); X res = _accept_connection(&con_port1, own_port1, 5); X if (res < 0 && Errno != ETIMEOUT) X _RuntimeError("P1: Error accepting connection"); X X if (_create_port(&own_port2)) X _RuntimeError("P1: Error creating dummy port"); X puts("P1: Test 2b: make_connection(...,'P1','dummy',5)"); X res = _make_connection(&con_port1, own_port1, own_port2, 5); X if (res < 0 && Errno != ETIMEOUT) X _RuntimeError("P1: Error making connection"); X _delete_port(own_port2); X X puts("P1: Test 2c: make_connection(...,'P1','P2',0)"); X if (_make_connection(&con_port1, own_port1, P2_port, 0)) X _RuntimeError("P1: Error making connection"); X puts("P1: Test 2c: recv_data(..., ..., ..., 5)"); X res = _recv_data(con_port1, buffer, 10, 5); X if (res < 0 && Errno != ETIMEOUT) X _RuntimeError("P1: Error reading data"); X if (res >= 0) { X puts("P1: Error in implementation of recv_data: message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X X#ifdef iPSC X printf("P1: Test 2d: waiting %d seconds\n", DELAY); X sleep(DELAY); X#endif /* iPSC /**/ X X puts("P1: Test 2d: send_data(..., ..., ..., 5)"); X res = _send_data(con_port2, buffer, 10, 5); X if (res < 0 && Errno != ETIMEOUT) X _RuntimeError("P1: Error writing data"); X if (res >= 0) { X puts("P1: Error in implementation of send_data: message sent!"); X _delete_port(own_port1); X exit(-1); X } X puts("P1: timeouts are OK"); X X puts("\nP1: Testing mutual exclusion of connections"); X printf("P1: Test 3: receiving %d messages\n", MSGNUM); X for (i=1; i<=100; i++) { X if (_recv_data(con_port1, buffer, 22, 0) < 0) X _RuntimeError("P1: Error in recv_data"); X sprintf(buffer2, "Test 3: Message %3d", i); X if (strcmp(buffer, buffer2)) { X puts("P1: Error: wrong message received!"); X _close_connection(con_port1); X _delete_port(own_port1); X exit(-1); X } X } X puts("P1: mutual exclusion of connections is OK"); X X X puts("\nP1: The test was successful."); X puts("P1: The communication primitives seem to be correct implemented"); X sleep(10); X _delete_port(own_port1); X puts("\nP1: Done!"); X exit(0); X} /* main */ END_OF_FILE if test 8046 -ne `wc -c <'ipc/p1.c'`; then echo shar: \"'ipc/p1.c'\" unpacked with wrong size! fi # end of 'ipc/p1.c' fi echo shar: End of archive 7 \(of 18\). cp /dev/null ark7isdone MISSING="" for I in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 ; do if test ! -f ark${I}isdone ; then MISSING="${MISSING} ${I}" fi done if test "${MISSING}" = "" ; then echo You have unpacked all 18 archives. rm -f ark[1-9]isdone ark[1-9][0-9]isdone else echo You still need to unpack the following archives: echo " " ${MISSING} fi ## End of shell archive. exit 0