/*?
?*?Copyright?2008?TKK/ComNet
?*?Released?under?GPLv3.?See?LICENSE.txt?for?details.?
?*/
package?core;

import?routing.MessageRouter;

/**
?*?A?connection?between?two?DTN?nodes.
?*/
public?class?Connection?{
	private?DTNHost?toNode;
	private?DTNHost?fromNode;
	private?DTNHost?msgFromNode;
	private?boolean?isUp;
	private?int?speed;
	private?Message?msgOnFly;
	private?double?transferDoneTime;
	/**?how?many?bytes?this?connection?has?transferred?*/
	private?int?bytesTransferred;
	/**
	?*?Creates?a?new?connection?between?nodes?and?sets?the?connection
	?*?state?to?“up“.
	?*?@param?fromNode?The?node?that?initiated?the?connection
	?*?@param?toNode?The?node?in?the?other?side?of?the?connection
	?*?@param?connectionSpeed?Transfer?speed?of?the?connection?（Bps）
	?*/
	public?Connection（DTNHost?fromNode?DTNHost?toNode?int?connectionSpeed）?{
		this.fromNode?=?fromNode;
		this.toNode?=?toNode;
		this.speed?=?connectionSpeed;
		this.isUp?=?true;
		this.transferDoneTime?=?0;
		this.bytesTransferred?=?0;
	}
	
	/**
	?*?Returns?true?if?the?connection?is?up
	?*?@return?state?of?the?connection
	?*/
	public?boolean?isUp（）?{
		return?this.isUp;
	}
	
	/**
	?*?Returns?true?if?the?given?node?is?the?initiator?of?the?connection?false
	?*?otherwise
	?*?@param?node?The?node?to?check
	?*?@return?true?if?the?given?node?is?the?initiator?of?the?connection
	?*/
	public?boolean?isInitiator（DTNHost?node）?{
		return?node?==?this.fromNode;
	}
	
	/**
	?*?Sets?the?state?of?the?connection.
	?*?@param?state?True?if?the?connection?is?up?false?if?not
	?*/
	public?void?setUpState（boolean?state）?{
		this.isUp?=?state;
	}
	
	/**
	?*?Sets?a?message?that?this?connection?is?currently?transferring.?If?message
	?*?passing?is?controlled?by?external?events?this?method?is?not?needed
	?*?（but?then?e.g.?{@link?#finalizeTransfer（）}?and?
	?*?{@link?#isMessageTransferred（）}?will?not?work?either）.?Only?a?one?message
	?*?at?a?time?can?be?transferred?using?one?connection.
	?*?@param?m?The?message
	?*?@return?The?value?returned?by?
	?*?{@link?MessageRouter#receiveMessage（Message?DTNHost）}
	?*/
	public?int?startTransfer（DTNHost?from?Message?m）?{
		assert?this.msgOnFly?==?null?:?“Already?transferring?“?+?
			this.msgOnFly?+?“?from?“?+?this.msgFromNode?+?“?to?“?+?
			this.getOtherNode（this.msgFromNode）?+?“.?Can‘t?“+?
			“start?transfer?of?“?+?m?+?“?from?“?+?from;
		
		this.msgFromNode?=?from;
		Message?newMessage?=?m.replicate（）;
		int?retVal?=?getOtherNode（from）.receiveMessage（newMessage?from）;
		
		if?（retVal?==?MessageRouter.RCV_OK）?{
			this.msgOnFly?=?newMessage;
			this.transferDoneTime?=?SimClock.getTime（）?+?
				（1.0*m.getSize（））?/?this.speed;
		}

		return?retVal;
	}

	/**
	?*?Aborts?the?transfer?of?the?currently?transferred?message.
	?*/
	public?void?abortTransfer（）?{
		assert?msgOnFly?!=?null?:?“No?message?to?abort?at?“?+?msgFromNode;
		int?bytesRemaining?=?getRemainingByteCount（）;

		this.bytesTransferred?+=?msgOnFl

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2008-08-25?19:45??one\
?????文件????????2480??2008-08-25?19:44??one\HISTORY.txt
?????文件?????????246??2007-07-19?12:24??one\prophet_settings.txt
?????目錄???????????0??2008-08-25?19:45??one\test\
?????文件????????5352??2008-08-19?22:21??one\test\ConnectionTest.java
?????文件????????3312??2008-08-19?22:21??one\test\TestUtils.java
?????文件????????1289??2008-08-19?22:21??one\test\WKTPointReaderTest.java
?????文件????????4410??2008-08-19?22:21??one\test\AbstractRouterTest.java
?????文件?????????747??2008-08-19?22:21??one\test\CoordTest.java
?????文件????????1222??2008-08-19?22:21??one\test\StationaryMovement.java
?????文件????????3594??2008-08-19?22:21??one\test\MessageChecker.java
?????文件????????6329??2008-08-19?22:21??one\test\PointsOfInterestTest.java
?????文件????????2274??2008-08-19?22:21??one\test\DijkstraPathFinderTest.java
?????文件???????18208??2008-08-19?22:21??one\test\EpidemicRouterTest.java
?????文件????????1921??2008-08-19?22:21??one\test\ExternalMovementReaderTest.java
?????文件????????4382??2007-11-20?23:07??one\test\MaxPropDijkstraTest.java
?????文件????????2181??2008-08-19?22:21??one\test\MapNodeTest.java
?????文件????????9463??2008-04-16?22:07??one\test\MaxPropRouterTest.java
?????文件????????6918??2008-08-19?22:21??one\test\WKTReaderTest.java
?????文件????????4560??2008-08-19?22:21??one\test\ContactTimesReportTest.java
?????文件????????2134??2008-08-19?22:21??one\test\MessageGraphvizReportTest.java
?????文件????????3345??2008-08-19?22:21??one\test\ExternalMovementTest.java
?????文件????????1560??2008-08-19?22:21??one\test\TestSettings.java
?????文件????????5673??2008-08-19?22:21??one\test\SettingsTest.java
?????文件????????1685??2008-08-19?22:21??one\test\ActivenessHandlerTest.java
?????文件????????2278??2008-08-19?22:21??one\test\DistanceDelayReportTest.java
?????文件????????3761??2008-08-19?22:21??one\test\TotalContactTimeReportTest.java
?????文件????????2608??2008-08-19?22:21??one\test\ExternalEventsQueueTest.java
?????文件?????????168??2007-07-19?12:24??one\test\package.html
?????文件????????4538??2008-08-19?22:21??one\test\ProphetRouterTest.java
?????文件????????1431??2008-08-19?22:21??one\test\TestDTNHost.java
............此處省略280個文件信息