| /dports/devel/gvfs/gvfs-1.46.2/daemon/ |
| H A D | gvfsjobseekread.c | 45 GVfsJobSeekRead *job; in g_vfs_job_seek_read_finalize() local
68 g_vfs_job_seek_read_init (GVfsJobSeekRead *job) in g_vfs_job_seek_read_init()
76 goffset offset, in g_vfs_job_seek_read_new()
79 GVfsJobSeekRead *job; in g_vfs_job_seek_read_new() local
95 send_reply (GVfsJob *job) in send_reply()
113 run (GVfsJob *job) in run()
133 try (GVfsJob *job) in try()
149 g_vfs_job_seek_read_set_offset (GVfsJobSeekRead *job, in g_vfs_job_seek_read_set_offset()
150 goffset offset) in g_vfs_job_seek_read_set_offset()
|
| H A D | gvfsjobseekwrite.c | 45 GVfsJobSeekWrite *job; in g_vfs_job_seek_write_finalize() local
68 g_vfs_job_seek_write_init (GVfsJobSeekWrite *job) in g_vfs_job_seek_write_init()
76 goffset offset, in g_vfs_job_seek_write_new()
79 GVfsJobSeekWrite *job; in g_vfs_job_seek_write_new() local
95 send_reply (GVfsJob *job) in send_reply()
113 run (GVfsJob *job) in run()
133 try (GVfsJob *job) in try()
149 g_vfs_job_seek_write_set_offset (GVfsJobSeekWrite *job, in g_vfs_job_seek_write_set_offset()
150 goffset offset) in g_vfs_job_seek_write_set_offset()
|
| /dports/devel/kf5-kio/kio-5.89.0/src/core/ |
| H A D | filecopyjob.cpp | 24 static inline Slave *jobSlave(SimpleJob *job) in jobSlave()
212 auto job = new DirectCopyJob(slave_url, packedArgs); in startCopyJob() local
220 q->connect(job, &DirectCopyJob::canResume, q, [this](KIO::Job *job, KIO::filesize_t offset) { in startCopyJob()
239 void FileCopyJobPrivate::connectSubjob(SimpleJob *job) in connectSubjob()
242 q->connect(job, &KJob::totalSize, q, [q](KJob *job, qulonglong totalSize) { in connectSubjob()
330 …>connect(m_putJob, &KIO::TransferJob::canResume, q, [this](KIO::Job *job, KIO::filesize_t offset) { in startDataPump()
339 void FileCopyJobPrivate::slotCanResume(KIO::Job *job, KIO::filesize_t offset) in slotCanResume()
393 … FileCopyJobPrivate::processCanResumeResult(KIO::Job *job, RenameDialog_Result result, KIO::filesi… in processCanResumeResult()
434 …>connect(m_getJob, &KIO::TransferJob::canResume, q, [this](KIO::Job *job, KIO::filesize_t offset) { in processCanResumeResult()
505 void FileCopyJob::slotResult(KJob *job) in slotResult()
[all …]
|
| H A D | forwardingslavebase.cpp | 214 KIO::SimpleJob *job = KIO::mkdir(new_url, permissions); in mkdir() local
232 KIO::Job *job = KIO::rename(new_src, new_dest, flags); in rename() local
260 KIO::SimpleJob *job = KIO::chmod(new_url, permissions); in chmod() local
308 KIO::SimpleJob *job = KIO::rmdir(new_url); in del() local
320 void ForwardingSlaveBasePrivate::connectJob(KIO::Job *job) in connectJob()
329 q->connect(job, &KJob::result, q, [this](KJob *job) { in connectJob()
344 q->connect(job, &KJob::speed, q, [this](KJob *job, ulong speed) { in connectJob()
357 void ForwardingSlaveBasePrivate::connectListJob(KIO::ListJob *job) in connectListJob()
377 q->connect(job, &KIO::TransferJob::canResume, q, [this](KIO::Job *job, KIO::filesize_t offset) { in connectTransferJob()
384 void ForwardingSlaveBasePrivate::_k_slotResult(KJob *job) in _k_slotResult()
[all …]
|
| /dports/devel/kf5-kio/kio-5.89.0/autotests/ |
| H A D | jobremotetest.cpp | 65 KIO::Job *job = KIO::mkdir(url, -1); in myMkdir() local
143 void JobRemoteTest::slotGetResult(KJob *job) in slotGetResult()
166 void JobRemoteTest::slotResult(KJob *job) in slotResult()
230 void JobRemoteTest::slotFileJobOpen(KIO::Job *job) in slotFileJobOpen()
248 void JobRemoteTest::slotFileJobPosition(KIO::Job *job, KIO::filesize_t offset) in slotFileJobPosition()
256 void JobRemoteTest::slotFileJobClose(KIO::Job *job) in slotFileJobClose()
337 void JobRemoteTest::slotFileJob2Open(KIO::Job *job) in slotFileJob2Open()
349 void JobRemoteTest::slotFileJob2Position(KIO::Job *job, KIO::filesize_t offset) in slotFileJob2Position()
410 void JobRemoteTest::slotFileJob3Open(KIO::Job *job) in slotFileJob3Open()
416 void JobRemoteTest::slotFileJob3Position(KIO::Job *job, KIO::filesize_t offset) in slotFileJob3Position()
[all …]
|
| /dports/net-im/ruqola/ruqola-1.6.1/src/rocketchatrestapi-qt5/ |
| H A D | connection.cpp | 268 auto job = new LoginJob(this); in login() local
304 auto job = new LogoutJob(this); in logout() local
720 void Connection::filesInRoom(const QString &roomId, const QString &type, int offset, int count) in filesInRoom()
750 void Connection::membersInRoom(const QString &roomId, const QString &type, int offset, int count) in membersInRoom()
1282 void Connection::channelGetAllUserMentions(const QString &roomId, int offset, int count) in channelGetAllUserMentions()
1595 void Connection::getDiscussions(const QString &roomId, int offset, int count) in getDiscussions()
1610 void Connection::getThreadsList(const QString &roomId, bool onlyUnread, int offset, int count) in getThreadsList()
1643 void Connection::getPinnedMessages(const QString &roomId, int offset, int count) in getPinnedMessages()
1661 void Connection::getMentionedMessages(const QString &roomId, int offset, int count) in getMentionedMessages()
1680 void Connection::getStarredMessages(const QString &roomId, int offset, int count) in getStarredMessages()
[all …]
|
| /dports/emulators/qemu-powernv/qemu-powernv-3.0.50/block/ |
| H A D | backup.c | 183 int64_t offset, uint64_t bytes, in backup_do_cow()
277 static void backup_commit(Job *job) in backup_commit()
285 static void backup_abort(Job *job) in backup_abort()
293 static void backup_clean(Job *job) in backup_clean()
308 void backup_do_checkpoint(BlockJob *job, Error **errp) in backup_do_checkpoint()
325 void backup_wait_for_overlapping_requests(BlockJob *job, int64_t offset, in backup_wait_for_overlapping_requests()
339 int64_t offset, uint64_t bytes) in backup_cow_request_begin()
356 static void backup_drain(BlockJob *job) in backup_drain()
434 int64_t offset; in backup_incremental_init_copy_bitmap() local
475 int64_t offset, nb_clusters; in backup_run() local
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/gpu/host1x/ |
| H A D | job.c | 29 struct host1x_job *job = NULL; in host1x_job_alloc() local
71 struct host1x_job *host1x_job_get(struct host1x_job *job) in host1x_job_get()
88 void host1x_job_put(struct host1x_job *job) in host1x_job_put()
95 unsigned int words, unsigned int offset) in host1x_job_add_gather()
327 unsigned int offset) in check_reloc()
342 struct host1x_job *job; member
349 unsigned int offset; member
358 static int check_register(struct host1x_firewall *fw, unsigned long offset) in check_register()
532 size_t offset = 0; in copy_gathers() local
592 int host1x_job_pin(struct host1x_job *job, struct device *dev) in host1x_job_pin()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/gpu/host1x/ |
| H A D | job.c | 29 struct host1x_job *job = NULL; in host1x_job_alloc() local
71 struct host1x_job *host1x_job_get(struct host1x_job *job) in host1x_job_get()
88 void host1x_job_put(struct host1x_job *job) in host1x_job_put()
95 unsigned int words, unsigned int offset) in host1x_job_add_gather()
327 unsigned int offset) in check_reloc()
342 struct host1x_job *job; member
349 unsigned int offset; member
358 static int check_register(struct host1x_firewall *fw, unsigned long offset) in check_register()
532 size_t offset = 0; in copy_gathers() local
592 int host1x_job_pin(struct host1x_job *job, struct device *dev) in host1x_job_pin()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/gpu/host1x/ |
| H A D | job.c | 29 struct host1x_job *job = NULL; in host1x_job_alloc() local
71 struct host1x_job *host1x_job_get(struct host1x_job *job) in host1x_job_get()
88 void host1x_job_put(struct host1x_job *job) in host1x_job_put()
95 unsigned int words, unsigned int offset) in host1x_job_add_gather()
327 unsigned int offset) in check_reloc()
342 struct host1x_job *job; member
349 unsigned int offset; member
358 static int check_register(struct host1x_firewall *fw, unsigned long offset) in check_register()
532 size_t offset = 0; in copy_gathers() local
592 int host1x_job_pin(struct host1x_job *job, struct device *dev) in host1x_job_pin()
[all …]
|
| /dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/webservices/vkontakte/backend/ |
| H A D | vkontakte_uploadphotosjob.cpp | 86 GetPhotoUploadServerJob* const job = new GetPhotoUploadServerJob(d->accessToken, d->dest); in start() local
99 GetPhotoUploadServerJob* const job = dynamic_cast<GetPhotoUploadServerJob*>(kjob); in serverJobFinished() local
125 for (int offset = 0 ; offset < totalCount ; offset += requestFilesCount) in serverJobFinished() local
140 void UploadPhotosJob::startPostJob(int offset, int count) in startPostJob()
142 PhotoPostJob* const job = new PhotoPostJob(d->dest, d->uploadUrl, d->files.mid(offset, count)); in startPostJob() local
161 PhotoPostJob* const job = dynamic_cast<PhotoPostJob*>(kjob); in postJobFinished() local
207 SavePhotoJob* const job = new SavePhotoJob(d->accessToken, d->dest, photoIdData); in startSaveJob() local
221 SavePhotoJob* const job = dynamic_cast<SavePhotoJob*>(kjob); in saveJobFinished() local
|
| /dports/net/libkvkontakte/libkvkontakte-5.0.0/src/ |
| H A D | uploadphotosjob.cpp | 80 GetPhotoUploadServerJob *job = new GetPhotoUploadServerJob(d->accessToken, d->dest); in start() local
90 GetPhotoUploadServerJob *job = dynamic_cast<GetPhotoUploadServerJob *>(kjob); in serverJobFinished() local
112 for (int offset = 0; offset < totalCount; offset += requestFilesCount) in serverJobFinished() local
125 void UploadPhotosJob::startPostJob(int offset, int count) in startPostJob()
127 PhotoPostJob *job = new PhotoPostJob(d->dest, d->uploadUrl, d->files.mid(offset, count)); in startPostJob() local
142 PhotoPostJob *job = dynamic_cast<PhotoPostJob *>(kjob); in postJobFinished() local
182 SavePhotoJob *job = new SavePhotoJob(d->accessToken, d->dest, photoIdData); in startSaveJob() local
193 SavePhotoJob *job = dynamic_cast<SavePhotoJob *>(kjob); in saveJobFinished() local
|
| H A D | allnoteslistjob.cpp | 53 void AllNotesListJob::startNewJob(int offset, int count) in startNewJob()
55 NotesListJob *job = new NotesListJob(d->accessToken, d->uid, offset, count); in startNewJob() local
68 NotesListJob *job = dynamic_cast<NotesListJob *>(kjob); in jobFinished() local
84 for (int offset = 100; offset < d->totalCount; offset += 100) in jobFinished() local
|
| /dports/emulators/qemu-utils/qemu-4.2.1/block/ |
| H A D | backup.c | 62 static int coroutine_fn backup_do_cow(BackupBlockJob *job, in backup_do_cow()
63 int64_t offset, uint64_t bytes, in backup_do_cow()
110 static void backup_commit(Job *job) in backup_commit()
118 static void backup_abort(Job *job) in backup_abort()
126 static void backup_clean(Job *job) in backup_clean()
133 void backup_do_checkpoint(BlockJob *job, Error **errp) in backup_do_checkpoint()
183 static int coroutine_fn backup_loop(BackupBlockJob *job) in backup_loop()
186 int64_t offset; in backup_loop() local
210 static void backup_init_copy_bitmap(BackupBlockJob *job) in backup_init_copy_bitmap()
243 int64_t offset = 0; in backup_run() local
[all …]
|
| /dports/emulators/qemu42/qemu-4.2.1/block/ |
| H A D | backup.c | 62 static int coroutine_fn backup_do_cow(BackupBlockJob *job, in backup_do_cow()
63 int64_t offset, uint64_t bytes, in backup_do_cow()
110 static void backup_commit(Job *job) in backup_commit()
118 static void backup_abort(Job *job) in backup_abort()
126 static void backup_clean(Job *job) in backup_clean()
133 void backup_do_checkpoint(BlockJob *job, Error **errp) in backup_do_checkpoint()
183 static int coroutine_fn backup_loop(BackupBlockJob *job) in backup_loop()
186 int64_t offset; in backup_loop() local
210 static void backup_init_copy_bitmap(BackupBlockJob *job) in backup_init_copy_bitmap()
243 int64_t offset = 0; in backup_run() local
[all …]
|
| /dports/emulators/qemu5/qemu-5.2.0/block/ |
| H A D | backup.c | 62 static int coroutine_fn backup_do_cow(BackupBlockJob *job, in backup_do_cow()
63 int64_t offset, uint64_t bytes, in backup_do_cow()
110 static void backup_commit(Job *job) in backup_commit()
118 static void backup_abort(Job *job) in backup_abort()
126 static void backup_clean(Job *job) in backup_clean()
132 void backup_do_checkpoint(BlockJob *job, Error **errp) in backup_do_checkpoint()
183 static int coroutine_fn backup_loop(BackupBlockJob *job) in backup_loop()
186 int64_t offset; in backup_loop() local
210 static void backup_init_bcs_bitmap(BackupBlockJob *job) in backup_init_bcs_bitmap()
243 int64_t offset = 0; in backup_run() local
[all …]
|
| /dports/emulators/qemu-cheri/qemu-0a323821042c36e21ea80e58b9545dfc3b0cb8ef/block/ |
| H A D | backup.c | 62 static int coroutine_fn backup_do_cow(BackupBlockJob *job, in backup_do_cow()
63 int64_t offset, uint64_t bytes, in backup_do_cow()
110 static void backup_commit(Job *job) in backup_commit()
118 static void backup_abort(Job *job) in backup_abort()
126 static void backup_clean(Job *job) in backup_clean()
136 void backup_do_checkpoint(BlockJob *job, Error **errp) in backup_do_checkpoint()
187 static int coroutine_fn backup_loop(BackupBlockJob *job) in backup_loop()
190 int64_t offset; in backup_loop() local
214 static void backup_init_bcs_bitmap(BackupBlockJob *job) in backup_init_bcs_bitmap()
247 int64_t offset = 0; in backup_run() local
[all …]
|
| /dports/emulators/qemu-guest-agent/qemu-5.0.1/block/ |
| H A D | backup.c | 62 static int coroutine_fn backup_do_cow(BackupBlockJob *job, in backup_do_cow()
63 int64_t offset, uint64_t bytes, in backup_do_cow()
110 static void backup_commit(Job *job) in backup_commit()
118 static void backup_abort(Job *job) in backup_abort()
126 static void backup_clean(Job *job) in backup_clean()
132 void backup_do_checkpoint(BlockJob *job, Error **errp) in backup_do_checkpoint()
183 static int coroutine_fn backup_loop(BackupBlockJob *job) in backup_loop()
186 int64_t offset; in backup_loop() local
210 static void backup_init_bcs_bitmap(BackupBlockJob *job) in backup_init_bcs_bitmap()
243 int64_t offset = 0; in backup_run() local
[all …]
|
| /dports/print/a2ps/a2ps-4.13/lib/ |
| H A D | prange.c | 88 interval_to_buffer (struct interval * interval, uchar * buf, int offset) in interval_to_buffer()
126 interval_applies_above (struct interval * interval, int offset) in interval_applies_above()
196 add_pages_interval (struct a2ps_job * job, int min, int max) in add_pages_interval()
215 page_range_to_buffer (struct page_range * page_range, uchar * buf, int offset) in page_range_to_buffer()
238 page_range_applies_above (struct page_range * page_range, int offset) in page_range_applies_above()
264 a2ps_page_range_set_string (struct a2ps_job * job, const char * string) in a2ps_page_range_set_string()
331 report_pages_to_print (struct a2ps_job * job, FILE * stream) in report_pages_to_print()
340 print_page (struct a2ps_job * job, int page_num) in print_page()
|
| /dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/webservices/vkontakte/backend/attic/ |
| H A D | vkontakte_allnoteslistjob.cpp | 61 void AllNotesListJob::startNewJob(int offset, int count) in startNewJob()
63 NotesListJob* const job = new NotesListJob(d->accessToken, d->uid, offset, count); in startNewJob() local
79 NotesListJob* const job = dynamic_cast<NotesListJob*>(kjob); in jobFinished() local
107 for (int offset = 100; offset < d->totalCount; offset += 100) in jobFinished() local
|
| H A D | vkontakte_allmessageslistjob.cpp | 72 void AllMessagesListJob::startNewJob(int offset, int count, int out) in startNewJob()
76 MessagesListJob* const job = new MessagesListJob(d->accessToken, out, in startNewJob() local
103 MessagesListJob* const job = dynamic_cast<MessagesListJob*>(kjob); in jobFinished() local
133 for (int offset = 100 ; offset < d->totalCount[out] ; offset += 100) in jobFinished() local
|
| /dports/security/intel-ipsec-mb/intel-ipsec-mb-55179f0/lib/include/ |
| H A D | docsis_common.h | 95 DOCSIS_LAST_BLOCK(IMB_JOB *job, const uint64_t key_size) in DOCSIS_LAST_BLOCK()
98 uint64_t offset = 0; in DOCSIS_LAST_BLOCK() local
146 DOCSIS_FIRST_BLOCK(IMB_JOB *job, const uint64_t key_size) in DOCSIS_FIRST_BLOCK()
175 SUBMIT_JOB_DOCSIS_SEC_ENC(MB_MGR_DOCSIS_AES_OOO *state, IMB_JOB *job, in SUBMIT_JOB_DOCSIS_SEC_ENC()
260 SUBMIT_JOB_DOCSIS_SEC_DEC(MB_MGR_DOCSIS_AES_OOO *state, IMB_JOB *job, in SUBMIT_JOB_DOCSIS_SEC_DEC()
317 IMB_JOB *job) in SUBMIT_JOB_DOCSIS128_SEC_CRC_ENC()
325 IMB_JOB *job) in SUBMIT_JOB_DOCSIS256_SEC_CRC_ENC()
392 IMB_JOB *job) in SUBMIT_JOB_DOCSIS128_SEC_CRC_DEC()
400 IMB_JOB *job) in SUBMIT_JOB_DOCSIS256_SEC_CRC_DEC()
418 DOCSIS_DES_ENC(IMB_JOB *job) in DOCSIS_DES_ENC()
[all …]
|
| /dports/misc/hashdb/hashdb-3.1.0-8-g1da1b9f/src_libhashdb/hasher/ |
| H A D | process_job.cpp | 62 const size_t offset, const size_t p_count) { in all_zero()
75 static void print_status(const hasher::job_t& job) { in print_status()
111 static void process_ingest_job(const hasher::job_t& job) { in process_ingest_job()
182 static void process_scan_job(const hasher::job_t& job) { in process_scan_job()
249 void process_job(const hasher::job_t& job) { in process_job()
|
| /dports/devel/kf5-kio/kio-5.89.0/src/kpac/ |
| H A D | downloader.cpp | 30 KIO::TransferJob *job = KIO::get(url, KIO::NoReload, KIO::HideProgressInfo); in download() local
53 unsigned offset = m_data.size(); in data() local
58 static bool hasErrorPage(KJob *job) in hasErrorPage()
64 void Downloader::result(KJob *job) in result()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/ |
| H A D | LineRecordReader.java | 92 public LineRecordReader(Configuration job, in LineRecordReader()
97 public LineRecordReader(Configuration job, FileSplit split, in LineRecordReader()
141 public LineRecordReader(InputStream in, long offset, long endOffset, in LineRecordReader()
146 public LineRecordReader(InputStream in, long offset, long endOffset, in LineRecordReader()
156 public LineRecordReader(InputStream in, long offset, long endOffset, in LineRecordReader()
157 Configuration job) in LineRecordReader()
162 public LineRecordReader(InputStream in, long offset, long endOffset, in LineRecordReader()
163 Configuration job, byte[] recordDelimiter) in LineRecordReader()
|