OpenCores
URL https://opencores.org/ocsvn/or1k/or1k/trunk

Subversion Repositories or1k

[/] [or1k/] [trunk/] [insight/] [gdb/] [29k-share/] [udi/] [udip2soc.c] - Blame information for rev 1765

Details | Compare with Previous | View Log

Line No. Rev Author Line
1 578 markom
/* Copyright 1993, 1998 Free Software Foundation, Inc.
2
 
3
   This file is part of GDB.
4
 
5
   This program is free software; you can redistribute it and/or modify
6
   it under the terms of the GNU General Public License as published by
7
   the Free Software Foundation; either version 2 of the License, or
8
   (at your option) any later version.
9
 
10
   This program is distributed in the hope that it will be useful,
11
   but WITHOUT ANY WARRANTY; without even the implied warranty of
12
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13
   GNU General Public License for more details.
14
 
15
   You should have received a copy of the GNU General Public License
16
   along with this program; if not, write to the Free Software
17
   Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.  */
18
 
19
static  char udip2soc_c[]="@(#)udip2soc.c       2.11  Daniel Mann";
20
static  char udip2soc_c_AMD[]="@(#)udip2soc.c   2.8, AMD";
21
/*
22
*       This module converts UDI Procedural calls into
23
*       UDI socket messages for UNIX.
24
*       It is used by DFE client processes
25
********************************************************************** HISTORY
26
*/
27
/* This is all unneeded on DOS machines.  */
28
#ifndef __GO32__
29
 
30
#include <stdio.h>
31
#include <string.h>
32
 
33
/* Before sys/file.h for Unixware.  */
34
#include <sys/types.h>
35
 
36
#include <sys/file.h>
37
 
38
/* This used to say sys/fcntl.h, but the only systems I know of that
39
   require that are old (pre-4.3, at least) BSD systems, which we
40
   probably don't need to worry about.  */
41
#include <fcntl.h>
42
 
43
#include <sys/wait.h>
44
#include <sys/time.h>
45
#include <sys/resource.h>
46
#include <sys/socket.h>
47
#include <netinet/in.h>
48
#include <netdb.h>
49
#include <signal.h>
50
#include <sys/errno.h>
51
#include "udiproc.h"
52
#include "udisoc.h"
53
 
54
extern  int             errno;
55
extern  int             sys_nerr;
56
extern  int             udr_errno;
57
extern  char*           getenv();
58
 
59
/* local type decs. and macro defs. not in a .h  file ************* MACRO/TYPE
60
*/
61
#define         version_c 0x121         /* DFE-IPC version id */
62
#define         TRUE -1
63
#define         FALSE 0
64
#define         PORT_NUM 7000
65
#define         MAX_SESSIONS 5          /* maximum DFE-TIP connections */
66
#define         SOC_BUF_SIZE 4* 1024    /* size of socket comms buffer */
67
#define         SBUF_SIZE 500           /* size of string buffer */
68
#define         ERRMSG_SIZE 500         /* size of error message buffer */
69
 
70
typedef struct connection_str           /* record of connect session */
71
{
72
    int         in_use;
73
    char        connect_id[20];         /* connection identifier */
74
    char        domain_string[20];      /* dommaing for conection */
75
    char        tip_string[30];         /* TIP host name for AF_INET */
76
    char        tip_exe[80];            /* TIP exe name */
77
    int         dfe_sd;                 /* associated DFE socket */
78
    int         tip_pid;                /* pid of TIP process */
79
    struct sockaddr_in dfe_sockaddr;
80
    struct sockaddr_in tip_sockaddr_in;
81
    struct sockaddr    tip_sockaddr;
82
} connection_t;
83
 
84
typedef struct session_str
85
{
86
    int           in_use;
87
    connection_t* soc_con_p;            /* associated connection */
88
    UDISessionId  tip_id;               /* associated TIP session ID */
89
} session_t;
90
 
91
/* global dec/defs. which are not in a .h   file ************* EXPORT DEC/DEFS
92
*/
93
UDIError        dfe_errno;
94
char    dfe_errmsg[ERRMSG_SIZE];/* error string */
95
 
96
/* local dec/defs. which are not in a .h   file *************** LOCAL DEC/DEFS
97
*/
98
LOCAL connection_t      soc_con[MAX_SESSIONS];
99
LOCAL session_t session[MAX_SESSIONS];
100
LOCAL UDR       udr;
101
LOCAL UDR*      udrs = &udr;            /* UDR for current session */
102
LOCAL int       current;                /* int-id for current session */
103
LOCAL char      sbuf[SBUF_SIZE];        /* String handler buffer */
104
LOCAL char      config_file[80];        /* path/name for config file */
105
 
106
/***************************************************************** UDI_CONNECT
107
* Establish a new FDE to TIP conection. The file "./udi_soc" or
108
* "/etc/udi_soc" may be examined to obtain the conection information
109
* if the "Config" parameter is not a completd "line entry".
110
*
111
* NOTE: the Session string must not start whith white-space characters.
112
* Format of string is:
113
* <session>   <domain> <soc_name|host_name> <tip_exe|port> <pass to UDIconnect>
114
* soc2cayman  AF_INET            cayman      7000           <not supported>
115
* soc2tip     AF_UNIX   astring              tip.exe        ...
116
*/
117
UDIError
118
UDIConnect(Config, Session)
119
     char *Config;              /* in  -- identification string */
120
     UDISessionId *Session;     /* out -- session ID */
