Skip to content

Commit

Permalink
FLUME-598: Update RPC to send CLOSING state information from LogicalN…
Browse files Browse the repository at this point in the history 
…ode Driver (autogen Thrift code)
  • Loading branch information
Jonathan Hsieh committed Apr 22, 2011
1 parent 341711a commit e630bef
Show file tree
Hide file tree
Showing 4 changed files with 20 additions and 1 deletion.
8 changes: 8 additions & 0 deletions src/gen-java/com/cloudera/flume/conf/thrift/FlumeMasterAdminServer.java
View file
Expand Up @@ -1495,6 +1495,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down Expand Up @@ -2088,6 +2090,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down Expand Up @@ -2681,6 +2685,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down Expand Up @@ -4362,6 +4368,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down
5 changes: 4 additions & 1 deletion src/gen-java/com/cloudera/flume/conf/thrift/FlumeNodeState.java
View file
Expand Up @@ -17,7 +17,8 @@ public enum FlumeNodeState implements org.apache.thrift.TEnum {
ACTIVE(3),
ERROR(4),
LOST(5),
DECOMMISSIONED(6);
DECOMMISSIONED(6),
CLOSING(7);

private final int value;

Expand Down Expand Up @@ -52,6 +53,8 @@ public static FlumeNodeState findByValue(int value) {
return LOST;
case 6:
return DECOMMISSIONED;
case 7:
return CLOSING;
default:
return null;
}
Expand Down
4 changes: 4 additions & 0 deletions src/gen-java/com/cloudera/flume/conf/thrift/ThriftFlumeClientServer.java
View file
Expand Up @@ -1783,6 +1783,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down Expand Up @@ -4736,6 +4738,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down
4 changes: 4 additions & 0 deletions src/gen-java/com/cloudera/flume/handlers/scribe/FacebookService.java
View file
Expand Up @@ -4510,6 +4510,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down Expand Up @@ -7324,6 +7326,8 @@ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOExcept

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
__isset_bit_vector = new BitSet(1);
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
Expand Down

0 comments on commit e630bef

Please sign in to comment.