headers/os/package/Request.h

38

status_t Process(bool failIfCanceledOnly = false);

src/add-ons/mail_daemon/inbound_protocols/imap/IMAPConnectionWorker.cpp

108

virtual status_t Process(IMAPConnectionWorker& worker) = 0;

src/add-ons/mail_daemon/inbound_protocols/imap/IMAPConnectionWorker.cpp

748

status = command->Process(*this);

src/add-ons/media/media-add-ons/vst_host/VSTHost.h

152

void Process(float *buffer, int samples, int channels);

src/add-ons/media/media-add-ons/vst_host/VSTNode.cpp

812

fPlugin->Process((float*)buffer->Data(), samples, channels);

src/apps/deskbar/Switcher.cpp

594

Process((modifiers & B_SHIFT_KEY) == 0, key == 0x11);

src/apps/deskbar/Switcher.cpp

691

Process((modifierKeys & B_SHIFT_KEY) == 0, key == 0x11);

src/apps/deskbar/Switcher.h

89

void Process(bool forward, bool byWindow = false);

src/apps/haikudepot/process/AbstractProcessNode.cpp

114

if (PredecessorAt(i)->Process()->ProcessState() != PROCESS_COMPLETE)

src/apps/haikudepot/process/AbstractProcessNode.cpp

146

return Process()->LogReport();

src/apps/haikudepot/process/AbstractProcessNode.cpp

47

return Process()->ProcessState() == PROCESS_RUNNING;

src/apps/haikudepot/process/AbstractProcessNode.cpp

71

if ((Process()->ProcessState() & desiredStatesMask) != 0)

src/apps/haikudepot/process/AbstractProcessNode.cpp

81

B_PRIi32 " seconds", Process()->Name(), secondElapsed);

src/apps/haikudepot/process/AbstractProcessNode.h

30

AbstractProcess* Process() const;

src/apps/haikudepot/process/ProcessCoordinator.cpp

146

node->Process()->SetListener(NULL);

src/apps/haikudepot/process/ProcessCoordinator.cpp

172

node->Process()->SetListener(this);

src/apps/haikudepot/process/ProcessCoordinator.cpp

214

node->Process()->Name());

src/apps/haikudepot/process/ProcessCoordinator.cpp

226

status_t result = fNodes.ItemAt(i)->Process()->ErrorStatus();

src/apps/haikudepot/process/ProcessCoordinator.cpp

249

result = fNodes.ItemAt(0)->Process()->Progress();

src/apps/haikudepot/process/ProcessCoordinator.cpp

254

AbstractProcess* process = fNodes.ItemAt(i)->Process();

src/apps/haikudepot/process/ProcessCoordinator.cpp

299

AbstractProcess* process = fNodes.ItemAt(i)->Process();

src/apps/haikudepot/process/ProcessCoordinator.cpp

388

if (node->Process()->ProcessState() == PROCESS_INITIAL) {

src/apps/haikudepot/process/ProcessCoordinator.cpp

393

"[%s] not started", node->Process()->Name());

src/apps/haikudepot/process/ProcessCoordinator.cpp

397

node->Process()->Name());

src/apps/haikudepot/process/ProcessCoordinator.cpp

412

AbstractProcess* process = node->Process();

src/apps/haikudepot/process/ProcessCoordinator.cpp

427

AbstractProcess* process = node->Process();

src/apps/haikudepot/process/ProcessCoordinator.cpp

431

predecessorNode->Process()->Name(), process->Name());

src/apps/haikudepot/process/ProcessCoordinator.cpp

444

AbstractProcess *process = fNodes.ItemAt(i)->Process();

src/apps/haikudepot/process/ThreadedProcessNode.cpp

107

AbstractProcess* process = Process();

src/apps/haikudepot/process/ThreadedProcessNode.cpp

137

HDTRACE("[Node<%s>] compute complete", Process()->Name());

src/apps/haikudepot/process/ThreadedProcessNode.cpp

60

HDTRACE("[Node<%s>] thread still running...", Process()->Name());

src/apps/haikudepot/process/ThreadedProcessNode.cpp

76

HDINFO("[Node<%s>] initiating threaded", Process()->Name());

src/apps/haikudepot/process/ThreadedProcessNode.cpp

78

fWorker = spawn_thread(&_RunProcessThreadEntry, Process()->Name(),

src/apps/haikudepot/process/ThreadedProcessNode.cpp

94

return Process()->Stop();

src/apps/haikudepot/server/LocalRepositoryUpdateProcess.cpp

144

result = refreshRequest.Process();

src/apps/mail/Content.cpp

2492

reader->Process(buffer, length, true);

src/apps/mail/Content.cpp

2497

reader->Process("\r\n", 2, true);

src/apps/mail/Content.cpp

2499

else if (!reader->Process(msg, len, true))

src/apps/mail/Content.cpp

2504

if (!reader->Process((const char *)msg + len, size - len))

src/apps/mail/Content.cpp

2551

if (!reader->Process(bodyText, bodyLength))

src/apps/mail/Content.h

255

bool Process(const char* data, int32 length,

src/apps/musiccollection/FileMonitor.cpp

179

return that->Process();

src/apps/musiccollection/FileMonitor.h

120

int32 Process();

src/bin/pkgman/PackageManager.cpp

347

request.Process();

src/bin/pkgman/command_add_repo.cpp

115

result = refreshRequest.Process(true);

src/bin/pkgman/command_add_repo.cpp

99

result = addRequest.Process(true);

src/bin/pkgman/command_drop_repo.cpp

88

result = dropRequest.Process(true);

src/bin/pkgman/command_refresh.cpp

104

result = refreshRequest.Process();

src/bin/setmime.cpp

1163

mimetype.Process();

src/bin/setmime.cpp

487

void Process();

src/kits/package/manager/PackageManager.cpp

886

.Process();

src/kits/package/manager/PackageManager.cpp

895

return BRefreshRepositoryRequest(context, repoConfig).Process();

src/kits/support/ZlibCompressionAlgorithm.cpp

289

int zlibError = Strategy::Process(fStream, flush);

src/kits/support/ZstdCompressionAlgorithm.cpp

283

size_t zstdError = Strategy::Process(fStream, &inBuffer, &outBuffer, flush);

src/preferences/repositories/TaskLooper.cpp

244

status_t result = dropRequest.Process();

src/preferences/repositories/TaskLooper.cpp

269

status_t result = addRequest.Process();

src/preferences/repositories/TaskLooper.cpp

288

result = refreshRequest.Process();

src/servers/launch/Worker.cpp

91

status_t status = self->Process();

src/servers/launch/Worker.h

25

virtual status_t Process();

src/tests/add-ons/kernel/file_systems/shared/consistency_check/consistency_check.cpp

141

status_t status = gSHA.Process(file);

src/tests/add-ons/kernel/file_systems/shared/consistency_check/generate_hashs.cpp

170

status_t status = gSHA.Process(file);