[fix]修正UdpServer在接收广播时连续启动接收的错误,在StarAgent中,此时可能收到广播包,SocketFlags是Broadcast,需要清空,否则报错“参考的对象类型不支持尝试的操作”; 无需设置SocketOptionName.PacketInformation,在ReceiveMessageFromAsync时会自动设置,并且支持ipv6;
石头
authored at
2024-10-10 00:36:00
石头
committed at
2024-10-10 00:45:43
X
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace XCode.Transform
{
/// <summary>数据抽取模块,用于自定义抽取过程中各个环节</summary>
public interface IETLModule
{
/// <summary>开始调度</summary>
void Start();
/// <summary>停止调度</summary>
void Stop();
/// <summary>首次初始化任务</summary>
void Init();
/// <summary>单批数据处理前</summary>
/// <param name="ctx">数据上下文</param>
/// <returns></returns>
Boolean Processing(DataContext ctx);
/// <summary>单批数据处理后</summary>
/// <param name="ctx">数据上下文</param>
void Processed(DataContext ctx);
/// <summary>抽取完成</summary>
/// <param name="ctx">数据上下文</param>
void Fetched(DataContext ctx);
/// <summary>实体列表完成后</summary>
/// <param name="ctx">数据上下文</param>
void OnFinished(DataContext ctx);
/// <summary>出错</summary>
/// <param name="ctx">数据上下文</param>
void OnError(DataContext ctx);
}
}
|