121
{
122
    UDIInt32    service_id = UDIConnect_c;
123
    int         domain;
124
    int         cnt=0;
125
    int         rcnt, pos, params_pos=0;
126
    char        *tip_main_string;
127
    char        *env_p;
128
    struct hostent      *tip_info_p;
129
    FILE        *fd;
130
#if 0
131
    FILE        *f_p;
132
#endif
133
    UDIUInt32   TIPIPCId;
134
    UDIUInt32   DFEIPCId;
135
 
136
#if 0 /* This is crap.  It assumes that udi_soc is executable! */
137
    sprintf(sbuf, "which udi_soc");
138
    f_p = popen(sbuf, "r");
139
    if(f_p)
140
    {   while( (sbuf[cnt++]=getc(f_p)) != EOF);
141
        sbuf[cnt-2]=0;
142
    }
143
    pclose(f_p);
144
#endif
145
 
146
    for (rcnt=0;
147
         rcnt < MAX_SESSIONS && session[rcnt].in_use;
148
         rcnt++);
149
 
150
    if (rcnt >= MAX_SESSIONS)
151
      {
152
        sprintf(dfe_errmsg, "DFE-ipc ERROR: Too many sessions already open");
153
        return UDIErrorIPCLimitation;
154
      }
155
 
156
    /* One connection can be multiplexed between several sessions. */
157
 
158
    for (cnt=0;
159
         cnt < MAX_SESSIONS && soc_con[cnt].in_use;
160
         cnt++);
161
 
162
    if (cnt >= MAX_SESSIONS)
163
      {
164
        sprintf(dfe_errmsg,
165
                "DFE-ipc ERROR: Too many connections already open");
166
        return UDIErrorIPCLimitation;
167
      }
168
 
169
    *Session = rcnt;
170
    session[rcnt].soc_con_p = &soc_con[cnt];
171
 
172
    if (strchr(Config, ' '))            /* test if file entry given */
173
      {
174
        soc_con[cnt].in_use = TRUE;
175
        sscanf(Config, "%s %s %s %s %n",
176
               soc_con[cnt].connect_id,
177
               soc_con[cnt].domain_string,
178
               soc_con[cnt].tip_string,
179
               soc_con[cnt].tip_exe,
180
               &params_pos);
181
        tip_main_string = Config + params_pos;
182
      }
183
    else                                /* here if need to read udi_soc file */
184
      {
185
        strcpy(config_file, "udi_soc");
186
        env_p = getenv("UDICONF");
187
        if (env_p)
188
          strcpy(config_file, env_p);
189
 
190
        fd = fopen(config_file, "r");
191
 
192
        if (!fd)
193
          {
194
            sprintf(dfe_errmsg, "UDIConnect, can't open udi_soc file:\n%s ",
195
                    strerror(errno));
196
            dfe_errno = UDIErrorCantOpenConfigFile;
197
            goto tip_failure;
198
          }
199
 
200
        while (1)
201
          {
202
            if (fscanf(fd, "%s %s %s %s %[^\n]\n",
203
                       soc_con[cnt].connect_id,
204
                       soc_con[cnt].domain_string,
205
                       soc_con[cnt].tip_string,
206
                       soc_con[cnt].tip_exe,
207
                       sbuf) == EOF)
208
              break;
209
 
210
            if (strcmp(Config, soc_con[cnt].connect_id) != 0)
211
              continue;
212
 
213
            soc_con[cnt].in_use = TRUE; /* here if entry found */
214
 
215
            tip_main_string = sbuf;
216
            break;
217
          }
218
 
219
        fclose(fd);
220
        if (!soc_con[cnt].in_use)
221
          {
222
            sprintf(dfe_errmsg,
223
                    "UDIConnect, can't find `%s' entry in udi_soc file",
224
                    Config);
225
            dfe_errno = UDIErrorNoSuchConfiguration;
226
            goto tip_failure;
227
          }
228
      }
229
/*----------------------------------------------------------- SELECT DOMAIN */
230
    if (strcmp(soc_con[cnt].domain_string, "AF_UNIX") == 0)
231
      domain = AF_UNIX;
232
    else if (strcmp(soc_con[cnt].domain_string, "AF_INET") == 0)
233
      domain = AF_INET;
234
    else
235
      {
236
        sprintf(dfe_errmsg, "DFE-ipc ERROR: socket address family not known");
237
        dfe_errno = UDIErrorBadConfigFileEntry;
238
        goto tip_failure;
239
      }
240
 
241
/*---------------------------------------------------- MULTIPLEXED SOCKET ? */
242
/* If the requested session requires communication with
243
   a TIP which already has a socket connection established,
244
   then we do not create a new socket but multiplex the
245
   existing one. A TIP is said to use the same socket if
246
   socket-name/host-name and the domain are the same.
247
 */
248
    for (rcnt=0; rcnt < MAX_SESSIONS; rcnt++)
249
      {
250
        if (soc_con[rcnt].in_use
251
            && rcnt != cnt
252
            && strcmp(soc_con[cnt].domain_string,
253
                      soc_con[rcnt].domain_string) == 0
254
            && strcmp(soc_con[cnt].tip_string,
255
                      soc_con[rcnt].tip_string) == 0)
256
          {
257
            session[*Session].soc_con_p = &soc_con[rcnt];
258
            soc_con[cnt].in_use = FALSE;        /* don't need new connect */
259
            goto tip_connect;
260
        }
261
      }
262
/*------------------------------------------------------------------ SOCKET */
263
    soc_con[cnt].dfe_sd = socket(domain, SOCK_STREAM, 0);
264
    if (soc_con[cnt].dfe_sd == -1)
265
      {
266
        sprintf(dfe_errmsg, "DFE-ipc ERROR, socket() call failed %s ",
267
                strerror (errno));
268
        dfe_errno = UDIErrorUnknownError;
269
        goto tip_failure;
270
      }
271
 
272
/*--------------------------------------------------------- AF_UNIX CONNECT */
273
    if (domain == AF_UNIX)
274
      {
275
        if (strcmp(soc_con[cnt].tip_string, "*") == 0)
276
          {
277
            for (pos = 0; pos < 20; pos++)
278
              {
279
                int f;
280
 
281
                sprintf(soc_con[cnt].tip_string,"/tmp/U%d", getpid() + pos);
282
                f = open(soc_con[cnt].tip_string, O_CREAT);
283
                if (f == -1)
284
                  continue;
285
 
286
                close(f);
287
                unlink(soc_con[cnt].tip_string);
288
                break;
289
              }
290
 
291
            if (pos >= 20)
292
              {
293
                sprintf(dfe_errmsg,
294
                        "DFE-ipc ERROR, can't create random socket name");
295
                dfe_errno = UDIErrorCantConnect;
296
                goto tip_failure;
297
              }
298
          }
299
 
300
        soc_con[cnt].tip_sockaddr.sa_family = domain;
301
        memcpy(soc_con[cnt].tip_sockaddr.sa_data,
302
              soc_con[cnt].tip_string,
303
              sizeof(soc_con[cnt].tip_sockaddr.sa_data));
304
        if (connect(soc_con[cnt].dfe_sd,
305
                    &soc_con[cnt].tip_sockaddr,
306
                    sizeof(soc_con[cnt].tip_sockaddr)))
307
          { /* if connect() fails assume TIP not yet started */
308
/*------------------------------------------------------------ AF_UNIX EXEC */
309
            int pid;
310
            int statusp;
311
            char *arg0;
312
 
313
            arg0 = strrchr(soc_con[cnt].tip_exe,'/');
314
 
315
            if (arg0)
316
              arg0++;
317
            else
318
              arg0 = soc_con[cnt].tip_exe;
319
 
320
            pid = vfork();
321
 
322
            if (pid == 0)        /* Child */
323
              {
324
                execlp(soc_con[cnt].tip_exe,
325
                       arg0,
326
                       soc_con[cnt].domain_string,
327
                       soc_con[cnt].tip_string,
328
                       NULL);
329
                _exit(1);
330
              }
331
 
332
            if (waitpid(pid, &statusp, WNOHANG))
333
              {
334
                sprintf(dfe_errmsg, "DFE-ipc ERROR: can't exec the TIP");
335
                dfe_errno = UDIErrorCantStartTIP;
336
                goto tip_failure;
337
              }
338
 
339
            pos = 3;
340
            for (pos = 3; pos > 0; pos--)
341
              {
342
                if (!connect(soc_con[cnt].dfe_sd,
343
                             &soc_con[cnt].tip_sockaddr,
344
                             sizeof(soc_con[cnt].tip_sockaddr)))
345
                  break;
346
                sleep(1);
347
              }
348
 
349
            if (pos == 0)
350
              {
351
                sprintf(dfe_errmsg, "DFE-ipc ERROR, connect() call failed: %s",
352
                        strerror (errno));
353
                dfe_errno = UDIErrorCantConnect;
354
                goto tip_failure;
355
              }
356
          }
357
      }
358
/*--------------------------------------------------------- AF_INET CONNECT */
359
    else if (domain == AF_INET)
360
      {
361
        fprintf(stderr,
362
                "DFE-ipc WARNING, need to have first started remote TIP");
363
 
364
        soc_con[cnt].tip_sockaddr_in.sin_family = domain;
365
        soc_con[cnt].tip_sockaddr_in.sin_addr.s_addr =
366
            inet_addr(soc_con[cnt].tip_string);
367
        if (soc_con[cnt].tip_sockaddr_in.sin_addr.s_addr == -1)
368
          {
369
            tip_info_p = gethostbyname(soc_con[cnt].tip_string);
370
            if (tip_info_p == NULL)
371
              {
372
                sprintf(dfe_errmsg,"DFE-ipc ERROR, No such host %s",
373
                        soc_con[cnt].tip_string);
374
                dfe_errno = UDIErrorNoSuchConnection;
375
                goto tip_failure;
376
              }
377
            memcpy((char *)&soc_con[cnt].tip_sockaddr_in.sin_addr,
378
                  tip_info_p->h_addr,
379
                  tip_info_p->h_length);
380
          }
381
        soc_con[cnt].tip_sockaddr_in.sin_port
382
          = htons(atoi(soc_con[cnt].tip_exe));
383
 
384
        if (connect(soc_con[cnt].dfe_sd,
385
                    (struct sockaddr *) &soc_con[cnt].tip_sockaddr_in,
386
                    sizeof(soc_con[cnt].tip_sockaddr_in)))
387
          {
388
            sprintf(dfe_errmsg, "DFE-ipc ERROR, connect() call failed %s ",
389
                    strerror (errno));
390
            dfe_errno = UDIErrorCantConnect;
391
            goto tip_failure;
392
          }
393
      }
394
/*------------------------------------------------------------- TIP CONNECT */
395
    if (cnt == 0) udr_create(udrs, soc_con[cnt].dfe_sd, SOC_BUF_SIZE);
396
 
397
tip_connect:
398
    current = cnt;
399
    session[*Session].in_use = TRUE;    /* session id is now in use */
400
 
401
    udr_errno = 0;
402
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
403
    udr_UDIInt32(udrs, &service_id);
404
 
405
    DFEIPCId = (company_c << 16) + (product_c << 12) + version_c;
406
    udr_UDIUInt32(udrs, &DFEIPCId);
407
 
408
    udr_string(udrs, tip_main_string);
409
 
410
    udr_sendnow(udrs);
411
 
412
    udrs->udr_op = UDR_DECODE;          /* recv all "out" parameters */
413
    udr_UDIUInt32(udrs, &TIPIPCId);
414
    if ((TIPIPCId & 0xfff) < version_c)
415
      sprintf(dfe_errmsg, "DFE-ipc: Obsolete TIP Specified");
416
 
417
    udr_UDIInt32(udrs, &soc_con[cnt].tip_pid);
418
 
419
    udr_UDISessionId(udrs, &session[*Session].tip_id);
420
 
421
    udr_UDIError(udrs, &dfe_errno);
422
    if (dfe_errno > 0) UDIKill(*Session, 0);
423
 
424
    return dfe_errno;
425
 
426
tip_failure:
427
 
428
    soc_con[cnt].in_use = FALSE;
429
    session[*Session].in_use = FALSE;
430
/* XXX - Should also close dfe_sd, but not sure what to do if muxed */
431
    return dfe_errno;
432
}
433
 
