Skip to content

dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
dingusdev merged 2 commits into from
Aug 22, 2026
+17 −66
Merged

dbdma: Interpret command lists until STOP #220

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
6aa8ab4
dbdma: Interpret command lists until STOP
mihaip Aug 22, 2026
a930d0e
dma: Remove the old pull/push completion API
mihaip Aug 22, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
74 changes: 16 additions & 58 deletions devices/common/dbdma.cpp
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
}
}

void DMAChannel::interpret_until_blocked() {
// Execute ready commands until a transfer is queued or the channel becomes idle/dead.
while (this->is_active()) {
this->interpret_cmd();
if (this->cmd_in_progress)
break;
}
}

void DMAChannel::update_cmd() {
if (this->cur_is_writable) {
if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
this->get_name().c_str());
}

this->interpret_cmd();
this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
this->finish_cmd();
}

this->interpret_cmd();
this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
}

// interpret DBDMA program until we get data or become idle
while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
this->interpret_cmd();
}
this->interpret_until_blocked();

// dequeue data if any
if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
}

// interpret DBDMA program until we get buffer to fill in or become idle
while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
this->interpret_cmd();
}
this->interpret_until_blocked();

if (this->queue_len) {
len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

// proceed with the DBDMA program if the buffer became exhausted
if (!this->queue_len) {
this->interpret_cmd();
this->interpret_until_blocked();
}

return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
if (!this->is_active()) {
// dead or idle channel? -> no more data
LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
this->get_name().c_str());
return;
}

if (this->queue_len) {
this->queue_len = 0;
} else {
this->ch_stat &= ~CH_STAT_FLUSH;
}

// proceed with the DBDMA program
this->interpret_cmd();
}

void DMAChannel::end_push_data() {
if (!this->is_active()) {
LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
this->get_name().c_str());
return;
}

if (this->queue_len) {
this->queue_len = 0;
} else {
this->ch_stat &= ~CH_STAT_FLUSH;
}

// proceed with the DBDMA program
this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
if (this->start_cb)
this->start_cb();

// some DBDMA programs contain commands that don't transfer data
// between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
// We thus interprete the DBDMA program until a data transfer between
// a device and memory is queued or the channel becomes idle/dead.
while (!this->cmd_in_progress && this->is_active()) {
this->interpret_cmd();
}
this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

// some DBDMA programs contain commands that don't transfer data
// between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
// We thus interprete the DBDMA program until a data transfer between
// a device and memory is queued or the channel becomes idle/dead.
while (!this->cmd_in_progress && this->is_active()) {
this->interpret_cmd();
}
this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down
5 changes: 1 addition & 4 deletions devices/common/dbdma.h
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
bool is_in_active() override;
DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
DmaPushResult push_data(const char* src_ptr, int len) override;
int get_pull_data_remaining() override { return this->queue_len; }
int get_push_data_remaining() override { return this->queue_len; }
void end_pull_data() override;
void end_push_data() override;

bool dma_is_ready() override;
void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
void interpret_cmd(void);
void interpret_until_blocked();
void update_cmd();
void finish_cmd();
void xfer_quad(bool is_store);
Expand Down
4 changes: 0 additions & 4 deletions devices/common/dmacore.h
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
virtual bool is_out_active() { return true; }
virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
uint8_t **p_data) = 0;
virtual int get_pull_data_remaining() { return 1; }
virtual void end_pull_data() {}

std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

virtual bool is_in_active() { return true; }
virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
virtual int get_push_data_remaining() { return 1; }
virtual void end_push_data() {}

std::string get_name(void) { return this->name; }

Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Add copy buttons to all 
 blocks
