•  About 
•  Changelog 
•  Documentation 
•  Download 
•  R.A.Q 
•         
• 

Documentation Generated on Thu Aug 31 00:02:31 2006
Commands.cpp File Reference #include "Commands.h" Include dependency graph for Commands.cpp: Go to the source code of this file. Defines #define  COMMANDS_CPP #define  NETINCLS #define  BABY_CORE Functions void *  data_wrapper (void *void_data) int  pam_conversate (int num_msg, const struct pam_message **msg, struct pam_response **resp, void *appdata_ptr) Variables Commands  comm Define Documentation #define BABY_CORE Definition at line 12 of file Commands.cpp. #define COMMANDS_CPP Definition at line 10 of file Commands.cpp. #define NETINCLS Definition at line 11 of file Commands.cpp. Function Documentation void* data_wrapper ( void *  void_data  )  Definition at line 17 of file Commands.cpp. References Connection::addr(), ANONYMOUS, BINARY, config, Connection::engage_tls(), Connection::host_name(), Utilities::itos(), Log::log_this(), Configuration::logger, logging, my_data, Connection::packet_size(), PWBUF_SIZE, Connection::receive(), RETR_TRANS, Connection::send(), Connection::settings(), Connection::thread_id(), Utilities::time_string(), TLS_PROT_D, TYPE_DEBUG, TYPE_XFER, Data::user, Connection::user_name(), util, and log_stru::xferlog. Referenced by Commands::retr(), and Commands::stor(). { class Data *data = static_cast<class Data*>(void_data); string message; time_t start_time = time(NULL); size_t trans_size = 0; // will hold the total number of sent bytes data->thread_id(pthread_self()); pthread_setspecific(my_data, void_data); pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL); data->host_name(inet_ntoa(data->addr().sin_addr)); // I don't like it, but we need to drop permissions again... // not true for new threads, need to look deeper into this. struct passwd pwd, *pwd_ptr; char pwdata[PWBUF_SIZE]; getpwnam_r(data->user->user_name().c_str(), &pwd, pwdata, sizeof(pwdata), &pwd_ptr); uid_t uid = pwd.pw_uid; gid_t gid = pwd.pw_gid; setuid(uid); setgid(gid); #ifdef USE_TLS // handshakes etc if(data->settings(TLS_PROT_D)) if(!data->engage_tls()) // failed handshake message = "451 Failed to negotiate TLS as was asked. Closing data connection."; #endif // USE_TLS while(message.empty()) { char *read_buf = new char[data->packet_size()]; size_t size = 0, size2 = 0; if(data->settings(RETR_TRANS)) { size2 = read(data->file_id(), read_buf, data->packet_size()); if(size2 > 0) size = data->send(read_buf, size2); } else // STOR_STRANS size = data->receive(read_buf, data->packet_size() - 1); trans_size += size; if(!data->settings(RETR_TRANS)) { if(size != 0 && (write(data->file_id(), read_buf, size) == -1)) { logging->log_this(3, TYPE_DEBUG, "Write failed to file: " + data->file_name() + " from host: " + data->host_name() + " with error %m"); message = "451 File transfer failed."; } else if(size == 0) { if(close(data->file_id()) != 0) message = "550 Failed saving file."; else message = "226 Transfer complete."; } } else // RETR_TRANS { if(size != size2) message = "550 Transfer failed."; else if(size2 != data->packet_size()) message = "226 Transfer complete."; } delete[] read_buf; } *data->user << message << "\r\n"; if(config->logger.xferlog) { string time_string; util.time_string(time_string, "%a %b %d %H:%M:%S %Y "); // as ' ' separates fields in the xferlog we convert them to '_' here string temp_name = data->file_name(); for(string::iterator name_it = temp_name.begin(); name_it != temp_name.end(); name_it++) if(isspace(*name_it)) *name_it = '_'; // let us build a string! string xferlog = time_string; xferlog += util.itos(time(NULL) - start_time); xferlog += " " + data->host_name(); xferlog += " " + util.itos(trans_size); xferlog += " " + temp_name + " "; xferlog += (data->settings(BINARY)?"b":"a"); xferlog += " _ "; // we don't support any special-action to flag here. xferlog += (data->settings(RETR_TRANS)?"o":"i"); xferlog += (data->user->settings(ANONYMOUS)? // a for anonymous, r for real " a " + data->user->anonymous_id(): // if the user is anonymous we log " r " + data->user->user_name()); // the id string, else the user name. xferlog += " FTP"; // maybe ftps for encrypted? no. IANA. xferlog += " 0"; // there should be more auth methods available here? xferlog += " *"; // or should this be uid? logging->log_this(1, TYPE_XFER, xferlog); } pthread_exit(NULL); } Here is the call graph for this function: int pam_conversate ( int  num_msg, const struct pam_message **  msg, struct pam_response **  resp, void *  appdata_ptr   ) Definition at line 171 of file Commands.cpp. References pam_data::password, and pam_data::user_name. Referenced by Commands::pass(). { struct pam_response *reply = NULL; int count = 0; struct pam_data *auth_data = (static_cast<struct pam_data*>(appdata_ptr)); for(int i = 0; i < num_msg; i++) { struct pam_response *reply_tmp; switch(msg[i]->msg_style) { case PAM_PROMPT_ECHO_ON: case PAM_PROMPT_ECHO_OFF: reply_tmp = (static_cast<struct pam_response*> (malloc(sizeof(struct pam_response) * (count + 1)))); memcpy(reply_tmp, reply, count); if(reply) free(reply); reply = reply_tmp; // is this really how it should be done? if(msg[i]->msg_style == PAM_PROMPT_ECHO_ON) reply[i].resp = strndup(auth_data->user_name.c_str(), auth_data->user_name.size()); else reply[i].resp = strndup(auth_data->password.c_str(), auth_data->password.size()); reply[count++].resp_retcode = PAM_SUCCESS; break; case PAM_TEXT_INFO: break; case PAM_ERROR_MSG: default: if(reply) free(reply); return PAM_CONV_ERR; } } *resp = reply; return PAM_SUCCESS; } Variable Documentation class Commands comm Definition at line 15 of file Commands.cpp. Referenced by exit_baby(), Handler::interpreter(), main(), Commands::pass(), and User::~User().

• Copyright © 2005, BabyFTPd

• Powered by:
• 
• 
•