434
/************************************************************** UDI_Disconnect
435
* UDIDisconnect() should be called before exiting the
436
* DFE to ensure proper shut down of the TIP.
437
*/
438
UDIError UDIDisconnect(Session,  Terminate)
439
UDISessionId    Session;
440
UDIBool         Terminate;
441
{
442
    int cnt;
443
    UDIInt32    service_id = UDIDisconnect_c;
444
    if(Session < 0 || Session > MAX_SESSIONS)
445
    {
446
        sprintf(dfe_errmsg," SessionId not valid (%d)", Session);
447
        return UDIErrorNoSuchConfiguration;
448
    }
449
    udr_errno = 0;
450
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
451
    udr_UDIInt32(udrs, &service_id);
452
    udr_UDISessionId(udrs, &session[Session].tip_id);
453
    udr_UDIBool(udrs, &Terminate);
454
    udr_sendnow(udrs);
455
 
456
    session[Session].in_use = FALSE;    /* session id is now free */
457
    for (cnt=0; cnt < MAX_SESSIONS; cnt++)
458
        if(session[cnt].in_use
459
        && session[cnt].soc_con_p == session[Session].soc_con_p
460
                ) break;
461
    if(cnt >= MAX_SESSIONS)     /* test if socket not multiplexed */
462
        if(shutdown(session[Session].soc_con_p->dfe_sd, 2))
463
        {
464
            sprintf(dfe_errmsg, "DFE-ipc WARNING: socket shutdown failed");
465
            return UDIErrorIPCInternal;
466
        }
467
        else
468
          session[Session].soc_con_p->in_use = 0;
469
 
470
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
471
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
472
    return dfe_errno;
473
}
474
 
