return ttype.name;
elif isinstance(ttype, Function):
- return typeToCTypeDeclaration(ttype.resultType)+ " "+ttype.name+"("+string.join([typeToCTypeDeclaration(arg) for arg in ttype.argFieldList], ", ")+")"
+ return typeToCTypeDeclaration(ttype.resultType)+ " "+ttype.name+"("+string.join([typeToCTypeDeclaration(arg) for arg in ttype.argsStruct.fieldList], ", ")+")"
elif isinstance(ttype, Field):
return typeToCTypeDeclaration(ttype.type)+ " "+ttype.name
else:
raise Exception, "Unknown type "+str(ttype)
-def writeTypeDefDefinition(cfile, typedef):
+def toTypeDefDefinition(typedef):
- cfile.writeln("typedef "+typeToCTypeDeclaration(typedef.definitionType)+" "+typedef.name+";")
+ return "typedef "+typeToCTypeDeclaration(typedef.definitionType)+" "+typedef.name+";"
-def writeEnumDefinition(cfile, enum):
+def toEnumDefinition(enum):
- cfile.write("enum "+enum.name+" ");
-
- cfile.beginBlock();
+ result = "enum "+enum.name+" {\n"
first = True
if first:
first = False
else:
- cfile.writeln(",")
- cfile.write(ed.name+" = "+str(ed.id))
+ result+= ",\n"
+ result+= " "+ed.name+" = "+str(ed.id)
+
+ result+= "\n};\n"
- cfile.writeln()
- cfile.endBlock(";");
+ return result
-def writeStructDefinition(cfile, struct):
- cfile.write("struct "+struct.name+" ");
+def toStructDefinition(struct):
- cfile.beginBlock()
+ result = "struct "+struct.name+" {\n"
for field in struct.fieldList:
- cfile.writeln(typeToCTypeDeclaration(field)+";")
+ result += " "+typeToCTypeDeclaration(field)+";\n"
- cfile.endBlock(";")
+ result+= "};\n"
+ return result
-CPP_DEFINITION_WRITER_MAP = {
- TypeDef : writeTypeDefDefinition,
- Enum : writeEnumDefinition,
- Struct : writeStructDefinition,
+CPP_DEFINITION_MAP = {
+ TypeDef : toTypeDefDefinition,
+ Enum : toEnumDefinition,
+ Struct : toStructDefinition,
Service : None
}
-def writeDefinitions(cfile, definitions):
+def toDefinitions(definitions):
+
+ result = ""
+
for definition in definitions:
- writer = CPP_DEFINITION_WRITER_MAP[type(definition)]
+ writer = CPP_DEFINITION_MAP[type(definition)]
if writer:
- writer(cfile, definition)
+ result+= writer(definition)+"\n"
- cfile.writeln()
+ return result
CPP_THRIFT_NS = "facebook::thrift"
${functionDeclarations}};
""")
-def writeServiceInterfaceDeclaration(cfile, service, debugp=None):
+def toServiceInterfaceDeclaration(service, debugp=None):
functionDeclarations = string.join([CPP_INTERFACE_FUNCTION_DECLARATION.substitute(service=service.name, functionDeclaration=typeToCTypeDeclaration(function)) for function in service.functionList], "")
- cfile.write(CPP_INTERFACE_DECLARATION.substitute(service=service.name, functionDeclarations=functionDeclarations))
+ return CPP_INTERFACE_DECLARATION.substitute(service=service.name, functionDeclarations=functionDeclarations)
CPP_SP = Template("boost::shared_ptr<${klass}> ")
CPP_TRANSPORT = CPP_TRANSPORT_NS+"::TTransport"
CPP_TRANSPORTP = CPP_SP.substitute(klass=CPP_TRANSPORT)
-CPP_SERVER_FUNCTION_DECLARATION = Template(""" void process_${function}("""+CPP_TRANSPORTP+""" _itrans, """+CPP_TRANSPORTP+""" _otrans);
+CPP_SERVER_FUNCTION_DECLARATION = Template(""" void process_${function}("""+CPP_TRANSPORTP+""" itrans, """+CPP_TRANSPORTP+""" otrans);
+""")
+
+CPP_SERVER_FUNCTION_DEFINITION = Template("""
+void ${service}ServerIf::process_${function}("""+CPP_TRANSPORTP+""" itrans, """+CPP_TRANSPORTP+""" otrans) {
+
+ uint32_t xfer = 0;
+
+${argsStructDeclaration}
+${argsStructReader}
+${resultDeclaration}
+${functionCall}
+${resultWriter}
+
+ otrans->flush();
+}
""")
CPP_PROTOCOL_TSTOP = CPP_PROTOCOL_NS+"::T_STOP"
if isinstance(ttype, PrimitiveType):
return CPP_TTYPE_MAP[ttype]
+ elif isinstance(ttype, Enum):
+ return CPP_TTYPE_MAP[I32_TYPE]
+
+ elif isinstance(ttype, TypeDef):
+ return toWireType(toCanonicalType(ttype))
+
elif isinstance(ttype, Struct) or isinstance(ttype, CollectionType):
return CPP_TTYPE_MAP[type(ttype)]
${functionDeclarations}};
""")
-def writeServerDeclaration(cfile, service, debugp=None):
+def toServerDeclaration(service, debugp=None):
functionDeclarations = string.join([CPP_SERVER_FUNCTION_DECLARATION.substitute(function=function.name) for function in service.functionList], "")
- cfile.write(CPP_SERVER_DECLARATION.substitute(service=service.name, functionDeclarations=functionDeclarations))
+ return CPP_SERVER_DECLARATION.substitute(service=service.name, functionDeclarations=functionDeclarations)
CPP_CLIENT_FUNCTION_DECLARATION = Template(""" ${functionDeclaration};
""")
"""+CPP_PROTOCOLP+""" _oprot;
};""")
-def writeClientDeclaration(cfile, service, debugp=None):
+def toServerServiceDefinition(service, debugp=None):
+
+ result = ""
+
+ for function in service.functionList:
+
+ if len(function.argsStruct.fieldList) > 0:
+ argsStructDeclaration = " "+typeToCTypeDeclaration(function.argsStruct)+" __args;\n"
+ argsStructReader = " "+toReaderCall("__args", function.argsStruct, "_iprot")+";\n"
+ else:
+ argsStructDeclaration = ""
+ argsStructReader = ""
+
+ functionCall = " "
+ resultDeclaration = ""
+ resultWriter = ""
+
+ if toCanonicalType(function.resultType) != VOID_TYPE:
+ resultDeclaration = " "+typeToCTypeDeclaration(function.resultType)+" __result;\n"
+ functionCall+= "__result = "
+
+ functionCall+= function.name+"("+string.join(["__args."+arg.name for arg in function.argsStruct.fieldList], ", ")+");\n"
+
+ if toCanonicalType(function.resultType) != VOID_TYPE:
+ resultWriter = " "+toWriterCall("__result", function.resultType, "_oprot")+";"
+
+ result+= CPP_SERVER_FUNCTION_DEFINITION.substitute(service=service.name, function=function.name,
+ argsStructDeclaration=argsStructDeclaration, argsStructReader=argsStructReader,
+ functionCall=functionCall,
+ resultDeclaration=resultDeclaration, resultWriter=resultWriter)
+
+ return result
+
+def toServerDefinition(program, debugp=None):
+
+ return string.join([toServerServiceDefinition(service) for service in program.serviceMap.values()], "\n")
+
+def toClientDeclaration(service, debugp=None):
functionDeclarations = string.join([CPP_CLIENT_FUNCTION_DECLARATION.substitute(functionDeclaration=typeToCTypeDeclaration(function)) for function in service.functionList], "")
- cfile.writeln(CPP_CLIENT_DECLARATION.substitute(service=service.name, functionDeclarations=functionDeclarations))
+ return CPP_CLIENT_DECLARATION.substitute(service=service.name, functionDeclarations=functionDeclarations)+"\n"
-def writeServiceDeclaration(cfile, service, debugp=None):
- writeServiceInterfaceDeclaration(cfile, service, debugp)
- writeServerDeclaration(cfile, service, debugp)
- writeClientDeclaration(cfile, service, debugp)
+def toServiceDeclaration(service, debugp=None):
+ return toServiceInterfaceDeclaration(service, debugp) + toServerDeclaration(service, debugp) + toClientDeclaration(service, debugp)
def toGenDir(filename, suffix="cpp-gen", debugp=None):
cfile.writeln(CPP_TYPES_HEADER.substitute(source=basename, date=time.ctime()))
- writeDefinitions(cfile, program.definitions)
+ cfile.write(toDefinitions(program.definitions))
cfile.writeln(CPP_TYPES_FOOTER.substitute(source=basename))
for service in services:
- writeServiceDeclaration(cfile, service)
+ cfile.write(toServiceDeclaration(service))
cfile.writeln(CPP_SERVICES_FOOTER.substitute(source=basename))
else:
raise Exception, "Unknown type "+str(ttype)
-def toReaderCall(value, ttype):
+def toReaderCall(value, ttype, reader="iprot"):
suffix = typeToIOMethodSuffix(ttype)
if isinstance(ttype, PrimitiveType):
- return "xfer += iprot->read"+suffix+"(itrans, "+value+")"
+ return "xfer += "+reader+"->read"+suffix+"(itrans, "+value+")"
elif isinstance(ttype, CollectionType):
- return "xfer+= read_"+suffix+"(iprot, itrans, "+value+")"
+ return "xfer+= read_"+suffix+"("+reader+", itrans, "+value+")"
elif isinstance(ttype, Struct):
- return "xfer+= read_"+suffix+"(iprot, itrans, "+value+")"
+ return "xfer+= read_"+suffix+"("+reader+", itrans, "+value+")"
elif isinstance(ttype, TypeDef):
- return toReaderCall("reinterpret_cast<"+typeToCTypeDeclaration(ttype.definitionType)+"&>("+value+")", ttype.definitionType)
+ return toReaderCall("reinterpret_cast<"+typeToCTypeDeclaration(ttype.definitionType)+"&>("+value+")", ttype.definitionType, reader)
elif isinstance(ttype, Enum):
- return toReaderCall("reinterpret_cast<"+typeToCTypeDeclaration(I32_TYPE)+"&>("+value+")", I32_TYPE)
+ return toReaderCall("reinterpret_cast<"+typeToCTypeDeclaration(I32_TYPE)+"&>("+value+")", I32_TYPE, reader)
else:
raise Exception, "Unknown type "+str(ttype)
-def toWriterCall(value, ttype):
+def toWriterCall(value, ttype, writer="oprot"):
suffix = typeToIOMethodSuffix(ttype)
if isinstance(ttype, PrimitiveType):
- return "xfer+= oprot->write"+suffix+"(otrans, "+value+")"
+ return "xfer+= "+writer+"->write"+suffix+"(otrans, "+value+")"
elif isinstance(ttype, CollectionType):
- return "xfer+= write_"+suffix+"(oprot, otrans, "+value+")"
+ return "xfer+= write_"+suffix+"("+writer+", otrans, "+value+")"
elif isinstance(ttype, Struct):
- return "xfer+= write_"+suffix+"(oprot, otrans, "+value+")"
+ return "xfer+= write_"+suffix+"("+writer+", otrans, "+value+")"
elif isinstance(ttype, TypeDef):
- return toWriterCall("reinterpret_cast<const "+typeToCTypeDeclaration(ttype.definitionType)+"&>("+value+")", ttype.definitionType)
+ return toWriterCall("reinterpret_cast<const "+typeToCTypeDeclaration(ttype.definitionType)+"&>("+value+")", ttype.definitionType, writer)
elif isinstance(ttype, Enum):
- return toWriterCall("reinterpret_cast<const "+typeToCTypeDeclaration(I32_TYPE)+"&>("+value+")", I32_TYPE)
+ return toWriterCall("reinterpret_cast<const "+typeToCTypeDeclaration(I32_TYPE)+"&>("+value+")", I32_TYPE, writer)
else:
raise Exception, "Unknown type "+str(ttype)
std::string name;
"""+CPP_PROTOCOL_TTYPE+""" type;
- uint16_t id;
+ int16_t id;
uint32_t xfer = 0;
while(true) {
elif isinstance(ttype, Function):
result = toOrderedIOList(ttype.resultType, result)
- for arg in ttype.argFieldList:
- result = toOrderedIOList(arg.type, result)
+ # skip the args struct itself and just order the arguments themselves
+ # we don't want the arg struct to be referred to until laters, since we need to
+ # inline those struct definitions with the implementation, not in the types header
+
+ for field in ttype.argsStruct.fieldList:
+ result = toOrderedIOList(field.type, result)
else:
raise Exception, "Unsupported thrift type: "+str(ttype)
def toIOMethodImplementations(program):
- # get orderede list of all types that need marshallers:
+ # get ordered list of all types that need marshallers:
iolist = toOrderedIOList(program)
result+= toReaderDefinition(ttype)
result+= toWriterDefinition(ttype)
+ # for all function argument lists we need to create both struct definitions
+ # and io methods. We keep the struct definitions local, since they aren't part of the service
+ # API
+ # Note that we don't need to do a depth-first traverse of arg structs since they can only include fields
+ # we've already seen
+
+ for service in program.serviceMap.values():
+ for function in service.functionList:
+ if len(function.argsStruct.fieldList) == 0:
+ continue
+ result+= toStructDefinition(function.argsStruct)
+ result+=toReaderDefinition(function.argsStruct)
+ result+=toWriterDefinition(function.argsStruct)
+
return result;
def toImplementationSourceName(filename, genDir=None, debugp=None):
cfile.write(toIOMethodImplementations(program))
+ cfile.write(toServerDefinition(program))
+
cfile.writeln(CPP_IMPL_FOOTER.substitute(source=basename))
cfile.close()
def assignId(field, currentId, ids):
'Finds the next available id number for a field'
- id= currentId - 1
+ id = currentId - 1
while id in ids:
- id -= 1
+ id-= 1
field.id = id
currentId = 0
- for fields in fieldList:
+ for field in fieldList:
if not field.id:
currentId = assignId(field, currentId, ids)
class Function(Definition):
- def __init__(self, symbols, name, resultType, argFieldList):
+ def __init__(self, symbols, name, resultType, argsStruct):
Definition.__init__(self, symbols, name)
self.resultType = resultType
- self.argFieldList = argFieldList
+ self.argsStruct = argsStruct
def validate(self):
- validateFieldList(self.argFieldList)
+ validateFieldList(self.argsStruct.fieldList)
def __str__(self):
- return self.name+"("+string.join(map(lambda a: str(a), self.argFieldList), ", ")+") => "+str(self.resultType)
+ return self.name+"("+string.join(map(lambda a: str(a), self.argsStruct), ", ")+") => "+str(self.resultType)
class Service(Definition):
except ErrorException, e:
errors+= e.errors
- for field in function.argFieldList:
+ for field in function.argsStruct.fieldList:
try:
field.type = self.getType(function, field)
except ErrorException, e:
except ErrorException, e:
self.errors+= e.errors
-# def p_definition_or_referencye_type_1(self, p):
-# XXX need to all typedef struct foo foo_t by allowing references
-# pass
-
def p_enum(self, p):
'enum : ENUM ID LBRACE enumdeflist RBRACE'
self.pdebug("p_enum", p)
def p_function(self, p):
'function : functiontype functionmodifiers ID LPAREN fieldlist RPAREN'
self.pdebug("p_function", p)
- p[0] = Function(p, p[3], p[1], p[5])
+ p[0] = Function(p, p[3], p[1], Struct(p, p[3]+"_args", p[5]))
try:
p[0].validate()
except ErrorException, e:
uint32_t TBinaryProtocol::writeFieldBegin(shared_ptr<TTransport> out,
const string& name,
const TType fieldType,
- const uint16_t fieldId) const {
+ const int16_t fieldId) const {
return
writeByte(out, (uint8_t)fieldType) +
- writeI32(out, (int32_t)fieldId);
+ writeI16(out, fieldId);
}
uint32_t TBinaryProtocol::writeFieldEnd(shared_ptr<TTransport> out) const {
return 0;
}
+uint32_t TBinaryProtocol::writeBool(shared_ptr<TTransport> out,
+ const bool value) const {
+ uint8_t tmp = value ? 1 : 0;
+ out->write(&tmp, 1);
+ return 1;
+}
+
uint32_t TBinaryProtocol::writeByte(shared_ptr<TTransport> out,
const uint8_t byte) const {
out->write(&byte, 1);
return 1;
}
-uint32_t TBinaryProtocol::writeU32(shared_ptr<TTransport> out,
- const uint32_t u32) const {
- uint32_t net = (uint32_t)htonl(u32);
- out->write((uint8_t*)&net, 4);
- return 4;
+uint32_t TBinaryProtocol::writeU16(shared_ptr<TTransport> out,
+ const uint16_t u16) const {
+ uint16_t net = (uint16_t)htons(u16);
+ out->write((uint8_t*)&net, 2);
+ return 2;
}
-uint32_t TBinaryProtocol::writeI32(shared_ptr<TTransport> out,
- const int32_t i32) const {
- int32_t net = (int32_t)htonl(i32);
- out->write((uint8_t*)&net, 4);
- return 4;
+uint32_t TBinaryProtocol::writeI16(shared_ptr<TTransport> out,
+ const int16_t i16) const {
+ int16_t net = (int16_t)htons(i16);
+ out->write((uint8_t*)&net, 2);
+ return 2;
}
uint32_t TBinaryProtocol::writeU64(shared_ptr<TTransport> out,
uint32_t TBinaryProtocol::readFieldBegin(shared_ptr<TTransport> in,
string& name,
TType& fieldType,
- uint16_t& fieldId) const {
+ int16_t& fieldId) const {
uint32_t result = 0;
uint8_t type;
result += readByte(in, type);
fieldId = 0;
return result;
}
- int32_t id;
- result += readI32(in, id);
- fieldId = (uint16_t)id;
+ result += readI16(in, fieldId);
return result;
}
return 0;
}
+uint32_t TBinaryProtocol::readBool(shared_ptr<TTransport> in,
+ bool& value) const {
+ uint8_t b[1];
+ in->readAll(b, 1);
+ value = *(uint8_t*)b != 0;
+ return 1;
+}
+
uint32_t TBinaryProtocol::readByte(shared_ptr<TTransport> in,
uint8_t& byte) const {
uint8_t b[1];
return 1;
}
+uint32_t TBinaryProtocol::readU16(shared_ptr<TTransport> in,
+ uint16_t& u16) const {
+ uint8_t b[2];
+ in->readAll(b, 2);
+ u16 = *(uint16_t*)b;
+ u16 = (uint16_t)ntohs(u16);
+ return 2;
+}
+
+uint32_t TBinaryProtocol::readI16(shared_ptr<TTransport> in,
+ int16_t& i16) const {
+ uint8_t b[2];
+ in->readAll(b, 2);
+ i16 = *(int16_t*)b;
+ i16 = (int16_t)ntohs(i16);
+ return 2;
+}
+
uint32_t TBinaryProtocol::readU32(shared_ptr<TTransport> in,
uint32_t& u32) const {
uint8_t b[4];
*
* @author Mark Slee <mcslee@facebook.com>
*/
-class TBinaryProtocol : public TProtocol {
- public:
+ class TBinaryProtocol : public TProtocol {
+ public:
TBinaryProtocol() {}
~TBinaryProtocol() {}
const TMessageType messageType,
const uint32_t seqid) const;
- virtual uint32_t writeMessageEnd (shared_ptr<TTransport> out) const;
+ virtual uint32_t writeMessageEnd(shared_ptr<TTransport> out) const;
- uint32_t writeStructBegin (shared_ptr<TTransport> out,
- const std::string& name) const;
+ uint32_t writeStructBegin(shared_ptr<TTransport> out,
+ const std::string& name) const;
- uint32_t writeStructEnd (shared_ptr<TTransport> out) const;
+ uint32_t writeStructEnd(shared_ptr<TTransport> out) const;
- uint32_t writeFieldBegin (shared_ptr<TTransport> out,
- const std::string& name,
- const TType fieldType,
- const uint16_t fieldId) const;
+ uint32_t writeFieldBegin(shared_ptr<TTransport> out,
+ const std::string& name,
+ const TType fieldType,
+ const int16_t fieldId) const;
- uint32_t writeFieldEnd (shared_ptr<TTransport> out) const;
+ uint32_t writeFieldEnd(shared_ptr<TTransport> out) const;
- uint32_t writeFieldStop (shared_ptr<TTransport> out) const;
+ uint32_t writeFieldStop(shared_ptr<TTransport> out) const;
- uint32_t writeMapBegin (shared_ptr<TTransport> out,
- const TType keyType,
- const TType valType,
- const int32_t size) const;
+ uint32_t writeMapBegin(shared_ptr<TTransport> out,
+ const TType keyType,
+ const TType valType,
+ const int32_t size) const;
- uint32_t writeMapEnd (shared_ptr<TTransport> out) const;
+ uint32_t writeMapEnd(shared_ptr<TTransport> out) const;
- uint32_t writeListBegin (shared_ptr<TTransport> out,
- const TType elemType,
- const int32_t size) const;
+ uint32_t writeListBegin(shared_ptr<TTransport> out,
+ const TType elemType,
+ const int32_t size) const;
- uint32_t writeListEnd (shared_ptr<TTransport> out) const;
+ uint32_t writeListEnd(shared_ptr<TTransport> out) const;
- uint32_t writeSetBegin (shared_ptr<TTransport> out,
- const TType elemType,
- const int32_t size) const;
+ uint32_t writeSetBegin(shared_ptr<TTransport> out,
+ const TType elemType,
+ const int32_t size) const;
- uint32_t writeSetEnd (shared_ptr<TTransport> out) const;
+ uint32_t writeSetEnd(shared_ptr<TTransport> out) const;
- uint32_t writeByte (shared_ptr<TTransport> out,
- const uint8_t byte) const;
+ uint32_t writeBool(shared_ptr<TTransport> out,
+ const bool value) const;
- uint32_t writeU32 (shared_ptr<TTransport> out,
- const uint32_t u32) const;
+ uint32_t writeByte(shared_ptr<TTransport> out,
+ const uint8_t byte) const;
- uint32_t writeI32 (shared_ptr<TTransport> out,
- const int32_t i32) const;
+ uint32_t writeU16(shared_ptr<TTransport> out,
+ const uint16_t u16) const;
- uint32_t writeU64 (shared_ptr<TTransport> out,
- const uint64_t u64) const;
+ uint32_t writeI16(shared_ptr<TTransport> out,
+ const int16_t i16) const;
- uint32_t writeI64 (shared_ptr<TTransport> out,
- const int64_t i64) const;
+ uint32_t writeU32(shared_ptr<TTransport> out,
+ const uint32_t u32) const;
- uint32_t writeString (shared_ptr<TTransport> out,
- const std::string& str) const;
+ uint32_t writeI32(shared_ptr<TTransport> out,
+ const int32_t i32) const;
+
+ uint32_t writeU64(shared_ptr<TTransport> out,
+ const uint64_t u64) const;
+
+ uint32_t writeI64(shared_ptr<TTransport> out,
+ const int64_t i64) const;
+
+ uint32_t writeString(shared_ptr<TTransport> out,
+ const std::string& str) const;
/**
* Reading functions
*/
- uint32_t readMessasgeBegin (shared_ptr<TTransport> in,
- TMessageType& messageType,
- uint32_t& seqid) const;
+ uint32_t readMessasgeBegin(shared_ptr<TTransport> in,
+ TMessageType& messageType,
+ uint32_t& seqid) const;
- uint32_t readMessageEnd (shared_ptr<TTransport> in) const;
+ uint32_t readMessageEnd(shared_ptr<TTransport> in) const;
- uint32_t readStructBegin (shared_ptr<TTransport> in,
- std::string& name) const;
+ uint32_t readStructBegin(shared_ptr<TTransport> in,
+ std::string& name) const;
- uint32_t readStructEnd (shared_ptr<TTransport> in) const;
+ uint32_t readStructEnd(shared_ptr<TTransport> in) const;
- uint32_t readFieldBegin (shared_ptr<TTransport> in,
- std::string& name,
- TType& fieldType,
- uint16_t& fieldId) const;
+ uint32_t readFieldBegin(shared_ptr<TTransport> in,
+ std::string& name,
+ TType& fieldType,
+ int16_t& fieldId) const;
- uint32_t readFieldEnd (shared_ptr<TTransport> in) const;
+ uint32_t readFieldEnd(shared_ptr<TTransport> in) const;
- uint32_t readMapBegin (shared_ptr<TTransport> in,
- TType& keyType,
- TType& valType,
- int32_t& size) const;
+ uint32_t readMapBegin(shared_ptr<TTransport> in,
+ TType& keyType,
+ TType& valType,
+ int32_t& size) const;
- uint32_t readMapEnd (shared_ptr<TTransport> in) const;
+ uint32_t readMapEnd(shared_ptr<TTransport> in) const;
- uint32_t readListBegin (shared_ptr<TTransport> in,
- TType& elemType,
- int32_t& size) const;
+ uint32_t readListBegin(shared_ptr<TTransport> in,
+ TType& elemType,
+ int32_t& size) const;
- uint32_t readListEnd (shared_ptr<TTransport> in) const;
+ uint32_t readListEnd(shared_ptr<TTransport> in) const;
+
+ uint32_t readSetBegin(shared_ptr<TTransport> in,
+ TType& elemType,
+ int32_t& size) const;
+
+ uint32_t readSetEnd(shared_ptr<TTransport> in) const;
- uint32_t readSetBegin (shared_ptr<TTransport> in,
- TType& elemType,
- int32_t& size) const;
+ uint32_t readBool(shared_ptr<TTransport> in,
+ bool& value) const;
- uint32_t readSetEnd (shared_ptr<TTransport> in) const;
+ uint32_t readByte(shared_ptr<TTransport> in,
+ uint8_t& byte) const;
- uint32_t readByte (shared_ptr<TTransport> in,
- uint8_t& byte) const;
+ uint32_t readU16(shared_ptr<TTransport> in,
+ uint16_t& u16) const;
- uint32_t readU32 (shared_ptr<TTransport> in,
- uint32_t& u32) const;
+ uint32_t readI16(shared_ptr<TTransport> in,
+ int16_t& i16) const;
- uint32_t readI32 (shared_ptr<TTransport> in,
- int32_t& i32) const;
+ uint32_t readU32(shared_ptr<TTransport> in,
+ uint32_t& u32) const;
- uint32_t readU64 (shared_ptr<TTransport> in,
- uint64_t& u64) const;
+ uint32_t readI32(shared_ptr<TTransport> in,
+ int32_t& i32) const;
- uint32_t readI64 (shared_ptr<TTransport> in,
- int64_t& i64) const;
+ uint32_t readU64(shared_ptr<TTransport> in,
+ uint64_t& u64) const;
- uint32_t readString (shared_ptr<TTransport> in,
- std::string& str) const;
+ uint32_t readI64(shared_ptr<TTransport> in,
+ int64_t& i64) const;
+ uint32_t readString(shared_ptr<TTransport> in,
+ std::string& str) const;
};
}}} // facebook::thrift::protocol
* Writing functions.
*/
- virtual uint32_t writeMessageBegin (shared_ptr<TTransport> out,
- const TMessageType messageType,
- const uint32_t seqid) const = 0;
+ virtual uint32_t writeMessageBegin(shared_ptr<TTransport> out,
+ const TMessageType messageType,
+ const uint32_t seqid) const = 0;
- virtual uint32_t writeMessageEnd (shared_ptr<TTransport> out) const = 0;
+ virtual uint32_t writeMessageEnd(shared_ptr<TTransport> out) const = 0;
- virtual uint32_t writeStructBegin (shared_ptr<TTransport> out,
- const std::string& name) const = 0;
-
- virtual uint32_t writeStructEnd (shared_ptr<TTransport> out) const = 0;
-
- virtual uint32_t writeFieldBegin (shared_ptr<TTransport> out,
- const std::string& name,
- const TType fieldType,
- const uint16_t fieldId) const = 0;
+ virtual uint32_t writeStructBegin(shared_ptr<TTransport> out,
+ const std::string& name) const = 0;
+
+ virtual uint32_t writeStructEnd(shared_ptr<TTransport> out) const = 0;
+
+ virtual uint32_t writeFieldBegin(shared_ptr<TTransport> out,
+ const std::string& name,
+ const TType fieldType,
+ const int16_t fieldId) const = 0;
- virtual uint32_t writeFieldEnd (shared_ptr<TTransport> out) const = 0;
+ virtual uint32_t writeFieldEnd(shared_ptr<TTransport> out) const = 0;
- virtual uint32_t writeFieldStop (shared_ptr<TTransport> out) const = 0;
+ virtual uint32_t writeFieldStop(shared_ptr<TTransport> out) const = 0;
- virtual uint32_t writeMapBegin (shared_ptr<TTransport> out,
- const TType keyType,
- const TType valType,
- const int32_t size) const = 0;
+ virtual uint32_t writeMapBegin(shared_ptr<TTransport> out,
+ const TType keyType,
+ const TType valType,
+ const int32_t size) const = 0;
+
+ virtual uint32_t writeMapEnd(shared_ptr<TTransport> out) const = 0;
+
+ virtual uint32_t writeListBegin(shared_ptr<TTransport> out,
+ const TType elemType,
+ const int32_t size) const = 0;
- virtual uint32_t writeMapEnd (shared_ptr<TTransport> out) const = 0;
+ virtual uint32_t writeListEnd(shared_ptr<TTransport> out) const = 0;
- virtual uint32_t writeListBegin (shared_ptr<TTransport> out,
- const TType elemType,
- const int32_t size) const = 0;
+ virtual uint32_t writeSetBegin(shared_ptr<TTransport> out,
+ const TType elemType,
+ const int32_t size) const = 0;
- virtual uint32_t writeListEnd (shared_ptr<TTransport> out) const = 0;
+ virtual uint32_t writeSetEnd(shared_ptr<TTransport> out) const = 0;
- virtual uint32_t writeSetBegin (shared_ptr<TTransport> out,
- const TType elemType,
- const int32_t size) const = 0;
+ virtual uint32_t writeBool(shared_ptr<TTransport> out,
+ const bool value) const = 0;
- virtual uint32_t writeSetEnd (shared_ptr<TTransport> out) const = 0;
+ virtual uint32_t writeByte(shared_ptr<TTransport> out,
+ const uint8_t byte) const = 0;
- virtual uint32_t writeByte (shared_ptr<TTransport> out,
- const uint8_t byte) const = 0;
+ virtual uint32_t writeI16(shared_ptr<TTransport> out,
+ const int16_t i16) const = 0;
- virtual uint32_t writeU32 (shared_ptr<TTransport> out,
- const uint32_t u32) const = 0;
+ virtual uint32_t writeU16(shared_ptr<TTransport> out,
+ const uint16_t u16) const = 0;
- virtual uint32_t writeI32 (shared_ptr<TTransport> out,
- const int32_t i32) const = 0;
+ virtual uint32_t writeU32(shared_ptr<TTransport> out,
+ const uint32_t u32) const = 0;
+
+ virtual uint32_t writeI32(shared_ptr<TTransport> out,
+ const int32_t i32) const = 0;
- virtual uint32_t writeU64 (shared_ptr<TTransport> out,
- const uint64_t u64) const = 0;
+ virtual uint32_t writeU64(shared_ptr<TTransport> out,
+ const uint64_t u64) const = 0;
- virtual uint32_t writeI64 (shared_ptr<TTransport> out,
- const int64_t i64) const = 0;
+ virtual uint32_t writeI64(shared_ptr<TTransport> out,
+ const int64_t i64) const = 0;
- virtual uint32_t writeString (shared_ptr<TTransport> out,
- const std::string& str) const = 0;
+ virtual uint32_t writeString(shared_ptr<TTransport> out,
+ const std::string& str) const = 0;
/**
* Reading functions
*/
- virtual uint32_t readMessasgeBegin (shared_ptr<TTransport> in,
- TMessageType& messageType,
- uint32_t& seqid) const = 0;
-
- virtual uint32_t readMessageEnd (shared_ptr<TTransport> in) const = 0;
+ virtual uint32_t readMessasgeBegin(shared_ptr<TTransport> in,
+ TMessageType& messageType,
+ uint32_t& seqid) const = 0;
+
+ virtual uint32_t readMessageEnd(shared_ptr<TTransport> in) const = 0;
- virtual uint32_t readStructBegin (shared_ptr<TTransport> in,
- std::string& name) const = 0;
+ virtual uint32_t readStructBegin(shared_ptr<TTransport> in,
+ std::string& name) const = 0;
- virtual uint32_t readStructEnd (shared_ptr<TTransport> in) const = 0;
+ virtual uint32_t readStructEnd(shared_ptr<TTransport> in) const = 0;
- virtual uint32_t readFieldBegin (shared_ptr<TTransport> in,
- std::string& name,
- TType& fieldType,
- uint16_t& fieldId) const = 0;
+ virtual uint32_t readFieldBegin(shared_ptr<TTransport> in,
+ std::string& name,
+ TType& fieldType,
+ int16_t& fieldId) const = 0;
- virtual uint32_t readFieldEnd (shared_ptr<TTransport> in) const = 0;
+ virtual uint32_t readFieldEnd(shared_ptr<TTransport> in) const = 0;
- virtual uint32_t readMapBegin (shared_ptr<TTransport> in,
- TType& keyType,
- TType& valType,
- int32_t& size) const = 0;
+ virtual uint32_t readMapBegin(shared_ptr<TTransport> in,
+ TType& keyType,
+ TType& valType,
+ int32_t& size) const = 0;
+
+ virtual uint32_t readMapEnd(shared_ptr<TTransport> in) const = 0;
+
+ virtual uint32_t readListBegin(shared_ptr<TTransport> in,
+ TType& elemType,
+ int32_t& size) const = 0;
+
+ virtual uint32_t readListEnd(shared_ptr<TTransport> in) const = 0;
- virtual uint32_t readMapEnd (shared_ptr<TTransport> in) const = 0;
+ virtual uint32_t readSetBegin(shared_ptr<TTransport> in,
+ TType& elemType,
+ int32_t& size) const = 0;
- virtual uint32_t readListBegin (shared_ptr<TTransport> in,
- TType& elemType,
- int32_t& size) const = 0;
+ virtual uint32_t readSetEnd(shared_ptr<TTransport> in) const = 0;
- virtual uint32_t readListEnd (shared_ptr<TTransport> in) const = 0;
+ virtual uint32_t readBool(shared_ptr<TTransport> in,
+ bool& value) const = 0;
- virtual uint32_t readSetBegin (shared_ptr<TTransport> in,
- TType& elemType,
- int32_t& size) const = 0;
+ virtual uint32_t readByte(shared_ptr<TTransport> in,
+ uint8_t& byte) const = 0;
- virtual uint32_t readSetEnd (shared_ptr<TTransport> in) const = 0;
+ virtual uint32_t readU16(shared_ptr<TTransport> in,
+ uint16_t& u16) const = 0;
- virtual uint32_t readByte (shared_ptr<TTransport> in,
- uint8_t& byte) const = 0;
+ virtual uint32_t readI16(shared_ptr<TTransport> in,
+ int16_t& i16) const = 0;
- virtual uint32_t readU32 (shared_ptr<TTransport> in,
- uint32_t& u32) const = 0;
+ virtual uint32_t readU32(shared_ptr<TTransport> in,
+ uint32_t& u32) const = 0;
- virtual uint32_t readI32 (shared_ptr<TTransport> in,
- int32_t& i32) const = 0;
+ virtual uint32_t readI32(shared_ptr<TTransport> in,
+ int32_t& i32) const = 0;
- virtual uint32_t readU64 (shared_ptr<TTransport> in,
- uint64_t& u64) const = 0;
+ virtual uint32_t readU64(shared_ptr<TTransport> in,
+ uint64_t& u64) const = 0;
- virtual uint32_t readI64 (shared_ptr<TTransport> in,
- int64_t& i64) const = 0;
+ virtual uint32_t readI64(shared_ptr<TTransport> in,
+ int64_t& i64) const = 0;
- virtual uint32_t readString (shared_ptr<TTransport> in,
- std::string& str) const = 0;
+ virtual uint32_t readString(shared_ptr<TTransport> in,
+ std::string& str) const = 0;
/**
* Method to arbitrarily skip over data.
{
uint32_t result = 0;
std::string name;
- uint16_t fid;
+ int16_t fid;
TType ftype;
result += readStructBegin(in, name);
while (true) {
struct Xtruct2
{
- byte byte_thing = 0,
- Xtruct struct_thing = 1,
- i32 i32_thing = 2
+ byte byte_thing,
+ Xtruct struct_thing,
+ i32 i32_thing
}
struct Insanity
{
map<Numberz, UserId> userMap = 0,
- list<Xtruct> xtructs = 1
+ list<Xtruct> xtructList = 1
}
service ThriftTest
/* So you think you've got this all worked, out eh? */
map<UserId, map<Numberz,Insanity>> testInsanity(Insanity argument = 0)
+
+ Xtruct testMulti(byte arg0, i32 arg1, u64 arg2, map<i16, string> arg3, Numberz arg4, UserId arg5)
}
Code Review / common / thrift.git / commitdiff
