Skip to content

Commit c81f0da

Browse files
committed
Spotless pass
1 parent 5a5cb27 commit c81f0da

2 files changed

Lines changed: 11 additions & 7 deletions

File tree

cuebot/src/main/java/com/imageworks/spcue/service/AccountingRedisPublisher.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@ public interface AccountingRedisPublisher {
3333
* committed (typically from {@code TransactionSynchronization.afterCommit}).
3434
*
3535
* @param proc the released VirtualProc; provides showId, jobId, layerId, allocationId,
36-
* folderId, deptId, coresReserved, gpusReserved. Callers must ensure folderId and
37-
* deptId are populated (production hydration paths do this via {@code
36+
* folderId, deptId, coresReserved, gpusReserved. Callers must ensure folderId and deptId
37+
* are populated (production hydration paths do this via {@code
3838
* ProcDaoJdbc.VIRTUAL_PROC_MAPPER}).
3939
*/
4040
void publishRelease(VirtualProc proc);

cuebot/src/main/java/com/imageworks/spcue/service/LettuceAccountingRedisPublisher.java

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -145,8 +145,10 @@ public void publishRelease(VirtualProc proc) {
145145
scriptSha = commands.scriptLoad(RELEASE_LUA);
146146
evalRelease(proc);
147147
} catch (Exception retry) {
148-
logger.warn("Redis publish retry failed for proc {} (show {}): {}; recompute "
149-
+ "will heal", proc.getProcId(), proc.getShowId(), retry.getMessage());
148+
logger.warn(
149+
"Redis publish retry failed for proc {} (show {}): {}; recompute "
150+
+ "will heal",
151+
proc.getProcId(), proc.getShowId(), retry.getMessage());
150152
}
151153
} catch (Exception e) {
152154
// §4.3 row 1: publish failure -> Redis missing a decrement -> next recompute
@@ -156,9 +158,11 @@ public void publishRelease(VirtualProc proc) {
156158
}
157159
}
158160

159-
/** Cuebot stores cores as centicores (cores × 100; see VirtualProc.java:143). Redis
160-
* stores cores (design §0 unit invariant), so we divide on the way out. The divide
161-
* is exact: VirtualProc forces coresReserved to a multiple of 100 at booking time. */
161+
/**
162+
* Cuebot stores cores as centicores (cores × 100; see VirtualProc.java:143). Redis stores cores
163+
* (design §0 unit invariant), so we divide on the way out. The divide is exact: VirtualProc
164+
* forces coresReserved to a multiple of 100 at booking time.
165+
*/
162166
static final int CENTICORES_PER_CORE = 100;
163167

164168
private void evalRelease(VirtualProc proc) {

0 commit comments

Comments
 (0)