475
/******************************************************************** UDI_KILL
476
* UDIKill() is used to send a signal to the TIP.
477
* This is a private IPC call.
478
*/
479
UDIError UDIKill(Session,  Signal)
480
UDISessionId    Session;
481
UDIInt32        Signal;
482
{
483
    int cnt;
484
    UDIInt32    service_id = UDIKill_c;
485
    if(Session < 0 || Session > MAX_SESSIONS)
486
    {
487
        sprintf(dfe_errmsg," SessionId not valid (%d)", Session);
488
        return UDIErrorNoSuchConfiguration;
489
    }
490
    udr_errno = 0;
491
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
492
    udr_UDIInt32(udrs, &service_id);
493
    udr_UDISessionId(udrs, &session[Session].tip_id);
494
    udr_UDIInt32(udrs, &Signal);
495
    udr_sendnow(udrs);
496
 
497
    session[Session].in_use = FALSE;    /* session id is now free */
498
    for (cnt=0; cnt < MAX_SESSIONS; cnt++)
499
        if(session[cnt].in_use
500
        && session[cnt].soc_con_p == session[Session].soc_con_p
501
                ) break;
502
    if(cnt < MAX_SESSIONS)      /* test if socket not multiplexed */
503
        if(shutdown(session[Session].soc_con_p->dfe_sd, 2))
504
        {
505
            sprintf(dfe_errmsg, "DFE-ipc WARNING: socket shutdown failed");
506
            return UDIErrorIPCInternal;
507
        }
508
        else
509
          session[Session].soc_con_p->in_use = 0;
510
 
511
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
512
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
513
    return dfe_errno;
514
}
515
 
516
/************************************************** UDI_Set_Current_Connection
517
* If you are connected to multiple TIPs, you can change
518
* TIPs using UDISetCurrentConnection().
519
*/
520
UDIError UDISetCurrentConnection(Session)
521
UDISessionId    Session;
522
{
523
    UDIInt32    service_id = UDISetCurrentConnection_c;
524
 
525
    if(Session < 0 || Session > MAX_SESSIONS)
526
        return UDIErrorNoSuchConfiguration;
527
    if(!session[Session].in_use)                /* test if not in use yet */
528
        return UDIErrorNoSuchConnection;
529
 
530
    current = Session;
531
    /* change socket or multiplex the same socket  */
532
    udrs->sd = session[Session].soc_con_p->dfe_sd;
533
 
534
    udr_errno = 0;
535
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
536
    udr_UDIInt32(udrs, &service_id);
537
    udr_UDISessionId(udrs, &session[Session].tip_id);
538
    udr_sendnow(udrs);
539
    if(udr_errno) return udr_errno;
540
 
541
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
542
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
543
    return dfe_errno;
544
}
545
 
546
/************************************************************ UDI_Capabilities
547
* The DFE uses UDICapabilities() to both inform the TIP
548
* of what services the DFE offers and to inquire of the
549
* TIP what services the TIP offers.
550
*/
551
UDIError UDICapabilities(TIPId, TargetId, DFEId, DFE, TIP, DFEIPCId,
552
                TIPIPCId, TIPString)
553
UDIUInt32       *TIPId;         /* out */
554
UDIUInt32       *TargetId;      /* out */
555
UDIUInt32       DFEId;          /* in */
556
UDIUInt32       DFE;            /* in */
557
UDIUInt32       *TIP;           /* out */
558
UDIUInt32       *DFEIPCId;      /* out */
559
UDIUInt32       *TIPIPCId;      /* out */
560
char            *TIPString;     /* out */
561
{
562
    UDIInt32    service_id = UDICapabilities_c;
563
    int         size;
564
 
565
    udr_errno = 0;
566
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
567
    udr_UDIInt32(udrs, &service_id);
568
    udr_UDIInt32(udrs, &DFEId);
569
    udr_UDIInt32(udrs, &DFE);
570
    udr_sendnow(udrs);
571
    if(udr_errno) return udr_errno;
572
 
573
    udrs->udr_op = UDR_DECODE;          /* receive all "out" paramters */
574
    udr_UDIInt32(udrs, TIPId);
575
    udr_UDIInt32(udrs, TargetId);
576
    udr_UDIInt32(udrs, TIP);
577
    udr_UDIInt32(udrs, DFEIPCId);
578
    *DFEIPCId = (company_c << 16) + (product_c << 12) + version_c;
579
    udr_UDIInt32(udrs, TIPIPCId);
580
    udr_string(udrs, sbuf);
581
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
582
    size = strlen(sbuf);
583
    if(size +1 > 80) return -1;         /* test if sufficient space */
584
    strcpy(TIPString, sbuf);
585
    return dfe_errno;
586
}
587
 
588
/********************************************************** UDI_Enumerate_TIPs
589
* Used by the DFE to enquire about available TIP
590
* connections.
591
*/
592
UDIError UDIEnumerateTIPs(UDIETCallback)
593
  int (*UDIETCallback)();               /* In -- function to callback */
594
{
595
    FILE        *fp;
596
 
597
    fp = fopen(config_file, "r");
598
    if(fp == NULL)
599
        return UDIErrorCantOpenConfigFile;
600
    while(fgets( sbuf, SBUF_SIZE, fp))
601
        if(UDIETCallback( sbuf) == UDITerminateEnumeration)
602
            break;
603
    fclose( fp);
604
    return UDINoError;                  /* return success */
605
}
606
 
