Lines Matching refs:request
52 UserlandRequestHandler::HandleRequest(Request* request)
54 if (fExpectReply && request->GetType() == fExpectedReply) {
59 switch (request->GetType()) {
62 return _HandleRequest((MountVolumeRequest*)request);
64 return _HandleRequest((UnmountVolumeRequest*)request);
66 return _HandleRequest((SyncVolumeRequest*)request);
68 return _HandleRequest((ReadFSInfoRequest*)request);
70 return _HandleRequest((WriteFSInfoRequest*)request);
74 return _HandleRequest((LookupRequest*)request);
76 return _HandleRequest((GetVNodeNameRequest*)request);
78 return _HandleRequest((ReadVNodeRequest*)request);
80 return _HandleRequest((WriteVNodeRequest*)request);
82 return _HandleRequest((FSRemoveVNodeRequest*)request);
86 return _HandleRequest((DoIORequest*)request);
88 return _HandleRequest((CancelIORequest*)request);
90 return _HandleRequest((IterativeIOGetVecsRequest*)request);
92 return _HandleRequest((IterativeIOFinishedRequest*)request);
96 return _HandleRequest((IOCtlRequest*)request);
98 return _HandleRequest((SetFlagsRequest*)request);
100 return _HandleRequest((SelectRequest*)request);
102 return _HandleRequest((DeselectRequest*)request);
104 return _HandleRequest((FSyncRequest*)request);
106 return _HandleRequest((ReadSymlinkRequest*)request);
108 return _HandleRequest((CreateSymlinkRequest*)request);
110 return _HandleRequest((LinkRequest*)request);
112 return _HandleRequest((UnlinkRequest*)request);
114 return _HandleRequest((RenameRequest*)request);
116 return _HandleRequest((AccessRequest*)request);
118 return _HandleRequest((ReadStatRequest*)request);
120 return _HandleRequest((WriteStatRequest*)request);
124 return _HandleRequest((CreateRequest*)request);
126 return _HandleRequest((OpenRequest*)request);
128 return _HandleRequest((CloseRequest*)request);
130 return _HandleRequest((FreeCookieRequest*)request);
132 return _HandleRequest((ReadRequest*)request);
134 return _HandleRequest((WriteRequest*)request);
138 return _HandleRequest((CreateDirRequest*)request);
140 return _HandleRequest((RemoveDirRequest*)request);
142 return _HandleRequest((OpenDirRequest*)request);
144 return _HandleRequest((CloseDirRequest*)request);
146 return _HandleRequest((FreeDirCookieRequest*)request);
148 return _HandleRequest((ReadDirRequest*)request);
150 return _HandleRequest((RewindDirRequest*)request);
154 return _HandleRequest((OpenAttrDirRequest*)request);
156 return _HandleRequest((CloseAttrDirRequest*)request);
158 return _HandleRequest((FreeAttrDirCookieRequest*)request);
160 return _HandleRequest((ReadAttrDirRequest*)request);
162 return _HandleRequest((RewindAttrDirRequest*)request);
166 return _HandleRequest((CreateAttrRequest*)request);
168 return _HandleRequest((OpenAttrRequest*)request);
170 return _HandleRequest((CloseAttrRequest*)request);
172 return _HandleRequest((FreeAttrCookieRequest*)request);
174 return _HandleRequest((ReadAttrRequest*)request);
176 return _HandleRequest((WriteAttrRequest*)request);
178 return _HandleRequest((ReadAttrStatRequest*)request);
180 return _HandleRequest((WriteAttrStatRequest*)request);
182 return _HandleRequest((RenameAttrRequest*)request);
184 return _HandleRequest((RemoveAttrRequest*)request);
188 return _HandleRequest((OpenIndexDirRequest*)request);
190 return _HandleRequest((CloseIndexDirRequest*)request);
192 return _HandleRequest((FreeIndexDirCookieRequest*)request);
194 return _HandleRequest((ReadIndexDirRequest*)request);
196 return _HandleRequest((RewindIndexDirRequest*)request);
198 return _HandleRequest((CreateIndexRequest*)request);
200 return _HandleRequest((RemoveIndexRequest*)request);
202 return _HandleRequest((ReadIndexStatRequest*)request);
206 return _HandleRequest((OpenQueryRequest*)request);
208 return _HandleRequest((CloseQueryRequest*)request);
210 return _HandleRequest((FreeQueryCookieRequest*)request);
212 return _HandleRequest((ReadQueryRequest*)request);
214 return _HandleRequest((RewindQueryRequest*)request);
218 return _HandleRequest((NodeMonitoringEventRequest*)request);
220 PRINT(("UserlandRequestHandler::HandleRequest(): unexpected request: %"
221 B_PRIu32 "\n", request->GetType()));
231 UserlandRequestHandler::_HandleRequest(MountVolumeRequest* request)
233 // check and execute the request
238 const char* device = (const char*)request->device.GetData();
242 if (const char* cwd = (const char*)request->cwd.GetData()) {
260 result = fFileSystem->CreateVolume(&volume, request->nsid);
265 RequestThreadContext context(volume, request);
266 result = volume->Mount(device, request->flags,
267 (const char*)request->parameters.GetData(), &rootID);
292 UserlandRequestHandler::_HandleRequest(UnmountVolumeRequest* request)
294 // check and execute the request
296 if (Volume* volume = (Volume*)request->volume) {
297 RequestThreadContext context(volume, request);
316 UserlandRequestHandler::_HandleRequest(SyncVolumeRequest* request)
318 // check and execute the request
320 Volume* volume = (Volume*)request->volume;
324 RequestThreadContext context(volume, request);
341 UserlandRequestHandler::_HandleRequest(ReadFSInfoRequest* request)
343 // check and execute the request
345 Volume* volume = (Volume*)request->volume;
350 RequestThreadContext context(volume, request);
368 UserlandRequestHandler::_HandleRequest(WriteFSInfoRequest* request)
370 // check and execute the request
372 Volume* volume = (Volume*)request->volume;
376 RequestThreadContext context(volume, request);
377 result = volume->WriteFSInfo(&request->info, request->mask);
398 UserlandRequestHandler::_HandleRequest(LookupRequest* request)
400 // check and execute the request
402 Volume* volume = (Volume*)request->volume;
408 RequestThreadContext context(volume, request);
409 result = volume->Lookup(request->node,
410 (const char*)request->entryName.GetData(), &vnid);
429 UserlandRequestHandler::_HandleRequest(GetVNodeNameRequest* request)
431 // check and execute the request
433 Volume* volume = (Volume*)request->volume;
437 void* node = request->node;
438 size_t bufferSize = request->size;
452 // execute the request
454 RequestThreadContext context(volume, request);
468 UserlandRequestHandler::_HandleRequest(ReadVNodeRequest* request)
470 // check and execute the request
472 Volume* volume = (Volume*)request->volume;
481 RequestThreadContext context(volume, request);
482 result = volume->ReadVNode(request->vnid, request->reenter, &node,
505 UserlandRequestHandler::_HandleRequest(WriteVNodeRequest* request)
507 // check and execute the request
509 Volume* volume = (Volume*)request->volume;
514 RequestThreadContext context(volume, request);
515 result = volume->WriteVNode(request->node, request->reenter);
533 UserlandRequestHandler::_HandleRequest(FSRemoveVNodeRequest* request)
535 // check and execute the request
537 Volume* volume = (Volume*)request->volume;
542 RequestThreadContext context(volume, request);
543 result = volume->RemoveVNode(request->node, request->reenter);
564 UserlandRequestHandler::_HandleRequest(DoIORequest* request)
566 // check and execute the request
568 Volume* volume = (Volume*)request->volume;
573 RequestThreadContext context(volume, request);
574 IORequestInfo requestInfo(request->request, request->isWrite,
575 request->offset, request->length, request->isVIP);
576 result = volume->DoIO(request->node, request->fileCookie, requestInfo);
594 UserlandRequestHandler::_HandleRequest(CancelIORequest* request)
596 // check and execute the request
598 Volume* volume = (Volume*)request->volume;
603 RequestThreadContext context(volume, request);
604 result = volume->CancelIO(request->node, request->fileCookie,
605 request->request);
624 UserlandRequestHandler::_HandleRequest(IterativeIOGetVecsRequest* request)
626 // check and execute the request
628 Volume* volume = (Volume*)request->volume;
635 RequestThreadContext context(volume, request);
636 result = volume->IterativeIOGetVecs(request->cookie, request->request,
637 request->offset, request->size, vecs, &vecCount);
665 UserlandRequestHandler::_HandleRequest(IterativeIOFinishedRequest* request)
667 // check and execute the request
669 Volume* volume = (Volume*)request->volume;
674 RequestThreadContext context(volume, request);
675 result = volume->IterativeIOFinished(request->cookie, request->request,
676 request->status, request->partialTransfer,
677 request->bytesTransferred);
699 UserlandRequestHandler::_HandleRequest(IOCtlRequest* request)
701 // get the request parameters
703 Volume* volume = (Volume*)request->volume;
707 void* buffer = request->bufferParameter;
708 size_t len = request->lenParameter;
709 bool isBuffer = request->isBuffer;
711 int32 writeSize = request->writeSize;
713 buffer = request->buffer.GetData();
714 bufferSize = request->buffer.GetSize();
736 // execute the request
739 RequestThreadContext context(volume, request);
740 ioctlError = volume->IOCtl(request->node, request->fileCookie,
741 request->command, buffer, len);
755 UserlandRequestHandler::_HandleRequest(SetFlagsRequest* request)
757 // check and execute the request
759 Volume* volume = (Volume*)request->volume;
764 RequestThreadContext context(volume, request);
765 result = volume->SetFlags(request->node, request->fileCookie,
766 request->flags);
784 UserlandRequestHandler::_HandleRequest(SelectRequest* request)
786 // check and execute the request
788 Volume* volume = (Volume*)request->volume;
793 RequestThreadContext context(volume, request);
794 result = volume->Select(request->node, request->fileCookie,
795 request->event, request->sync);
813 UserlandRequestHandler::_HandleRequest(DeselectRequest* request)
815 // check and execute the request
817 Volume* volume = (Volume*)request->volume;
822 RequestThreadContext context(volume, request);
823 result = volume->Deselect(request->node, request->fileCookie,
824 request->event, request->sync);
842 UserlandRequestHandler::_HandleRequest(FSyncRequest* request)
844 // check and execute the request
846 Volume* volume = (Volume*)request->volume;
851 RequestThreadContext context(volume, request);
852 result = volume->FSync(request->node);
870 UserlandRequestHandler::_HandleRequest(ReadSymlinkRequest* request)
872 // check and execute the request
874 Volume* volume = (Volume*)request->volume;
878 void* node = request->node;
879 size_t bufferSize = request->size;
893 // execute the request
896 RequestThreadContext context(volume, request);
911 UserlandRequestHandler::_HandleRequest(CreateSymlinkRequest* request)
913 // check and execute the request
915 Volume* volume = (Volume*)request->volume;
920 RequestThreadContext context(volume, request);
921 result = volume->CreateSymlink(request->node,
922 (const char*)request->name.GetData(),
923 (const char*)request->target.GetData(), request->mode);
941 UserlandRequestHandler::_HandleRequest(LinkRequest* request)
943 // check and execute the request
945 Volume* volume = (Volume*)request->volume;
950 RequestThreadContext context(volume, request);
951 result = volume->Link(request->node,
952 (const char*)request->name.GetData(), request->target);
970 UserlandRequestHandler::_HandleRequest(UnlinkRequest* request)
972 // check and execute the request
974 Volume* volume = (Volume*)request->volume;
979 RequestThreadContext context(volume, request);
980 result = volume->Unlink(request->node,
981 (const char*)request->name.GetData());
999 UserlandRequestHandler::_HandleRequest(RenameRequest* request)
1001 // check and execute the request
1003 Volume* volume = (Volume*)request->volume;
1008 RequestThreadContext context(volume, request);
1009 result = volume->Rename(request->oldDir,
1010 (const char*)request->oldName.GetData(), request->newDir,
1011 (const char*)request->newName.GetData());
1029 UserlandRequestHandler::_HandleRequest(AccessRequest* request)
1031 // check and execute the request
1033 Volume* volume = (Volume*)request->volume;
1038 RequestThreadContext context(volume, request);
1039 result = volume->Access(request->node, request->mode);
1057 UserlandRequestHandler::_HandleRequest(ReadStatRequest* request)
1059 // check and execute the request
1061 Volume* volume = (Volume*)request->volume;
1067 RequestThreadContext context(volume, request);
1068 result = volume->ReadStat(request->node, &st);
1087 UserlandRequestHandler::_HandleRequest(WriteStatRequest* request)
1089 // check and execute the request
1091 Volume* volume = (Volume*)request->volume;
1096 RequestThreadContext context(volume, request);
1097 result = volume->WriteStat(request->node, &request->st, request->mask);
1119 UserlandRequestHandler::_HandleRequest(CreateRequest* request)
1121 // check and execute the request
1123 Volume* volume = (Volume*)request->volume;
1130 RequestThreadContext context(volume, request);
1131 result = volume->Create(request->node,
1132 (const char*)request->name.GetData(), request->openMode,
1133 request->mode, &fileCookie, &vnid);
1153 UserlandRequestHandler::_HandleRequest(OpenRequest* request)
1155 // check and execute the request
1157 Volume* volume = (Volume*)request->volume;
1163 RequestThreadContext context(volume, request);
1164 result = volume->Open(request->node, request->openMode, &fileCookie);
1183 UserlandRequestHandler::_HandleRequest(CloseRequest* request)
1185 // check and execute the request
1187 Volume* volume = (Volume*)request->volume;
1192 RequestThreadContext context(volume, request);
1193 result = volume->Close(request->node, request->fileCookie);
1211 UserlandRequestHandler::_HandleRequest(FreeCookieRequest* request)
1213 // check and execute the request
1215 Volume* volume = (Volume*)request->volume;
1220 RequestThreadContext context(volume, request);
1221 result = volume->FreeCookie(request->node, request->fileCookie);
1239 UserlandRequestHandler::_HandleRequest(ReadRequest* request)
1241 // check and execute the request
1243 Volume* volume = (Volume*)request->volume;
1247 void* node = request->node;
1248 void* fileCookie = request->fileCookie;
1249 off_t pos = request->pos;
1250 size_t size = request->size;
1265 // execute the request
1268 RequestThreadContext context(volume, request);
1283 UserlandRequestHandler::_HandleRequest(WriteRequest* request)
1285 // check and execute the request
1287 Volume* volume = (Volume*)request->volume;
1293 RequestThreadContext context(volume, request);
1294 result = volume->Write(request->node, request->fileCookie,
1295 request->pos, request->buffer.GetData(), request->buffer.GetSize(),
1319 UserlandRequestHandler::_HandleRequest(CreateDirRequest* request)
1321 // check and execute the request
1323 Volume* volume = (Volume*)request->volume;
1328 RequestThreadContext context(volume, request);
1329 result = volume->CreateDir(request->node,
1330 (const char*)request->name.GetData(), request->mode);
1348 UserlandRequestHandler::_HandleRequest(RemoveDirRequest* request)
1350 // check and execute the request
1352 Volume* volume = (Volume*)request->volume;
1357 RequestThreadContext context(volume, request);
1358 result = volume->RemoveDir(request->node,
1359 (const char*)request->name.GetData());
1377 UserlandRequestHandler::_HandleRequest(OpenDirRequest* request)
1379 // check and execute the request
1381 Volume* volume = (Volume*)request->volume;
1387 RequestThreadContext context(volume, request);
1388 result = volume->OpenDir(request->node, &dirCookie);
1407 UserlandRequestHandler::_HandleRequest(CloseDirRequest* request)
1409 // check and execute the request
1411 Volume* volume = (Volume*)request->volume;
1416 RequestThreadContext context(volume, request);
1417 result = volume->CloseDir(request->node, request->dirCookie);
1435 UserlandRequestHandler::_HandleRequest(FreeDirCookieRequest* request)
1437 // check and execute the request
1439 Volume* volume = (Volume*)request->volume;
1444 RequestThreadContext context(volume, request);
1445 result = volume->FreeDirCookie(request->node, request->dirCookie);
1463 UserlandRequestHandler::_HandleRequest(ReadDirRequest* request)
1465 // check the request
1467 Volume* volume = (Volume*)request->volume;
1471 void* node = request->node;
1472 void* dirCookie = request->dirCookie;
1473 size_t bufferSize = request->bufferSize;
1474 uint32 count = request->count;
1489 // execute the request
1492 RequestThreadContext context(volume, request);
1520 UserlandRequestHandler::_HandleRequest(RewindDirRequest* request)
1522 // check and execute the request
1524 Volume* volume = (Volume*)request->volume;
1529 RequestThreadContext context(volume, request);
1530 result = volume->RewindDir(request->node, request->dirCookie);
1552 UserlandRequestHandler::_HandleRequest(OpenAttrDirRequest* request)
1554 // check and execute the request
1556 Volume* volume = (Volume*)request->volume;
1562 RequestThreadContext context(volume, request);
1563 result = volume->OpenAttrDir(request->node, &attrDirCookie);
1582 UserlandRequestHandler::_HandleRequest(CloseAttrDirRequest* request)
1584 // check and execute the request
1586 Volume* volume = (Volume*)request->volume;
1591 RequestThreadContext context(volume, request);
1592 result = volume->CloseAttrDir(request->node, request->attrDirCookie);
1610 UserlandRequestHandler::_HandleRequest(FreeAttrDirCookieRequest* request)
1612 // check and execute the request
1614 Volume* volume = (Volume*)request->volume;
1619 RequestThreadContext context(volume, request);
1620 result = volume->FreeAttrDirCookie(request->node,
1621 request->attrDirCookie);
1639 UserlandRequestHandler::_HandleRequest(ReadAttrDirRequest* request)
1641 // check and execute the request
1643 Volume* volume = (Volume*)request->volume;
1647 void* node = request->node;
1648 void* attrDirCookie = request->attrDirCookie;
1649 size_t bufferSize = request->bufferSize;
1650 uint32 count = request->count;
1665 // execute the request
1668 RequestThreadContext context(volume, request);
1684 UserlandRequestHandler::_HandleRequest(RewindAttrDirRequest* request)
1686 // check and execute the request
1688 Volume* volume = (Volume*)request->volume;
1693 RequestThreadContext context(volume, request);
1694 result = volume->RewindAttrDir(request->node, request->attrDirCookie);
1716 UserlandRequestHandler::_HandleRequest(CreateAttrRequest* request)
1718 // check and execute the request
1720 Volume* volume = (Volume*)request->volume;
1726 RequestThreadContext context(volume, request);
1727 result = volume->CreateAttr(request->node,
1728 (const char*)request->name.GetData(), request->type,
1729 request->openMode, &attrCookie);
1748 UserlandRequestHandler::_HandleRequest(OpenAttrRequest* request)
1750 // check and execute the request
1752 Volume* volume = (Volume*)request->volume;
1758 RequestThreadContext context(volume, request);
1759 result = volume->OpenAttr(request->node,
1760 (const char*)request->name.GetData(), request->openMode,
1780 UserlandRequestHandler::_HandleRequest(CloseAttrRequest* request)
1782 // check and execute the request
1784 Volume* volume = (Volume*)request->volume;
1789 RequestThreadContext context(volume, request);
1790 result = volume->CloseAttr(request->node, request->attrCookie);
1808 UserlandRequestHandler::_HandleRequest(FreeAttrCookieRequest* request)
1810 // check and execute the request
1812 Volume* volume = (Volume*)request->volume;
1817 RequestThreadContext context(volume, request);
1818 result = volume->FreeAttrCookie(request->node, request->attrCookie);
1836 UserlandRequestHandler::_HandleRequest(ReadAttrRequest* request)
1838 // check and execute the request
1840 Volume* volume = (Volume*)request->volume;
1844 void* node = request->node;
1845 void* attrCookie = request->attrCookie;
1846 off_t pos = request->pos;
1847 size_t size = request->size;
1862 // execute the request
1865 RequestThreadContext context(volume, request);
1881 UserlandRequestHandler::_HandleRequest(WriteAttrRequest* request)
1883 // check and execute the request
1885 Volume* volume = (Volume*)request->volume;
1891 RequestThreadContext context(volume, request);
1892 result = volume->WriteAttr(request->node, request->attrCookie,
1893 request->pos, request->buffer.GetData(), request->buffer.GetSize(),
1913 UserlandRequestHandler::_HandleRequest(ReadAttrStatRequest* request)
1915 // check and execute the request
1917 Volume* volume = (Volume*)request->volume;
1923 RequestThreadContext context(volume, request);
1924 result = volume->ReadAttrStat(request->node, request->attrCookie,
1944 UserlandRequestHandler::_HandleRequest(WriteAttrStatRequest* request)
1946 // check and execute the request
1948 Volume* volume = (Volume*)request->volume;
1953 RequestThreadContext context(volume, request);
1954 result = volume->WriteAttrStat(request->node, request->attrCookie,
1955 &request->st, request->mask);
1973 UserlandRequestHandler::_HandleRequest(RenameAttrRequest* request)
1975 // check and execute the request
1977 Volume* volume = (Volume*)request->volume;
1982 RequestThreadContext context(volume, request);
1984 request->oldNode, (const char*)request->oldName.GetData(),
1985 request->newNode, (const char*)request->newName.GetData());
2003 UserlandRequestHandler::_HandleRequest(RemoveAttrRequest* request)
2005 // check and execute the request
2007 Volume* volume = (Volume*)request->volume;
2012 RequestThreadContext context(volume, request);
2013 result = volume->RemoveAttr(request->node,
2014 (const char*)request->name.GetData());
2036 UserlandRequestHandler::_HandleRequest(OpenIndexDirRequest* request)
2038 // check and execute the request
2040 Volume* volume = (Volume*)request->volume;
2046 RequestThreadContext context(volume, request);
2066 UserlandRequestHandler::_HandleRequest(CloseIndexDirRequest* request)
2068 // check and execute the request
2070 Volume* volume = (Volume*)request->volume;
2075 RequestThreadContext context(volume, request);
2076 result = volume->CloseIndexDir(request->indexDirCookie);
2094 UserlandRequestHandler::_HandleRequest(FreeIndexDirCookieRequest* request)
2096 // check and execute the request
2098 Volume* volume = (Volume*)request->volume;
2103 RequestThreadContext context(volume, request);
2104 result = volume->FreeIndexDirCookie(request->indexDirCookie);
2122 UserlandRequestHandler::_HandleRequest(ReadIndexDirRequest* request)
2124 // check and execute the request
2126 Volume* volume = (Volume*)request->volume;
2130 void* indexDirCookie = request->indexDirCookie;
2131 size_t bufferSize = request->bufferSize;
2132 uint32 count = request->count;
2147 // execute the request
2150 RequestThreadContext context(volume, request);
2166 UserlandRequestHandler::_HandleRequest(RewindIndexDirRequest* request)
2168 // check and execute the request
2170 Volume* volume = (Volume*)request->volume;
2175 RequestThreadContext context(volume, request);
2176 result = volume->RewindIndexDir(request->indexDirCookie);
2194 UserlandRequestHandler::_HandleRequest(CreateIndexRequest* request)
2196 // check and execute the request
2198 Volume* volume = (Volume*)request->volume;
2203 RequestThreadContext context(volume, request);
2204 result = volume->CreateIndex((const char*)request->name.GetData(),
2205 request->type, request->flags);
2223 UserlandRequestHandler::_HandleRequest(RemoveIndexRequest* request)
2225 // check and execute the request
2227 Volume* volume = (Volume*)request->volume;
2232 RequestThreadContext context(volume, request);
2233 result = volume->RemoveIndex((const char*)request->name.GetData());
2251 UserlandRequestHandler::_HandleRequest(ReadIndexStatRequest* request)
2253 // check and execute the request
2255 Volume* volume = (Volume*)request->volume;
2261 RequestThreadContext context(volume, request);
2262 result = volume->ReadIndexStat((const char*)request->name.GetData(),
2286 UserlandRequestHandler::_HandleRequest(OpenQueryRequest* request)
2288 // check and execute the request
2290 Volume* volume = (Volume*)request->volume;
2296 RequestThreadContext context(volume, request);
2297 result = volume->OpenQuery((const char*)request->queryString.GetData(),
2298 request->flags, request->port, request->token, &queryCookie);
2317 UserlandRequestHandler::_HandleRequest(CloseQueryRequest* request)
2319 // check and execute the request
2321 Volume* volume = (Volume*)request->volume;
2326 RequestThreadContext context(volume, request);
2327 result = volume->CloseQuery(request->queryCookie);
2345 UserlandRequestHandler::_HandleRequest(FreeQueryCookieRequest* request)
2347 // check and execute the request
2349 Volume* volume = (Volume*)request->volume;
2354 RequestThreadContext context(volume, request);
2355 result = volume->FreeQueryCookie(request->queryCookie);
2373 UserlandRequestHandler::_HandleRequest(ReadQueryRequest* request)
2375 // check and execute the request
2377 Volume* volume = (Volume*)request->volume;
2381 void* queryCookie = request->queryCookie;
2382 size_t bufferSize = request->bufferSize;
2383 uint32 count = request->count;
2398 // execute the request
2401 RequestThreadContext context(volume, request);
2417 UserlandRequestHandler::_HandleRequest(RewindQueryRequest* request)
2419 // check and execute the request
2421 Volume* volume = (Volume*)request->volume;
2426 RequestThreadContext context(volume, request);
2427 result = volume->RewindQuery(request->queryCookie);
2449 UserlandRequestHandler::_HandleRequest(NodeMonitoringEventRequest* request)
2451 // check and execute the request
2453 event.SetTo(request->event.GetData(), request->event.GetSize());
2454 ((NotificationListener*)request->listener)->EventOccurred(