2 * $Id: afp_asp.c,v 1.8 2001-12-10 20:16:53 srittau Exp $
4 * Copyright (c) 1997 Adrian Sun (asun@zoology.washington.edu)
5 * Copyright (c) 1990,1993 Regents of The University of Michigan.
6 * All Rights Reserved. See COPYRIGHT.
8 * modified from main.c. this handles afp over asp.
13 #endif /* HAVE_CONFIG_H */
23 #ifdef HAVE_SYS_TIME_H
25 #endif /* HAVE_SYS_TIME_H */
26 #ifdef HAVE_SYS_STAT_H
28 #endif /* HAVE_SYS_STAT_H */
30 #include <netatalk/endian.h>
31 #include <atalk/atp.h>
32 #include <atalk/asp.h>
33 #include <atalk/compat.h>
34 #include <atalk/util.h>
41 extern struct oforks *writtenfork;
45 static __inline__ void afp_asp_close(AFPObj *obj)
47 ASP asp = obj->handle;
53 syslog(LOG_INFO, "%.2fKB read, %.2fKB written",
54 asp->read_count / 1024.0, asp->write_count / 1024.0);
57 static void afp_asp_die(const int sig)
59 ASP asp = child->handle;
61 asp_attention(asp, AFPATTN_SHUTDOWN);
62 if ( asp_shutdown( asp ) < 0 ) {
63 syslog( LOG_ERR, "afp_die: asp_shutdown: %s", strerror(errno) );
67 if (sig == SIGTERM || sig == SIGALRM)
73 static void afp_asp_timedown()
78 /* shutdown and don't reconnect. server going down in 5 minutes. */
79 asp_attention(child->handle, AFPATTN_SHUTDOWN | AFPATTN_NORECONNECT |
82 it.it_interval.tv_sec = 0;
83 it.it_interval.tv_usec = 0;
84 it.it_value.tv_sec = 300;
85 it.it_value.tv_usec = 0;
86 if ( setitimer( ITIMER_REAL, &it, 0 ) < 0 ) {
87 syslog( LOG_ERR, "afp_timedown: setitimer: %s", strerror(errno) );
91 memset(&sv, 0, sizeof(sv));
92 sv.sa_handler = afp_asp_die;
93 sigemptyset( &sv.sa_mask );
94 sv.sa_flags = SA_RESTART;
95 if ( sigaction( SIGALRM, &sv, 0 ) < 0 ) {
96 syslog( LOG_ERR, "afp_timedown: sigaction: %s", strerror(errno) );
101 void afp_over_asp(AFPObj *obj)
104 struct sigaction action;
105 int func, ccnt = 0, reply = 0;
107 obj->exit = afp_asp_die;
108 obj->reply = (int (*)()) asp_cmdreply;
109 obj->attention = (int (*)(void *, AFPUserBytes)) asp_attention;
111 asp = (ASP) obj->handle;
113 /* install signal handlers */
114 memset(&action, 0, sizeof(action));
115 action.sa_handler = afp_asp_timedown;
116 sigemptyset( &action.sa_mask );
117 action.sa_flags = SA_RESTART;
118 if ( sigaction( SIGHUP, &action, 0 ) < 0 ) {
119 syslog( LOG_ERR, "afp_over_asp: sigaction: %s", strerror(errno) );
123 action.sa_handler = afp_asp_die;
124 sigemptyset( &action.sa_mask );
125 action.sa_flags = SA_RESTART;
126 if ( sigaction( SIGTERM, &action, 0 ) < 0 ) {
127 syslog( LOG_ERR, "afp_over_asp: sigaction: %s", strerror(errno) );
131 syslog( LOG_INFO, "session from %u.%u:%u on %u.%u:%u",
132 ntohs( asp->asp_sat.sat_addr.s_net ),
133 asp->asp_sat.sat_addr.s_node, asp->asp_sat.sat_port,
134 ntohs( atp_sockaddr( asp->asp_atp )->sat_addr.s_net ),
135 atp_sockaddr( asp->asp_atp )->sat_addr.s_node,
136 atp_sockaddr( asp->asp_atp )->sat_port );
138 while ((reply = asp_getrequest(asp))) {
141 if (obj->options.authprintdir) {
142 char addr_filename[256];
145 sprintf(addr_filename, "%s/net%d.%dnode%d", obj->options.authprintdir,
146 ntohs( asp->asp_sat.sat_addr.s_net )/256,
147 ntohs( asp->asp_sat.sat_addr.s_net )%256,
148 asp->asp_sat.sat_addr.s_node );
150 if(stat(addr_filename, &cap_st) == 0) {
151 if(unlink(addr_filename) == 0) {
152 syslog(LOG_INFO, "removed %s", addr_filename);
154 syslog(LOG_INFO, "error removing %s: %s",
155 addr_filename, strerror(errno));
158 syslog(LOG_INFO, "error stat'ing %s: %s",
159 addr_filename, strerror(errno));
164 syslog( LOG_INFO, "done" );
166 if ( obj->options.flags & OPTION_DEBUG ) {
175 if ( flushfork( writtenfork ) < 0 ) {
176 syslog( LOG_ERR, "main flushfork: %m" );
181 func = (u_char) asp->commands[0];
182 if ( obj->options.flags & OPTION_DEBUG ) {
183 printf( "command: %d\n", func );
184 bprint( asp->commands, asp->cmdlen );
186 if ( afp_switch[ func ] != NULL ) {
188 * The function called from afp_switch is expected to
189 * read its parameters out of buf, put its
190 * results in replybuf (updating rbuflen), and
191 * return an error code.
193 asp->datalen = ASP_DATASIZ;
194 reply = (*afp_switch[ func ])(obj,
195 asp->commands, asp->cmdlen,
196 asp->data, &asp->datalen);
198 syslog( LOG_ERR, "bad function %X", func );
202 if ( obj->options.flags & OPTION_DEBUG ) {
203 printf( "reply: %d, %d\n", reply, ccnt++ );
204 bprint( asp->data, asp->datalen );
207 if ( asp_cmdreply( asp, reply ) < 0 ) {
208 syslog( LOG_ERR, "asp_cmdreply: %s", strerror(errno) );
214 func = (u_char) asp->commands[0];
215 if ( obj->options.flags & OPTION_DEBUG ) {
216 printf( "(write) command: %d\n", func );
217 bprint( asp->commands, asp->cmdlen );
219 if ( afp_switch[ func ] != NULL ) {
220 asp->datalen = ASP_DATASIZ;
221 reply = (*afp_switch[ func ])(obj,
222 asp->commands, asp->cmdlen,
223 asp->data, &asp->datalen);
225 syslog( LOG_ERR, "(write) bad function %X", func );
229 if ( obj->options.flags & OPTION_DEBUG ) {
230 printf( "(write) reply code: %d, %d\n", reply, ccnt++ );
231 bprint( asp->data, asp->datalen );
233 if ( asp_wrtreply( asp, reply ) < 0 ) {
234 syslog( LOG_ERR, "asp_wrtreply: %s", strerror(errno) );
240 * Bad asp packet. Probably should have asp filter them,
241 * since they are typically things like out-of-order packet.
243 syslog( LOG_INFO, "main: asp_getrequest: %d", reply );
247 if ( obj->options.flags & OPTION_DEBUG ) {
251 of_pforkdesc( stdout );