607
/*********************************************************** UDI_GET_ERROR_MSG
608
* Some errors are target specific. They are indicated
609
* by a negative error return value. The DFE uses
610
* UDIGetErrorMsg() to get the descriptive text for
611
* the error message which can then  be  displayed  to
612
* the user.
613
*/
614
UDIError UDIGetErrorMsg(error_code, msg_len, msg, CountDone)
615
UDIError        error_code;             /* In */
616
UDISizeT        msg_len;                /* In  -- allowed message space */
617
char*           msg;                    /* Out -- length of message*/
618
UDISizeT        *CountDone;             /* Out -- number of characters */
619
{
620
    UDIInt32    service_id = UDIGetErrorMsg_c;
621
    int         size;
622
 
623
    udr_errno = 0;
624
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
625
    udr_UDIInt32(udrs, &service_id);
626
    udr_UDIError(udrs, &error_code);
627
    udr_UDISizeT(udrs, &msg_len);
628
    udr_sendnow(udrs);
629
    if(udr_errno) return udr_errno;
630
 
631
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
632
    udr_string(udrs, sbuf);
633
    udr_UDISizeT(udrs, CountDone);
634
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
635
    size = strlen(sbuf);
636
    if(size +1 > msg_len) return -1;    /* test if sufficient space */
637
    strcpy(msg, sbuf);
638
    return dfe_errno;
639
}
640
 
641
/******************************************************* UDI_GET_TARGET_CONFIG
642
* UDIGetTargetConfig() gets information about the target.
643
*/
644
UDIError UDIGetTargetConfig(KnownMemory, NumberOfRanges, ChipVersions,
645
                NumberOfChips)
646
UDIMemoryRange  KnownMemory[];          /* Out */
647
UDIInt          *NumberOfRanges;        /* In and Out */
648
UDIUInt32       ChipVersions[];         /* Out */
649
UDIInt          *NumberOfChips;         /* In and Out */
650
{
651
    UDIInt32    service_id = UDIGetTargetConfig_c;
652
    int         cnt;
653
    int         MaxOfRanges = *NumberOfRanges;
654
 
655
    udr_errno = 0;
656
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
657
    udr_UDIInt32(udrs, &service_id);
658
    udr_UDIInt(udrs, NumberOfRanges);
659
    udr_UDIInt(udrs, NumberOfChips);
660
    udr_sendnow(udrs);
661
    if(udr_errno) return udr_errno;
662
 
663
    udrs->udr_op = UDR_DECODE;          /* receive all "out" paramters */
664
    for(cnt=1; cnt <= MaxOfRanges; cnt++)
665
        udr_UDIMemoryRange(udrs, &KnownMemory[cnt-1]);
666
    udr_UDIInt(udrs, NumberOfRanges);
667
    udr_UDIInt(udrs, NumberOfChips);
668
    for(cnt=1; cnt <= *NumberOfChips; cnt++)
669
        udr_UDIUInt32(udrs, &ChipVersions[cnt -1]);
670
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
671
    return dfe_errno;
672
}
673
 
674
/********************************************************** UDI_CREATE_PRCOESS
675
* UDICreateProcess() tells the  target  OS  that  a
676
* process is to be created and gets a PID back unless
677
* there is some error.
678
*/
679
UDIError UDICreateProcess(pid)
680
UDIPId  *pid;   /* out */
681
{
682
    UDIInt32    service_id = UDICreateProcess_c;
683
 
684
    udr_errno = 0;
685
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
686
    udr_UDIInt32(udrs, &service_id);
687
    udr_sendnow(udrs);
688
    if(udr_errno) return udr_errno;
689
 
690
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
691
    udr_UDIPId(udrs, pid);
692
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
693
    return dfe_errno;
694
}
695
 
696
/***************************************************** UDI_Set_Current_Process
697
* UDISetCurrentProcess  uses   a   pid   supplied   by
698
* UDICreateProcess  and  sets it as the default for all
699
* udi calls until a new one is set.  A user of  a
700
*/
701
UDIError UDISetCurrentProcess (pid)
702
UDIPId  pid;                    /* In */
703
{
704
    UDIInt32    service_id = UDISetCurrentProcess_c;
705
 
706
    udr_errno = 0;
707
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
708
    udr_UDIInt32(udrs, &service_id);
709
    udr_UDIPId(udrs, &pid);
710
    udr_sendnow(udrs);
711
    if(udr_errno) return udr_errno;
712
 
713
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
714
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
715
    return dfe_errno;
716
}
717
 
718
/****************************************************** UDI_INITIALISE_PROCESS
719
* UDIInitializeProcess() prepare process for
720
* execution. (Reset processor if process os processor).
721
*/
722
UDIError UDIInitializeProcess( ProcessMemory, NumberOfRanges, EntryPoint,
723
                StackSizes, NumberOfStacks, ArgString)
724
UDIMemoryRange  ProcessMemory[];        /* In */
725
UDIInt          NumberOfRanges;         /* In */
726
UDIResource     EntryPoint;             /* In */
727
CPUSizeT        *StackSizes;            /* In */
728
UDIInt          NumberOfStacks;         /* In */
729
char            *ArgString;             /* In */
730
{
731
    UDIInt32    service_id = UDIInitializeProcess_c;
732
    int         cnt;
733
 
734
    udr_errno = 0;
735
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
736
    udr_UDIInt32(udrs, &service_id);
737
    udr_UDIInt(udrs, &NumberOfRanges);
738
    for(cnt = 0; cnt < NumberOfRanges; cnt++)
739
        udr_UDIMemoryRange(udrs, &ProcessMemory[cnt] );
740
    udr_UDIResource(udrs, &EntryPoint);
741
    udr_UDIInt(udrs, &NumberOfStacks);
742
    for(cnt = 0; cnt < NumberOfStacks; cnt++)
743
        udr_CPUSizeT(udrs, &StackSizes[cnt]);
744
    udr_string(udrs, ArgString);
745
    udr_sendnow(udrs);
746
    if(udr_errno) return udr_errno;
747
 
748
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
749
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
750
    return dfe_errno;
751
}
752
 
753
/********************************************************* UDI_DESTROY_PROCESS
754
* UDIDestroyProcess() frees a process resource
755
* previously created by UDICreateProcess().
756
*/
757
UDIError UDIDestroyProcess(pid)
758
UDIPId   pid;   /* in */
759
{
760
    UDIInt32    service_id = UDIDestroyProcess_c;
761
 
762
    udr_errno = 0;
763
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
764
    udr_UDIInt32(udrs, &service_id);
765
    udr_UDIPId(udrs, &pid);
766
    udr_sendnow(udrs);
767
    if(udr_errno) return udr_errno;
768
 
769
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
770
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
771
    return dfe_errno;
772
}
773
 
774
/****************************************************************** UDI_READ
775
* UDIRead() reads a block of objects from  a  target
776
* address space  to host space.
777
*/
778
 
