Skip to content

Commit

Permalink
just use message length not bytes
Browse files Browse the repository at this point in the history
  • Loading branch information
ssalinas committed Jun 6, 2016
1 parent b32f29e commit 096aa29
Show file tree
Hide file tree
Showing 3 changed files with 16 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,9 +14,9 @@ public class SingularityTaskMetadataConfiguration {

private Optional<String> sendTaskCompletedMailOnceMetadataTypeIsAvailable = Optional.absent();

private long maxMetadataMessageBytes = 10000;
private long maxMetadataMessageLength = 10000;

private long maxMetadataTitleBytes = 2000;
private long maxMetadataTitleLength = 2000;

public long getTaskPersistAfterFinishBufferMillis() {
return taskPersistAfterFinishBufferMillis;
Expand Down Expand Up @@ -50,19 +50,19 @@ public void setSendTaskCompletedMailOnceMetadataTypeIsAvailable(Optional<String>
this.sendTaskCompletedMailOnceMetadataTypeIsAvailable = sendTaskCompletedMailOnceMetadataTypeIsAvailable;
}

public long getMaxMetadataMessageBytes() {
return maxMetadataMessageBytes;
public long getMaxMetadataMessageLength() {
return maxMetadataMessageLength;
}

public void setMaxMetadataMessageBytes(long maxMetadataMessageBytes) {
this.maxMetadataMessageBytes = maxMetadataMessageBytes;
public void setMaxMetadataMessageLength(long maxMetadataMessageLength) {
this.maxMetadataMessageLength = maxMetadataMessageLength;
}

public long getMaxMetadataTitleBytes() {
return maxMetadataTitleBytes;
public long getMaxMetadataTitleLength() {
return maxMetadataTitleLength;
}

public void setMaxMetadataTitleBytes(long maxMetadataTitleBytes) {
this.maxMetadataTitleBytes = maxMetadataTitleBytes;
public void setMaxMetadataTitleLength(long maxMetadataTitleLength) {
this.maxMetadataTitleLength = maxMetadataTitleLength;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -340,11 +340,12 @@ public void postTaskMetadata(@PathParam("taskId") String taskId, final Singulari

authorizationHelper.checkForAuthorizationByTaskId(taskId, user, SingularityAuthorizationScope.WRITE);

WebExceptions.checkBadRequest(taskMetadataRequest.getTitle().getBytes().length < taskMetadataConfiguration.getMaxMetadataTitleBytes(),
"Task metadata title too long, must be less than %s bytes", taskMetadataConfiguration.getMaxMetadataTitleBytes());
WebExceptions.checkBadRequest(taskMetadataRequest.getTitle().length() < taskMetadataConfiguration.getMaxMetadataTitleLength(),
"Task metadata title too long, must be less than %s bytes", taskMetadataConfiguration.getMaxMetadataTitleLength());

WebExceptions.checkBadRequest(!taskMetadataRequest.getMessage().isPresent() || taskMetadataRequest.getMessage().get().getBytes().length < taskMetadataConfiguration.getMaxMetadataMessageBytes(),
"Task metadata message too long, must be less than %s bytes", taskMetadataConfiguration.getMaxMetadataMessageBytes());
int messageLength = taskMetadataRequest.getMessage().isPresent() ? taskMetadataRequest.getMessage().get().length() : 0;
WebExceptions.checkBadRequest(!taskMetadataRequest.getMessage().isPresent() || messageLength < taskMetadataConfiguration.getMaxMetadataMessageLength(),
"Task metadata message too long, must be less than %s bytes", taskMetadataConfiguration.getMaxMetadataMessageLength());

if (taskMetadataConfiguration.getAllowedMetadataTypes().isPresent()) {
WebExceptions.checkBadRequest(taskMetadataConfiguration.getAllowedMetadataTypes().get().contains(taskMetadataRequest.getType()), "%s is not one of the allowed metadata types %s",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -645,7 +645,7 @@ private List<SingularityPendingTask> getScheduledTaskIds(int numMissingInstances
final List<SingularityPendingTask> newTasks = Lists.newArrayListWithCapacity(numMissingInstances);

int nextInstanceNumber = 1;

t
for (int i = 0; i < numMissingInstances; i++) {
while (inuseInstanceNumbers.contains(nextInstanceNumber)) {
nextInstanceNumber++;
Expand Down

0 comments on commit 096aa29

Please sign in to comment.