mc/vfs/mcserv.c

1300 lines
28 KiB
C
Raw Normal View History

1998-02-27 07:54:42 +03:00
/* Server for the Midnight Commander Virtual File System.
Copyright (C) 1995, 1996, 1997 The Free Software Foundation
Written by:
Miguel de Icaza, 1995, 1997,
Andrej Borsenkow 1996.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
1998-02-27 07:54:42 +03:00
TODO:
opendir instead of keeping its table of file handles could return
the pointer and expect the client to send a proper value back each
time :-)
We should use syslog to register login/logout.
*/
/* {{{ Includes and global variables */
#include <config.h>
#include <stdio.h>
#include <stdlib.h>
#ifdef HAVE_UNISTD_H
# include <unistd.h>
#endif
#include <fcntl.h>
#include <string.h>
#ifdef HAVE_LIMITS_H
# include <limits.h>
#endif
#ifndef NGROUPS_MAX
# include <sys/param.h>
# ifdef NGROUPS
# define NGROUPS_MAX NGROUPS
# endif
#endif
#ifdef HAVE_GRP_H
# include <grp.h>
#endif
#ifdef HAVE_SHADOW_H
# include <shadow.h>
#else
# ifdef HAVE_SHADOW_SHADOW_H
# include <shadow/shadow.h>
# endif
#endif
#ifdef HAVE_CRYPT_H
# include <crypt.h>
#endif
#include <sys/types.h>
#include <sys/stat.h>
These are a bunch of changes to fix CORBA and session management. They are almost complete (i.e. to handle all nitty gritty cases), but they seem to be working OK right now. SM should be much more stable now. Please tell me if you find any weird behavior - Federico 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * gdesktop-icon.c (desktop_icon_realize): Remove the WM_CLIENT_LEADER property from icon windows so that window managers will not store SM information for them. * gnome-open-dialog.c: Added missing #includes. * gdesktop-init.c (desktop_init_at): Removed an unused variable. * gdesktop.h: Added some missing prototypes. * gmain.h: Added some missing prototypes. * Makefile.in: Added gsession.[ch] to the list of sources. * gmain.c (create_panels): Consider whether we have a CORBA server and session management. * gdesktop.c: #include "gdesktop-init.h" * gdesktop.c: Added a missing cast to GNOME_DIALOG. * gmain.c (create_panels): Removed the run_desktop global variable. * glayout.c (create_container): Set the wmclass of the panel to include its unique ID. * gsession.[ch]: New file with the functions that deal with session management. * glayout.c (gnome_exit): Use session_set_restart(). * gcorba.c (corba_init): Now returns an int with an error value. (corba_init_server): Initialize the server properly. Fixed all the object implementation code. (corba_create_window): New function used to create a window with the CORBA server. * gmain.c (gnome_check_super_user): Now the check for running as root is done here. There should be no GUI code in src/. 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * dlg.c (dlg_run_done): Do not call the callback of a NULL current widget. * setup.h: Added missing prototype for setup_init(). * filegui.c (check_progress_buttons): Added a missing return value. * dlg.c (remove_widget): Added a missing return value. * main.c: Removed the global directory_list variable. Removed the main_corba_register_server() function. * main.h: Removed the global run_desktop variable. * panel.h: Now the panel structure has a unique numerical ID used for session management. * screen.c (panel_new): Maintain a unique ID for each panel. * main.c (maybe_display_linksdir): Handle display of the desktop init dir here. (main): Call gnome_check_super_user(). (init_corba_with_args): Call corba_init_server(). * main.c (init_corba_with_args): Do CORBA initialization here. Also removed the global force_activation option. 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * vfs.c (vfs_add_current_stamps): Only do stamping of the panels if they exist. * mcserv.c: #include <sys/wait.h> (get_client): Put `#ifdef __EMX__' around an otherwise-unused variable. * utilvfs.c (vfs_split_url): Fix NULL <-> 0 confusion when comparing characters. * ftpfs.c (retrieve_dir): Removed unused variable dot_dot_found. * extfs.c (extfs_init): Assign `key' to c, not `&key'.
1999-03-30 10:09:56 +04:00
#include <sys/wait.h>
1998-02-27 07:54:42 +03:00
#include <errno.h>
#include <signal.h>
/* Network include files */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <arpa/inet.h>
#ifdef HAVE_PMAP_SET
# include <rpc/rpc.h>
# include <rpc/pmap_prot.h>
# ifdef HAVE_RPC_PMAP_CLNT_H
# include <rpc/pmap_clnt.h>
# endif
#endif
/* Authentication include files */
#include <pwd.h>
#ifdef HAVE_PAM
# include <security/pam_misc.h>
# ifndef PAM_ESTABLISH_CRED
# define PAM_ESTABLISH_CRED PAM_CRED_ESTABLISH
# endif
#endif
#include "utilvfs.h"
#include "vfs.h"
1998-02-27 07:54:42 +03:00
#include "mcfs.h"
#include "tcputil.h"
/* The socket from which we accept commands */
int msock;
/* Requested version number from client */
static int clnt_version;
/* If non zero, we accept further commands */
int logged_in = 0;
/* Home directory */
char *home_dir = NULL;
char *up_dir = NULL;
/* Were we started from inetd? */
int inetd_started = 0;
/* Are we running as a daemon? */
int isDaemon = 0;
/* guess */
int verbose = 0;
/* ftp auth */
int ftp = 0;
/* port number in which we listen to connections,
* if zero, we try to contact the portmapper to get a port, and
* if it's not possible, then we use a hardcoded value
*/
int portnum = 0;
/* if the server will use rcmd based authentication (hosts.equiv .rhosts) */
int r_auth = 0;
#define OPENDIR_HANDLES 8
#define DO_QUIT_VOID() \
do { \
quit_server = 1; \
return_code = 1; \
return; \
} while (0)
/* Only used by get_port_number */
#define DO_QUIT_NONVOID(a) \
do { \
quit_server = 1; \
return_code = 1; \
return (a); \
} while (0)
char buffer [4096];
int debug = 1;
static int quit_server;
static int return_code;
/* }}} */
/* {{{ Misc routines */
static void send_status (int status, int errno_number)
1998-02-27 07:54:42 +03:00
{
rpc_send (msock, RPC_INT, status, RPC_INT, errno_number, RPC_END);
errno = 0;
}
/* }}} */
/* {{{ File with handle operations */
static void do_open (void)
1998-02-27 07:54:42 +03:00
{
int handle, flags, mode;
char *arg;
rpc_get (msock, RPC_STRING, &arg, RPC_INT, &flags, RPC_INT, &mode,RPC_END);
handle = open (arg, flags, mode);
send_status (handle, errno);
g_free (arg);
1998-02-27 07:54:42 +03:00
}
static void do_read (void)
1998-02-27 07:54:42 +03:00
{
int handle, count, n;
void *data;
rpc_get (msock, RPC_INT, &handle, RPC_INT, &count, RPC_END);
data = g_malloc (count);
1998-02-27 07:54:42 +03:00
if (!data){
send_status (-1, ENOMEM);
return;
}
if (verbose) printf ("count=%d\n", count);
n = read (handle, data, count);
if (verbose) printf ("result=%d\n", n);
if (n < 0){
send_status (-1, errno);
return;
}
send_status (n, 0);
rpc_send (msock, RPC_BLOCK, n, data, RPC_END);
g_free (data);
1998-02-27 07:54:42 +03:00
}
static void do_write (void)
1998-02-27 07:54:42 +03:00
{
int handle, count, status, written = 0;
char buf[8192];
1998-02-27 07:54:42 +03:00
rpc_get (msock, RPC_INT, &handle, RPC_INT, &count, RPC_END);
status = 0;
while (count) {
1998-02-27 07:54:42 +03:00
int nbytes = count > 8192 ? 8192 : count;
rpc_get (msock, RPC_BLOCK, nbytes, buf, RPC_END);
status = write (handle, buf, nbytes);
if (status < 0) {
send_status (status, errno);
return;
}
/* FIXED: amount written must be returned to caller */
written += status;
if (status < nbytes) {
send_status (written, errno);
return;
}
1998-02-27 07:54:42 +03:00
count -= nbytes;
}
send_status (written, errno);
1998-02-27 07:54:42 +03:00
}
static void do_lseek (void)
1998-02-27 07:54:42 +03:00
{
int handle, offset, whence, status;
rpc_get (msock,
RPC_INT, &handle,
RPC_INT, &offset,
RPC_INT, &whence, RPC_END);
status = lseek (handle, offset, whence);
send_status (status, errno);
}
static void do_close (void)
1998-02-27 07:54:42 +03:00
{
int handle, status;
rpc_get (msock, RPC_INT, &handle, RPC_END);
status = close (handle);
send_status (status, errno);
}
/* }}} */
/* {{{ Stat family routines */
static void send_time (int sock, time_t time)
1998-02-27 07:54:42 +03:00
{
if (clnt_version == 1) {
char *ct;
int month;
ct = ctime (&time);
ct [3] = ct [10] = ct [13] = ct [16] = ct [19] = 0;
/* Jan Feb Mar Apr May Jun Jul Aug Sep Oct Nov Dec */
if (ct [4] == 'J'){
if (ct [5] == 'a'){
month = 0;
} else
month = (ct [6] == 'n') ? 5 : 6;
} else if (ct [4] == 'F'){
month = 1;
} else if (ct [4] == 'M'){
month = (ct [6] == 'r') ? 2 : 5;
} else if (ct [4] == 'A'){
month = (ct [5] == 'p') ? 3 : 7;
} else if (ct [4] == 'S'){
month = 8;
} else if (ct [4] == 'O'){
month = 9;
} else if (ct [4] == 'N'){
month = 10;
} else
month = 11;
rpc_send (msock,
RPC_INT, atoi (&ct [17]), /* sec */
RPC_INT, atoi (&ct [14]), /* min */
RPC_INT, atoi (&ct [11]), /* hour */
RPC_INT, atoi (&ct [8]), /* mday */
RPC_INT, atoi (&ct [20]), /* year */
RPC_INT, month, /* month */
RPC_END);
} else {
long ltime = (long) time;
char buf[BUF_SMALL];
1998-02-27 07:54:42 +03:00
g_snprintf (buf, sizeof(buf), "%lx", ltime);
1998-02-27 07:54:42 +03:00
rpc_send (msock,
RPC_STRING, buf,
RPC_END);
}
}
static void send_stat_info (struct stat *st)
1998-02-27 07:54:42 +03:00
{
long mylong;
1998-02-27 07:54:42 +03:00
int blocks =
#ifdef HAVE_ST_BLOCKS
st->st_blocks;
#else
st->st_size / 1024;
#endif
#ifdef HAVE_ST_RDEV
mylong = st->st_rdev;
#else
mylong = 0;
#endif
rpc_send (msock, RPC_INT, (long) mylong,
1998-02-27 07:54:42 +03:00
RPC_INT, (long) st->st_ino,
RPC_INT, (long) st->st_mode,
RPC_INT, (long) st->st_nlink,
RPC_INT, (long) st->st_uid,
RPC_INT, (long) st->st_gid,
RPC_INT, (long) st->st_size,
RPC_INT, (long) blocks, RPC_END);
send_time (msock, st->st_atime);
send_time (msock, st->st_mtime);
send_time (msock, st->st_ctime);
}
static void do_lstat (void)
1998-02-27 07:54:42 +03:00
{
struct stat st;
char *file;
int n;
rpc_get (msock, RPC_STRING, &file, RPC_END);
n = lstat (file, &st);
send_status (n, errno);
if (n >= 0)
send_stat_info (&st);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_fstat (void)
1998-02-27 07:54:42 +03:00
{
int handle;
int n;
struct stat st;
rpc_get (msock, RPC_INT, &handle, RPC_END);
n = fstat (handle, &st);
send_status (n, errno);
if (n < 0)
return;
send_stat_info (&st);
}
static void do_stat (void)
1998-02-27 07:54:42 +03:00
{
struct stat st;
int n;
char *file;
rpc_get (msock, RPC_STRING, &file, RPC_END);
n = stat (file, &st);
send_status (n, errno);
if (n >= 0)
send_stat_info (&st);
g_free (file);
1998-02-27 07:54:42 +03:00
}
/* }}} */
/* {{{ Directory lookup operations */
static struct {
int used;
DIR *dirs [OPENDIR_HANDLES];
char *names [OPENDIR_HANDLES];
} mcfs_DIR;
static void close_handle (int handle)
1998-02-27 07:54:42 +03:00
{
if (mcfs_DIR.used > 0) mcfs_DIR.used--;
if (mcfs_DIR.dirs [handle])
closedir (mcfs_DIR.dirs [handle]);
if (mcfs_DIR.names [handle])
g_free (mcfs_DIR.names [handle]);
1998-02-27 07:54:42 +03:00
mcfs_DIR.dirs [handle] = 0;
mcfs_DIR.names [handle] = 0;
}
static void do_opendir (void)
1998-02-27 07:54:42 +03:00
{
int handle, i;
char *arg;
DIR *p;
rpc_get (msock, RPC_STRING, &arg, RPC_END);
if (mcfs_DIR.used == OPENDIR_HANDLES){
send_status (-1, ENFILE); /* Error */
g_free (arg);
1998-02-27 07:54:42 +03:00
return;
}
handle = -1;
for (i = 0; i < OPENDIR_HANDLES; i++){
if (mcfs_DIR.dirs [i] == 0){
handle = i;
break;
}
}
if (handle == -1){
send_status (-1, EMFILE);
g_free (arg);
1998-02-27 07:54:42 +03:00
if (!inetd_started)
fprintf (stderr, "OOPS! you have found a bug in mc - do_opendir()!\n");
return;
}
if (verbose) printf ("handle=%d\n", handle);
p = opendir (arg);
if (p){
mcfs_DIR.dirs [handle] = p;
mcfs_DIR.names [handle] = arg;
mcfs_DIR.used ++;
/* Because 0 is an error value */
rpc_send (msock, RPC_INT, handle+1, RPC_INT, 0, RPC_END);
} else {
send_status (-1, errno);
g_free (arg);
1998-02-27 07:54:42 +03:00
}
}
/* Sends the complete directory listing, as well as the stat information */
static void do_readdir (void)
1998-02-27 07:54:42 +03:00
{
struct dirent *dirent;
struct stat st;
int handle, n;
1998-02-27 07:54:42 +03:00
char *fname = 0;
rpc_get (msock, RPC_INT, &handle, RPC_END);
if (!handle){
rpc_send (msock, RPC_INT, 0, RPC_END);
return;
}
/* We incremented it in opendir */
handle --;
while ((dirent = readdir (mcfs_DIR.dirs [handle]))){
int length = NLENGTH (dirent);
rpc_send (msock, RPC_INT, length, RPC_END);
rpc_send (msock, RPC_BLOCK, length, dirent->d_name, RPC_END);
fname = g_strconcat (mcfs_DIR.names [handle],
PATH_SEP_STR, dirent->d_name, NULL);
1998-02-27 07:54:42 +03:00
n = lstat (fname, &st);
send_status (n, errno);
g_free (fname);
1998-02-27 07:54:42 +03:00
if (n >= 0)
send_stat_info (&st);
}
rpc_send (msock, RPC_INT, 0, RPC_END);
}
static void do_closedir (void)
1998-02-27 07:54:42 +03:00
{
int handle;
rpc_get (msock, RPC_INT, &handle, RPC_END);
close_handle (handle-1);
}
/* }}} */
/* {{{ Operations with one and two file name argument */
static void do_chdir (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int status;
rpc_get (msock, RPC_STRING, &file, RPC_END);
status = chdir (file);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_rmdir (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int status;
rpc_get (msock, RPC_STRING, &file, RPC_END);
status = rmdir (file);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_mkdir (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int mode, status;
rpc_get (msock, RPC_STRING, &file, RPC_INT, &mode, RPC_END);
status = mkdir (file, mode);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_mknod (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int mode, dev, status;
rpc_get (msock, RPC_STRING, &file, RPC_INT, &mode, RPC_INT, &dev, RPC_END);
status = mknod (file, mode, dev);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_readlink (void)
1998-02-27 07:54:42 +03:00
{
char buffer [2048];
char *file;
int n;
rpc_get (msock, RPC_STRING, &file, RPC_END);
n = readlink (file, buffer, 2048);
send_status (n, errno);
if (n >= 0) {
buffer [n] = 0;
rpc_send (msock, RPC_STRING, buffer, RPC_END);
}
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_unlink (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int status;
rpc_get (msock, RPC_STRING, &file, RPC_END);
status = unlink (file);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_rename (void)
1998-02-27 07:54:42 +03:00
{
char *f1, *f2;
int status;
rpc_get (msock, RPC_STRING, &f1, RPC_STRING, &f2, RPC_END);
status = rename (f1, f2);
send_status (status, errno);
g_free (f1); g_free (f2);
1998-02-27 07:54:42 +03:00
}
static void do_symlink (void)
1998-02-27 07:54:42 +03:00
{
char *f1, *f2;
int status;
rpc_get (msock, RPC_STRING, &f1, RPC_STRING, &f2, RPC_END);
status = symlink (f1, f2);
send_status (status, errno);
g_free (f1); g_free (f2);
1998-02-27 07:54:42 +03:00
}
static void do_link (void)
1998-02-27 07:54:42 +03:00
{
char *f1, *f2;
int status;
rpc_get (msock, RPC_STRING, &f1, RPC_STRING, &f2, RPC_END);
status = link (f1, f2);
send_status (status, errno);
g_free (f1); g_free (f2);
1998-02-27 07:54:42 +03:00
}
/* }}} */
/* {{{ Misc commands */
static void do_gethome (void)
1998-02-27 07:54:42 +03:00
{
rpc_send (msock, RPC_STRING, (home_dir) ? home_dir : "/", RPC_END);
}
static void do_getupdir (void)
1998-02-27 07:54:42 +03:00
{
rpc_send (msock, RPC_STRING, (up_dir) ? up_dir : "/", RPC_END);
}
static void do_chmod (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int mode, status;
rpc_get (msock, RPC_STRING, &file, RPC_INT, &mode, RPC_END);
status = chmod (file, mode);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_chown (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int owner, group, status;
rpc_get (msock, RPC_STRING, &file,RPC_INT, &owner, RPC_INT,&group,RPC_END);
status = chown (file, owner, group);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_utime (void)
1998-02-27 07:54:42 +03:00
{
char *file;
int status;
long atime;
long mtime;
char *as;
char *ms;
struct utimbuf times;
rpc_get (msock, RPC_STRING, &file,
RPC_STRING, &as,
RPC_STRING, &ms,
RPC_END);
sscanf (as, "%lx", &atime);
sscanf (ms, "%lx", &mtime);
if (verbose) printf ("Got a = %s, m = %s, comp a = %ld, m = %ld\n",
as, ms, atime, mtime);
g_free (as);
g_free (ms);
1998-02-27 07:54:42 +03:00
times.actime = (time_t) atime;
times.modtime = (time_t) mtime;
status = utime (file, &times);
send_status (status, errno);
g_free (file);
1998-02-27 07:54:42 +03:00
}
static void do_quit (void)
1998-02-27 07:54:42 +03:00
{
quit_server = 1;
}
#ifdef HAVE_PAM
struct user_pass {
char *username;
char *password;
};
static int
1998-02-27 07:54:42 +03:00
mc_pam_conversation (int messages, const struct pam_message **msg,
struct pam_response **resp, void *appdata_ptr)
{
struct pam_response *r;
struct user_pass *up = appdata_ptr;
int status;
r = g_new (struct pam_response, messages);
1998-02-27 07:54:42 +03:00
if (!r)
return PAM_CONV_ERR;
*resp = r;
for (status = PAM_SUCCESS; messages--; msg++, r++){
switch ((*msg)->msg_style){
case PAM_PROMPT_ECHO_ON:
r->resp = g_strdup (up->username);
1998-02-27 07:54:42 +03:00
r->resp_retcode = PAM_SUCCESS;
break;
case PAM_PROMPT_ECHO_OFF:
r->resp = g_strdup (up->password);
1998-02-27 07:54:42 +03:00
r->resp_retcode = PAM_SUCCESS;
break;
case PAM_ERROR_MSG:
r->resp = NULL;
r->resp_retcode = PAM_SUCCESS;
break;
case PAM_TEXT_INFO:
r->resp = NULL;
r->resp_retcode = PAM_SUCCESS;
break;
}
}
return status;
}
static struct pam_conv conv = { &mc_pam_conversation, NULL };
/* Return 0 if authentication failed, 1 otherwise */
static int
1998-02-27 07:54:42 +03:00
mc_pam_auth (char *username, char *password)
{
pam_handle_t *pamh;
struct user_pass up;
int status;
up.username = username;
up.password = password;
conv.appdata_ptr = &up;
if ((status = pam_start("mcserv", username, &conv, &pamh)) != PAM_SUCCESS)
goto failed_pam;
if ((status = pam_authenticate (pamh, 0)) != PAM_SUCCESS)
goto failed_pam;
if ((status = pam_acct_mgmt (pamh, 0)) != PAM_SUCCESS)
goto failed_pam;
if ((status = pam_setcred (pamh, PAM_ESTABLISH_CRED)) != PAM_SUCCESS)
goto failed_pam;
pam_end (pamh, status);
return 0;
failed_pam:
pam_end (pamh, status);
return 1;
}
#else /* Code for non-PAM authentication */
/* Keep reading until we find a \n */
static int next_line (int socket)
{
char c;
while (1){
if (read (socket, &c, 1) <= 0)
return 0;
if (c == '\n')
return 1;
}
}
static int ftp_answer (int sock, char *text)
{
char answer [4];
next_line (sock);
socket_read_block (sock, answer, 3);
answer [3] = 0;
if (strcmp (answer, text) == 0)
return 1;
return 0;
}
static int do_ftp_auth (char *username, char *password)
1998-02-27 07:54:42 +03:00
{
struct sockaddr_in local_address;
unsigned long inaddr;
int my_socket;
char answer [4];
bzero ((char *) &local_address, sizeof (local_address));
local_address.sin_family = AF_INET;
/* FIXME: extract the ftp port with the proper function */
local_address.sin_port = htons (21);
/* Convert localhost to usable format */
if ((inaddr = inet_addr ("127.0.0.1")) != -1)
bcopy ((char *) &inaddr, (char *) &local_address.sin_addr,
sizeof (inaddr));
if ((my_socket = socket (AF_INET, SOCK_STREAM, 0)) < 0){
if (!isDaemon) fprintf (stderr, "do_auth: can't create socket\n");
return 0;
}
if (connect (my_socket, (struct sockaddr *) &local_address,
sizeof (local_address)) < 0){
fprintf (stderr,
"do_auth: can't connect to ftp daemon for authentication\n");
close (my_socket);
return 0;
}
send_string (my_socket, "user ");
send_string (my_socket, username);
send_string (my_socket, "\r\n");
if (!ftp_answer (my_socket, "331")){
send_string (my_socket, "quit\r\n");
close (my_socket);
return 0;
}
next_line (my_socket); /* Eat all the line */
send_string (my_socket, "pass ");
send_string (my_socket, password);
send_string (my_socket, "\r\n");
socket_read_block (my_socket, answer, 3);
answer [3] = 0;
send_string (my_socket, "\r\n");
send_string (my_socket, "quit\r\n");
close (my_socket);
if (strcmp (answer, "230") == 0)
return 1;
return 0;
}
static int do_classic_auth (char *username, char *password)
1998-02-27 07:54:42 +03:00
{
struct passwd *this;
int ret;
#ifdef LINUX_SHADOW
struct spwd *spw;
extern char *pw_encrypt (char *, char *);
#else
#ifdef NEED_CRYPT_PROTOTYPE
extern char *crypt (const char *, const char *);
#endif
#endif
if ((this = getpwnam (username)) == 0)
return 0;
#ifdef LINUX_SHADOW
if ((spw = getspnam (username)) == NULL)
this->pw_passwd = "*";
else
this->pw_passwd = spw->sp_pwdp;
if (strcmp (pw_encrypt (password, this->pw_passwd), this->pw_passwd) == 0)
ret = 1;
else
ret = 0;
#else
#ifdef HAVE_CRYPT
if (strcmp (crypt (password, this->pw_passwd), this->pw_passwd) == 0){
ret = 1;
} else
#endif
{
ret = 0;
}
#endif
endpwent ();
return ret;
}
#endif /* non-PAM authentication */
/* Try to authenticate the user based on:
- PAM if the system has it, else it checks:
- pwdauth if the system supports it.
- conventional auth (check salt on /etc/passwd, crypt, and compare
- try to contact the local ftp server and login (if -f flag used)
*/
static int
1998-02-27 07:54:42 +03:00
do_auth (char *username, char *password)
{
int auth = 0;
struct passwd *this;
if (strcmp (username, "anonymous") == 0)
username = "ftp";
#ifdef HAVE_PAM
if (mc_pam_auth (username, password) == 0)
auth = 1;
#else /* if there is no pam */
#ifdef HAVE_PWDAUTH
if (pwdauth (username, password) == 0)
auth = 1;
else
#endif
if (do_classic_auth (username, password))
auth = 1;
else if (ftp)
auth = do_ftp_auth (username, password);
#endif /* not pam */
if (!auth)
return 0;
this = getpwnam (username);
if (this == 0)
return 0;
if (chdir (this->pw_dir) == -1)
return 0;
if (this->pw_dir [strlen (this->pw_dir) - 1] == '/')
home_dir = g_strdup (this->pw_dir);
1998-02-27 07:54:42 +03:00
else {
home_dir = g_malloc (strlen (this->pw_dir) + 2);
1998-02-27 07:54:42 +03:00
if (home_dir) {
strcpy (home_dir, this->pw_dir);
strcat (home_dir, "/");
} else
home_dir = "/";
}
if (setgid (this->pw_gid) == -1)
return 0;
#ifdef HAVE_INITGROUPS
#ifdef NGROUPS_MAX
if (NGROUPS_MAX > 1 && initgroups (this->pw_name, this->pw_gid))
return 0;
#endif
#endif
#if defined (HAVE_SETUID)
1998-02-27 07:54:42 +03:00
if (setuid (this->pw_uid))
return 0;
#elif defined (HAVE_SETREUID)
1998-02-27 07:54:42 +03:00
if (setreuid (this->pw_uid, this->pw_uid))
return 0;
#endif
1998-02-27 07:54:42 +03:00
/* If the setuid call failed, then deny access */
/* This should fix the problem on those machines with strange setups */
if (getuid () != this->pw_uid)
return 0;
if (strcmp (username, "ftp") == 0)
chroot (this->pw_dir);
endpwent ();
return auth;
}
#if 0
static int do_rauth (int socket)
1998-02-27 07:54:42 +03:00
{
struct sockaddr_in from;
struct hostent *hp;
if (getpeername(0, (struct sockaddr *)&from, &fromlen) < 0)
return 0;
from.sin_port = ntohs ((unsigned short) from.sin_port);
/* Strange, this should not happend */
if (from.sin_family != AF_INET)
return 0;
hp = gethostbyaddr((char *)&fromp.sin_addr, sizeof (struct in_addr),
fromp.sin_family);
}
#endif
static int do_rauth (int msock)
1998-02-27 07:54:42 +03:00
{
return 0;
}
static void login_reply (int logged_in)
1998-02-27 07:54:42 +03:00
{
rpc_send (msock, RPC_INT,
logged_in ? MC_LOGINOK : MC_INVALID_PASS,
RPC_END);
}
/* FIXME: Implement the anonymous login */
static void do_login (void)
1998-02-27 07:54:42 +03:00
{
char *username;
char *password;
int result;
rpc_get (msock, RPC_LIMITED_STRING, &up_dir, RPC_LIMITED_STRING, &username, RPC_END);
if (verbose) printf ("username: %s\n", username);
if (r_auth){
logged_in = do_rauth (msock);
if (logged_in){
login_reply (logged_in);
return;
}
}
rpc_send (msock, RPC_INT, MC_NEED_PASSWORD, RPC_END);
rpc_get (msock, RPC_INT, &result, RPC_END);
if (result == MC_QUIT)
DO_QUIT_VOID ();
if (result != MC_PASS){
if (verbose) printf ("do_login: Unknown response: %d\n", result);
DO_QUIT_VOID ();
}
rpc_get (msock, RPC_LIMITED_STRING, &password, RPC_END);
logged_in = do_auth (username, password);
endpwent ();
login_reply (logged_in);
}
/* }}} */
/* {{{ Server and dispatching functions */
/* This structure must be kept in synch with mcfs.h enums */
static struct _command {
1998-02-27 07:54:42 +03:00
char *command;
void (*callback)(void);
} commands [] = {
{ "open", do_open },
{ "close", do_close },
{ "read", do_read },
{ "write", do_write },
{ "opendir", do_opendir },
{ "readdir", do_readdir },
{ "closedir", do_closedir },
{ "stat ", do_stat },
{ "lstat ", do_lstat },
{ "fstat", do_fstat },
{ "chmod", do_chmod },
{ "chown", do_chown },
{ "readlink ", do_readlink },
{ "unlink", do_unlink },
{ "rename", do_rename },
{ "chdir ", do_chdir },
{ "lseek", do_lseek },
{ "rmdir", do_rmdir },
{ "symlink", do_symlink },
{ "mknod", do_mknod },
{ "mkdir", do_mkdir },
{ "link", do_link },
{ "gethome", do_gethome },
{ "getupdir", do_getupdir },
{ "login", do_login },
{ "quit", do_quit },
{ "utime", do_utime },
};
static int ncommands = sizeof(commands)/sizeof(struct _command);
1998-02-27 07:54:42 +03:00
static void exec_command (int command)
1998-02-27 07:54:42 +03:00
{
if (command < 0 ||
command >= ncommands ||
commands [command].command == 0){
fprintf (stderr, "Got unknown command: %d\n", command);
DO_QUIT_VOID ();
}
if (verbose) printf ("Command: %s\n", commands [command].command);
(*commands [command].callback)();
}
static void check_version (void)
1998-02-27 07:54:42 +03:00
{
int version;
rpc_get (msock, RPC_INT, &version, RPC_END);
if (version >= 1 &&
version <= RPC_PROGVER)
rpc_send (msock, RPC_INT, MC_VERSION_OK, RPC_END);
else
rpc_send (msock, RPC_INT, MC_VERSION_MISMATCH, RPC_END);
clnt_version = version;
}
/* This routine is called by rpc_get/rpc_send when the connection is closed */
void tcp_invalidate_socket (int sock)
{
if (verbose) printf ("Connection closed\n");
DO_QUIT_VOID();
}
static void server (int sock)
1998-02-27 07:54:42 +03:00
{
int command;
msock = sock;
quit_server = 0;
check_version ();
do {
if (rpc_get (sock, RPC_INT, &command, RPC_END) &&
(logged_in || command == MC_LOGIN))
exec_command (command);
} while (!quit_server);
}
/* }}} */
/* {{{ Net support code */
static char *get_client (int portnum)
1998-02-27 07:54:42 +03:00
{
int sock, clilen, newsocket;
struct sockaddr_in client_address, server_address;
struct hostent *hp;
char hostname [255];
int yes = 1;
These are a bunch of changes to fix CORBA and session management. They are almost complete (i.e. to handle all nitty gritty cases), but they seem to be working OK right now. SM should be much more stable now. Please tell me if you find any weird behavior - Federico 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * gdesktop-icon.c (desktop_icon_realize): Remove the WM_CLIENT_LEADER property from icon windows so that window managers will not store SM information for them. * gnome-open-dialog.c: Added missing #includes. * gdesktop-init.c (desktop_init_at): Removed an unused variable. * gdesktop.h: Added some missing prototypes. * gmain.h: Added some missing prototypes. * Makefile.in: Added gsession.[ch] to the list of sources. * gmain.c (create_panels): Consider whether we have a CORBA server and session management. * gdesktop.c: #include "gdesktop-init.h" * gdesktop.c: Added a missing cast to GNOME_DIALOG. * gmain.c (create_panels): Removed the run_desktop global variable. * glayout.c (create_container): Set the wmclass of the panel to include its unique ID. * gsession.[ch]: New file with the functions that deal with session management. * glayout.c (gnome_exit): Use session_set_restart(). * gcorba.c (corba_init): Now returns an int with an error value. (corba_init_server): Initialize the server properly. Fixed all the object implementation code. (corba_create_window): New function used to create a window with the CORBA server. * gmain.c (gnome_check_super_user): Now the check for running as root is done here. There should be no GUI code in src/. 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * dlg.c (dlg_run_done): Do not call the callback of a NULL current widget. * setup.h: Added missing prototype for setup_init(). * filegui.c (check_progress_buttons): Added a missing return value. * dlg.c (remove_widget): Added a missing return value. * main.c: Removed the global directory_list variable. Removed the main_corba_register_server() function. * main.h: Removed the global run_desktop variable. * panel.h: Now the panel structure has a unique numerical ID used for session management. * screen.c (panel_new): Maintain a unique ID for each panel. * main.c (maybe_display_linksdir): Handle display of the desktop init dir here. (main): Call gnome_check_super_user(). (init_corba_with_args): Call corba_init_server(). * main.c (init_corba_with_args): Do CORBA initialization here. Also removed the global force_activation option. 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * vfs.c (vfs_add_current_stamps): Only do stamping of the panels if they exist. * mcserv.c: #include <sys/wait.h> (get_client): Put `#ifdef __EMX__' around an otherwise-unused variable. * utilvfs.c (vfs_split_url): Fix NULL <-> 0 confusion when comparing characters. * ftpfs.c (retrieve_dir): Removed unused variable dot_dot_found. * extfs.c (extfs_init): Assign `key' to c, not `&key'.
1999-03-30 10:09:56 +04:00
#ifdef __EMX__
1999-02-14 00:39:18 +03:00
char *me;
These are a bunch of changes to fix CORBA and session management. They are almost complete (i.e. to handle all nitty gritty cases), but they seem to be working OK right now. SM should be much more stable now. Please tell me if you find any weird behavior - Federico 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * gdesktop-icon.c (desktop_icon_realize): Remove the WM_CLIENT_LEADER property from icon windows so that window managers will not store SM information for them. * gnome-open-dialog.c: Added missing #includes. * gdesktop-init.c (desktop_init_at): Removed an unused variable. * gdesktop.h: Added some missing prototypes. * gmain.h: Added some missing prototypes. * Makefile.in: Added gsession.[ch] to the list of sources. * gmain.c (create_panels): Consider whether we have a CORBA server and session management. * gdesktop.c: #include "gdesktop-init.h" * gdesktop.c: Added a missing cast to GNOME_DIALOG. * gmain.c (create_panels): Removed the run_desktop global variable. * glayout.c (create_container): Set the wmclass of the panel to include its unique ID. * gsession.[ch]: New file with the functions that deal with session management. * glayout.c (gnome_exit): Use session_set_restart(). * gcorba.c (corba_init): Now returns an int with an error value. (corba_init_server): Initialize the server properly. Fixed all the object implementation code. (corba_create_window): New function used to create a window with the CORBA server. * gmain.c (gnome_check_super_user): Now the check for running as root is done here. There should be no GUI code in src/. 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * dlg.c (dlg_run_done): Do not call the callback of a NULL current widget. * setup.h: Added missing prototype for setup_init(). * filegui.c (check_progress_buttons): Added a missing return value. * dlg.c (remove_widget): Added a missing return value. * main.c: Removed the global directory_list variable. Removed the main_corba_register_server() function. * main.h: Removed the global run_desktop variable. * panel.h: Now the panel structure has a unique numerical ID used for session management. * screen.c (panel_new): Maintain a unique ID for each panel. * main.c (maybe_display_linksdir): Handle display of the desktop init dir here. (main): Call gnome_check_super_user(). (init_corba_with_args): Call corba_init_server(). * main.c (init_corba_with_args): Do CORBA initialization here. Also removed the global force_activation option. 1999-03-30 Federico Mena Quintero <federico@nuclecu.unam.mx> * vfs.c (vfs_add_current_stamps): Only do stamping of the panels if they exist. * mcserv.c: #include <sys/wait.h> (get_client): Put `#ifdef __EMX__' around an otherwise-unused variable. * utilvfs.c (vfs_split_url): Fix NULL <-> 0 confusion when comparing characters. * ftpfs.c (retrieve_dir): Removed unused variable dot_dot_found. * extfs.c (extfs_init): Assign `key' to c, not `&key'.
1999-03-30 10:09:56 +04:00
#endif
1998-02-27 07:54:42 +03:00
if ((sock = socket (AF_INET, SOCK_STREAM, 0)) < 0)
return "Can't create socket";
/* Use this to debug: */
if (setsockopt (sock, SOL_SOCKET, SO_REUSEADDR, (char *) &yes, sizeof (yes)) < 0)
return "setsockopt failed";
gethostname (hostname, 255);
if (verbose) printf ("hostname=%s\n", hostname);
hp = gethostbyname (hostname);
1999-02-14 00:39:18 +03:00
#ifdef __EMX__
if (hp == 0 && (me = getenv("HOSTNAME")) && (0 == strcmp(hostname, me)))
hp = gethostbyname ("localhost");
#endif
1998-02-27 07:54:42 +03:00
if (hp == 0)
return "hp = 0!";
bzero ((char *) &server_address, sizeof (server_address));
server_address.sin_family = hp->h_addrtype;
server_address.sin_addr.s_addr = htonl (INADDR_ANY);
server_address.sin_port = htons (portnum);
if (bind (sock, (struct sockaddr *) &server_address,
sizeof (server_address)) < 0)
return "Can't bind";
listen (sock, 5);
for (;;){
int child;
clilen = sizeof (client_address);
newsocket = accept (sock, (struct sockaddr *) &client_address,
&clilen);
if (isDaemon && (child = fork())) {
int status;
close (newsocket);
waitpid (child, &status, 0);
continue;
}
if (isDaemon && fork()) exit (0);
server (newsocket);
close (newsocket);
return 0;
}
}
#ifdef HAVE_PMAP_SET
static void signal_int_handler (int sig)
1998-02-27 07:54:42 +03:00
{
pmap_unset (RPC_PROGNUM, RPC_PROGVER);
}
#endif
#ifndef IPPORT_RESERVED
#define IPPORT_RESERVED 1024;
#endif
static int get_port_number (void)
1998-02-27 07:54:42 +03:00
{
int port = 0;
#ifdef HAVE_RRESVPORT
int start_port = IPPORT_RESERVED;
port = rresvport (&start_port);
if (port == -1){
if (geteuid () == 0){
fprintf (stderr, "Could not bind the server on a reserved port\n");
DO_QUIT_NONVOID (-1);
}
port = 0;
}
#endif
if (port)
return port;
port = mcserver_port;
return port;
}
static void register_port (int portnum, int abort_if_fail)
1998-02-27 07:54:42 +03:00
{
#ifdef HAVE_PMAP_SET
/* Register our service with the portmapper */
/* protocol: pmap_set (prognum, versnum, protocol, portp) */
if (pmap_set (RPC_PROGNUM, RPC_PROGVER, IPPROTO_TCP, portnum))
signal (SIGINT, signal_int_handler);
else {
fprintf (stderr, "Could not register service with portmapper\n");
if (abort_if_fail)
exit (1);
}
#else
if (abort_if_fail){
fprintf (stderr,
"This system lacks port registration, try using the -p\n"
"flag to force installation at a given port");
}
#endif
}
/* }}} */
int main (int argc, char *argv [])
{
char *result;
extern char *optarg;
int c;
while ((c = getopt (argc, argv, "fdiqp:v")) != -1){
switch (c){
case 'd':
isDaemon = 1;
verbose = 0;
break;
case 'v':
verbose = 1;
break;
case 'f':
ftp = 1;
break;
case 'q':
verbose = 0;
break;
case 'p':
portnum = atoi (optarg);
break;
case 'i':
inetd_started = 1;
break;
case 'r':
r_auth = 1;
break;
default:
fprintf (stderr, "Usage is: mcserv [options] [-p portnum]\n\n"
"options are:\n"
"-d become a daemon (sets -q)\n"
"-q quiet mode\n"
/* "-r use rhost based authentication\n" */
#ifndef HAVE_PAM
"-f force ftp authentication\n"
#endif
"-v verbose mode\n"
"-p to specify a port number to listen\n");
exit (0);
}
}
if (isDaemon && fork()) exit (0);
if (portnum == 0)
portnum = get_port_number ();
if (portnum != -1) {
register_port (portnum, 0);
if (verbose)
printf ("Using port %d\n", portnum);
if ((result = get_client (portnum)))
perror (result);
#ifdef HAVE_PMAP_SET
if (!isDaemon)
pmap_unset (RPC_PROGNUM, RPC_PROGVER);
#endif
}
exit (return_code);
}
/* FIXME: This function should not be used in mcserv */
void vfs_die( char *m )
1998-02-27 07:54:42 +03:00
{
fprintf (stderr, m);
exit (1);
}