779
UDIError UDIRead (from, to, count, size, count_done, host_endian)
780
UDIResource     from;           /* in - source address on target */
781
UDIHostMemPtr   to;             /* out - destination address on host */
782
UDICount        count;          /* in -- count of objects to be transferred */
783
UDISizeT        size;           /* in -- size of each object */
784
UDICount        *count_done;    /* out - count actually transferred */
785
UDIBool         host_endian;    /* in -- flag for endian information */
786
{
787
    UDIInt32    service_id = UDIRead_c;
788
    int         byte_count;
789
 
790
    udr_errno = 0;
791
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
792
    udr_UDIInt32(udrs, &service_id);
793
    udr_UDIResource(udrs, &from);
794
    udr_UDICount(udrs, &count);
795
    udr_UDISizeT(udrs, &size);
796
    udr_UDIBool(udrs, &host_endian);
797
    udr_sendnow(udrs);
798
    if(udr_errno) return udr_errno;
799
 
800
    udrs->udr_op = UDR_DECODE;          /* receive all "out" paramters */
801
    udr_UDICount(udrs, count_done);
802
    byte_count = (*count_done) * size;
803
    if(*count_done > 0 && *count_done <= count)
804
        udr_bytes(udrs, to, byte_count);
805
    if(udr_errno) return udr_errno;
806
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
807
    return dfe_errno;
808
}
809
 
810
/****************************************************************** UDI_WRITE
811
* UDIWrite() writes a block  of  objects  from  host
812
* space  to  a  target  address+space.
813
*/
814
UDIError UDIWrite( from, to, count, size, count_done, host_endian )
815
UDIHostMemPtr   from;           /* in -- source address on host */
816
UDIResource     to;             /* in -- destination address on target */
817
UDICount        count;          /* in -- count of objects to be transferred */
818
UDISizeT        size;           /* in -- size of each object */
819
UDICount        *count_done;    /* out - count actually transferred */
820
UDIBool         host_endian;    /* in -- flag for endian information */
821
{
822
    UDIInt32    service_id = UDIWrite_c;
823
    int         byte_count = count * size;
824
 
825
    udr_errno = 0;
826
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
827
    udr_UDIInt32(udrs, &service_id);
828
    udr_UDIResource(udrs, &to);
829
    udr_UDICount(udrs, &count);
830
    udr_UDISizeT(udrs, &size);
831
    udr_UDIBool(udrs, &host_endian);
832
    udr_bytes(udrs, from, byte_count);
833
    udr_sendnow(udrs);
834
    if(udr_errno) return udr_errno;
835
 
836
    udrs->udr_op = UDR_DECODE;          /* receive all "out" paramters */
837
    udr_UDICount(udrs, count_done);
838
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
839
    return dfe_errno;
840
}
841
 
842
/******************************************************************** UDI_COPY
843
* UDICopy() copies a block of objects from one  target
844
* get  address/space to another target address/space.
845
*/
846
UDIError UDICopy(from, to, count, size, count_done, direction )
847
UDIResource     from;           /* in -- destination address on target */
848
UDIResource     to;             /* in -- source address on target */
849
UDICount        count;          /* in -- count of objects to be transferred */
850
UDISizeT        size;           /* in -- size of each object */
851
UDICount        *count_done;    /* out - count actually transferred */
852
UDIBool         direction;      /* in -- high-to-low or reverse */
853
{
854
    UDIInt32    service_id = UDICopy_c;
855
 
856
    udr_errno = 0;
857
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
858
    udr_UDIInt32(udrs, &service_id);
859
    udr_UDIResource(udrs, &from);
860
    udr_UDIResource(udrs, &to);
861
    udr_UDICount(udrs, &count);
862
    udr_UDISizeT(udrs, &size);
863
    udr_UDIBool(udrs, &direction);
864
    udr_sendnow(udrs);
865
    if(udr_errno) return udr_errno;
866
 
867
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
868
    udr_UDICount(udrs, count_done);
869
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
870
    return dfe_errno;
871
}
872
 
873
/***************************************************************** UDI_EXECUTE
874
* UDIExecute() continues execution  of  the  default
875
* process from the current PC.
876
*/
877
UDIError UDIExecute()
878
{
879
    UDIInt32    service_id = UDIExecute_c;
880
 
881
    udr_errno = 0;
882
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
883
    udr_UDIInt32(udrs, &service_id);
884
    udr_sendnow(udrs);
885
    if(udr_errno) return udr_errno;
886
 
887
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
888
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
889
    return dfe_errno;
890
}
891
 
892
/******************************************************************** UDI_STEP
893
* UDIStep()  specifies  a  number  of  "instruction"
894
* steps  to  make.
895
*/
896
UDIError UDIStep(steps, steptype, range)
897
UDIUInt32       steps;          /* in -- number of steps */
898
UDIStepType     steptype;       /* in -- type of stepping to be done */
899
UDIRange        range;          /* in -- range if StepInRange is TRUE */
900
{
901
    UDIInt32    service_id = UDIStep_c;
902
 
903
    udr_errno = 0;
904
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
905
    udr_UDIInt32(udrs, &service_id);
906
    udr_UDIInt32(udrs, &steps);
907
    udr_UDIStepType(udrs, &steptype);
908
    udr_UDIRange(udrs, &range);
909
    udr_sendnow(udrs);
910
    if(udr_errno) return udr_errno;
911
 
912
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
913
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
914
    return dfe_errno;
915
}
916
 
917
/******************************************************************** UDI_STOP
918
* UDIStop() stops the default process
919
*/
920
UDIVoid UDIStop()
921
{
922
    if (strcmp(session[current].soc_con_p->domain_string, "AF_UNIX") == 0)
923
      kill(session[current].soc_con_p->tip_pid, SIGINT);
924
    else
925
      udr_signal(udrs);
926
 
927
/* XXX - should clean up session[] and soc_con[] structs here as well... */
928
 
929
    return;
930
}
931
 
932
/******************************************************************** UDI_WAIT
933
* UDIWait() returns the state of the target  procesor.
934
*/
935
UDIError UDIWait(maxtime, pid, stop_reason)
936
UDIInt32   maxtime;        /* in -- maximum time to wait for completion */
937
UDIPId     *pid;           /* out -- pid of process which stopped if any */
938
UDIUInt32  *stop_reason;   /* out -- PC where process stopped */
939
{
940
    UDIInt32    service_id = UDIWait_c;
941
 
942
    udr_errno = 0;
943
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
944
    udr_UDIInt32(udrs, &service_id);
945
    udr_UDIInt32(udrs, &maxtime);
946
    udr_sendnow(udrs);
947
    if(udr_errno) return udr_errno;
948
 
949
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
950
    udr_UDIPId(udrs, pid);
951
    udr_UDIUInt32(udrs, stop_reason);
952
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
953
    return dfe_errno;
954
}
955
 
