1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
/*
* Copyright (C) 1990-2000 by CERN/IT/PDP/DM
* All rights reserved
*/
#ifndef lint
static char cvsId[] = "@(#)$RCSfile: setnetio.c,v $ $Revision: 1.2 $ $Date: 2008/01/10 08:27:59 $ CERN/IT/PDP/DM Olof Barring";
#endif /* not lint */
/* setnetio.c Set network input/output characteristics */
#include <stdio.h> /* Standard Input/Output */
#include <sys/types.h> /* Standard data types */
#if defined(_WIN32)
#include <winsock2.h>
#else
#include <sys/socket.h> /* Socket interface */
#include <netinet/in.h> /* Internet data types */
#include <netdb.h> /* Network "data base" */
#endif
#include <errno.h> /* Error numbers */
#include <string.h>
#include <serrno.h> /* SHIFT error codes */
#include <log.h> /* Genralized error logger */
#include <trace.h> /* tracing definitions */
#include <Cnetdb.h> /* reentrant netdb funct. */
extern char *getifnam(); /* get interface name */
extern char *getconfent(); /* get configuration entry */
extern int (*recvfunc)();
extern int (*sendfunc)();
extern int s_recv(); /* Normal recv() */
extern int s_send(); /* Normal send() */
#ifdef MINBLOCKSIZE /* Minimum blocksize is required */
extern int seg_recv(); /* Segmented recv() */
extern int seg_send(); /* Segmented send() */
#endif /* MINBLOCKSIZE */
int DLL_DECL setnetio(s)
int s;
{
#ifdef MINBLOCKSIZE
const char *hostname;
static int na_key = -1;
char *p1, *p2;
INIT_TRACE("COMMON_TRACE");
TRACE(1,"setnetio", "setnetio(0x%x) entered", s)
if ((p1 = getifnam(s)) != NULL) {
log(LOG_INFO, "connection from interface [%s]\n", p1);
TRACE(1, "setnetio", "connection from interface [%s]\n", p1);
}
else {
log(LOG_ERR,"fatal: unable to get interface name\n");
TRACE(1, "setnetio","fatal: unable to get interface name\n");
END_TRACE();
return(-1);
}
hostname = Cgetnetaddress(s, NULL, 0, &na_key, NULL, NULL, 0, 0);
if (hostname == NULL) {
log(LOG_INFO, "unable to get host name\n");
TRACE(1, "setnetio", "unable to get host name\n");
END_TRACE();
return(-1);
}
/*
* Hack needed for CRAY/LSC Ultranet problem
*/
if ((p2 = getconfent("SEGMENT", hostname, 0)) == NULL) {
serrno = 0; /* reset global error number */
log(LOG_INFO, "using unsegmented network read/write\n");
TRACE(1, "setnetio", "using unsegmented network read/write\n");
recvfunc = s_recv;
sendfunc = s_send;
}
else {
if (strcmp(p1, p2)) {
log(LOG_INFO, "using unsegmented network read/write\n");
TRACE(1, "setnetio", "using unsegmented network read/write\n");
recvfunc = s_recv;
sendfunc = s_send;
}
else {
log(LOG_INFO, "using segmented network read/write\n");
TRACE(1, "setnetio", "using segmented network read/write\n");
/*
* Here we switch the read/write functions
*/
recvfunc = seg_recv;
sendfunc = seg_send;
}
}
#else /* MINBLOCKSIZE */
recvfunc = s_recv;
sendfunc = s_send;
#endif /* MINBLOCKSIZE */
END_TRACE();
return(0);
}
|
