diff --git a/include/rogue/interfaces/stream/Slave.h b/include/rogue/interfaces/stream/Slave.h
index c730e35ef..029d44b1e 100644
--- a/include/rogue/interfaces/stream/Slave.h
+++ b/include/rogue/interfaces/stream/Slave.h
@@ -126,6 +126,29 @@ class Slave : public rogue::interfaces::stream::Pool,
      */
     uint64_t getByteCount();
 
+    //! Ensure frame is a single buffer
+    /** This method makes sure the passed frame is composed of a single buffer.
+     *  If the reqNew flag is true and the passed frame is not a single buffer, a
+     *  new frame will be requested and the frame data will be copied, with the passed
+     *  frame pointer being updated. The return value will indicate if the frame is a
+     *  single buffer at the end of the process. A frame lock must be held when this
+     *  method is called.
+     *
+     * Not exposed to Python
+     * @param frame Reference to frame pointer (FramePtr)
+     * @param rewEn Flag to determine if a new frame should be requested
+     */
+    bool ensureSingleBuffer(std::shared_ptr<rogue::interfaces::stream::Frame>& frame, bool reqEn);
+
+    // Process a local frame request
+    /* Method to service a local frame request
+     *
+     * size Minimum size for requested Frame, larger Frame may be allocated
+     * zeroCopyEn Flag which indicates if a zero copy mode Frame is allowed.
+     * Newly allocated Frame pointer (FramePtr)
+     */
+    std::shared_ptr<rogue::interfaces::stream::Frame> reqLocalFrame(uint32_t size, bool zeroCopyEn);
+
 #ifndef NO_PYTHON
 
     //! Support << operator in python
diff --git a/src/rogue/hardware/axi/AxiStreamDma.cpp b/src/rogue/hardware/axi/AxiStreamDma.cpp
index 702aec446..d7330925a 100644
--- a/src/rogue/hardware/axi/AxiStreamDma.cpp
+++ b/src/rogue/hardware/axi/AxiStreamDma.cpp
@@ -270,7 +270,7 @@ ris::FramePtr rha::AxiStreamDma::acceptReq(uint32_t size, bool zeroCopyEn) {
 
     // Zero copy is disabled. Allocate from memory.
     if (zeroCopyEn == false || desc_->rawBuff == NULL) {
-        frame = ris::Pool::acceptReq(size, false);
+        frame = reqLocalFrame(size, false);
     }
 
     // Allocate zero copy buffers from driver
diff --git a/src/rogue/interfaces/stream/Slave.cpp b/src/rogue/interfaces/stream/Slave.cpp
index 68fa6b323..3ba5107c7 100644
--- a/src/rogue/interfaces/stream/Slave.cpp
+++ b/src/rogue/interfaces/stream/Slave.cpp
@@ -140,6 +140,40 @@ uint64_t ris::Slave::getByteCount() {
     return (frameBytes_);
 }
 
+// Ensure passed frame is a single buffer
+bool ris::Slave::ensureSingleBuffer(ris::FramePtr& frame, bool reqEn) {
+    // Frame is a single buffer
+    if (frame->bufferCount() == 1)
+        return true;
+
+    else if (!reqEn)
+        return false;
+
+    else {
+        uint32_t size        = frame->getPayload();
+        ris::FramePtr nFrame = reqLocalFrame(size, true);
+
+        if (nFrame->bufferCount() != 1)
+            return false;
+
+        else {
+            nFrame->setPayload(size);
+
+            ris::FrameIterator srcIter = frame->begin();
+            ris::FrameIterator dstIter = nFrame->begin();
+
+            ris::copyFrame(srcIter, size, dstIter);
+            frame = nFrame;
+            return true;
+        }
+    }
+}
+
+// Process a local frame request
+ris::FramePtr ris::Slave::reqLocalFrame(uint32_t size, bool zeroCopyEn) {
+   return ris::Pool::acceptReq(size,zeroCopyEn);
+}
+
 void ris::Slave::setup_python() {
 #ifndef NO_PYTHON
 
diff --git a/src/rogue/interfaces/stream/TcpCore.cpp b/src/rogue/interfaces/stream/TcpCore.cpp
index 00523de97..2a5d91b4a 100644
--- a/src/rogue/interfaces/stream/TcpCore.cpp
+++ b/src/rogue/interfaces/stream/TcpCore.cpp
@@ -271,7 +271,7 @@ void ris::TcpCore::runThread() {
             size = zmq_msg_size(&(msg[3]));
 
             // Generate frame
-            frame = ris::Pool::acceptReq(size, false);
+            frame = reqLocalFrame(size, false);
             frame->setPayload(size);
 
             // Copy data
diff --git a/src/rogue/protocols/udp/Client.cpp b/src/rogue/protocols/udp/Client.cpp
index d8ad96dd3..579079d8a 100644
--- a/src/rogue/protocols/udp/Client.cpp
+++ b/src/rogue/protocols/udp/Client.cpp
@@ -197,7 +197,7 @@ void rpu::Client::runThread(std::weak_ptr<int> lockPtr) {
     udpLog_->logThreadId();
 
     // Preallocate frame
-    frame = ris::Pool::acceptReq(maxPayload(), false);
+    frame = reqLocalFrame(maxPayload(), false);
 
     while (threadEn_) {
         // Attempt receive
@@ -215,7 +215,7 @@ void rpu::Client::runThread(std::weak_ptr<int> lockPtr) {
             }
 
             // Get new frame
-            frame = ris::Pool::acceptReq(maxPayload(), false);
+            frame = reqLocalFrame(maxPayload(), false);
         } else {
             // Setup fds for select call
             FD_ZERO(&fds);
diff --git a/src/rogue/protocols/udp/Server.cpp b/src/rogue/protocols/udp/Server.cpp
index 7aa0826ee..03fec128a 100644
--- a/src/rogue/protocols/udp/Server.cpp
+++ b/src/rogue/protocols/udp/Server.cpp
@@ -200,7 +200,7 @@ void rpu::Server::runThread(std::weak_ptr<int> lockPtr) {
     udpLog_->logThreadId();
 
     // Preallocate frame
-    frame = ris::Pool::acceptReq(maxPayload(), false);
+    frame = reqLocalFrame(maxPayload(), false);
 
     while (threadEn_) {
         // Attempt receive
@@ -219,7 +219,7 @@ void rpu::Server::runThread(std::weak_ptr<int> lockPtr) {
             }
 
             // Get new frame
-            frame = ris::Pool::acceptReq(maxPayload(), false);
+            frame = reqLocalFrame(maxPayload(), false);
 
             // Lock before updating address
             if (memcmp(&remAddr_, &tmpAddr, sizeof(remAddr_)) != 0) {