onedev/agent

■ ■ ■ ■ ■ ■

pom.xml

		skipped 9 lines
10	10		<version>1.0.5</version>
11	11		</parent>
12	12		<artifactId>agent</artifactId>
13		-	<version>1.1.5</version>
	13	+	<version>1.1.6</version>
14	14		<build>
15	15		<plugins>
16	16		<plugin>
		skipped 128 lines
145	145		</dependency>
146	146		</dependencies>
147	147		<properties>
148		-	<k8shelper.version>2.3.2</k8shelper.version>
	148	+	<k8shelper.version>2.4.0</k8shelper.version>
149	149		<jackson.version>2.12.1</jackson.version>
150	150		<jersey.version>2.26</jersey.version>
151	151		<bootstrap>true</bootstrap>
		skipped 4 lines

■ ■ ■ ■ ■ ■

src/main/java/io/onedev/agent/DockerExecutorUtils.java

		skipped 326 lines
327	327
328	328		if (!successful)
329	329		throw new FailedException();
330		-
331		-	jobLogger.log("Reporting job caches...");
332		-
333		-	target = client.target(Agent.serverUrl).path("api/k8s/report-job-caches");
334		-	builder = target.request();
335		-	builder.header(HttpHeaders.AUTHORIZATION, BEARER + " " + jobData.getJobToken());
336		-	StringBuilder toStringBuilder = new StringBuilder();
337		-	for (CacheInstance instance: getCacheInstances(hostCacheHome).keySet())
338		-	toStringBuilder.append(instance.toString()).append(";");
339		-	Response response = builder.post(Entity.entity(toStringBuilder.toString(), MediaType.APPLICATION_OCTET_STREAM));
340		-	try {
341		-	checkStatus(response);
342		-	} finally {
343		-	response.close();
344		-	}
345	330		} catch (IOException e) {
346	331		throw new RuntimeException(e);
347	332		} finally {
		skipped 507 lines

■ ■ ■ ■ ■ ■

src/main/java/io/onedev/agent/ShellExecutorUtils.java

		skipped 258 lines
259	259
260	260		if (!successful)
261	261		throw new FailedException();
262		-
263		-	jobLogger.log("Reporting job caches...");
264		-
265		-	target = client.target(Agent.serverUrl).path("api/k8s/report-job-caches");
266		-	builder = target.request();
267		-	builder.header(HttpHeaders.AUTHORIZATION, BEARER + " " + jobData.getJobToken());
268		-	StringBuilder toStringBuilder = new StringBuilder();
269		-	for (CacheInstance instance: getCacheInstances(cacheHomeDir).keySet())
270		-	toStringBuilder.append(instance.toString()).append(";");
271		-	Response response = builder.post(Entity.entity(toStringBuilder.toString(), MediaType.APPLICATION_OCTET_STREAM));
272		-	try {
273		-	checkStatus(response);
274		-	} finally {
275		-	response.close();
276		-	}
277	262		} finally {
278	263		jobThreads.remove(jobData.getJobToken());
279	264		client.close();
		skipped 114 lines