VirtualBox

source: vbox/trunk/src/VBox/Main/src-client/GuestDirectoryImpl.cpp@ 58449

Last change on this file since 58449 was 57358, checked in by vboxsync, 9 years ago

*: scm cleanup run.
  • Property svn:eol-style set to native
  • Property svn:keywords set to Author Date Id Revision
File size: 11.9 KB
Line 
1/* $Id: GuestDirectoryImpl.cpp 57358 2015-08-14 15:16:38Z vboxsync $ */
2/** @file
3 * VirtualBox Main - Guest directory handling.
4 */
5
6/*
7 * Copyright (C) 2012-2015 Oracle Corporation
8 *
9 * This file is part of VirtualBox Open Source Edition (OSE), as
10 * available from http://www.virtualbox.org. This file is free software;
11 * you can redistribute it and/or modify it under the terms of the GNU
12 * General Public License (GPL) as published by the Free Software
13 * Foundation, in version 2 as it comes in the "COPYING" file of the
14 * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
15 * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
16 */
17
18
19/*********************************************************************************************************************************
20* Header Files *
21*********************************************************************************************************************************/
22#ifndef VBOX_WITH_GUEST_CONTROL
23# error "VBOX_WITH_GUEST_CONTROL must defined in this file"
24#endif
25#include "GuestDirectoryImpl.h"
26#include "GuestSessionImpl.h"
27#include "GuestCtrlImplPrivate.h"
28
29#include "Global.h"
30#include "AutoCaller.h"
31
32#include <VBox/com/array.h>
33
34#ifdef LOG_GROUP
35 #undef LOG_GROUP
36#endif
37#define LOG_GROUP LOG_GROUP_GUEST_CONTROL
38#include <VBox/log.h>
39
40
41// constructor / destructor
42/////////////////////////////////////////////////////////////////////////////
43
44DEFINE_EMPTY_CTOR_DTOR(GuestDirectory)
45
46HRESULT GuestDirectory::FinalConstruct(void)
47{
48 LogFlowThisFunc(("\n"));
49 return BaseFinalConstruct();
50}
51
52void GuestDirectory::FinalRelease(void)
53{
54 LogFlowThisFuncEnter();
55 uninit();
56 BaseFinalRelease();
57 LogFlowThisFuncLeave();
58}
59
60// public initializer/uninitializer for internal purposes only
61/////////////////////////////////////////////////////////////////////////////
62
63int GuestDirectory::init(Console *pConsole, GuestSession *pSession,
64 ULONG uDirID, const GuestDirectoryOpenInfo &openInfo)
65{
66 LogFlowThisFunc(("pConsole=%p, pSession=%p, uDirID=%RU32, strPath=%s, strFilter=%s, uFlags=%x\n",
67 pConsole, pSession, uDirID, openInfo.mPath.c_str(), openInfo.mFilter.c_str(),
68 openInfo.mFlags));
69
70 AssertPtrReturn(pConsole, VERR_INVALID_POINTER);
71 AssertPtrReturn(pSession, VERR_INVALID_POINTER);
72
73 /* Enclose the state transition NotReady->InInit->Ready. */
74 AutoInitSpan autoInitSpan(this);
75 AssertReturn(autoInitSpan.isOk(), E_FAIL);
76
77 int vrc = bindToSession(pConsole, pSession, uDirID /* Object ID */);
78 if (RT_SUCCESS(vrc))
79 {
80 mSession = pSession;
81
82 mData.mID = uDirID;
83 mData.mOpenInfo = openInfo;
84 }
85
86 if (RT_SUCCESS(vrc))
87 {
88 /* Start the directory process on the guest. */
89 GuestProcessStartupInfo procInfo;
90 procInfo.mName = Utf8StrFmt(tr("Reading directory \"%s\""), openInfo.mPath.c_str());
91 procInfo.mTimeoutMS = 5 * 60 * 1000; /* 5 minutes timeout. */
92 procInfo.mFlags = ProcessCreateFlag_WaitForStdOut;
93 procInfo.mExecutable= Utf8Str(VBOXSERVICE_TOOL_LS);
94
95 procInfo.mArguments.push_back(procInfo.mExecutable);
96 procInfo.mArguments.push_back(Utf8Str("--machinereadable"));
97 /* We want the long output format which contains all the object details. */
98 procInfo.mArguments.push_back(Utf8Str("-l"));
99#if 0 /* Flags are not supported yet. */
100 if (uFlags & DirectoryOpenFlag_NoSymlinks)
101 procInfo.mArguments.push_back(Utf8Str("--nosymlinks")); /** @todo What does GNU here? */
102#endif
103 /** @todo Recursion support? */
104 procInfo.mArguments.push_back(openInfo.mPath); /* The directory we want to open. */
105
106 /*
107 * Start the process asynchronously and keep it around so that we can use
108 * it later in subsequent read() calls.
109 * Note: No guest rc available because operation is asynchronous.
110 */
111 vrc = mData.mProcessTool.Init(mSession, procInfo,
112 true /* Async */, NULL /* Guest rc */);
113 }
114
115 if (RT_SUCCESS(vrc))
116 {
117 /* Confirm a successful initialization when it's the case. */
118 autoInitSpan.setSucceeded();
119 return vrc;
120 }
121 else
122 autoInitSpan.setFailed();
123
124 return vrc;
125}
126
127/**
128 * Uninitializes the instance.
129 * Called from FinalRelease().
130 */
131void GuestDirectory::uninit(void)
132{
133 LogFlowThisFuncEnter();
134
135 /* Enclose the state transition Ready->InUninit->NotReady. */
136 AutoUninitSpan autoUninitSpan(this);
137 if (autoUninitSpan.uninitDone())
138 return;
139
140 LogFlowThisFuncLeave();
141}
142
143// implementation of private wrapped getters/setters for attributes
144/////////////////////////////////////////////////////////////////////////////
145
146HRESULT GuestDirectory::getDirectoryName(com::Utf8Str &aDirectoryName)
147{
148 LogFlowThisFuncEnter();
149
150 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
151
152 aDirectoryName = mData.mOpenInfo.mPath;
153
154 return S_OK;
155}
156
157HRESULT GuestDirectory::getFilter(com::Utf8Str &aFilter)
158{
159 LogFlowThisFuncEnter();
160
161 AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
162
163 aFilter = mData.mOpenInfo.mFilter;
164
165 return S_OK;
166}
167
168// private methods
169/////////////////////////////////////////////////////////////////////////////
170
171int GuestDirectory::i_callbackDispatcher(PVBOXGUESTCTRLHOSTCBCTX pCbCtx, PVBOXGUESTCTRLHOSTCALLBACK pSvcCb)
172{
173 AssertPtrReturn(pCbCtx, VERR_INVALID_POINTER);
174 AssertPtrReturn(pSvcCb, VERR_INVALID_POINTER);
175
176 LogFlowThisFunc(("strPath=%s, uContextID=%RU32, uFunction=%RU32, pSvcCb=%p\n",
177 mData.mOpenInfo.mPath.c_str(), pCbCtx->uContextID, pCbCtx->uFunction, pSvcCb));
178
179 int vrc;
180 switch (pCbCtx->uFunction)
181 {
182 case GUEST_DIR_NOTIFY:
183 {
184 int idx = 1; /* Current parameter index. */
185 CALLBACKDATA_DIR_NOTIFY dataCb;
186 /* pSvcCb->mpaParms[0] always contains the context ID. */
187 pSvcCb->mpaParms[idx++].getUInt32(&dataCb.uType);
188 pSvcCb->mpaParms[idx++].getUInt32(&dataCb.rc);
189
190 int guestRc = (int)dataCb.rc; /* uint32_t vs. int. */
191
192 LogFlowFunc(("uType=%RU32, guestRc=%Rrc\n",
193 dataCb.uType, guestRc));
194
195 switch (dataCb.uType)
196 {
197 /* Nothing here yet, nothing to dispatch further. */
198
199 default:
200 vrc = VERR_NOT_SUPPORTED;
201 break;
202 }
203 break;
204 }
205
206 default:
207 /* Silently ignore not implemented functions. */
208 vrc = VERR_NOT_SUPPORTED;
209 break;
210 }
211
212#ifdef DEBUG
213 LogFlowFuncLeaveRC(vrc);
214#endif
215 return vrc;
216}
217
218/* static */
219Utf8Str GuestDirectory::i_guestErrorToString(int guestRc)
220{
221 Utf8Str strError;
222
223 /** @todo pData->u32Flags: int vs. uint32 -- IPRT errors are *negative* !!! */
224 switch (guestRc)
225 {
226 case VERR_DIR_NOT_EMPTY:
227 strError += Utf8StrFmt("Directoy is not empty");
228 break;
229
230 default:
231 strError += Utf8StrFmt("%Rrc", guestRc);
232 break;
233 }
234
235 return strError;
236}
237
238/**
239 * Called by IGuestSession right before this directory gets
240 * removed from the public directory list.
241 */
242int GuestDirectory::i_onRemove(void)
243{
244 LogFlowThisFuncEnter();
245
246 int vrc = VINF_SUCCESS;
247
248 LogFlowFuncLeaveRC(vrc);
249 return vrc;
250}
251
252/* static */
253HRESULT GuestDirectory::i_setErrorExternal(VirtualBoxBase *pInterface, int guestRc)
254{
255 AssertPtr(pInterface);
256 AssertMsg(RT_FAILURE(guestRc), ("Guest rc does not indicate a failure when setting error\n"));
257
258 return pInterface->setError(VBOX_E_IPRT_ERROR, GuestDirectory::i_guestErrorToString(guestRc).c_str());
259}
260
261// implementation of public methods
262/////////////////////////////////////////////////////////////////////////////
263HRESULT GuestDirectory::close()
264{
265 LogFlowThisFuncEnter();
266
267 AutoCaller autoCaller(this);
268 if (FAILED(autoCaller.rc())) return autoCaller.rc();
269
270 HRESULT hr = S_OK;
271
272 int guestRc;
273 int rc = mData.mProcessTool.i_terminate(30 * 1000, &guestRc);
274 if (RT_FAILURE(rc))
275 {
276 switch (rc)
277 {
278 case VERR_GSTCTL_GUEST_ERROR:
279 hr = GuestProcess::i_setErrorExternal(this, guestRc);
280 break;
281
282 case VERR_NOT_SUPPORTED:
283 /* Silently skip old Guest Additions which do not support killing the
284 * the guest directory handling process. */
285 break;
286
287 default:
288 hr = setError(VBOX_E_IPRT_ERROR,
289 tr("Terminating open guest directory \"%s\" failed: %Rrc"),
290 mData.mOpenInfo.mPath.c_str(), rc);
291 break;
292 }
293 }
294
295 AssertPtr(mSession);
296 int rc2 = mSession->i_directoryRemoveFromList(this);
297 if (RT_SUCCESS(rc))
298 rc = rc2;
299
300 LogFlowThisFunc(("Returning rc=%Rrc\n", rc));
301 return hr;
302}
303
304HRESULT GuestDirectory::read(ComPtr<IFsObjInfo> &aObjInfo)
305{
306 LogFlowThisFuncEnter();
307
308 AutoCaller autoCaller(this);
309 if (FAILED(autoCaller.rc())) return autoCaller.rc();
310
311 GuestProcessStreamBlock curBlock;
312 int guestRc;
313
314 int rc = mData.mProcessTool.i_waitEx(GUESTPROCESSTOOL_FLAG_STDOUT_BLOCK,
315 &curBlock, &guestRc);
316
317 /*
318 * Note: The guest process can still be around to serve the next
319 * upcoming stream block next time.
320 */
321 if ( RT_SUCCESS(rc)
322 && !mData.mProcessTool.i_isRunning())
323 {
324 rc = mData.mProcessTool.i_terminatedOk(NULL /* Exit code */);
325 if (rc == VERR_NOT_EQUAL)
326 rc = VERR_ACCESS_DENIED;
327 }
328
329 if (RT_SUCCESS(rc))
330 {
331 if (curBlock.GetCount()) /* Did we get content? */
332 {
333 GuestFsObjData objData;
334 rc = objData.FromLs(curBlock);
335 if (RT_FAILURE(rc))
336 rc = VERR_PATH_NOT_FOUND;
337
338 if (RT_SUCCESS(rc))
339 {
340 /* Create the object. */
341 ComObjPtr<GuestFsObjInfo> pFsObjInfo;
342 HRESULT hr2 = pFsObjInfo.createObject();
343 if (FAILED(hr2))
344 rc = VERR_COM_UNEXPECTED;
345
346 if (RT_SUCCESS(rc))
347 rc = pFsObjInfo->init(objData);
348
349 if (RT_SUCCESS(rc))
350 {
351 /* Return info object to the caller. */
352 hr2 = pFsObjInfo.queryInterfaceTo(aObjInfo.asOutParam());
353 if (FAILED(hr2))
354 rc = VERR_COM_UNEXPECTED;
355 }
356 }
357 }
358 else
359 {
360 /* Nothing to read anymore. Tell the caller. */
361 rc = VERR_NO_MORE_FILES;
362 }
363 }
364
365 HRESULT hr = S_OK;
366
367 if (RT_FAILURE(rc)) /** @todo Add more errors here. */
368 {
369 switch (rc)
370 {
371 case VERR_GSTCTL_GUEST_ERROR:
372 hr = GuestProcess::i_setErrorExternal(this, guestRc);
373 break;
374
375 case VERR_ACCESS_DENIED:
376 hr = setError(VBOX_E_IPRT_ERROR, tr("Reading directory \"%s\" failed: Unable to read / access denied"),
377 mData.mOpenInfo.mPath.c_str());
378 break;
379
380 case VERR_PATH_NOT_FOUND:
381 hr = setError(VBOX_E_IPRT_ERROR, tr("Reading directory \"%s\" failed: Path not found"),
382 mData.mOpenInfo.mPath.c_str());
383 break;
384
385 case VERR_NO_MORE_FILES:
386 /* See SDK reference. */
387 hr = setError(VBOX_E_OBJECT_NOT_FOUND, tr("No more entries for directory \"%s\""),
388 mData.mOpenInfo.mPath.c_str());
389 break;
390
391 default:
392 hr = setError(VBOX_E_IPRT_ERROR, tr("Error while reading directory \"%s\": %Rrc\n"),
393 mData.mOpenInfo.mPath.c_str(), rc);
394 break;
395 }
396 }
397
398 LogFlowThisFunc(("Returning rc=%Rrc\n", rc));
399 return hr;
400}
401
Note: See TracBrowser for help on using the repository browser.

© 2024 Oracle Support Privacy / Do Not Sell My Info Terms of Use Trademark Policy Automated Access Etiquette