Netcore

Transport Layer (Pipe)

Overview

The Pipe layer provides a unified interface for data transmission, abstracting away the underlying transport mechanism.

Core Concepts

1. Transport Functions

• Receive function: recv_func(size) -> bytes
• Send function: send_func(data) -> None

2. Queue Management

• Mission queue for outgoing data
• Reception queue for incoming data
• Automatic queue processing

3. Threading Model

• Separate send/receive threads
• Thread safety mechanisms
• Error handling

Features

1. Mission-based Transfer

• Unique mission IDs
• Progress tracking
• Completion verification

2. Error Handling

• Automatic retry
• Exception management
• Logging system

3. Queue Management

• Priority queuing
• Flow control
• Buffer management

Implementation Examples

Basic Implementation

from netcore import Pipe

def recv_func(size):
    # Implement receive logic
    return data

def send_func(data):
    # Implement send logic
    pass

pipe = Pipe(recv_func, send_func)
pipe.start()

With Error Handling

def recv_func(size):
    try:
        return device.read(size)
    except Exception as e:
        logger.error(f"Read error: {e}")
        return b''

pipe = Pipe(recv_func, send_func)

This site is open source. Improve this page.