956
/********************************************************** UDI_SET_BREAKPOINT
957
* UDISetBreakpoint() sets a breakpoint  at  an  adress
958
* and  uses  the  passcount  to state how many
959
* times that instruction should  be  hit  before  the
960
* break  occurs.
961
*/
962
UDIError UDISetBreakpoint (addr, passcount, type, break_id)
963
UDIResource     addr;           /* in -- where breakpoint gets set */
964
UDIInt32        passcount;      /* in -- passcount for breakpoint  */
965
UDIBreakType    type;           /* in -- breakpoint type */
966
UDIBreakId      *break_id;      /* out - assigned break id */
967
{
968
    UDIInt32    service_id = UDISetBreakpoint_c;
969
 
970
    udr_errno = 0;
971
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
972
    udr_UDIInt32(udrs, &service_id);
973
    udr_UDIResource(udrs, &addr);
974
    udr_UDIInt32(udrs, &passcount);
975
    udr_UDIBreakType(udrs, &type);
976
    udr_sendnow(udrs);
977
    if(udr_errno) return udr_errno;
978
 
979
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
980
    udr_UDIBreakId(udrs, break_id);
981
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
982
    return dfe_errno;
983
}
984
 
985
/******************************************************** UDI_QUERY_BREAKPOINT
986
*/
987
UDIError UDIQueryBreakpoint (break_id, addr, passcount, type, current_count)
988
UDIBreakId      break_id;       /* in -- assigned break id */
989
UDIResource     *addr;          /* out - where breakpoint was set */
990
UDIInt32        *passcount;     /* out - trigger passcount for breakpoint  */
991
UDIBreakType    *type;          /* out - breakpoint type */
992
UDIInt32        *current_count; /* out - current count for breakpoint  */
993
{
994
    UDIInt32    service_id = UDIQueryBreakpoint_c;
995
 
996
    udr_errno = 0;
997
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
998
    udr_UDIInt32(udrs, &service_id);
999
    udr_UDIBreakId(udrs, &break_id);
1000
    udr_sendnow(udrs);
1001
    if(udr_errno) return udr_errno;
1002
 
1003
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1004
    udr_UDIResource(udrs, addr);
1005
    udr_UDIInt32(udrs, passcount);
1006
    udr_UDIBreakType(udrs, type);
1007
    udr_UDIInt32(udrs, current_count);
1008
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1009
    return dfe_errno;
1010
}
1011
 
1012
/******************************************************** UDI_CLEAR_BREAKPOINT
1013
* UDIClearBreakpoint() is used to  clear  a  breakpoint.
1014
*/
1015
UDIError UDIClearBreakpoint (break_id)
1016
UDIBreakId      break_id;       /* in -- assigned break id */
1017
{
1018
    UDIInt32    service_id = UDIClearBreakpoint_c;
1019
 
1020
    udr_errno = 0;
1021
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1022
    udr_UDIInt32(udrs, &service_id);
1023
    udr_UDIBreakId(udrs, &break_id);
1024
    udr_sendnow(udrs);
1025
    if(udr_errno) return udr_errno;
1026
 
1027
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1028
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1029
    return dfe_errno;
1030
}
1031
 
1032
/************************************************************** UDI_GET_STDOUT
1033
* UDIGetStdout()  is  called   when   a   call   to
1034
* UDIWait() indicates there is STD output data ready.
1035
*/
1036
UDIError UDIGetStdout(buf, bufsize, count_done)
1037
UDIHostMemPtr   buf;            /* out -- buffer to be filled */
1038
UDISizeT        bufsize;        /* in  -- buffer size in bytes */
1039
UDISizeT        *count_done;    /* out -- number of bytes written to buf */
1040
{
1041
    UDIInt32    service_id = UDIGetStdout_c;
1042
 
1043
    udr_errno = 0;
1044
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1045
    udr_UDIInt32(udrs, &service_id);
1046
    udr_UDISizeT(udrs, &bufsize);
1047
    udr_sendnow(udrs);
1048
    if(udr_errno) return udr_errno;
1049
 
1050
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1051
    udr_UDISizeT(udrs, count_done);
1052
    udr_bytes(udrs, buf, *count_done);
1053
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1054
    return dfe_errno;
1055
}
1056
 
1057
/************************************************************** UDI_GET_STDERR
1058
* UDIGetStderr()  is  called   when   a   call   to
1059
* UDIWait() indicates there is STDERR output data ready
1060
*/
1061
UDIError UDIGetStderr(buf, bufsize, count_done)
1062
UDIHostMemPtr   buf;            /* out -- buffer to be filled */
1063
UDISizeT        bufsize;        /* in  -- buffer size in bytes */
1064
UDISizeT        *count_done;    /* out -- number of bytes written to buf */
1065
{
1066
    UDIInt32    service_id = UDIGetStderr_c;
1067
 
1068
    udr_errno = 0;
1069
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1070
    udr_UDIInt32(udrs, &service_id);
1071
    udr_UDISizeT(udrs, &bufsize);
1072
    udr_sendnow(udrs);
1073
    if(udr_errno) return udr_errno;
1074
 
1075
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1076
    udr_UDISizeT(udrs, count_done);
1077
    udr_bytes(udrs, buf, *count_done);
1078
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1079
    return dfe_errno;
1080
}
1081
 
1082
/*************************************************************** UDI_PUT_STDIN
1083
* UDIPutStdin() is called whenever the DFE wants to
1084
* deliver an input character to the TIP.
1085
*/
1086
UDIError UDIPutStdin (buf, count, count_done)
1087
UDIHostMemPtr   buf;            /* in -- buffer to be filled */
1088
UDISizeT        count;          /* in -- buffer size in bytes */
1089
UDISizeT        *count_done;    /* out - number of bytes written to buf */
1090
{
1091
    UDIInt32    service_id = UDIPutStdin_c;
1092
 
1093
    udr_errno = 0;
1094
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1095
    udr_UDIInt32(udrs, &service_id);
1096
    udr_UDISizeT(udrs, &count);
1097
    udr_bytes(udrs, buf, count);
1098
    udr_sendnow(udrs);
1099
    if(udr_errno) return udr_errno;
1100
 
1101
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1102
    udr_UDISizeT(udrs, count_done);
1103
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1104
    return dfe_errno;
1105
}
1106
 
