wip

Author: xoviat

src/common.ts

@@ -456,13 +456,14 @@ export class RTTServerHelper {
         });
     }
 
-    public emitConfigures(cfg: RTTConfiguration, obj: EventEmitter): boolean {
+    public emitConfigures(cfg: RTTConfiguration, executable: string, obj: EventEmitter): boolean {
         let ret = false;
         if (cfg.enabled) {
             for (const dec of cfg.decoders) {
                 if (dec.tcpPort || dec.tcpPorts) {
                     obj.emit('event', new RTTConfigureEvent({
                         type: 'socket',
+                        executable: executable,
                         decoder: dec
                     }));
                     ret = true;

src/frontend/extension.ts

@@ -12,7 +12,7 @@ import { MemoryContentProvider } from './memory_content_provider';
 import Reporting from '../reporting';
 
 import { CortexDebugConfigurationProvider } from './configprovider';
-import { JLinkSocketRTTSource, SocketRTTSource, SocketSWOSource, PeMicroSocketSource } from './swo/sources/socket';
+import { JLinkSocketRTTSource, SocketRTTSource, SocketSWOSource, PeMicroSocketSource, DefmtSocketRTTSource } from './swo/sources/socket';
 import { FifoSWOSource } from './swo/sources/fifo';
 import { FileSWOSource } from './swo/sources/file';
 import { SerialSWOSource } from './swo/sources/serial';
@@ -770,7 +770,7 @@ export class CortexDebugExtension {
     private receivedRTTConfigureEvent(e: vscode.DebugSessionCustomEvent) {
         if (e.body.type === 'socket') {
             const decoder: RTTCommonDecoderOpts = e.body.decoder;
-            if ((decoder.type === 'console') || (decoder.type === 'binary')) {
+            if ((decoder.type === 'console') || (decoder.type === 'binary') || (decoder.type === 'defmt')) {
                 Reporting.sendEvent('RTT', 'Source', 'Socket: Console');
                 this.rttCreateTerninal(e, decoder as RTTConsoleDecoderOpts);
             } else {
@@ -801,6 +801,8 @@ export class CortexDebugExtension {
             }
             if (mySession.config.servertype === 'jlink') {
                 src = new JLinkSocketRTTSource(tcpPort, channel);
+            } else if (e.body.decoder.type === 'defmt') {
+                src = new DefmtSocketRTTSource(tcpPort, channel, e.body.executable);
             } else {
                 src = new SocketRTTSource(tcpPort, channel);
             }

src/frontend/swo/sources/socket.ts

@@ -5,6 +5,7 @@ import { parseHostPort } from '../../../common';
 import * as vscode from 'vscode';
 import { TextDecoder } from 'util';
 import { setFlagsFromString } from 'v8';
+import * as ChildProcess from 'child_process';
 
 const TimerInterval = 250;
 export class SocketSWOSource extends EventEmitter implements SWORTTSource {
@@ -135,6 +136,33 @@ export class SocketRTTSource extends SocketSWOSource {
     }
 }
 
+export class DefmtSocketRTTSource extends SocketRTTSource {
+    private process: ChildProcess.ChildProcess;
+    private executable: string;
+    private cwd: string;
+
+    protected processData(buffer: Buffer): void {
+        this.process.stdin.write(buffer);
+    }
+
+    public start(timeout = (1000 * 60 * 5)): Promise<void> {
+        this.process = ChildProcess.spawn(
+            'defmt-print',['-e', this.executable], { cwd: this.cwd }
+        );
+
+        this.process.stdout.on('data', (buffer) => this.emit('data', buffer));
+
+        return super.start(timeout);
+    }
+
+    constructor(tcpPort: string, public readonly channel: number, executable: string) {
+        super(tcpPort, channel);
+
+        this.executable = executable;
+        this.cwd = process.cwd(); // TODO: Use workspace directory as cwd
+    }    
+}
+
 export class JLinkSocketRTTSource extends SocketRTTSource {
     constructor(tcpPort: string, public readonly channel: number) {
         super(tcpPort, channel);

src/jlink.ts

@@ -222,6 +222,6 @@ export class JLinkServerController extends EventEmitter implements GDBServerCont
     }
     public debuggerLaunchStarted(): void {}
     public debuggerLaunchCompleted(): void {
-        this.rttHelper.emitConfigures(this.args.rttConfig, this);
+        this.rttHelper.emitConfigures(this.args.rttConfig, this.args.executable, this);
     }
 }

src/openocd.ts

@@ -307,7 +307,7 @@ export class OpenOCDServerController extends EventEmitter implements GDBServerCo
         this.session = obj;
     }
     public debuggerLaunchCompleted(): void {
-        const hasRtt = this.rttHelper.emitConfigures(this.args.rttConfig, this);
+        const hasRtt = this.rttHelper.emitConfigures(this.args.rttConfig, this.args.executable, this);
         if (this.args.ctiOpenOCDConfig?.enabled) {
             this.ctiStopResume(CTIAction.init);
         }