Examples of CodingException

Examples of org.apache.aurora.codec.ThriftBinaryCodec.CodingException

219
220
221
222
223
224
225
226
227
        byte[] chunkData = chunkFrame.getChunk().getData();
        digest.update(chunkData);
        chunks[i] = chunkData;
      }
      if (!Arrays.equals(header.getChecksum(), digest.digest())) {
        throw new CodingException("Read back a framed log entry that failed its checksum");
      }
      return Entries.thriftBinaryDecode(Bytes.concat(chunks));
    }
View Full Code Here

Examples of org.apache.aurora.codec.ThriftBinaryCodec.CodingException

77
78
79
80
81
82
83
84
      }

      COMPRESSION_BYTES_SAVED.addAndGet(bytesSaved);
      return LogEntry.deflatedEntry(ByteBuffer.wrap(deflatedData));
    } catch (IOException e) {
      throw new CodingException("Failed to deflate snapshot: " + e, e);
    }
  }
View Full Code Here

Examples of org.apache.aurora.codec.ThriftBinaryCodec.CodingException

105
106
107
108
109
110
111
112
      ByteStreams.copy(inflater, inflated);
      byte[] inflatedData = inflated.toByteArray();
      LOG.info("Inflated log entry size: " + inflatedData.length);
      return thriftBinaryDecode(inflatedData);
    } catch (IOException e) {
      throw new CodingException("Failed to inflate compressed log entry.", e);
    }
  }
View Full Code Here

Examples of org.apache.aurora.codec.ThriftBinaryCodec.CodingException

158
159
160
161
162
163
164
165
166
      byte[] chunkData = chunkFrame.getChunk().getData();
      hasher.putBytes(chunkData);
      chunks[i] = chunkData;
    }
    if (!Arrays.equals(header.getChecksum(), hasher.hash().asBytes())) {
      throw new CodingException("Read back a framed log entry that failed its checksum");
    }
    return Entries.thriftBinaryDecode(Bytes.concat(chunks));
  }
View Full Code Here

Examples of org.apache.aurora.codec.ThriftBinaryCodec.CodingException

128
129
130
131
132
133
134
135
136
137
138
        int taskConfigId = partialTask.getTaskConfigId();
        TaskConfig config;
        try {
          config = deduplicatedSnapshot.getTaskConfigs().get(taskConfigId);
        } catch (IndexOutOfBoundsException e) {
          throw new CodingException(
              "DeduplicatedScheduledTask referenced invalid task index " + taskConfigId, e);
        }
        scheduledTask.getAssignedTask().setTask(config);
        snapshot.addToTasks(scheduledTask);
      }
View Full Code Here

Examples of org.raist.common.codec.CodingException

93
94
95
96
97
98
99
100
101
    if( dest == null || dest.isEmpty() )
      return null;

    E result = map.get(dest);
    if( result == null )
      throw new CodingException(type.getSimpleName() + " not found: " + dest);

    return result;
  }
View Full Code Here

Examples of org.raist.common.codec.CodingException

68
69
70
71
72
73
74
    if (val.equalsIgnoreCase("true"))
      return Boolean.TRUE;
    else if (val.equalsIgnoreCase("false"))
      return Boolean.FALSE;
    else
      throw new CodingException("Invalid boolean value expression: " + val);
  }
View Full Code Here

Examples of org.raist.common.codec.CodingException

101
102
103
104
105
106
107
  public char decodeChar(String val) {

    if (val.length() == 1)
      return val.charAt(0);
    else
      throw new CodingException("Invalid char value expression: " + val);
  }
View Full Code Here

Examples of org.raist.common.codec.CodingException

137
138
139
140
141
142
143
144
      return Integer.parseInt(val);
    }
    catch (NumberFormatException ex) {

      throw new CodingException(ex.getMessage(), ex);
    }
  }
View Full Code Here

Examples of org.raist.common.codec.CodingException

177
178
179
180
181
182
183
184
      return Long.parseLong(val);
    }
    catch (NumberFormatException ex) {

      throw new CodingException(ex.getMessage(), ex);
    }
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.