1107
/************************************************************** UDI_STDIN_MODE
1108
* UDIStdinMode() is used to change the mode that chazcters
1109
* are fetched from the user.
1110
*/
1111
UDIError        UDIStdinMode(mode)
1112
UDIMode         *mode;          /* out - */
1113
{
1114
    UDIInt32    service_id = UDIStdinMode_c;
1115
 
1116
    udr_errno = 0;
1117
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1118
    udr_UDIInt32(udrs, &service_id);
1119
    udr_sendnow(udrs);
1120
    if(udr_errno) return udr_errno;
1121
 
1122
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1123
    udr_UDIMode(udrs, mode);
1124
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1125
    return dfe_errno;
1126
}
1127
 
1128
/*************************************************************** UDI_PUT_TRANS
1129
* UDIPutTrans() is used to feed input to  the  passthru  mode.
1130
*/
1131
UDIError        UDIPutTrans (buf, count, count_done)
1132
UDIHostMemPtr   buf;            /* in -- buffer address containing input data */
1133
UDISizeT        count;          /* in -- number of bytes in buf */
1134
UDISizeT        *count_done;    /* out-- number of bytes transfered */
1135
{
1136
    UDIInt32    service_id = UDIPutTrans_c;
1137
 
1138
    udr_errno = 0;
1139
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1140
    udr_UDIInt32(udrs, &service_id);
1141
    udr_UDISizeT(udrs, &count);
1142
    udr_bytes(udrs, buf, count);
1143
    udr_sendnow(udrs);
1144
    if(udr_errno) return udr_errno;
1145
 
1146
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1147
    udr_UDISizeT(udrs, count_done);
1148
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1149
    return dfe_errno;
1150
}
1151
 
1152
/*************************************************************** UDI_GET_TRANS
1153
* UDIGetTrans() is used to get output lines from the
1154
* passthru mode.
1155
*/
1156
UDIError        UDIGetTrans (buf, bufsize, count_done)
1157
UDIHostMemPtr   buf;            /* out -- buffer to be filled */
1158
UDISizeT        bufsize;        /* in  -- size of buf */
1159
UDISizeT        *count_done;    /* out -- number of bytes in buf */
1160
{
1161
    UDIInt32    service_id = UDIGetTrans_c;
1162
 
1163
    udr_errno = 0;
1164
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1165
    udr_UDIInt32(udrs, &service_id);
1166
    udr_UDISizeT(udrs, &bufsize);
1167
    udr_sendnow(udrs);
1168
    if(udr_errno) return udr_errno;
1169
 
1170
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1171
    udr_UDISizeT(udrs, count_done);
1172
    udr_bytes(udrs, buf, *count_done);
1173
    udr_UDIError(udrs, &dfe_errno);     /* get any TIP error */
1174
    return dfe_errno;
1175
}
1176
 
1177
/************************************************************** UDI_Trans_Mode
1178
* UDITransMode() is used to change the mode that the
1179
* transparent routines operate in.
1180
*/
1181
UDIError UDITransMode(mode)
1182
UDIMode         *mode;          /* out  -- selected mode */
1183
{
1184
    UDIInt32    service_id = UDITransMode_c;
1185
 
1186
    udr_errno = 0;
1187
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1188
    udr_UDIInt32(udrs, &service_id);
1189
    udr_UDIMode(udrs, mode);
1190
    udr_sendnow(udrs);
1191
    if(udr_errno) return udr_errno;
1192
 
1193
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1194
    udr_UDIError(udrs, &dfe_errno);
1195
    return dfe_errno;
1196
}
1197
 
1198
/******************************************************************** UDI_TEST
1199
*/
1200
UDIError UDITest( cnt, str_p, array)
1201
UDISizeT        cnt;
1202
UDIHostMemPtr   str_p;
1203
UDIInt32        array[];
1204
{
1205
    UDIInt32    service_id = UDITest_c;
1206
    UDIInt16    scnt = cnt;
1207
    UDISizeT    r_cnt;
1208
    char        buf[256];
1209
 
1210
    udr_errno = 0;
1211
    udrs->udr_op = UDR_ENCODE;          /* send all "in" parameters */
1212
    udr_UDIInt32(udrs, &service_id);
1213
 
1214
    printf("send        cnt=%d scnt=%d\n", cnt, scnt);
1215
    udr_UDISizeT(udrs, &cnt);
1216
    udr_UDIInt16(udrs, &scnt);
1217
    printf("    array[0]=0x%x array[1]=0x%x array[2]=0x%x array[3]=0x%x\n",
1218
        array[0], array[1], array[2], array[3]);
1219
    udr_bytes(udrs, (char*)array, 4*sizeof(UDIInt32));
1220
    printf("    string=%s\n", str_p);
1221
    udr_string(udrs, str_p);
1222
    udr_sendnow(udrs);
1223
    if(udr_errno)
1224
    {   fprintf(stderr, " DFE-ipc Send ERROR\n");
1225
        return udr_errno;
1226
    }
1227
 
1228
    udrs->udr_op = UDR_DECODE;          /* receive all "out" parameters */
1229
    printf("recv        ");
1230
    udr_UDISizeT(udrs, &r_cnt);
1231
    udr_UDIInt16(udrs, &scnt);
1232
    printf("    rcnt=%d scnt=%d\n", r_cnt, scnt);
1233
    udr_bytes(udrs, (char*)array, 4*sizeof(UDIInt32));
1234
 
1235
    printf("    array[0]=0x%x array[1]=0x%x array[2]=0x%x array[3]=0x%x\n",
1236
        array[0], array[1], array[2], array[3]);
1237
    udr_string(udrs, str_p);
1238
    printf("    string=%s\n", str_p);
1239
 
1240
    udr_UDIError(udrs, &dfe_errno);
1241
    return dfe_errno;
1242
}
1243
 
1244
 
1245
 
1246
UDIUInt32 UDIGetDFEIPCId()
1247
{
1248
    return ((company_c << 16) + (product_c << 12) + version_c);
1249
}
1250
#endif /* __GO32__ */

powered by: WebSVN 2.1.0

© copyright 1999-2024 OpenCores.org, equivalent to Oliscience, all rights reserved. OpenCores®, registered trademark.