mirror of
https://gitee.com/willfree/min-dev-java.git
synced 2026-10-04 19:42:01 +08:00
add class init
This commit is contained in:
1 parent
2a957851fa
commit
ff3e44c2e6
2 files changed
+6
-4
No files matched your search
@@ -23,7 +23,7 @@ public class LogicFace {
|
|||||||
// 成员变量区
|
// 成员变量区
|
||||||
public int logicFaceType;
|
public int logicFaceType;
|
||||||
public ITransport transport; // 与logicFace绑定的transport
|
public ITransport transport; // 与logicFace绑定的transport
|
||||||
public LinkService linkService; // 与logicFace绑定的linkService
|
public LinkService linkService=new LinkService(); // 与logicFace绑定的linkService
|
||||||
public LogicFaceCounters logicFaceCounters=new LogicFaceCounters(); // logicFace 流量统计对象
|
public LogicFaceCounters logicFaceCounters=new LogicFaceCounters(); // logicFace 流量统计对象
|
||||||
public long expireTime; // 超时时间 ms
|
public long expireTime; // 超时时间 ms
|
||||||
public boolean state; // true 为 up , false 为down
|
public boolean state; // true 为 up , false 为down
|
||||||
|
|||||||
@@ -12,8 +12,10 @@ import util.ConcurrentHelper;
|
|||||||
import util.TimeHelper;
|
import util.TimeHelper;
|
||||||
|
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
import java.util.concurrent.PriorityBlockingQueue;
|
import java.util.concurrent.PriorityBlockingQueue;
|
||||||
import java.util.concurrent.locks.Lock;
|
import java.util.concurrent.locks.Lock;
|
||||||
|
import java.util.concurrent.locks.ReentrantLock;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* @Author: Wang Feng
|
* @Author: Wang Feng
|
||||||
@@ -25,8 +27,8 @@ import java.util.concurrent.locks.Lock;
|
|||||||
public class LogicFaceICN extends LogicFace {
|
public class LogicFaceICN extends LogicFace {
|
||||||
public Timer timer; // 定时器,在processEvent函数中就被设置成很大的值
|
public Timer timer; // 定时器,在processEvent函数中就被设置成很大的值
|
||||||
public long recentExpireTime; // 最近将要超时的时间戳
|
public long recentExpireTime; // 最近将要超时的时间戳
|
||||||
public Map<String, PITEntry> mPit; // PIT表
|
public Map<String, PITEntry> mPit=new ConcurrentHashMap<>(); // PIT表
|
||||||
public Lock timeoutEventHeapLock; // 锁, mpit 、timeoutEventHeap、recentExpireTime
|
public Lock timeoutEventHeapLock=new ReentrantLock(); // 锁, mpit 、timeoutEventHeap、recentExpireTime
|
||||||
// 超时事件堆, 以超时时间排序的最小堆,初始化大小为1000
|
// 超时事件堆, 以超时时间排序的最小堆,初始化大小为1000
|
||||||
public PriorityBlockingQueue<TimeoutEvent> timeoutEventHeap
|
public PriorityBlockingQueue<TimeoutEvent> timeoutEventHeap
|
||||||
=new PriorityBlockingQueue<TimeoutEvent>(1000,new Comparator<TimeoutEvent>(){
|
=new PriorityBlockingQueue<TimeoutEvent>(1000,new Comparator<TimeoutEvent>(){
|
||||||
@@ -36,7 +38,7 @@ public class LogicFaceICN extends LogicFace {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
public Map<String, OnInterestInterface> mFib;
|
public Map<String, OnInterestInterface> mFib=new ConcurrentHashMap<>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 通过最长匹配原则查找FIB表,找到合适的兴趣包处理函数
|
* 通过最长匹配原则查找FIB表,找到合适的兴趣包处理函数
|
||||||
|
|||||||
Reference in new issue
Block a user