自学教程：C++ vmprintf函数代码示例

voidVirshType::Config(){	char *config_value = NULL;	config_value = param("VM_NETWORKING_BRIDGE_INTERFACE");	if( config_value ) {		m_vm_bridge_interface = delete_quotation_marks(config_value).Value();		free(config_value);	} else if( vmgahp->m_gahp_config->m_vm_networking_types.contains("bridge") == true) {		vmprintf( D_ALWAYS, "ERROR: 'VM_NETWORKING_TYPE' contains "				"'bridge' but VM_NETWORKING_BRIDGE_INTERFACE "				"isn't defined, so 'bridge' "				"networking is disabled/n");		vmgahp->m_gahp_config->m_vm_networking_types.remove("bridge");		if( vmgahp->m_gahp_config->m_vm_networking_types.isEmpty() ) {			vmprintf( D_ALWAYS, "ERROR: 'VM_NETWORKING' is true "					"but 'VM_NETWORKING_TYPE' contains "					"no valid entries, so 'VM_NETWORKING' "					"is disabled/n");			vmgahp->m_gahp_config->m_vm_networking = false;		} else {			vmprintf( D_ALWAYS,					"Setting default networking type to 'nat'/n");			vmgahp->m_gahp_config->m_vm_default_networking_type = "nat";		}	}}

