C++ processMessage函数代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› C++›C++教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了C++中processMessage函数的典型用法代码示例。如果您正苦于以下问题：C++ processMessage函数的具体用法？C++ processMessage怎么用？C++ processMessage使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了processMessage函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C++代码示例。

示例1: processMessage

    void PathDisplay::setColor(const Ogre::ColourValue& color)
    {
        color_ = color;

        processMessage(current_message_);
        causeRender();
    }

开发者ID:talkingrobots，项目名称:NIFTi_OCU，代码行数:7，代码来源:PathDisplay.cpp

示例2: processMessage

void Server::processMessageGroup(QString message_gr, quint32 ipaddr)
{
    QStringList message_list = message_gr.split("\r\n", QString::KeepEmptyParts);
    for(int i=0; i<message_list.size(); i++) {
        processMessage(message_list.at(i), ipaddr);
    }
}

开发者ID:bukmare，项目名称:ESP_CStation，代码行数:7，代码来源:server.cpp

示例3: while

void Socket::processingLoop() {
    while (connected) {
        std::unique_lock<std::mutex> lock(processingMutex);
        while (connected && processingQueue.empty()) processingCondition.wait(lock);

        if (connected) {
            char *buffer = processingQueue.back();
            processingQueue.pop_back();
            lock.unlock();

            std::unique_lock<std::mutex> handlerLock(handlerSwapMutex);
            while (handlerSwapping) handlerSwapProcessingCondition.wait(handlerLock);
            handlerLock.unlock();

            activeProcessingCount++;

            processMessage(buffer);
            free(buffer);

            activeProcessingCount--;
            handlerSwapCondition.notify_all();
        } else {
            lock.unlock();
        }
    }
}

开发者ID:ColinEaster，项目名称:Cloud11，代码行数:26，代码来源:clientsocket.cpp

示例4: qDebug

// =====================================================================
//                          QWebSocket
// =====================================================================
void CWebSocketServer::onNewConnection()
{
    qDebug() << "CWebSocketServer : New Connection";
    QWebSocket *pSocket = m_pWebSocketServer->nextPendingConnection();
    if (!pSocket) return;

    m_clients.insert(pSocket, m_client_count);
    m_clients_rev.insert(m_client_count, pSocket);

    connect(pSocket, SIGNAL(textMessageReceived(QString)), this, SLOT(processMessage(QString)));
    connect(pSocket, SIGNAL(binaryMessageReceived(QByteArray)), this, SLOT(processMessage(QByteArray)));
    connect(pSocket, SIGNAL(disconnected()), this, SLOT(socketDisconnected()));

    emit connected(m_client_count);
    m_client_count++;
}

开发者ID:CRLG，项目名称:LABOTBOX，代码行数:19，代码来源:CWebSocketServer.cpp

示例5: cDebugDom

void AVReceiver::dataGet(std::string msg)
{
    if (msg.find('\n') == std::string::npos &&
        msg.find('\r') == std::string::npos)
    {
        //We have not a complete paquet yet, buffurize it.
        recv_buffer += msg;

        cDebugDom("output") << "Bufferize data.";

        return;
    }

    if (!recv_buffer.empty())
    {
        //Put last data in buffer
        recv_buffer += msg;
        msg = recv_buffer;
        recv_buffer.clear();
    }

    replace_str(msg, "\r\n", "\n");
    replace_str(msg, "\r", "\n");

    std::vector<std::string> tokens;
    Utils::split(msg, tokens, "\n");

    cDebugDom("output") << "Got " << tokens.size() << " messages.";

    for(uint i = 0; i < tokens.size(); i++)
        processMessage(tokens[i]);
}

开发者ID:expertisesolutions，项目名称:calaos_base，代码行数:32，代码来源:AVReceiver.cpp

示例6: D

void RenderWindow::repaint() {
    D("Entering\n");
    RenderWindowMessage msg;
    msg.cmd = CMD_REPAINT;
    (void) processMessage(msg);
    D("Exiting\n");
}

开发者ID:a-martynovich，项目名称:platform_external_qemu，代码行数:7，代码来源:RenderWindow.cpp

示例7: processMessage

    void GridCellsDisplay::setColor(const Ogre::ColourValue& color)
    {
        this->color = color;

        processMessage(current_message_);
        causeRender();
    }

开发者ID:talkingrobots，项目名称:NIFTi_OCU，代码行数:7，代码来源:GridCellsDisplay.cpp

示例8: memset

void ClientNetwork::readData()
{
    char msg[1024];
    memset(msg, 0, 1024);
    int len = clientSocket->read(msg, 1024);
    emit processMessage(msg, len);
}

开发者ID:zxymd5，项目名称:QtChess，代码行数:7，代码来源:clientnetwork.cpp

示例9: while

void Network::nextTick()
{
	// Перекладываем все сообщения в temp_queue, чтобы не начать обрабатывать сообщения следующего тика
	queue<Message> temp_queue;

	while(!message_queue.empty()) {
	    temp_queue.push(message_queue.front());
	    message_queue.pop();
	}

	applyInstability();

	if (temp_queue.empty())
	{
		idle_ticks++;
	}
	else
	{
		idle_ticks = 0;
		while(!temp_queue.empty()) {
		    processMessage(temp_queue.front());
		    temp_queue.pop();
		}
	}

	runIdleCalls();
}

开发者ID:ffloyd，项目名称:ds_simul，代码行数:27，代码来源:network.cpp

示例10: processMessage

void Network::runIdleCalls()
{
	for (int process_id = 0; process_id < processes.size(); ++process_id)
	{
		processMessage(Message(process_id));
	}
}

