本文整理汇总了C++中chan函数的典型用法代码示例。如果您正苦于以下问题:C++ chan函数的具体用法?C++ chan怎么用?C++ chan使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了chan函数的18个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: channelName
bool PvaClientMonitor::waitEvent(double secondsToWait)
{
if(PvaClient::getDebug()) {
string channelName("disconnected");
Channel::shared_pointer chan(channel.lock());
if(chan) channelName = chan->getChannelName();
cout << "PvaClientMonitor::waitEvent"
<< " channelName " << channelName
<< endl;
}
if(!isStarted) {
Channel::shared_pointer chan(channel.lock());
string channelName("disconnected");
if(chan) channelName = chan->getChannelName();
string message = string("channel ") + channelName
+ " PvaClientMonitor::waitEvent illegal state ";
throw std::runtime_error(message);
}
if(poll()) return true;
userWait = true;
if(secondsToWait==0.0) {
waitForEvent.wait();
} else {
waitForEvent.wait(secondsToWait);
}
userWait = false;
return poll();
}
开发者ID:anjohnson,项目名称:pvaClientCPP,代码行数:28,代码来源:pvaClientMonitor.cpp
示例2: chan
/*
install an alternative protocol handler. This allows another
protocol to take over the link if MAVLink goes idle. It is used to
allow for the AP_BLHeli pass-thru protocols to run on hal.uartA
*/
bool GCS::install_alternative_protocol(mavlink_channel_t c, GCS_MAVLINK::protocol_handler_fn_t handler)
{
if (c >= num_gcs()) {
return false;
}
if (chan(c).alternative.handler) {
// already have one installed - we may need to add support for
// multiple alternative handlers
return false;
}
chan(c).alternative.handler = handler;
return true;
}
开发者ID:Javiercerna,项目名称:ardupilot,代码行数:18,代码来源:GCS.cpp
示例3: chan
NS_IMETHODIMP
nsStreamLoader::OnStartRequest(nsIRequest* request, nsISupports *ctxt)
{
nsCOMPtr<nsIChannel> chan( do_QueryInterface(request) );
if (chan) {
int64_t contentLength = -1;
chan->GetContentLength(&contentLength);
if (contentLength >= 0) {
if (contentLength > UINT32_MAX) {
// Too big to fit into uint32, so let's bail.
// XXX we should really make mAllocated and mLength 64-bit instead.
return NS_ERROR_OUT_OF_MEMORY;
}
uint32_t contentLength32 = uint32_t(contentLength);
// preallocate buffer
mData = static_cast<uint8_t*>(NS_Alloc(contentLength32));
if (!mData) {
return NS_ERROR_OUT_OF_MEMORY;
}
mAllocated = contentLength32;
}
}
mContext = ctxt;
return NS_OK;
}
开发者ID:AshishNamdev,项目名称:mozilla-central,代码行数:25,代码来源:nsStreamLoader.cpp
示例4: checkRPCState
void PvaClientRPC::request(
PVStructure::shared_pointer const & pvArgument,
PvaClientRPCRequesterPtr const & pvaClientRPCRequester)
{
checkRPCState();
this->pvaClientRPCRequester = pvaClientRPCRequester;
if(responseTimeout<=0.0) {
{
Lock xx(mutex);
if(rpcState!=rpcIdle) {
Channel::shared_pointer chan(channel.lock());
string channelName("disconnected");
if(chan) channelName = chan->getChannelName();
string message = "channel "
+ channelName
+ " PvaClientRPC::request request aleady active ";
throw std::runtime_error(message);
}
rpcState = rpcActive;
}
channelRPC->request(pvArgument);
return;
}
request(pvArgument);
}
开发者ID:epics-base,项目名称:pvaClientCPP,代码行数:25,代码来源:pvaClientRPC.cpp
示例5: main
int main() {
freopen("form.in","r",stdin);
freopen("form.out","w",stdout);
scanf("%d%d",&N,&M);
null=new Splay;
nullinit();
seq=null;
for (i=1;i<=N;++i) {
scanf("%d",&a[i]);
b[i]=a[i];
mini(dist,abs(seq->closest(b[i])->data-b[i]));
seq->ins(b[i]);
}
h[0]=N-1;
for (i=1;i<N;++i) h[i]=abs(b[i]-a[i+1]),hh[i]=t[i]=i;
t[N]=0;
for (i=N-1;i;--i) down(i);
char opt[14];
int cnt=0;
while (M--) {
scanf("%s",opt);
switch (opt[4]) {
case 'R': scanf("%d%d",&i,&k);
chan(t[i],abs(b[i]-k));
b[i]=k;
if (i<N) inse(abs((b[i])-a[i+1]),i);
mini(dist,abs(k-seq->closest(k)->data));
seq->ins(k);
break;
case 'G': ++cnt; printf("%d\n",h[1]); break;
case 'S': ++cnt; printf("%d\n",dist); break;
}
}
}
开发者ID:wwt17,项目名称:BZOJ,代码行数:34,代码来源:1058+[ZJOI2007]报表统计(O2WA)#.cpp
示例6: RasterImage
/* static */ already_AddRefed<Image>
ImageFactory::CreateRasterImage(nsIRequest* aRequest,
imgStatusTracker* aStatusTracker,
const nsCString& aMimeType,
ImageURL* aURI,
uint32_t aImageFlags,
uint32_t aInnerWindowId)
{
nsresult rv;
nsRefPtr<RasterImage> newImage = new RasterImage(aStatusTracker, aURI);
rv = newImage->Init(aMimeType.get(), aImageFlags);
NS_ENSURE_SUCCESS(rv, BadImage(newImage));
newImage->SetInnerWindowID(aInnerWindowId);
uint32_t len = GetContentSize(aRequest);
// Pass anything usable on so that the RasterImage can preallocate
// its source buffer.
if (len > 0) {
uint32_t sizeHint = std::min<uint32_t>(len, 20000000); // Bound by something reasonable
rv = newImage->SetSourceSizeHint(sizeHint);
if (NS_FAILED(rv)) {
// Flush memory, try to get some back, and try again.
rv = nsMemory::HeapMinimize(true);
nsresult rv2 = newImage->SetSourceSizeHint(sizeHint);
// If we've still failed at this point, things are going downhill.
if (NS_FAILED(rv) || NS_FAILED(rv2)) {
NS_WARNING("About to hit OOM in imagelib!");
}
}
}
nsAutoCString ref;
aURI->GetRef(ref);
mozilla::net::nsMediaFragmentURIParser parser(ref);
if (parser.HasResolution()) {
newImage->SetRequestedResolution(parser.GetResolution());
}
if (parser.HasSampleSize()) {
/* Get our principal */
nsCOMPtr<nsIChannel> chan(do_QueryInterface(aRequest));
nsCOMPtr<nsIPrincipal> principal;
if (chan) {
nsContentUtils::GetSecurityManager()->GetChannelPrincipal(chan,
getter_AddRefs(principal));
}
if ((principal &&
principal->GetAppStatus() == nsIPrincipal::APP_STATUS_CERTIFIED) ||
gEnableMozSampleSize) {
newImage->SetRequestedSampleSize(parser.GetSampleSize());
}
}
return newImage.forget();
}
开发者ID:JCROM-FxOS,项目名称:b2jc_gecko,代码行数:60,代码来源:ImageFactory.cpp
示例7: getRasterLayerStatistics
int getRasterLayerStatistics(Layer* pLayer, uint32_t channel,
uint32_t component, struct RasterStatistics* pStatistics)
{
RasterLayer* pRaster = dynamic_cast<RasterLayer*>(pLayer);
RasterChannelType chan(static_cast<RasterChannelTypeEnum>(channel));
ComplexComponent comp(static_cast<ComplexComponentEnum>(component));
if (pRaster == NULL || pStatistics == NULL || !chan.isValid() || !comp.isValid())
{
setLastError(SIMPLE_BAD_PARAMS);
return 1;
}
Statistics* pStats = pRaster->getStatistics(chan);
if (pStats == NULL || !pStats->areStatisticsCalculated(comp))
{
setLastError(SIMPLE_OTHER_FAILURE);
return 1;
}
pStatistics->min = pStats->getMin(comp);
pStatistics->max = pStats->getMax(comp);
pStatistics->mean = pStats->getAverage(comp);
pStatistics->stddev = pStats->getStandardDeviation(comp);
const double* pTmp = NULL;
const unsigned int* pTmp2 = NULL;
pStats->getHistogram(pTmp, pTmp2, comp);
pStatistics->pHistogramCenters = const_cast<double*>(pTmp);
pStatistics->pHistogramCounts = const_cast<unsigned int*>(pTmp2);
pStatistics->pPercentiles = const_cast<double*>(pStats->getPercentiles(comp));
pStatistics->resolution = pStats->getStatisticsResolution();
setLastError(SIMPLE_NO_ERROR);
return 0;
}
开发者ID:Siddharthk,项目名称:opticks,代码行数:32,代码来源:SimpleViews.cpp
示例8: chan
Status PvaClientMonitor::waitConnect()
{
if(PvaClient::getDebug()) cout << "PvaClientMonitor::waitConnect\n";
if(connectState==connected) {
if(!connectStatus.isOK()) connectState = connectIdle;
return connectStatus;
}
if(connectState!=connectActive) {
Channel::shared_pointer chan(channel.lock());
string channelName("disconnected");
if(chan) channelName = chan->getChannelName();
string message = string("channel ")
+ channelName
+ " PvaClientMonitor::waitConnect illegal connect state ";
throw std::runtime_error(message);
}
if(PvaClient::getDebug()) {
cout << "PvaClientMonitor::waitConnect calling waitForConnect.wait\n";
}
waitForConnect.wait();
connectState = connectStatus.isOK() ? connected : connectIdle;
if(PvaClient::getDebug()) {
cout << "PvaClientMonitor::waitConnect"
<< " connectStatus " << (connectStatus.isOK() ? "connected" : "not connected");
}
return connectStatus;
}
开发者ID:anjohnson,项目名称:pvaClientCPP,代码行数:27,代码来源:pvaClientMonitor.cpp
示例9: tolower
void ServerState::addChannel(string& name, Channel* channel) {
string lname = name;
int size = lname.size();
for (int i = 0; i < size; ++i) {
lname[i] = (char) tolower(lname[i]);
}
ChannelPtr chan(channel);
channelMap[lname] = chan;
}
开发者ID:41149512,项目名称:fserv,代码行数:9,代码来源:server_state.cpp
示例10: chan
// ÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑ
// ¥ ThrowRuntimeError
// ÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑÑ
// Throws a VM error. Adds the channel that threw to the error message.
void CProgMoanChannel::ThrowRuntimeError(
OSErr inErr)
{
StAEDescriptor chan(mId);
AERecord context= {typeNull,0};
UAEDesc::AddKeyDesc(&context,keyTBMoanChannel,chan);
ThrowAEErr_(inErr,context);
}
开发者ID:mctully,项目名称:tntbasic,代码行数:14,代码来源:CProgMoanChannel.cpp
示例11: chan
void WaveConfigPopout::SaveChannel(UInt_t chNum)
{
ChannelConfig chan(fBEnabled->GetState(),
fNEntryOffset->GetNumber(),
fNEntryChThreshold->GetNumber(),
(ChannelTrigger)fCBChTrig->GetSelected());
if(chNum == 0)
config.setGlobalChan(chan);
else
config.addChannel(chNum-1, chan);
}
开发者ID:anthoak13,项目名称:CAEN-DAQ,代码行数:11,代码来源:WaveConfigPopout.cpp
示例12: channelName
PvaClientRPC::~PvaClientRPC()
{
if(PvaClient::getDebug()) {
string channelName("disconnected");
Channel::shared_pointer chan(channel.lock());
if(chan) channelName = chan->getChannelName();
cout<< "PvaClientRPC::~PvaClientRPC"
<< " channelName " << channelName
<< endl;
}
}
开发者ID:epics-base,项目名称:pvaClientCPP,代码行数:11,代码来源:pvaClientRPC.cpp
示例13: xx
void PvaClientRPC::requestDone(
const Status& status,
ChannelRPC::shared_pointer const & channelRPC,
PVStructure::shared_pointer const & pvResponse)
{
PvaClientRPCRequesterPtr req = pvaClientRPCRequester.lock();
{
Lock xx(mutex);
requestStatus = status;
if(PvaClient::getDebug()) {
string channelName("disconnected");
Channel::shared_pointer chan(channel.lock());
if(chan) channelName = chan->getChannelName();
cout << "PvaClientRPC::requestDone"
<< " channelName " << channelName
<< endl;
}
if(rpcState!=rpcActive) {
string channelName("disconnected");
Channel::shared_pointer chan(channel.lock());
if(chan) channelName = chan->getChannelName();
string message = "channel "
+ channelName
+" PvaClientRPC::requestDone"
+ " but not active";
throw std::runtime_error(message);
}
if(req && (responseTimeout<=0.0)) {
rpcState = rpcIdle;
} else {
rpcState = rpcComplete;
if(!req) this->pvResponse = pvResponse;
waitForDone.signal();
}
}
if(req) {
req->requestDone(status,shared_from_this(),pvResponse);
}
}
开发者ID:epics-base,项目名称:pvaClientCPP,代码行数:39,代码来源:pvaClientRPC.cpp
示例14: chan
struct fuse_chan *fuse_mount(const char *mountpoint, struct fuse_args *args)
{
if (mountpoint==NULL || strlen(mountpoint)==0) return NULL;
std::auto_ptr<fuse_chan> chan(new fuse_chan());
//NOTE: we used to do chan->init() here to check that Dokan DLLs can be loaded.
//However, this does not live well with Cygwin. It's common for filesystem drivers
//to daemon()ize themselves (which involves fork() call) and forking doesn't work
//with Dokan. So defer loading until the main loop.
chan->mountpoint=mountpoint;
return chan.release();
}
开发者ID:cnhup,项目名称:encfs4win-reloaded,代码行数:13,代码来源:docanfuse.cpp
示例15: query
bool ScanDTVTransport::FillFromDB(DTVTunerType type, uint mplexid)
{
if (!DTVMultiplex::FillFromDB(type, mplexid))
return false;
MSqlQuery query(MSqlQuery::InitCon());
query.prepare(
"SELECT c.mplexid, c.sourceid, c.chanid, "
" c.callsign, c.name, c.channum, "
" c.serviceid, c.atsc_major_chan, c.atsc_minor_chan, "
" c.useonairguide, c.visible, c.freqid, "
" c.icon, c.tvformat, c.xmltvid, "
" d.transportid, d.networkid, c.default_authority "
"FROM channel AS c, dtv_multiplex AS d "
"WHERE c.mplexid = :MPLEXID AND"
" c.mplexid = d.mplexid");
query.bindValue(":MPLEXID", mplexid);
if (!query.exec())
{
MythDB::DBError("ScanDTVTransport::FillFromDB", query);
return false;
}
while (query.next())
{
ChannelInsertInfo chan(
query.value(0).toUInt(), query.value(1).toUInt(),
query.value(2).toUInt(), query.value(3).toString(),
query.value(4).toString(), query.value(5).toString(),
query.value(6).toUInt(),
query.value(7).toUInt(), query.value(8).toUInt(),
query.value(9).toUInt(), !query.value(10).toUInt(),
false,
query.value(11).toString(), query.value(12).toString(),
query.value(13).toString(), query.value(14).toString(),
0, 0, 0,
query.value(15).toUInt(), query.value(16).toUInt(),
0,
QString::null,
false, false, false, false,
false, false, false, false,
false, false, false, 0,
query.value(17).toString() /* default_authority */);
channels.push_back(chan);
}
return true;
}
开发者ID:mojie126,项目名称:mythtv,代码行数:50,代码来源:dtvmultiplex.cpp
示例16: chan
void PvaClientRPC::rpcConnect(
const Status& status,
ChannelRPC::shared_pointer const & channelRPC)
{
Channel::shared_pointer chan(channel.lock());
if(PvaClient::getDebug()) {
string channelName("disconnected");
Channel::shared_pointer chan(channel.lock());
if(chan) channelName = chan->getChannelName();
cout << "PvaClientRPC::rpcConnect"
<< " channelName " << channelName
<< " status.isOK " << (status.isOK() ? "true" : "false")
<< endl;
}
if(!chan) return;
connectStatus = status;
connectState = connected;
if(PvaClient::getDebug()) {
cout << "PvaClientRPC::rpcConnect calling waitForConnect.signal\n";
}
waitForConnect.signal();
}
开发者ID:epics-base,项目名称:pvaClientCPP,代码行数:23,代码来源:pvaClientRPC.cpp
示例17: issueConnect
void PvaClientMonitor::connect()
{
if(PvaClient::getDebug()) cout << "PvaClientMonitor::connect\n";
issueConnect();
Status status = waitConnect();
if(status.isOK()) return;
Channel::shared_pointer chan(channel.lock());
string channelName("disconnected");
if(chan) channelName = chan->getChannelName();
string message = string("channel ")
+ channelName
+ " PvaClientMonitor::connect "
+ status.getMessage();
throw std::runtime_error(message);
}
开发者ID:anjohnson,项目名称:pvaClientCPP,代码行数:15,代码来源:pvaClientMonitor.cpp
示例18: issueConnect
void PvaClientRPC::connect()
{
if(PvaClient::getDebug()) cout << "PvaClientRPC::connect\n";
issueConnect();
Status status = waitConnect();
if(status.isOK()) return;
Channel::shared_pointer chan(channel.lock());
string channelName("disconnected");
if(chan) channelName = chan->getChannelName();
string message = string("channel ")
+ channelName
+ " PvaClientRPC::connect "
+ status.getMessage();
throw RPCRequestException(Status::STATUSTYPE_ERROR,message);
}
开发者ID:epics-base,项目名称:pvaClientCPP,代码行数:15,代码来源:pvaClientRPC.cpp
注:本文中的chan函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论