Sexy chatmsg

- * @param share File * Queues a Share File for calculating its URN.

Sexy chatmsg-79Sexy chatmsg-15

* @param hash Calc Queue if not null the thex calculation will be queued with * it if Shared File Thex Data is not yet available. DPhex; @@ -50,7 51,7 @@ /** * */ -public class Shared Files Service public class Shared Files Service implements File Hash Calculation Handler /** - * Queues a share file for calculating the urn. Modified Paths: -------------- phex/branches/i2phex/src/main/java/phex/net/Online Modified: phex/branches/i2phex/src/main/java/phex/net/Online =================================================================== --- phex/branches/i2phex/src/main/java/phex/net/Online 2007-11-05 UTC (rev 4030) phex/branches/i2phex/src/main/java/phex/net/Online 2007-11-06 UTC (rev 4031) @@ -60,7 60,7 @@ failed Connections ; if ( Debug Enabled( Online Observer.class ) && - failed Connections % 5 == 0 ) failed Connections % 3 == 0 ) This was sent by the Source collaborative development platform, the world's largest Open Source development site.

- * @param do Calculation set to true if the thex calculation should be - * performed if Thex Data is not yet available. Thex Calculation Worker; import phex.utils.*; import sax. = null) Modified: phex/trunk/src/main/java/phex/upload/handler/File Upload =================================================================== --- phex/trunk/src/main/java/phex/upload/handler/File Upload 2007-11-08 UTC (rev 4036) phex/trunk/src/main/java/phex/upload/handler/File Upload 2007-11-08 UTC (rev 4037) @@ -36,6 36,7 @@ import private Host Fetching Strategy host Fetching Strategy; private Host Manager() @@ -151,6 157,11 @@ public Host Fetching Strategy get Host Fetching Strategy() /////////////// START Network Hosts Container wrapper methods /////////////////////// This was sent by the Source collaborative development platform, the world's largest Open Source development site. rev=4031&view=rev Author: Arne Bab Date: 2007-11-05 -0800 (Mon, ) Log Message: ----------- Decreased number of failed connections necessary to start a GWeb Cache request (to 6), because i2Phex changes (and starts new) connections far slower than Phex.

Thex Calculation Worker; import phex.utils.*; @@ -165,7 166,7 @@ new File Rescan Timer(), File Rescan Timer. TIMER_PERIOD ); - search Engine = new Query Result Search Engine( this ); search Engine = new Query Result Search Engine( Instance(), this ); directory Share Map = new Hash Map(); Modified: phex/trunk/src/main/java/phex/share/export/Export =================================================================== --- phex/trunk/src/main/java/phex/share/export/Export 2007-11-10 UTC (rev 4040) phex/trunk/src/main/java/phex/share/export/Export 2007-11-10 UTC (rev 4041) @@ -33,6 33,7 @@ import transform.stream.

Share Manager; @@ -47,18 48,20 @@ public static final String USE_MAGNET_URL_WITH_XS = "Use Magnet URLWith XS"; public static final String USE_MAGNET_URL_WITH_FREEBASE = "Use Magnet URLWith Free Base"; private final Dest Address servent Address; private Input Stream style Sheet Stream; private Output Stream destination Stream; private List export Options ) { if ( destination Stream == null ) - this.servent Address = servent Address; this.style Sheet Stream = style Sheet Stream; this.destination Stream = destination Stream; this.export Data = export Data; @@ -101,8 104,8 @@ { piped Out Stream.connect( piped Input Stream ); - Shared Files Pipe Filler filler Runnable = new Shared Files Pipe Filler( piped Out Stream, - export Data, export Options ); Shared Files Pipe Filler filler Runnable = new Shared Files Pipe Filler( servent Address, piped Out Stream, export Data, export Options ); Thread Instance()Job( filler Runnable, "Shared Files Pipe Filler" ); Modified: phex/trunk/src/main/java/phex/share/export/Shared Files Pipe =================================================================== --- phex/trunk/src/main/java/phex/share/export/Shared Files Pipe 2007-11-10 UTC (rev 4040) phex/trunk/src/main/java/phex/share/export/Shared Files Pipe 2007-11-10 UTC (rev 4041) @@ -65,17 65,23 @@ */ public class Shared Files Pipe Filler implements Runnable { private final Dest Address servent Address; private Writer utf8Writer; private List options ) { this.servent Address = servent Address; if ( export Data == null ) this.export Data = export Data; try @@ -95,7 100,6 @@ { try This was sent by the Source collaborative development platform, the world's largest Open Source development site. rev=4038&view=rev Author: gregork Date: 2007-11-09 -0800 (Fri, ) Log Message: ----------- reduced Shared Files Service coupling Modified Paths: -------------- phex/trunk/src/main/java/phex/gui/dialogs/Export phex/trunk/src/main/java/phex/msg/Message phex/trunk/src/main/java/phex/msg/Msg phex/trunk/src/main/java/phex/msg/Pong phex/trunk/src/main/java/phex/share/Share phex/trunk/src/main/java/phex/share/export/Export phex/trunk/src/main/java/phex/udp/Udp Message phex/trunk/src/test/java/phex/msg/Query Response Msg Modified: phex/trunk/src/main/java/phex/gui/dialogs/Export =================================================================== --- phex/trunk/src/main/java/phex/gui/dialogs/Export 2007-11-08 UTC (rev 4037) phex/trunk/src/main/java/phex/gui/dialogs/Export 2007-11-09 UTC (rev 4038) @@ -58,6 58,8 @@ import common.

Statistic Provider Constants; import phex.statistic. = null && source Vendor().index Of( "Lime Wire" ) ! * This node is currently a ultrapeer if it is forced to be a ultrapeer or @@ -42,6 41,13 @@ * @return true if it has connected incoming, false otherwise.

Uptime Statistic Provider; @@ -41,12 41,15 @@ private static final long ONE_HOUR = 60 * 60 * 1000; private static final long TWO_HOURS = 2 * 60 * 60 * 1000; private final Servent Info servent Info; private boolean is Ultrapeer Capable; private boolean is Ultrapeer OS; private Uptime Statistic Provider uptime Provider; - public Ultrapeer Capability Checker() public Ultrapeer Capability Checker( Servent Info servent Info ) { this.servent Info = servent Info; Environment env = Instance(); is Ultrapeer OS = Ultrapeer OS(); @@ -78,7 81,7 @@ // if not we dont need to continue checking... Allow To Become UP.get().boolean Value() && // host should not be firewalled. servent Firewalled() && // host should provide a Ultrapeer capable OS is Ultrapeer OS && // the connection speed should be more then single ISDN Modified: phex/trunk/src/main/java/phex/msg/Message =================================================================== --- phex/trunk/src/main/java/phex/msg/Message 2007-11-10 UTC (rev 4040) phex/trunk/src/main/java/phex/msg/Message 2007-11-10 UTC (rev 4041) @@ -512,7 512,8 @@ ( is Firewalled && source Ultrapeer() ) ) && source Push Proxy Supported() ) { - Push Proxy Request VMsg pprmsg = new Push Proxy Request VMsg(); Push Proxy Request VMsg pprmsg = new Push Proxy Request VMsg( network Servent Guid() ); // TODO2 remove this once Limewire support PPR v2 if ( source Vendor() ! This will be the forced address Modified: phex/trunk/src/main/java/phex/servent/Servent =================================================================== --- phex/trunk/src/main/java/phex/servent/Servent 2007-11-10 UTC (rev 4040) phex/trunk/src/main/java/phex/servent/Servent 2007-11-10 UTC (rev 4041) @@ -6,7 6,6 @@ public interface Servent Info { - /** * Returns true if this node is currently a ultrapeer, false otherwise. - if ( Upload Instance()Host Busy() ) if ( servent Upload Limit Reached() ) Modified: phex/trunk/src/main/java/phex/share/Share =================================================================== --- phex/trunk/src/main/java/phex/share/Share 2007-11-10 UTC (rev 4040) phex/trunk/src/main/java/phex/share/Share 2007-11-10 UTC (rev 4041) @@ -44,6 44,7 @@ import connection.

Dest Address; public class Connection Status Event Modified: phex/trunk/src/main/java/phex/event/Phex Event =================================================================== --- phex/trunk/src/main/java/phex/event/Phex Event 2007-11-12 UTC (rev 4042) phex/trunk/src/main/java/phex/event/Phex Event 2007-11-12 UTC (rev 4043) @@ -3,6 3,7 @@ public interface Phex Event Topics /** @@ -260,7 259,6 @@ - fire Caught Hosts Changed( ); } return is New; } @@ -331,14 329,15 @@ } /** - * Reports the connection status of a just tried network connection to a * Handles the Connection Status Event of a just tried network connection to a * Host Address, this is used to update the Catched Host Cache.

Event Listener; - -public interface Caught Hosts Change Listener - extends Event Listener - \ No newline at end of file Added: phex/trunk/src/main/java/phex/event/Connection Status =================================================================== --- phex/trunk/src/main/java/phex/event/Connection Status (rev 0) phex/trunk/src/main/java/phex/event/Connection Status 2007-11-12 UTC (rev 4043) @@ -0,0 1,57 @@ package phex.event; import phex.common.address.

*/ private List( 3 ); public Network Hosts Container() ///////////////////// START event handling methods //////////////////////// - public void add Network Hosts Change Listener( Network Hosts Change Listener listener ) private void fire Network Host Added( Host host, int position ) - public void remove Network Hosts Change Listener( Network Hosts Change Listener listener ) private void fire Network Host Removed( Host host, int position ) - - private void fire Network Host Changed( final int position ) - - - private void fire Network Host Added( final int position ) - - - private void fire Network Host Removed( final int position ) - - - public void fire Network Host Changed( Host host ) - - // BEGIN Network Listener handler methods public void connected To Network() \ No newline at end of file Modified: phex/trunk/src/main/java/phex/connection/handshake/Handshake =================================================================== --- phex/trunk/src/main/java/phex/connection/handshake/Handshake 2007-11-12 UTC (rev 4042) phex/trunk/src/main/java/phex/connection/handshake/Handshake 2007-11-12 UTC (rev 4043) @@ -128,8 128,8 @@ return new Handshake Status( status Code, status Message, response Headers ); Deleted: phex/trunk/src/main/java/phex/event/Caught Hosts Change =================================================================== --- phex/trunk/src/main/java/phex/event/Caught Hosts Change 2007-11-12 UTC (rev 4042) phex/trunk/src/main/java/phex/event/Caught Hosts Change 2007-11-12 UTC (rev 4043) @@ -1,31 0,0 @@ -/* - * PHEX - The pure-java Gnutella-servent. @@ -48,45 54,56 @@ - public void mark Failed Connection() public void reset() @Event Topic Subscriber(topic=Phex Event Topics. TIMER_PERIOD, new Update GWeb Cache Timer( Instance() ), Update GWeb Cache Timer. TIMER_PERIOD ); return true; } @@ -267,6 269,13 @@ { // once per 45 minutes public static final long TIMER_PERIOD = 1000 * 60 * 45; private final Servent Info servent Info; public Update GWeb Cache Timer( Servent Info servent Info ) @Override public void run() @@ -281,9 290,9 @@ network Hosts Total Connection Count() 0 ) { Dest Address local Address = null; - if ( network Connected Incoming() ) if ( ! This will be the forced address Modified: phex/trunk/src/main/java/phex/share/Query Result Search =================================================================== --- phex/trunk/src/main/java/phex/share/Query Result Search 2007-11-10 UTC (rev 4040) phex/trunk/src/main/java/phex/share/Query Result Search 2007-11-10 UTC (rev 4041) @@ -9,20 9,21 @@ import phex.common.collections.

Tags: , ,