开发者ID:ffloyd，项目名称:ds_simul，代码行数:7，代码来源:network.cpp

示例11: while

void Connection::readyReadHandler()
{
    while (true) {
        size_t fileDescriptorsCount = 0;
        size_t bytesToRead = m_readBuffer.size() - m_readBufferSize;
        ssize_t bytesRead = readBytesFromSocket(m_socketDescriptor, m_readBuffer.data() + m_readBufferSize, bytesToRead,
                                                m_fileDescriptors.data() + m_fileDescriptorsSize, &fileDescriptorsCount);

        if (bytesRead < 0) {
            // EINTR was already handled by readBytesFromSocket.
            if (errno == EAGAIN || errno == EWOULDBLOCK)
                return;

            if (m_isConnected) {
                WTFLogAlways("Error receiving IPC message on socket %d in process %d: %s", m_socketDescriptor, getpid(), strerror(errno));
                connectionDidClose();
            }
            return;
        }

        m_readBufferSize += bytesRead;
        m_fileDescriptorsSize += fileDescriptorsCount;

        if (!bytesRead) {
            connectionDidClose();
            return;
        }

        // Process messages from data received.
        while (true) {
            if (!processMessage())
                break;
        }
    }
}

开发者ID:valbok，项目名称:WebKitForWayland，代码行数:35，代码来源:ConnectionUnix.cpp

示例12: waitFor

void C_GetTime::waitFor( void )
{
  do
  {
    if( _timeSlice == true ) processMessage();
  } while( !timeUp() );
}

开发者ID:Raxtion，项目名称:CT82，代码行数:7，代码来源:C_GetTime.cpp

示例13: zstr_recv

void MessageProcessor::processSocket()
{
    char* msg = zstr_recv(zmqSocket_);
    if (msg == nullptr) {
        Log::Error("zeromq recv() failed\n");
        return;
    }
    std::string requestString(msg);
    zstr_free(&msg);

    std::string responseString;

    bool error = processMessage(requestString, responseString);

    if (error) {
        responseString = "";
    }

    int rc = zstr_send(zmqSocket_, responseString.c_str());

    if (rc != 0) {
        Log::vError("MessageProcessor: failed to send response\n"
                    "request:\n%s\n\n"
                    "response:\n%s\n\n",
                    requestString.c_str(), responseString.c_str());
    }
}

开发者ID:Kodachi75，项目名称:opentxs，代码行数:27，代码来源:MessageProcessor.cpp

示例14: while

void OSCController::update()
{
    while (listener.hasWaitingMessages()) {
		osc::Message msg;
		listener.getNextMessage(&msg);
        processMessage( msg );
    }
}

开发者ID:panGenerator，项目名称:dodecaudionK20Visuals，代码行数:8，代码来源:OSCController.cpp

示例15: connect

void Client::addSocket(QtWebsocket::QWsSocket *socket)
{
    sockets << socket;

    connect(socket, SIGNAL(frameReceived(QString)), this, SLOT(processMessage(QString)));
    connect(socket, SIGNAL(disconnected()), this, SLOT(socketDisconnected()));
    connect(socket, SIGNAL(pong(quint64)), this, SLOT(processPong(quint64)));
}

开发者ID:abhipr1，项目名称:OpenTradingPlatform，代码行数:8，代码来源:client.cpp

示例16: processMessage

void QQmlProfilerService::pixmapEventImpl(PixmapEventType eventType, const QUrl &url, int count)
{
    // assuming enabled checked by caller
    QQmlProfilerData rd = {m_timer.nsecsElapsed(), (int)PixmapCacheEvent, (int)eventType,
                           url.toString(), -1, -1, -1, count, -1,
                           0, 0, 0, 0, 0};
    processMessage(rd);
}

开发者ID:CodeDJ，项目名称:qt5-hidpi，代码行数:8，代码来源:qqmlprofilerservice.cpp

示例17: propertyChanged

void NXTUltrasonicDisplay::setColor( const rviz::Color& color )
{
  color_ = color;

  propertyChanged(color_property_);

  processMessage(current_message_);
  causeRender();
}

开发者ID:alejandrobrazabarba，项目名称:nxt-original-，代码行数:9，代码来源:nxt_ultrasonic_display.cpp

示例18: QMainWindow

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow),
    _handler(makeHandler())
{
    ui->setupUi(this);
    connect(this,SIGNAL(vMessage(MsgPtr)),
        this,SLOT(processMessage(MsgPtr)));
}

开发者ID:davidkazlauskas，项目名称:DecoupledGuiExamples，代码行数:9，代码来源:mainwindow.cpp

示例19: QString

void QQmlProfilerService::endRange(RangeType range)
{
    if (!QQmlDebugService::isDebuggingEnabled() || !m_enabled)
        return;

    QQmlProfilerData rd = {m_timer.nsecsElapsed(), (int)RangeEnd, (int)range,
                           QString(), -1, -1, 0, 0, 0};
    processMessage(rd);
}

开发者ID:crobertd，项目名称:qtdeclarative，代码行数:9，代码来源:qqmlprofilerservice.cpp

示例20: processMessage

void QQmlProfilerService::rangeLocation(RangeType range, const QUrl &fileName, int line, int column)
{
    if (!QQmlDebugService::isDebuggingEnabled() || !m_enabled)
        return;

    QQmlProfilerData rd = {m_timer.nsecsElapsed(), (int)RangeLocation, (int)range,
                           fileName.toString(), line, column, 0, 0, 0};
    processMessage(rd);
}

开发者ID:crobertd，项目名称:qtdeclarative，代码行数:9，代码来源:qqmlprofilerservice.cpp

注：本文中的processMessage函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。