I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

_context/getContext()

Browse Source 
(missed one)
This commit is contained in:
jrandom
2004-07-15 05:23:18 +00:00
committed by zzz
parent e737e5c950
commit 806d598a04
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
router/java/src/net/i2p/router/SubmitMessageHistoryJob.java
View File

@ -60,13 +60,13 @@ public class SubmitMessageHistoryJob extends JobImpl {
I2PThread t = new I2PThread(new Runnable() { I2PThread t = new I2PThread(new Runnable() {
public void run() { public void run() {
_log.debug("Submitting data"); _log.debug("Submitting data");
_context.messageHistory().setPauseFlushes(true); getContext().messageHistory().setPauseFlushes(true);
String filename = _context.messageHistory().getFilename(); String filename = getContext().messageHistory().getFilename();
send(filename); send(filename);
_context.messageHistory().setPauseFlushes(false); getContext().messageHistory().setPauseFlushes(false);
Job job = new SubmitMessageHistoryJob(_context); Job job = new SubmitMessageHistoryJob(getContext());
job.getTiming().setStartAfter(_context.clock().now() + getRequeueDelay()); job.getTiming().setStartAfter(getContext().clock().now() + getRequeueDelay());
_context.jobQueue().addJob(job); getContext().jobQueue().addJob(job);
} }
}); });
t.setName("SubmitData"); t.setName("SubmitData");
@ -88,7 +88,7 @@ public class SubmitMessageHistoryJob extends JobImpl {
if (size > 0) if (size > 0)
expectedSend += (int)size/10; // compression expectedSend += (int)size/10; // compression
FileInputStream fin = new FileInputStream(dataFile); FileInputStream fin = new FileInputStream(dataFile);
BandwidthLimitedInputStream in = new BandwidthLimitedInputStream(_context, fin, null, true); BandwidthLimitedInputStream in = new BandwidthLimitedInputStream(getContext(), fin, null, true);
boolean sent = HTTPSendData.postData(url, size, in); boolean sent = HTTPSendData.postData(url, size, in);
fin.close(); fin.close();
boolean deleted = dataFile.delete(); boolean deleted = dataFile.delete();
@ -99,7 +99,7 @@ public class SubmitMessageHistoryJob extends JobImpl {
} }
private String getURL() { private String getURL() {
String str = _context.router().getConfigSetting(PARAM_SUBMIT_URL); String str = getContext().router().getConfigSetting(PARAM_SUBMIT_URL);
if ( (str == null) || (str.trim().length() <= 0) ) if ( (str == null) || (str.trim().length() <= 0) )
return DEFAULT_SUBMIT_URL; return DEFAULT_SUBMIT_URL;
else else
@ -107,7 +107,7 @@ public class SubmitMessageHistoryJob extends JobImpl {
} }
private boolean shouldSubmit() { private boolean shouldSubmit() {
String str = _context.router().getConfigSetting(PARAM_SUBMIT_DATA); String str = getContext().router().getConfigSetting(PARAM_SUBMIT_DATA);
if (str == null) { if (str == null) {
_log.debug("History submit config not specified [" + PARAM_SUBMIT_DATA + "], default = " + DEFAULT_SUBMIT_DATA); _log.debug("History submit config not specified [" + PARAM_SUBMIT_DATA + "], default = " + DEFAULT_SUBMIT_DATA);
return DEFAULT_SUBMIT_DATA; return DEFAULT_SUBMIT_DATA;