]> arthur.barton.de Git - netatalk.git/blob - etc/afpd/messages.c
remove SIGUSR2 (message) from the list of blocked signals when writing to the client...
[netatalk.git] / etc / afpd / messages.c
1 /*
2  * $Id: messages.c,v 1.21 2009-10-22 05:53:20 didg Exp $
3  *
4  * Copyright (c) 1997 Adrian Sun (asun@zoology.washington.edu)
5  * All Rights Reserved.  See COPYRIGHT.
6  */
7
8 #ifdef HAVE_CONFIG_H
9 #include "config.h"
10 #endif /* HAVE_CONFIG_H */
11
12 #ifdef HAVE_UNISTD_H
13 #include <unistd.h>
14 #endif /* HAVE_UNISTD_H */
15 #include <stdio.h>
16 #include <string.h>
17 #include <errno.h>
18 #include <stdlib.h>
19 #include <atalk/afp.h>
20 #include <atalk/dsi.h>
21 #include <atalk/util.h>
22 #include <atalk/logger.h>
23 #include "globals.h"
24 #include "misc.h"
25
26
27 #define MAXMESGSIZE 199
28
29 /* this is only used by afpd children, so it's okay. */
30 static char servermesg[MAXPATHLEN] = "";
31 static char localized_message[MAXPATHLEN] = "";
32
33 void setmessage(const char *message)
34 {
35     strlcpy(servermesg, message, MAXMESGSIZE);
36 }
37
38 void readmessage(AFPObj *obj)
39 {
40     /* Read server message from file defined as SERVERTEXT */
41 #ifdef SERVERTEXT
42     FILE *message;
43     char * filename;
44     unsigned int i; 
45     int rc;
46     static int c;
47     uid_t euid;
48     u_int32_t maxmsgsize;
49
50     maxmsgsize = (obj->proto == AFPPROTO_DSI)?MIN(MAX(((DSI*)obj->handle)->attn_quantum, MAXMESGSIZE),MAXPATHLEN):MAXMESGSIZE;
51
52     i=0;
53     /* Construct file name SERVERTEXT/message.[pid] */
54     if ( NULL == (filename=(char*) malloc(sizeof(SERVERTEXT)+15)) ) {
55         LOG(log_error, logtype_afpd, "readmessage: malloc: %s", strerror(errno) );
56         return;
57     }
58
59     sprintf(filename, "%s/message.%d", SERVERTEXT, getpid());
60
61 #ifdef DEBUG
62     LOG(log_debug, logtype_afpd, "Reading file %s ", filename);
63 #endif /* DEBUG */
64
65     message=fopen(filename, "r");
66     if (message==NULL) {
67         LOG(log_info, logtype_afpd, "Unable to open file %s", filename);
68         sprintf(filename, "%s/message", SERVERTEXT);
69         message=fopen(filename, "r");
70     }
71
72     /* if either message.pid or message exists */
73     if (message!=NULL) {
74         /* added while loop to get characters and put in servermesg */
75         while ((( c=fgetc(message)) != EOF) && (i < (maxmsgsize - 1))) {
76             if ( c == '\n')  c = ' ';
77             servermesg[i++] = c;
78         }
79         servermesg[i] = 0;
80
81         /* cleanup */
82         fclose(message);
83
84         /* Save effective uid and switch to root to delete file. */
85         /* Delete will probably fail otherwise, but let's try anyways */
86         euid = geteuid();
87         if (seteuid(0) < 0) {
88             LOG(log_error, logtype_afpd, "Could not switch back to root: %s",
89                                 strerror(errno));
90         }
91
92         if ( 0 < (rc = unlink(filename)) )
93             LOG(log_error, logtype_afpd, "File '%s' could not be deleted", strerror(errno));
94
95         /* Drop privs again, failing this is very bad */
96         if (seteuid(euid) < 0) {
97             LOG(log_error, logtype_afpd, "Could not switch back to uid %d: %s", euid, strerror(errno));
98             exit(EXITERR_SYS);
99         }
100
101         if (rc < 0) {
102             LOG(log_error, logtype_afpd, "Error deleting %s: %s", filename, strerror(rc));
103         }
104 #ifdef DEBUG
105         else {
106             LOG(log_info, logtype_afpd, "Deleted %s", filename);
107         }
108
109         LOG(log_info, logtype_afpd, "Set server message to \"%s\"", servermesg);
110 #endif /* DEBUG */
111     }
112     free(filename);
113 #endif /* SERVERTEXT */
114 }
115
116 int afp_getsrvrmesg(AFPObj *obj, char *ibuf, size_t ibuflen _U_, char *rbuf, size_t *rbuflen)
117 {
118     char *message;
119     u_int16_t type, bitmap;
120     u_int16_t msgsize;
121     size_t outlen = 0;
122     size_t msglen = 0;
123     int utf8 = 0;
124
125     *rbuflen = 0;
126
127     msgsize = (obj->proto == AFPPROTO_DSI)?MAX(((DSI*)obj->handle)->attn_quantum, MAXMESGSIZE):MAXMESGSIZE;
128
129     memcpy(&type, ibuf + 2, sizeof(type));
130     memcpy(&bitmap, ibuf + 4, sizeof(bitmap));
131
132     switch (ntohs(type)) {
133     case AFPMESG_LOGIN: /* login */
134         message = obj->options.loginmesg;
135         break;
136     case AFPMESG_SERVER: /* server */
137         message = servermesg;
138         break;
139     default:
140         return AFPERR_BITMAP;
141     }
142
143     /* output format:
144      * message type:   2 bytes
145      * bitmap:         2 bytes
146      * message length: 1 byte ( 2 bytes for utf8)
147      * message:        up to 199 bytes (dsi attn_quantum for utf8)
148      */
149     memcpy(rbuf, &type, sizeof(type));
150     rbuf += sizeof(type);
151     *rbuflen += sizeof(type);
152     memcpy(rbuf, &bitmap, sizeof(bitmap));
153     rbuf += sizeof(bitmap);
154     *rbuflen += sizeof(bitmap);
155
156     utf8 = ntohs(bitmap) & 2; 
157     msglen = strlen(message);
158     if (msglen > msgsize)
159         msglen = msgsize;
160
161     if (msglen) { 
162         if ( (size_t)-1 == (outlen = convert_string(obj->options.unixcharset, utf8?CH_UTF8_MAC:obj->options.maccharset,
163                                                     message, msglen, localized_message, msgsize)) )
164         {
165             memcpy(rbuf+((utf8)?2:1), message, msglen); /*FIXME*/
166             outlen = msglen;
167         }
168         else
169         {
170             memcpy(rbuf+((utf8)?2:1), localized_message, outlen);
171         }
172     }
173     
174     if ( utf8 ) {
175         /* UTF8 message, 2 byte length */
176         msgsize = htons(outlen);
177         memcpy(rbuf, &msgsize, sizeof(msgsize));
178         *rbuflen += sizeof(msgsize);
179     }
180     else {
181         *rbuf = outlen;
182         *rbuflen += 1;
183     }
184     *rbuflen += outlen;
185
186     return AFP_OK;
187 }