|
Lines 34-39
Link Here
|
| 34 |
import org.eclipse.core.runtime.SubProgressMonitor; |
34 |
import org.eclipse.core.runtime.SubProgressMonitor; |
| 35 |
import org.eclipse.mylyn.commons.core.StatusHandler; |
35 |
import org.eclipse.mylyn.commons.core.StatusHandler; |
| 36 |
import org.eclipse.mylyn.commons.net.Policy; |
36 |
import org.eclipse.mylyn.commons.net.Policy; |
|
|
37 |
import org.eclipse.mylyn.internal.tasks.core.AbstractTask; |
| 37 |
import org.eclipse.mylyn.internal.tasks.core.RepositoryQuery; |
38 |
import org.eclipse.mylyn.internal.tasks.core.RepositoryQuery; |
| 38 |
import org.eclipse.mylyn.tasks.core.AbstractRepositoryConnector; |
39 |
import org.eclipse.mylyn.tasks.core.AbstractRepositoryConnector; |
| 39 |
import org.eclipse.mylyn.tasks.core.IRepositoryQuery; |
40 |
import org.eclipse.mylyn.tasks.core.IRepositoryQuery; |
|
Lines 211-217
Link Here
|
| 211 |
String urlQueryBase = repository.getRepositoryUrl() + CHANGED_BUGS_CGI_QUERY |
212 |
String urlQueryBase = repository.getRepositoryUrl() + CHANGED_BUGS_CGI_QUERY |
| 212 |
+ URLEncoder.encode(dateString, repository.getCharacterEncoding()) + CHANGED_BUGS_CGI_ENDDATE; |
213 |
+ URLEncoder.encode(dateString, repository.getCharacterEncoding()) + CHANGED_BUGS_CGI_ENDDATE; |
| 213 |
|
214 |
|
| 214 |
String urlQueryString = urlQueryBase + BUG_ID; |
215 |
StringBuilder urlQueryString = new StringBuilder(Math.min(30 + 9 * session.getTasks().size(), 7009)); |
|
|
216 |
urlQueryString.append(urlQueryBase + BUG_ID); |
| 215 |
|
217 |
|
| 216 |
Set<ITask> changedTasks = new HashSet<ITask>(); |
218 |
Set<ITask> changedTasks = new HashSet<ITask>(); |
| 217 |
Iterator<ITask> itr = session.getTasks().iterator(); |
219 |
Iterator<ITask> itr = session.getTasks().iterator(); |
|
Lines 221-240
Link Here
|
| 221 |
ITask task = itr.next(); |
223 |
ITask task = itr.next(); |
| 222 |
checking.add(task); |
224 |
checking.add(task); |
| 223 |
queryCounter++; |
225 |
queryCounter++; |
| 224 |
String newurlQueryString = URLEncoder.encode(task.getTaskId() + ",", repository.getCharacterEncoding()); //$NON-NLS-1$ |
226 |
urlQueryString.append(URLEncoder.encode(task.getTaskId() + ",", repository.getCharacterEncoding())); //$NON-NLS-1$ |
| 225 |
urlQueryString += newurlQueryString; |
227 |
if (urlQueryString.length() >= 7000) { |
| 226 |
if (queryCounter >= 1000) { |
228 |
queryForChanged(repository, changedTasks, urlQueryString.toString(), session, |
| 227 |
queryForChanged(repository, changedTasks, urlQueryString, session, new SubProgressMonitor(monitor, |
229 |
new SubProgressMonitor(monitor, queryCounter)); |
| 228 |
queryCounter)); |
|
|
| 229 |
|
230 |
|
| 230 |
queryCounter = 0; |
231 |
queryCounter = 0; |
| 231 |
urlQueryString = urlQueryBase + BUG_ID; |
232 |
urlQueryString.setLength(0); |
| 232 |
newurlQueryString = ""; //$NON-NLS-1$ |
233 |
urlQueryString.append(urlQueryBase + BUG_ID); |
| 233 |
} |
234 |
} |
| 234 |
|
235 |
|
| 235 |
if (!itr.hasNext() && queryCounter != 0) { |
236 |
if (!itr.hasNext() && queryCounter != 0) { |
| 236 |
queryForChanged(repository, changedTasks, urlQueryString, session, new SubProgressMonitor(monitor, |
237 |
queryForChanged(repository, changedTasks, urlQueryString.toString(), session, |
| 237 |
queryCounter)); |
238 |
new SubProgressMonitor(monitor, queryCounter)); |
| 238 |
} |
239 |
} |
| 239 |
} |
240 |
} |
| 240 |
|
241 |
|
|
Lines 275-281
Link Here
|
| 275 |
changedTasks.add(changedTask); |
276 |
changedTasks.add(changedTask); |
| 276 |
} |
277 |
} |
| 277 |
} |
278 |
} |
| 278 |
if (collector.getQueryTimestamp() != null) { |
279 |
if (syncSession.getData() == null && collector.getQueryTimestamp() != null) { |
| 279 |
syncSession.setData(collector.getQueryTimestamp()); |
280 |
syncSession.setData(collector.getQueryTimestamp()); |
| 280 |
} |
281 |
} |
| 281 |
|
282 |
|
