Commit | Line | Data |
---|---|---|
805e021f CE |
1 | /* |
2 | * Copyright 2000, International Business Machines Corporation and others. | |
3 | * All Rights Reserved. | |
4 | * | |
5 | * This software has been released under the terms of the IBM Public | |
6 | * License. For details, see the LICENSE file in the top-level source | |
7 | * directory or online at http://www.openafs.org/dl/license10.html | |
8 | */ | |
9 | ||
10 | /* | |
11 | * afs_mariner.c - fetch/store monitoring facility. | |
12 | */ | |
13 | /* | |
14 | * Implements: | |
15 | */ | |
16 | #include <afsconfig.h> | |
17 | #include "afs/param.h" | |
18 | ||
19 | ||
20 | #include "afs/sysincludes.h" /*Standard vendor system headers */ | |
21 | #include "afsincludes.h" /*AFS-based standard headers */ | |
22 | #include "afs/afs_stats.h" /* statistics */ | |
23 | ||
24 | /* Exported variables */ | |
25 | struct rx_service *afs_server; | |
26 | ||
27 | ||
28 | #define SMAR 20 /* size of a mariner name */ | |
29 | #define NMAR 10 /* number of mariner names */ | |
30 | static char marinerNames[NMAR][SMAR]; | |
31 | static struct vcache *marinerVCs[NMAR]; | |
32 | static int marinerPtr = 0; /* pointer to next mariner slot to use */ | |
33 | ||
34 | /* Exported variables */ | |
35 | afs_int32 afs_mariner = 0; | |
36 | afs_int32 afs_marinerHost = 0; | |
37 | ||
38 | int | |
39 | afs_AddMarinerName(char *aname, struct vcache *avc) | |
40 | { | |
41 | int i; | |
42 | char *tp; | |
43 | ||
44 | AFS_STATCNT(afs_AddMarinerName); | |
45 | i = marinerPtr++; | |
46 | if (i >= NMAR) { | |
47 | i = 0; | |
48 | marinerPtr = 1; | |
49 | } | |
50 | tp = marinerNames[i]; | |
51 | strncpy(tp, aname, SMAR); | |
52 | tp[SMAR - 1] = 0; | |
53 | marinerVCs[i] = avc; | |
54 | return 0; | |
55 | } | |
56 | ||
57 | char * | |
58 | afs_GetMariner(struct vcache *avc) | |
59 | { | |
60 | int i; | |
61 | AFS_STATCNT(afs_GetMariner); | |
62 | for (i = 0; i < NMAR; i++) { | |
63 | if (marinerVCs[i] == avc) { | |
64 | return marinerNames[i]; | |
65 | } | |
66 | } | |
67 | return "a file"; | |
68 | } | |
69 | ||
70 | void | |
71 | afs_MarinerLogFetch(struct vcache *avc, afs_int32 off, | |
72 | afs_int32 bytes, afs_int32 idx) | |
73 | { | |
74 | afs_MarinerLog("fetch$Fetching", avc); | |
75 | } /*afs_MarinerLogFetch */ | |
76 | ||
77 | void | |
78 | afs_MarinerLog(char *astring, struct vcache *avc) | |
79 | { | |
80 | struct sockaddr_in taddr; | |
81 | char *tp, *tp1, *buf; | |
82 | struct iovec dvec; | |
83 | ||
84 | AFS_STATCNT(afs_MarinerLog); | |
85 | taddr.sin_family = AF_INET; | |
86 | taddr.sin_addr.s_addr = afs_marinerHost; | |
87 | taddr.sin_port = htons(2106); | |
88 | #ifdef STRUCT_SOCKADDR_HAS_SA_LEN | |
89 | taddr.sin_len = sizeof(taddr); | |
90 | #endif | |
91 | tp = buf = osi_AllocSmallSpace(AFS_SMALLOCSIZ); | |
92 | ||
93 | strcpy(tp, astring); | |
94 | tp += strlen(astring); | |
95 | if (avc) { | |
96 | *tp++ = ' '; | |
97 | tp1 = afs_GetMariner(avc); | |
98 | strcpy(tp, tp1); | |
99 | tp += strlen(tp1); | |
100 | } | |
101 | *tp++ = '\n'; | |
102 | /* note, console doesn't want a terminating null */ | |
103 | /* I don't care if mariner packets fail to be sent */ | |
104 | dvec.iov_base = buf; | |
105 | dvec.iov_len = tp - buf; | |
106 | AFS_GUNLOCK(); | |
107 | (void)osi_NetSend(afs_server->socket, &taddr, &dvec, 1, tp - buf, 0); | |
108 | AFS_GLOCK(); | |
109 | osi_FreeSmallSpace(buf); | |
110 | } /*afs_MarinerLog */ | |
111 | ||
112 | void | |
113 | shutdown_mariner(void) | |
114 | { | |
115 | int i; | |
116 | ||
117 | marinerPtr = 0; | |
118 | afs_mariner = 0; | |
119 | ||
120 | for (i = 0; i < NMAR; i++) | |
121 | marinerVCs[i] = 0; | |
122 | } |