(function() {
function addCopyButtons() {
document.querySelectorAll('pre code').forEach(function(codeBlock) {
if (codeBlock.parentElement.hasAttribute('data-copy-added')) return;
codeBlock.parentElement.setAttribute('data-copy-added', 'true');
var btn = document.createElement('button');
btn.textContent = 'Copy';
btn.style.cssText = 'position:absolute;top:4px;right:4px;padding:2px 8px;font-size:11px;background:#4ecdc4;border:none;border-radius:4px;color:#1a1a2e;cursor:pointer;opacity:0.7;transition:opacity 0.2s;';
btn.onmouseover = function() { this.style.opacity = '1'; };
btn.onmouseout = function() { this.style.opacity = '0.7'; };
btn.onclick = function() {
navigator.clipboard.writeText(codeBlock.textContent).then(function() {
btn.textContent = 'Copied!';
setTimeout(function() { btn.textContent = 'Copy'; }, 1500);
});
};
codeBlock.parentElement.style.position = 'relative';
codeBlock.parentElement.appendChild(btn);
});
}
addCopyButtons();
// Re-run on dynamic content
var observer = new MutationObserver(addCopyButtons);
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:Add Copy Buttons to Code Blocks]', __e); }
})();
(function(){
try {
var __m = "github.com";
var __re = new RegExp('^' + "github\\.com" + '
dbdma: Interpret command lists until STOP by mihaip · Pull Request #220 · dingusdev/dingusppc · GitHub
Skip to content
dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

dingusdev
merged 2 commits into

from

Aug 22, 2026

+17

−66

 Merged


dbdma: Interpret command lists until STOP
#220
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


2 commits


Select commit
Hold shift + click to select a range
6aa8ab4

dbdma: Interpret command lists until STOP


mihaip Aug 22, 2026
a930d0e

dma: Remove the old pull/push completion API


mihaip Aug 22, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


74 changes: 16 additions & 58 deletions
devices/common/dbdma.cpp

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
 }
}

void DMAChannel::interpret_until_blocked() {
 // Execute ready commands until a transfer is queued or the channel becomes idle/dead.
 while (this->is_active()) {
 this->interpret_cmd();
 if (this->cmd_in_progress)
 break;
 }
}

void DMAChannel::update_cmd() {
 if (this->cur_is_writable) {
 if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
 this->get_name().c_str());
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
 this->finish_cmd();
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
 }

 // interpret DBDMA program until we get data or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 // dequeue data if any
 if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
 }

 // interpret DBDMA program until we get buffer to fill in or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 if (this->queue_len) {
 len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

 // proceed with the DBDMA program if the buffer became exhausted
 if (!this->queue_len) {
 this->interpret_cmd();
 this->interpret_until_blocked();
 }

 return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
 if (!this->is_active()) {
 // dead or idle channel? -> no more data
 LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

void DMAChannel::end_push_data() {
 if (!this->is_active()) {
 LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
 return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
 if (this->start_cb)
 this->start_cb();

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

 LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down

5 changes: 1 addition & 4 deletions
devices/common/dbdma.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
 bool is_in_active() override;
 DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
 DmaPushResult push_data(const char* src_ptr, int len) override;
 int get_pull_data_remaining() override { return this->queue_len; }
 int get_push_data_remaining() override { return this->queue_len; }
 void end_pull_data() override;
 void end_push_data() override;

 bool dma_is_ready() override;
 void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
 DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
 void interpret_cmd(void);
 void interpret_until_blocked();
 void update_cmd();
 void finish_cmd();
 void xfer_quad(bool is_store);
Expand Down

4 changes: 0 additions & 4 deletions
devices/common/dmacore.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
 virtual bool is_out_active() { return true; }
 virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
 uint8_t **p_data) = 0;
 virtual int get_pull_data_remaining() { return 1; }
 virtual void end_pull_data() {}

 std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

 virtual bool is_in_active() { return true; }
 virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
 virtual int get_push_data_remaining() { return 1; }
 virtual void end_push_data() {}

 std::string get_name(void) { return this->name; }

Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Force GitHub README to respect dark mode
(function() {
var style = document.createElement('style');
style.textContent = '
.markdown-body {
color-scheme: dark light;
}
.markdown-body pre { background: #161b22 !important; }
.markdown-body code { background: rgba(110, 118, 129, 0.4) !important; }
.markdown-body table th, .markdown-body table td { border-color: #30363d !important; }
.markdown-body img { background: #0d1117; }
.markdown-body blockquote { border-left-color: #8b949e; }
.markdown-body hr { border-color: #30363d; }
';
document.head.appendChild(style);
})();
}
} catch(__e) { console.warn('[Userscript:GitHub Dark Mode README Fix]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
dbdma: Interpret command lists until STOP by mihaip · Pull Request #220 · dingusdev/dingusppc · GitHub
Skip to content
dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

dingusdev
merged 2 commits into

from

Aug 22, 2026

+17

−66

 Merged


dbdma: Interpret command lists until STOP
#220
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


2 commits


Select commit
Hold shift + click to select a range
6aa8ab4

dbdma: Interpret command lists until STOP


mihaip Aug 22, 2026
a930d0e

dma: Remove the old pull/push completion API


mihaip Aug 22, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


74 changes: 16 additions & 58 deletions
devices/common/dbdma.cpp

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
 }
}

void DMAChannel::interpret_until_blocked() {
 // Execute ready commands until a transfer is queued or the channel becomes idle/dead.
 while (this->is_active()) {
 this->interpret_cmd();
 if (this->cmd_in_progress)
 break;
 }
}

void DMAChannel::update_cmd() {
 if (this->cur_is_writable) {
 if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
 this->get_name().c_str());
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
 this->finish_cmd();
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
 }

 // interpret DBDMA program until we get data or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 // dequeue data if any
 if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
 }

 // interpret DBDMA program until we get buffer to fill in or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 if (this->queue_len) {
 len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

 // proceed with the DBDMA program if the buffer became exhausted
 if (!this->queue_len) {
 this->interpret_cmd();
 this->interpret_until_blocked();
 }

 return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
 if (!this->is_active()) {
 // dead or idle channel? -> no more data
 LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

void DMAChannel::end_push_data() {
 if (!this->is_active()) {
 LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
 return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
 if (this->start_cb)
 this->start_cb();

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

 LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down

5 changes: 1 addition & 4 deletions
devices/common/dbdma.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
 bool is_in_active() override;
 DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
 DmaPushResult push_data(const char* src_ptr, int len) override;
 int get_pull_data_remaining() override { return this->queue_len; }
 int get_push_data_remaining() override { return this->queue_len; }
 void end_pull_data() override;
 void end_push_data() override;

 bool dma_is_ready() override;
 void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
 DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
 void interpret_cmd(void);
 void interpret_until_blocked();
 void update_cmd();
 void finish_cmd();
 void xfer_quad(bool is_store);
Expand Down

4 changes: 0 additions & 4 deletions
devices/common/dmacore.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
 virtual bool is_out_active() { return true; }
 virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
 uint8_t **p_data) = 0;
 virtual int get_pull_data_remaining() { return 1; }
 virtual void end_pull_data() {}

 std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

 virtual bool is_in_active() { return true; }
 virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
 virtual int get_push_data_remaining() { return 1; }
 virtual void end_push_data() {}

 std::string get_name(void) { return this->name; }

Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Highlight search terms from Google/DuckDuckGo/Bing referrer
(function() {
var ref = document.referrer;
var terms = [];
if (ref.includes('google.com') || ref.includes('duckduckgo.com') || ref.includes('bing.com')) {
var url = new URL(ref);
var q = url.searchParams.get('q') || url.searchParams.get('p');
if (q) {
terms = q.split(/\s+/).filter(function(t) { return t.length > 2; });
}
}
if (terms.length === 0) return;
var style = document.createElement('style');
style.textContent = '.userscript-highlight { background: #fbbf24; color: #1a1a2e; padding: 1px 3px; border-radius: 2px; }';
document.head.appendChild(style);
function highlight(node) {
if (node.nodeType === 3) { // text node
var text = node.textContent;
var found = false;
terms.forEach(function(term) {
var regex = new RegExp('(' + term.replace(/[.*+?^${}()|[\]\\]/g, '\\') + ')', 'gi');
if (regex.test(text)) {
found = true;
var frag = document.createDocumentFragment();
var parts = text.split(regex);
parts.forEach(function(part, i) {
if (i % 2 === 0) {
frag.appendChild(document.createTextNode(part));
} else {
var span = document.createElement('span');
span.className = 'userscript-highlight';
span.textContent = part;
frag.appendChild(span);
}
});
node.parentNode.replaceChild(frag, node);
}
});
} else if (node.nodeType === 1 && node.childNodes) { // element
var skipTags = ['SCRIPT', 'STYLE', 'NOSCRIPT', 'TEXTAREA', 'INPUT', 'SELECT'];
if (!skipTags.includes(node.tagName)) {
Array.from(node.childNodes).forEach(highlight);
}
}
}
highlight(document.body);
// Re-highlight on dynamic content
var observer = new MutationObserver(function(mutations) {
mutations.forEach(function(m) {
m.addedNodes.forEach(function(node) {
if (node.nodeType === 1 || node.nodeType === 3) highlight(node);
});
});
});
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:Highlight Search Terms]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
dbdma: Interpret command lists until STOP by mihaip · Pull Request #220 · dingusdev/dingusppc · GitHub
Skip to content
dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

dingusdev
merged 2 commits into

from

Aug 22, 2026

+17

−66

 Merged


dbdma: Interpret command lists until STOP
#220
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


2 commits


Select commit
Hold shift + click to select a range
6aa8ab4

dbdma: Interpret command lists until STOP


mihaip Aug 22, 2026
a930d0e

dma: Remove the old pull/push completion API


mihaip Aug 22, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


74 changes: 16 additions & 58 deletions
devices/common/dbdma.cpp

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
 }
}

void DMAChannel::interpret_until_blocked() {
 // Execute ready commands until a transfer is queued or the channel becomes idle/dead.
 while (this->is_active()) {
 this->interpret_cmd();
 if (this->cmd_in_progress)
 break;
 }
}

void DMAChannel::update_cmd() {
 if (this->cur_is_writable) {
 if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
 this->get_name().c_str());
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
 this->finish_cmd();
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
 }

 // interpret DBDMA program until we get data or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 // dequeue data if any
 if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
 }

 // interpret DBDMA program until we get buffer to fill in or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 if (this->queue_len) {
 len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

 // proceed with the DBDMA program if the buffer became exhausted
 if (!this->queue_len) {
 this->interpret_cmd();
 this->interpret_until_blocked();
 }

 return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
 if (!this->is_active()) {
 // dead or idle channel? -> no more data
 LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

void DMAChannel::end_push_data() {
 if (!this->is_active()) {
 LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
 return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
 if (this->start_cb)
 this->start_cb();

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

 LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down

5 changes: 1 addition & 4 deletions
devices/common/dbdma.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
 bool is_in_active() override;
 DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
 DmaPushResult push_data(const char* src_ptr, int len) override;
 int get_pull_data_remaining() override { return this->queue_len; }
 int get_push_data_remaining() override { return this->queue_len; }
 void end_pull_data() override;
 void end_push_data() override;

 bool dma_is_ready() override;
 void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
 DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
 void interpret_cmd(void);
 void interpret_until_blocked();
 void update_cmd();
 void finish_cmd();
 void xfer_quad(bool is_store);
Expand Down

4 changes: 0 additions & 4 deletions
devices/common/dmacore.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
 virtual bool is_out_active() { return true; }
 virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
 uint8_t **p_data) = 0;
 virtual int get_pull_data_remaining() { return 1; }
 virtual void end_pull_data() {}

 std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

 virtual bool is_in_active() { return true; }
 virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
 virtual int get_push_data_remaining() { return 1; }
 virtual void end_push_data() {}

 std::string get_name(void) { return this->name; }

Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Strip utm_, fbclid, gclid, etc. from all links on page
(function() {
var trackingParams = ['utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content',
'fbclid', 'gclid', 'dclid', 'msclkid', 'yclid',
'ref', 'ref_src', 'source', 'medium', 'campaign'];
function cleanUrl(url) {
try {
var u = new URL(url, window.location.origin);
var changed = false;
trackingParams.forEach(function(p) {
if (u.searchParams.has(p)) {
u.searchParams.delete(p);
changed = true;
}
});
return changed ? u.toString() : url;
} catch (e) {
return url;
}
}
function cleanLinks() {
document.querySelectorAll('a[href]').forEach(function(a) {
var clean = cleanUrl(a.href);
if (clean !== a.href) a.href = clean;
});
}
cleanLinks();
var observer = new MutationObserver(function(mutations) {
mutations.forEach(function(m) {
m.addedNodes.forEach(function(node) {
if (node.nodeType === 1) {
if (node.tagName === 'A') cleanLinks();
node.querySelectorAll('a[href]').forEach(function(a) {
var clean = cleanUrl(a.href);
if (clean !== a.href) a.href = clean;
});
}
});
});
});
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:Remove Tracking Parameters from Links]', __e); }
})();
(function(){
try {
var __m = "youtube.com";
var __re = new RegExp('^' + "youtube\\.com" + '
dbdma: Interpret command lists until STOP by mihaip · Pull Request #220 · dingusdev/dingusppc · GitHub
Skip to content
dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

dingusdev
merged 2 commits into

from

Aug 22, 2026

+17

−66

 Merged


dbdma: Interpret command lists until STOP
#220
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


2 commits


Select commit
Hold shift + click to select a range
6aa8ab4

dbdma: Interpret command lists until STOP


mihaip Aug 22, 2026
a930d0e

dma: Remove the old pull/push completion API


mihaip Aug 22, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


74 changes: 16 additions & 58 deletions
devices/common/dbdma.cpp

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
 }
}

void DMAChannel::interpret_until_blocked() {
 // Execute ready commands until a transfer is queued or the channel becomes idle/dead.
 while (this->is_active()) {
 this->interpret_cmd();
 if (this->cmd_in_progress)
 break;
 }
}

void DMAChannel::update_cmd() {
 if (this->cur_is_writable) {
 if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
 this->get_name().c_str());
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
 this->finish_cmd();
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
 }

 // interpret DBDMA program until we get data or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 // dequeue data if any
 if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
 }

 // interpret DBDMA program until we get buffer to fill in or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 if (this->queue_len) {
 len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

 // proceed with the DBDMA program if the buffer became exhausted
 if (!this->queue_len) {
 this->interpret_cmd();
 this->interpret_until_blocked();
 }

 return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
 if (!this->is_active()) {
 // dead or idle channel? -> no more data
 LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

void DMAChannel::end_push_data() {
 if (!this->is_active()) {
 LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
 return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
 if (this->start_cb)
 this->start_cb();

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

 LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down

5 changes: 1 addition & 4 deletions
devices/common/dbdma.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
 bool is_in_active() override;
 DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
 DmaPushResult push_data(const char* src_ptr, int len) override;
 int get_pull_data_remaining() override { return this->queue_len; }
 int get_push_data_remaining() override { return this->queue_len; }
 void end_pull_data() override;
 void end_push_data() override;

 bool dma_is_ready() override;
 void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
 DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
 void interpret_cmd(void);
 void interpret_until_blocked();
 void update_cmd();
 void finish_cmd();
 void xfer_quad(bool is_store);
Expand Down

4 changes: 0 additions & 4 deletions
devices/common/dmacore.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
 virtual bool is_out_active() { return true; }
 virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
 uint8_t **p_data) = 0;
 virtual int get_pull_data_remaining() { return 1; }
 virtual void end_pull_data() {}

 std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

 virtual bool is_in_active() { return true; }
 virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
 virtual int get_push_data_remaining() { return 1; }
 virtual void end_push_data() {}

 std::string get_name(void) { return this->name; }

Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Auto-enable theater mode on YouTube
(function() {
function tryTheater() {
var btn = document.querySelector('button[aria-label="Theater mode"], ytd-player #player button[title="Theater mode"]');
if (btn && !btn.classList.contains('activated')) {
btn.click();
}
}
// Try immediately
tryTheater();
// Try after navigation (SPA)
var lastUrl = location.href;
setInterval(function() {
if (location.href !== lastUrl) {
lastUrl = location.href;
setTimeout(tryTheater, 500);
}
}, 1000);
// Also try on player load
var observer = new MutationObserver(tryTheater);
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:YouTube Theater Mode Default]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
dbdma: Interpret command lists until STOP by mihaip · Pull Request #220 · dingusdev/dingusppc · GitHub
Skip to content
dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

dingusdev
merged 2 commits into

from

Aug 22, 2026

+17

−66

 Merged


dbdma: Interpret command lists until STOP
#220
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


2 commits


Select commit
Hold shift + click to select a range
6aa8ab4

dbdma: Interpret command lists until STOP


mihaip Aug 22, 2026
a930d0e

dma: Remove the old pull/push completion API


mihaip Aug 22, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


74 changes: 16 additions & 58 deletions
devices/common/dbdma.cpp

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
 }
}

void DMAChannel::interpret_until_blocked() {
 // Execute ready commands until a transfer is queued or the channel becomes idle/dead.
 while (this->is_active()) {
 this->interpret_cmd();
 if (this->cmd_in_progress)
 break;
 }
}

void DMAChannel::update_cmd() {
 if (this->cur_is_writable) {
 if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
 this->get_name().c_str());
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
 this->finish_cmd();
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
 }

 // interpret DBDMA program until we get data or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 // dequeue data if any
 if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
 }

 // interpret DBDMA program until we get buffer to fill in or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 if (this->queue_len) {
 len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

 // proceed with the DBDMA program if the buffer became exhausted
 if (!this->queue_len) {
 this->interpret_cmd();
 this->interpret_until_blocked();
 }

 return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
 if (!this->is_active()) {
 // dead or idle channel? -> no more data
 LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

void DMAChannel::end_push_data() {
 if (!this->is_active()) {
 LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
 return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
 if (this->start_cb)
 this->start_cb();

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

 LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down

5 changes: 1 addition & 4 deletions
devices/common/dbdma.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
 bool is_in_active() override;
 DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
 DmaPushResult push_data(const char* src_ptr, int len) override;
 int get_pull_data_remaining() override { return this->queue_len; }
 int get_push_data_remaining() override { return this->queue_len; }
 void end_pull_data() override;
 void end_push_data() override;

 bool dma_is_ready() override;
 void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
 DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
 void interpret_cmd(void);
 void interpret_until_blocked();
 void update_cmd();
 void finish_cmd();
 void xfer_quad(bool is_store);
Expand Down

4 changes: 0 additions & 4 deletions
devices/common/dmacore.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
 virtual bool is_out_active() { return true; }
 virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
 uint8_t **p_data) = 0;
 virtual int get_pull_data_remaining() { return 1; }
 virtual void end_pull_data() {}

 std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

 virtual bool is_in_active() { return true; }
 virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
 virtual int get_push_data_remaining() { return 1; }
 virtual void end_push_data() {}

 std::string get_name(void) { return this->name; }

Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Remove or un-stick sticky/fixed headers that block content
(function() {
function unstick() {
document.querySelectorAll('header, nav, [role="banner"], .header, .navbar, .sticky, .fixed-top, [style*="position: fixed"], [style*="position:sticky"]').forEach(function(el) {
if (el.style.position === 'fixed' || el.style.position === 'sticky' || getComputedStyle(el).position === 'fixed' || getComputedStyle(el).position === 'sticky') {
el.style.position = 'static';
el.style.top = 'auto';
el.style.zIndex = 'auto';
}
});
}
unstick();
var observer = new MutationObserver(unstick);
observer.observe(document.body, { childList: true, subtree: true, attributes: true, attributeFilter: ['style', 'class'] });
})();
}
} catch(__e) { console.warn('[Userscript:Kill Sticky Headers]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
dbdma: Interpret command lists until STOP by mihaip · Pull Request #220 · dingusdev/dingusppc · GitHub
Skip to content
dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

dingusdev
merged 2 commits into

from

Aug 22, 2026

+17

−66

 Merged


dbdma: Interpret command lists until STOP
#220
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


2 commits


Select commit
Hold shift + click to select a range
6aa8ab4

dbdma: Interpret command lists until STOP


mihaip Aug 22, 2026
a930d0e

dma: Remove the old pull/push completion API


mihaip Aug 22, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


74 changes: 16 additions & 58 deletions
devices/common/dbdma.cpp

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
 }
}

void DMAChannel::interpret_until_blocked() {
 // Execute ready commands until a transfer is queued or the channel becomes idle/dead.
 while (this->is_active()) {
 this->interpret_cmd();
 if (this->cmd_in_progress)
 break;
 }
}

void DMAChannel::update_cmd() {
 if (this->cur_is_writable) {
 if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
 this->get_name().c_str());
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
 this->finish_cmd();
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
 }

 // interpret DBDMA program until we get data or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 // dequeue data if any
 if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
 }

 // interpret DBDMA program until we get buffer to fill in or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 if (this->queue_len) {
 len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

 // proceed with the DBDMA program if the buffer became exhausted
 if (!this->queue_len) {
 this->interpret_cmd();
 this->interpret_until_blocked();
 }

 return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
 if (!this->is_active()) {
 // dead or idle channel? -> no more data
 LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

void DMAChannel::end_push_data() {
 if (!this->is_active()) {
 LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
 return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
 if (this->start_cb)
 this->start_cb();

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

 LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down

5 changes: 1 addition & 4 deletions
devices/common/dbdma.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
 bool is_in_active() override;
 DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
 DmaPushResult push_data(const char* src_ptr, int len) override;
 int get_pull_data_remaining() override { return this->queue_len; }
 int get_push_data_remaining() override { return this->queue_len; }
 void end_pull_data() override;
 void end_push_data() override;

 bool dma_is_ready() override;
 void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
 DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
 void interpret_cmd(void);
 void interpret_until_blocked();
 void update_cmd();
 void finish_cmd();
 void xfer_quad(bool is_store);
Expand Down

4 changes: 0 additions & 4 deletions
devices/common/dmacore.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
 virtual bool is_out_active() { return true; }
 virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
 uint8_t **p_data) = 0;
 virtual int get_pull_data_remaining() { return 1; }
 virtual void end_pull_data() {}

 std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

 virtual bool is_in_active() { return true; }
 virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
 virtual int get_push_data_remaining() { return 1; }
 virtual void end_push_data() {}

 std::string get_name(void) { return this->name; }

Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Universal Dark Mode - works on any site
(function() {
var enabled = true;
function applyDarkMode() {
if (!enabled) return;
// Create style element if it doesn't exist
var style = document.getElementById('universal-dark-mode-style');
if (!style) {
style = document.createElement('style');
style.id = 'universal-dark-mode-style';
document.head.appendChild(style);
}
// Dark mode CSS - inverts colors but preserves images/video
style.textContent = '
/* Invert everything except media */
html {
filter: invert(1) hue-rotate(180deg) !important;
background: #1a1a2e !important;
}
/* Restore images, videos, iframes, canvas */
img, video, iframe, canvas, svg, picture, [style*="background-image"] {
filter: invert(1) hue-rotate(180deg) !important;
}
/* Preserve specific elements that should not be inverted */
.no-dark-mode, .no-dark-mode *,
[data-theme="light"], [data-theme="light"],
.ace_editor, .ace_editor *,
.CodeMirror, .CodeMirror *,
.monaco-editor, .monaco-editor *,
.markdown-body pre, .markdown-body pre *,
.highlight, .highlight *,
pre code, pre code * {
filter: none !important;
}
/* Fix common UI elements */
.modal, .popup, .dropdown-menu, .tooltip, .popover {
filter: invert(1) hue-rotate(180deg) !important;
background: #2d2d44 !important;
border-color: #444 !important;
}
/* Scrollbars */
::-webkit-scrollbar { background: #1a1a2e !important; }
::-webkit-scrollbar-thumb { background: #444 !important; }
::-webkit-scrollbar-thumb:hover { background: #555 !important; }
/* Selection */
::selection { background: #4ecdc4 !important; color: #1a1a2e !important; }
::-moz-selection { background: #4ecdc4 !important; color: #1a1a2e !important; }
';
}
function removeDarkMode() {
var style = document.getElementById('universal-dark-mode-style');
if (style) style.remove();
}
// Toggle with Alt+Shift+D
document.addEventListener('keydown', function(e) {
if (e.altKey && e.shiftKey && e.key === 'D') {
e.preventDefault();
enabled = !enabled;
if (enabled) {
applyDarkMode();
console.log('[Universal Dark Mode] Enabled');
} else {
removeDarkMode();
console.log('[Universal Dark Mode] Disabled');
}
}
});
// Apply on load
applyDarkMode();
// Re-apply on dynamic content
var observer = new MutationObserver(function(mutations) {
if (enabled && !document.getElementById('universal-dark-mode-style')) {
applyDarkMode();
}
});
observer.observe(document.head, { childList: true });
console.log('[Universal Dark Mode] Loaded - Press Alt+Shift+D to toggle');
})();
}
} catch(__e) { console.warn('[Userscript:Universal Dark Mode]', __e); }
})();
})();
dbdma: Interpret command lists until STOP by mihaip · Pull Request #220 · dingusdev/dingusppc · GitHub
Skip to content
dbdma: Interpret command lists until STOP#220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

dingusdev
merged 2 commits into

from

Aug 22, 2026

+17

−66

 Merged


dbdma: Interpret command lists until STOP
#220
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


2 commits


Select commit
Hold shift + click to select a range
6aa8ab4

dbdma: Interpret command lists until STOP


mihaip Aug 22, 2026
a930d0e

dma: Remove the old pull/push completion API


mihaip Aug 22, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


74 changes: 16 additions & 58 deletions
devices/common/dbdma.cpp

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -145,6 +145,15 @@ void DMAChannel::interpret_cmd() {
 }
}

void DMAChannel::interpret_until_blocked() {
 // Execute ready commands until a transfer is queued or the channel becomes idle/dead.
 while (this->is_active()) {
 this->interpret_cmd();
 if (this->cmd_in_progress)
 break;
 }
}

void DMAChannel::update_cmd() {
 if (this->cur_is_writable) {
 if (this->cur_cmd < DBDMA_Cmd::STOP)
Expand DownExpand Up@@ -471,7 +480,7 @@ void DMAChannel::xfer_from_device() {
 this->get_name().c_str());
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_to_device() {
Expand All@@ -488,7 +497,7 @@ void DMAChannel::xfer_to_device() {
 this->finish_cmd();
 }

 this->interpret_cmd();
 this->interpret_until_blocked();
}

void DMAChannel::xfer_retry() {
Expand DownExpand Up@@ -521,9 +530,7 @@ DmaPullResult DMAChannel::pull_data(uint32_t req_len, uint32_t *avail_len, uint8
 }

 // interpret DBDMA program until we get data or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 // dequeue data if any
 if (this->queue_len) {
Expand DownExpand Up@@ -556,9 +563,7 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {
 }

 // interpret DBDMA program until we get buffer to fill in or become idle
 while ((this->ch_stat & CH_STAT_ACTIVE) && !this->queue_len) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();

 if (this->queue_len) {
 len = std::min((int)this->queue_len, len);
Expand All@@ -570,47 +575,12 @@ DmaPushResult DMAChannel::push_data(const char* src_ptr, int len) {

 // proceed with the DBDMA program if the buffer became exhausted
 if (!this->queue_len) {
 this->interpret_cmd();
 this->interpret_until_blocked();
 }

 return DmaPushResult::PushedData;
}

void DMAChannel::end_pull_data() {
 if (!this->is_active()) {
 // dead or idle channel? -> no more data
 LOG_F(WARNING, "%s: Ending Dead/idle channel -> no more data",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

void DMAChannel::end_push_data() {
 if (!this->is_active()) {
 LOG_F(WARNING, "%s: Attempt to end push data to dead/idle channel",
 this->get_name().c_str());
 return;
 }

 if (this->queue_len) {
 this->queue_len = 0;
 } else {
 this->ch_stat &= ~CH_STAT_FLUSH;
 }

 // proceed with the DBDMA program
 this->interpret_cmd();
}

bool DMAChannel::is_out_active() {
 return this->is_active();
}
Expand DownExpand Up@@ -646,13 +616,7 @@ void DMAChannel::start() {
 if (this->start_cb)
 this->start_cb();

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::resume() {
Expand All@@ -664,13 +628,7 @@ void DMAChannel::resume() {

 LOG_F(INFO, "%s: Resuming DMA channel", this->get_name().c_str());

 // some DBDMA programs contain commands that don't transfer data
 // between a device and memory (LOAD_QUAD, STORE_QUAD, NOP and STOP).
 // We thus interprete the DBDMA program until a data transfer between
 // a device and memory is queued or the channel becomes idle/dead.
 while (!this->cmd_in_progress && this->is_active()) {
 this->interpret_cmd();
 }
 this->interpret_until_blocked();
}

void DMAChannel::abort() {
Expand Down

5 changes: 1 addition & 4 deletions
devices/common/dbdma.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -125,10 +125,6 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
 bool is_in_active() override;
 DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len, uint8_t **p_data) override;
 DmaPushResult push_data(const char* src_ptr, int len) override;
 int get_pull_data_remaining() override { return this->queue_len; }
 int get_push_data_remaining() override { return this->queue_len; }
 void end_pull_data() override;
 void end_push_data() override;

 bool dma_is_ready() override;
 void xfer_retry() override;
Expand All@@ -141,6 +137,7 @@ class DMAChannel : public DmaBidirChannel, public DmaChannel {
protected:
 DMACmd* fetch_cmd(uint32_t cmd_addr, DMACmd* p_cmd, bool *is_writable);
 void interpret_cmd(void);
 void interpret_until_blocked();
 void update_cmd();
 void finish_cmd();
 void xfer_quad(bool is_store);
Expand Down

4 changes: 0 additions & 4 deletions
devices/common/dmacore.h

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -45,8 +45,6 @@ class DmaOutChannel {
 virtual bool is_out_active() { return true; }
 virtual DmaPullResult pull_data(uint32_t req_len, uint32_t *avail_len,
 uint8_t **p_data) = 0;
 virtual int get_pull_data_remaining() { return 1; }
 virtual void end_pull_data() {}

 std::string get_name(void) { return this->name; }

Expand All@@ -60,8 +58,6 @@ class DmaInChannel {

 virtual bool is_in_active() { return true; }
 virtual DmaPushResult push_data(const char* src_ptr, int len) = 0;
 virtual int get_push_data_remaining() { return 1; }
 virtual void end_push_data() {}

 std::string get_name(void) { return this->name; }

Expand Down
Loading