intVMGahp::waitForCommand(int   /*pipe_end*/){	MyString *line = NULL;	while((line = m_request_buffer.GetNextLine()) != NULL) {		const char *command = line->Value();		Gahp_Args args;		VMRequest *new_req = NULL;		if( m_inClassAd )  {			if( strcasecmp(command, VMGAHP_COMMAND_CLASSAD_END) == 0 ) {				m_inClassAd = false;				// Everything is Ok. Now we got vmClassAd				returnOutputSuccess();			}else {				if( !m_jobAd->Insert(command) ) {					vmprintf(D_ALWAYS, "Failed to insert /"%s/" into classAd, "							"ignoring this attribute/n", command);				}			}		}else {			if(parse_vmgahp_command(command, args) &&					verifyCommand(args.argv, args.argc)) {				new_req = preExecuteCommand(command, &args);				if( new_req != NULL ) {					// Execute the new request					executeCommand(new_req);					if(new_req->m_has_result) {						movePendingReqToResultList(new_req);						if (m_async_mode) {							if (!m_new_results_signaled) {								write_to_daemoncore_pipe("R/n");							}							// So that we only do it once							m_new_results_signaled = true;						}					}				}			}else {				returnOutputError();			}		}		delete line;		line = NULL;	}	// check if GetNextLine() returned NULL because of an error or EOF	if(m_request_buffer.IsError() || m_request_buffer.IsEOF()) {		vmprintf(D_ALWAYS, "Request buffer closed, exiting/n");		cleanUp();		DC_Exit(0);	}	return true;}

boolVirshType::ResumeFromSoftSuspend(void){	vmprintf(D_FULLDEBUG, "Inside VirshType::ResumeFromSoftSuspend/n");	if( (m_configfile.Length() == 0)) {		return false;	}	if( m_is_soft_suspended ) {		priv_state priv = set_root_priv();		virDomainPtr dom = virDomainLookupByName(m_libvirt_connection, m_vm_name.Value());		set_priv(priv);		if(dom == NULL)		  {		    virErrorPtr err = virConnGetLastError(m_libvirt_connection);		    vmprintf(D_ALWAYS, "Error finding domain %s: %s/n", m_vm_name.Value(), (err ? err->message : "No reason found"));		    return false;		  }		priv = set_root_priv();		int result = virDomainResume(dom);		virDomainFree(dom);		set_priv(priv);		if( result != 0 ) {			// unpause failed.			vmprintf(D_ALWAYS, "Unpausing VM failed in "					"VirshType::ResumeFromSoftSuspend/n");			return false;		}		m_is_soft_suspended = false;	}	return true;}

voidVMGahp::executeCheckpoint(VMRequest *req){	// Expecting: VMGAHP_COMMAND_VM_CHECKPOINT <req_id> <vmid>	int vm_id = strtol(req->m_args.argv[2],(char **)NULL, 10);	MyString err_message;	VMType *vm = findVM(vm_id);	if(vm == NULL) {		req->m_has_result = true;		req->m_is_success = false;		req->m_result = VMGAHP_ERR_VM_NOT_FOUND;		vmprintf(D_FULLDEBUG, "VM(id=%d) is not found in executeCheckpoint/n",					vm_id);		return;	}else {		int result = vm->Checkpoint();		if(result == false) {			req->m_has_result = true;			req->m_is_success = false;			req->m_result = makeErrorMessage(vm->m_result_msg.Value());			vmprintf(D_FULLDEBUG, "executeCheckpoint fail!/n");			return;		} else {			req->m_has_result = true;			req->m_is_success = true;			req->m_result = "";			vmprintf(D_FULLDEBUG, "executeCheckpoint success!/n");			return;		}	}}

voidVMGahp::killAllProcess(){	if( !m_jobAd ) {		// Virtual machine is absolutely not created.		return;	}#if defined (HAVE_EXT_LIBVIRT) && !defined(VMWARE_ONLY)	if( strcasecmp(m_gahp_config->m_vm_type.Value(),				CONDOR_VM_UNIVERSE_XEN ) == 0 ) {		priv_state priv = set_root_priv();		if( m_jobAd && XenType::checkXenParams(m_gahp_config) ) {			MyString vmname;			if( VMType::createVMName(m_jobAd, vmname) ) {				XenType::killVMFast(vmname.Value());				vmprintf( D_FULLDEBUG, "killVMFast is called/n");			}		}		set_priv(priv);	} else if(strcasecmp(m_gahp_config->m_vm_type.Value(),			     CONDOR_VM_UNIVERSE_KVM ) == 0 ) {		priv_state priv = set_root_priv();		if( m_jobAd && KVMType::checkXenParams(m_gahp_config) ) {			MyString vmname;			if( VMType::createVMName(m_jobAd, vmname) ) {				KVMType::killVMFast(vmname.Value());				vmprintf( D_FULLDEBUG, "killVMFast is called/n");			}		}		set_priv(priv);	} else#endif	if( strcasecmp(m_gahp_config->m_vm_type.Value(),				CONDOR_VM_UNIVERSE_VMWARE ) == 0 ) {		priv_state priv = set_user_priv();		if( VMwareType::checkVMwareParams(m_gahp_config) ) {			VMwareType::killVMFast(m_gahp_config->m_prog_for_script.Value(),					m_gahp_config->m_vm_script.Value(), m_workingdir.Value());			vmprintf( D_FULLDEBUG, "killVMFast is called/n");		}		set_priv(priv);	}	// [PRAGMA] Kill Rocks VM Process	else if( strcasecmp(m_gahp_config->m_vm_type.Value(),					CONDOR_VM_UNIVERSE_VMWARE ) == 0 ) {			priv_state priv = set_user_priv();			if( RocksType::checkRocksParams(m_gahp_config) ) {				RocksType::killVMFast(m_gahp_config->m_prog_for_script.Value(),						m_gahp_config->m_vm_script.Value(), m_workingdir.Value());				vmprintf( D_FULLDEBUG, "killVMFast is called/n");			}			set_priv(priv);		}}

boolVMType::createConfigUsingScript(const char* configfile){	vmprintf(D_FULLDEBUG, "Inside VMType::createConfigUsingScript/n");	if( !configfile || m_scriptname.IsEmpty() ) {		return false;	}	// Set temporary environments for script program	StringList name_list;	const char *name;	ExprTree* expr = NULL;	m_classAd.ResetExpr();	while( m_classAd.NextExpr(name, expr) ) {		if( !strncasecmp( name, "JobVM", strlen("JobVM") ) ||			!strncasecmp( name, "VMPARAM", strlen("VMPARAM") )) {			name_list.append(name);			SetEnv(name, ExprTreeToString(expr));		}	}	ArgList systemcmd;	if( m_prog_for_script.IsEmpty() == false ) {		systemcmd.AppendArg(m_prog_for_script);	}	systemcmd.AppendArg(m_scriptname);	systemcmd.AppendArg("createconfig");	systemcmd.AppendArg(configfile);	int result = systemCommand(systemcmd, m_file_owner);	// UnSet temporary environments for script program	const char *tmp_name = NULL;	name_list.rewind();	while( (tmp_name = name_list.next()) != NULL ) {		UnsetEnv(tmp_name);	}	if( result != 0 ) {		vmprintf(D_ALWAYS, "Failed to create Configuration file('%s') using "				"script program('%s')/n", configfile, 				m_scriptname.Value());		return false;	}	return true;}

/*** Set the socket error message.*/void socket_set_errmsg(const char *zFormat, ...){  va_list ap;  socket_clear_errmsg();  va_start(ap, zFormat);  socketErrMsg = vmprintf(zFormat, ap);  va_end(ap);}

voidVMGahp::executeCommand(VMRequest *req){	char *command = req->m_args.argv[0];	priv_state priv = set_user_priv();	if(strcasecmp(command, VMGAHP_COMMAND_VM_START) == 0 ) {		executeStart(req);	} else if(strcasecmp(command, VMGAHP_COMMAND_VM_STOP) == 0 ) {		executeStop(req);	} else if(strcasecmp(command, VMGAHP_COMMAND_VM_SUSPEND) == 0 ) {		executeSuspend(req);	} else if(strcasecmp(command, VMGAHP_COMMAND_VM_SOFT_SUSPEND) == 0 ) {		executeSoftSuspend(req);	} else if(strcasecmp(command, VMGAHP_COMMAND_VM_RESUME) == 0 ) {		executeResume(req);	} else if(strcasecmp(command, VMGAHP_COMMAND_VM_CHECKPOINT) == 0 ) {		executeCheckpoint(req);	} else if(strcasecmp(command, VMGAHP_COMMAND_VM_STATUS) == 0 ) {		executeStatus(req);	} else if(strcasecmp(command, VMGAHP_COMMAND_VM_GETPID) == 0 ) {		executeGetpid(req);	} else {		vmprintf(D_ALWAYS, "Unknown command(%s)/n", command);	}	set_priv(priv);}

// check if a file was transferred.// if so, fullname will have full path in working directory.// Otherwise, fullname will be same to file_namebool VMType::isTransferedFile(const char* file_name, MyString& fullname) {	if( !file_name || m_initial_working_files.isEmpty() ) {		return false;	}	// check if this file was transferred.	MyString tmp_fullname;	if( filelist_contains_file(file_name,				&m_initial_working_files, true) ) {		// this file was transferred.		// make full path with workingdir		tmp_fullname.formatstr("%s%c%s", m_workingpath.Value(), 				DIR_DELIM_CHAR, condor_basename(file_name));		fullname = tmp_fullname;		return true;	}else {		// this file is not transferred		if( fullpath(file_name) == false ) {			vmprintf(D_ALWAYS, "Warning: The file(%s) doesn't have "					"full path even though it is not "					"transferred/n", file_name);		}		fullname = file_name;		return false;	}	return false;}

// Check whether the given vmtype is in supported vmtype listbool verify_vm_type(const char *vmtype){	//[PRAGMA] print verify_vm_type process.	vmprintf(D_ALWAYS, "[PRAGMA] verify_vm_type/n"); //[PRAGMA]	int i=0;	while(support_vms_list[i] != NULL) {		//[PRAGMA] print supported vm type.		vmprintf(D_ALWAYS, "[PRAGMA] supported VM TYPE(%s)/n", support_vms_list[i]); //[PRAGMA] vmprintf all vm types		if(strcasecmp(vmtype, support_vms_list[i]) == 0 ) {			return true;		}		i++;	}	vmprintf(D_ALWAYS, "Not supported VM TYPE(%s)/n", vmtype);	return false;}

/*** Generate <form method="post" action=ARG>.  The ARG value is inserted** by javascript.*/void form_begin(const char *zOtherArgs, const char *zAction, ...){  char *zLink;  va_list ap;  if( zOtherArgs==0 ) zOtherArgs = "";  va_start(ap, zAction);  zLink = vmprintf(zAction, ap);  va_end(ap);  if( g.perm.Hyperlink && !g.javascriptHyperlink ){    @ <form method="POST" action="%z(zLink)" %s(zOtherArgs)>  }else{

/* * Just so that we can get out of the habit of using "goto". */void virshIOError(const char * filename, FILE * fp){	vmprintf(D_ALWAYS, "failed to fprintf in CreateVirshConfigFile(%s:%s)/n",			filename, strerror(errno));	if( fp ) {		fclose(fp);	}	unlink(filename);}

boolVMGahp::verify_request_id(const char *s){	if( verify_digit_arg(s) == false) {		return false;	}	int req_id = (int)strtol(s, (char **)NULL, 10);	if( req_id <= 0 ) {		vmprintf(D_ALWAYS, "Invalid Request id(%s)/n", s);		return false;	}	// check duplicated req_id	if( findPendingRequest(req_id) != NULL ) {		vmprintf(D_ALWAYS, "Request id(%s) is conflict with "						"the existing one/n", s);		return false;	}	return true;}

static char*mprintf(const char *fmt, ...){    va_list ap;    char *s;    va_start(ap, fmt);    s = vmprintf(fmt, ap);    va_end(ap);    return s;}