Usenet 1994 January/usenetsourcesnewsgroupsinfomagicjanuary1994.iso/sources/unix/volume27/distributed-c-2.1/part07

Text File | 1993-12-22 | 86.8 KB | 2,478 lines

Newsgroups: comp.sources.unix
From: [e-mail] (Christoph Pleier)
Subject: v27i181: distributed-c-2.1 - Distributed C Development Environment, V2.1, Part07/18
References: <[e-mail]>
Sender: [e-mail]
Approved: [e-mail]

Submitted-By: [e-mail] (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 <file", e.g..  If this archive is complete, you
# will see the following message at the end:
#        "End of archive 7 (of 18)."
# Contents:  config/debug.c config/system.y dcadmin/Status.c
#   dcinstall/Compile.c dcinstall/ParseOptions.c dcinstall/main.c
#   include/com_Errno.h include/globals.h include/run_errlist.h
#   ipc/p1.c
# Wrapped by [e-mail] on Thu Dec 23 00:12:00 1993
PATH=/bin:/usr/bin:/usr/ucb ; export PATH
if test -f 'config/debug.c' -a "${1}" != "-c" ; then
  echo shar: Will not clobber existing file \"'config/debug.c'\"
else
echo shar: Extracting \"'config/debug.c'\" \(9082 characters\)
sed "s/^X//" >'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 <stdio.h>
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 <stdio.h>
X#include <stdlib.h>
X#include <sys/types.h>
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 <y_str>    STRING
X%type <y_symb>   IDENT operating_system_definition
X%type <y_float>  NUMBER size_specification time_specification
X%type <y_float>  optional_disk_size_definition optional_disk_speed_definition
X%type <y_multi>  multiprocessor_specification
X%type <y_ocomp>  optional_computer_attribute_list optional_computer_attribute
X%type <y_comsp>  computer_specification
X%type <y_target> target_specification target_list compilation_specification
X%type <y_accfs>  filesystem_definition filesystems_list
X%type <y_accfs>  accessible_filesystems_definition
X%type <y_idlist> 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 <stdio.h>
X#include <sys/types.h>
X#ifdef HETEROGENEOUS
X# include <rpc/rpc.h>
X#endif
X#include <signal.h>
X#include <time.h>
X#ifndef UNICOS
X# include <sys/timeb.h>
X#endif
X#include <errno.h>
X#ifdef BSD
X# include <sys/wait.h>
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 <stdio.h>
X#include <pwd.h>
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 <stdio.h>
X#include <string.h>
X#include <sys/types.h>
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: "<name>.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: "<name>.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 <stdio.h>
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 <stdio.h>
X#include <sys/types.h>
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