这篇教程C++ transport函数代码示例写得很实用，希望能帮到您。
本文整理汇总了C++中transport函数的典型用法代码示例。如果您正苦于以下问题：C++ transport函数的具体用法？C++ transport怎么用？C++ transport使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。 在下文中一共展示了transport函数的27个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C++代码示例。 示例1: ROS_ASSERTTransportTCPPtr TransportTCP::accept(){ ROS_ASSERT(is_server_); sockaddr client_address; socklen_t len = sizeof(client_address); int new_sock = ::accept(sock_, (sockaddr *)&client_address, &len); if (new_sock >= 0) { ROSCPP_LOG_DEBUG("Accepted connection on socket [%d], new socket [%d]", sock_, new_sock); TransportTCPPtr transport(new TransportTCP(poll_set_, flags_)); if (!transport->setSocket(new_sock)) { ROS_ERROR("Failed to set socket on transport for socket %d", new_sock); } return transport; } else { ROS_ERROR("accept() on socket [%d] failed with error [%s]", sock_, last_socket_error_string()); } return TransportTCPPtr();}
开发者ID:robotambassador，项目名称:robot-ambassadors，代码行数:25，
示例2: f_thrift_protocol_write_binaryvoid f_thrift_protocol_write_binary(CObjRef transportobj, const String& method_name, int64_t msgtype, CObjRef request_struct, int seqid, bool strict_write) { PHPOutputTransport transport(transportobj); if (strict_write) { int32_t version = VERSION_1 | msgtype; transport.writeI32(version); transport.writeString(method_name.data(), method_name.size()); transport.writeI32(seqid); } else { transport.writeString(method_name.data(), method_name.size()); transport.writeI8(msgtype); transport.writeI32(seqid); } Variant spec = HHVM_FN(hphp_get_static_property)( request_struct->o_getClassName(), s_TSPEC, false); binary_serialize_spec(request_struct, transport, spec.toArray()); transport.flush();}
开发者ID:ClaudiuC，项目名称:hhvm，代码行数:25，
示例3: transportbool uwsgi_handler::handle_request() { // Do something with the url for example // const std::string& url = request().var("REQUEST_URI"); // Or print all incoming variables // request().print_vars(); typedef tasks::net::uwsgi_thrift_transport<tasks::net::http_response> transport_type; typedef apache::thrift::protocol::TBinaryProtocol protocol_type; boost::shared_ptr<transport_type> transport(new transport_type(response_p())); boost::shared_ptr<protocol_type> protocol(new protocol_type(transport)); tasks::tools::thrift_server_writer<id_name, transport_type, protocol_type> writer("lookup", transport, protocol); id_name m; m.id = 33; m.name = "testtest"; writer.write(m); // Now send back a response response().set_status("200 OK"); response().set_header("Content-Type", "application/x-thrift"); send_response(); stats::inc_req(); return true;}
开发者ID:adtechlabs，项目名称:libtasks，代码行数:27，
示例4: mainint main(int argc, char** argv){ QApplication application(argc,argv); ros::init(argc, argv, "pcl_view"); ros::NodeHandle n; ros::Rate loop_rate(100); ROS_INFO("Start"); CloudMaker *filter = new Filter(); Viewer *viewer = new Viewer(); viewer->setFPSIsDisplayed(true); viewer->setFilter(filter); viewer->setWindowTitle("animation"); image_transport::ImageTransport transport(n); image_transport::CameraSubscriber depth_sub = transport.subscribeCamera("/camera/depth/image_raw", 1, &Filter::depthCb, filter); viewer->show(); return application.exec();}
开发者ID:walchko，项目名称:kinect，代码行数:25，
示例5: transportint ModuleSpanningTree::OnStats(char statschar, userrec* user, string_list &results){ if ((statschar == 'c') || (statschar == 'n')) { for (unsigned int i = 0; i < Utils->LinkBlocks.size(); i++) { results.push_back(std::string(ServerInstance->Config->ServerName)+" 213 "+user->nick+" "+statschar+" *@"+(Utils->LinkBlocks[i].HiddenFromStats ? "<hidden>" : Utils->LinkBlocks[i].IPAddr)+" * "+Utils->LinkBlocks[i].Name.c_str()+" "+ConvToStr(Utils->LinkBlocks[i].Port)+" "+(Utils->LinkBlocks[i].Hook.empty() ? "plaintext" : Utils->LinkBlocks[i].Hook)+" "+(Utils->LinkBlocks[i].AutoConnect ? 'a' : '-')+'s'); if (statschar == 'c') results.push_back(std::string(ServerInstance->Config->ServerName)+" 244 "+user->nick+" H * * "+Utils->LinkBlocks[i].Name.c_str()); } results.push_back(std::string(ServerInstance->Config->ServerName)+" 219 "+user->nick+" "+statschar+" :End of /STATS report"); ServerInstance->SNO->WriteToSnoMask('t',"%s '%c' requested by %s (%[email
C++ transport_disconnect函数代码示例
C++ transmit_register_setup函数代码示例
|
