/dports/net-im/telepathy-qt/telepathy-qt-0.9.8/TelepathyQt/ |
H A D | message.cpp | 523 ReceivedMessage::DeliveryDetails &ReceivedMessage::DeliveryDetails::operator=( in operator =() 714 ReceivedMessage::ReceivedMessage() in ReceivedMessage() function in Tp::ReceivedMessage 725 ReceivedMessage::ReceivedMessage(const MessagePartList &parts, in ReceivedMessage() function in Tp::ReceivedMessage 740 ReceivedMessage::ReceivedMessage(const ReceivedMessage &other) in ReceivedMessage() function in Tp::ReceivedMessage 748 ReceivedMessage &ReceivedMessage::operator=(const ReceivedMessage &other) in operator =() 760 ReceivedMessage::~ReceivedMessage() in ~ReceivedMessage() 845 bool ReceivedMessage::isRescued() const in isRescued() 857 bool ReceivedMessage::isSilent() const in isSilent() 881 ReceivedMessage::DeliveryDetails ReceivedMessage::deliveryDetails() const in deliveryDetails() 896 uint ReceivedMessage::pendingId() const in pendingId() [all …]
|
H A D | message.h | 85 friend class ReceivedMessage; variable 97 class TP_QT_EXPORT ReceivedMessage : public Message 128 friend class ReceivedMessage; 137 ReceivedMessage(const ReceivedMessage &other); 138 ReceivedMessage &operator=(const ReceivedMessage &other); 139 ~ReceivedMessage(); 159 ReceivedMessage(const MessagePartList &parts, 161 ReceivedMessage();
|
H A D | text-channel.h | 38 class ReceivedMessage; variable 69 QList<ReceivedMessage> messageQueue() const; 75 void acknowledge(const QList<ReceivedMessage> &messages); 77 void forget(const QList<ReceivedMessage> &messages); 102 void messageReceived(const Tp::ReceivedMessage &message); 104 const Tp::ReceivedMessage &message);
|
H A D | simple-text-observer.cpp | 81 SIGNAL(messageReceived(Tp::ReceivedMessage)), in TextChannelWrapper() 82 SLOT(onChannelMessageReceived(Tp::ReceivedMessage))); in TextChannelWrapper() 93 const Tp::ReceivedMessage &message) in onChannelMessageReceived() 253 SIGNAL(channelMessageReceived(Tp::ReceivedMessage,Tp::TextChannelPtr)), in onNewChannels() 254 SIGNAL(messageReceived(Tp::ReceivedMessage,Tp::TextChannelPtr))); in onNewChannels() 256 foreach (const ReceivedMessage &message, textChannel->messageQueue()) { in onNewChannels()
|
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | received_message.go | 18 type ReceivedMessage struct { struct 24 type receivedMsgParseFn func([]byte) (*ReceivedMessage, error) 39 func parseReceivedMessage(wm []byte) (*ReceivedMessage, error) { 60 func parseOpReply(wm []byte) (*ReceivedMessage, error) { 85 rm := &ReceivedMessage{ 91 func parseReceivedOpMsg(wm []byte) (*ReceivedMessage, error) { 107 rm := &ReceivedMessage{ 113 func parseReceivedOpCompressed(wm []byte) (*ReceivedMessage, error) {
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | received_message.go | 18 type ReceivedMessage struct { struct 24 type receivedMsgParseFn func([]byte) (*ReceivedMessage, error) 39 func parseReceivedMessage(wm []byte) (*ReceivedMessage, error) { 60 func parseOpReply(wm []byte) (*ReceivedMessage, error) { 85 rm := &ReceivedMessage{ 91 func parseReceivedOpMsg(wm []byte) (*ReceivedMessage, error) { 107 rm := &ReceivedMessage{ 113 func parseReceivedOpCompressed(wm []byte) (*ReceivedMessage, error) {
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | received_message.go | 18 type ReceivedMessage struct { struct 24 type receivedMsgParseFn func([]byte) (*ReceivedMessage, error) 39 func parseReceivedMessage(wm []byte) (*ReceivedMessage, error) { 60 func parseOpReply(wm []byte) (*ReceivedMessage, error) { 85 rm := &ReceivedMessage{ 91 func parseReceivedOpMsg(wm []byte) (*ReceivedMessage, error) { 107 rm := &ReceivedMessage{ 113 func parseReceivedOpCompressed(wm []byte) (*ReceivedMessage, error) {
|
/dports/misc/mxnet/incubator-mxnet-1.9.0/3rdparty/tvm/tests/crt/ |
H A D | session_test.cc | 41 class ReceivedMessage { class 43 ReceivedMessage(MessageType type, std::string message) : type{type}, message{message} {} in ReceivedMessage() function in ReceivedMessage 45 bool operator==(const ReceivedMessage& other) const { in operator ==() 80 std::vector<ReceivedMessage> messages_received; 104 ReceivedMessage(message_type, message)); in TestSessionMessageReceivedThunk() 114 void PrintTo(ReceivedMessage msg, std::ostream* os) { in PrintTo() 170 EXPECT_EQ(bob_.messages_received[1], ReceivedMessage(MessageType::kNormal, "hello")); in TEST_F() 188 EXPECT_EQ(bob_.messages_received[0], ReceivedMessage(MessageType::kLog, "log1")); in TEST_F() 194 EXPECT_EQ(alice_.messages_received[0], ReceivedMessage(MessageType::kLog, "zero")); in TEST_F() 202 EXPECT_EQ(bob_.messages_received[0], ReceivedMessage(MessageType::kLog, "log1")); in TEST_F() [all …]
|
/dports/net-im/ktp-common-internals/ktp-common-internals-21.12.3/KTp/OTR/ |
H A D | channel-adapter.cpp | 33 static int getId(const Tp::ReceivedMessage &recvMes) in getId() 38 class OTRMessage : public Tp::ReceivedMessage 41 OTRMessage(const Tp::ReceivedMessage &recMes) in OTRMessage() 42 : Tp::ReceivedMessage(recMes) in OTRMessage() 47 : Tp::ReceivedMessage(message, channel) in OTRMessage() 69 ReceivedMessage::setSender(contact); in setSender() 150 SIGNAL(messageReceived(Tp::ReceivedMessage))); in setupTextChannel() 249 QList<Tp::ReceivedMessage> toAck; in acknowledge() 250 QList<Tp::ReceivedMessage> eventsToRemove; in acknowledge() 252 Q_FOREACH(const Tp::ReceivedMessage &mes, messages) { in acknowledge() [all …]
|
H A D | utils.cpp | 29 Tp::UIntList getPendingMessagesIDs(const QList<Tp::ReceivedMessage> &messageQueue) in getPendingMessagesIDs() 32 Q_FOREACH(const Tp::ReceivedMessage &mes, messageQueue) { in getPendingMessagesIDs() 61 bool isOtrEvent(const Tp::ReceivedMessage &message) in isOtrEvent() 66 QString processOtrMessage(const Tp::ReceivedMessage &message) in processOtrMessage()
|
H A D | utils.h | 32 … KTPOTR_EXPORT Tp::UIntList getPendingMessagesIDs(const QList<Tp::ReceivedMessage> &messageQueue); 41 KTPOTR_EXPORT bool isOtrEvent(const Tp::ReceivedMessage &message); 47 KTPOTR_EXPORT QString processOtrMessage(const Tp::ReceivedMessage &message);
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/whisper/whisperv5/ |
H A D | filter.go | 38 Messages map[common.Hash]*ReceivedMessage 57 watcher.Messages = make(map[common.Hash]*ReceivedMessage) 97 var msg *ReceivedMessage 134 func (f *Filter) processEnvelope(env *Envelope) *ReceivedMessage { 156 func (f *Filter) Trigger(msg *ReceivedMessage) { 165 func (f *Filter) Retrieve() (all []*ReceivedMessage) { 169 all = make([]*ReceivedMessage, 0, len(f.Messages)) 174 f.Messages = make(map[common.Hash]*ReceivedMessage) // delete old messages 178 func (f *Filter) MatchMessage(msg *ReceivedMessage) bool {
|
H A D | message.go | 58 type ReceivedMessage struct { struct 81 func (msg *ReceivedMessage) isSymmetricEncryption() bool { argument 85 func (msg *ReceivedMessage) isAsymmetricEncryption() bool { argument 257 func (msg *ReceivedMessage) decryptSymmetric(key []byte, nonce []byte) error { argument 279 func (msg *ReceivedMessage) decryptAsymmetric(key *ecdsa.PrivateKey) error { argument 288 func (msg *ReceivedMessage) Validate() bool { argument 319 func (msg *ReceivedMessage) extractPadding(end int) (int, bool) { argument 334 func (msg *ReceivedMessage) SigToPubKey() *ecdsa.PublicKey { argument 346 func (msg *ReceivedMessage) hash() []byte { argument
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/whisper/whisperv6/ |
H A D | filter.go | 40 Messages map[common.Hash]*ReceivedMessage 72 watcher.Messages = make(map[common.Hash]*ReceivedMessage) 158 var msg *ReceivedMessage 204 func (f *Filter) Trigger(msg *ReceivedMessage) { 215 func (f *Filter) Retrieve() (all []*ReceivedMessage) { 219 all = make([]*ReceivedMessage, 0, len(f.Messages)) 224 f.Messages = make(map[common.Hash]*ReceivedMessage) // delete old messages 232 func (f *Filter) MatchMessage(msg *ReceivedMessage) bool {
|
H A D | message.go | 61 type ReceivedMessage struct { struct 84 func (msg *ReceivedMessage) isSymmetricEncryption() bool { argument 88 func (msg *ReceivedMessage) isAsymmetricEncryption() bool { argument 267 func (msg *ReceivedMessage) decryptSymmetric(key []byte) error { argument 292 func (msg *ReceivedMessage) decryptAsymmetric(key *ecdsa.PrivateKey) error { argument 301 func (msg *ReceivedMessage) ValidateAndParse() bool { argument 338 func (msg *ReceivedMessage) SigToPubKey() *ecdsa.PublicKey { argument 350 func (msg *ReceivedMessage) hash() []byte { argument
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/internal/ |
H A D | subscription_message_queue_test.cc | 37 std::vector<google::pubsub::v1::ReceivedMessage> GenerateMessages() { in GenerateMessages() 65 google::pubsub::v1::ReceivedMessage m0; in GenerateMessages() 67 google::pubsub::v1::ReceivedMessage m1; in GenerateMessages() 69 google::pubsub::v1::ReceivedMessage m2; in GenerateMessages() 76 std::vector<google::pubsub::v1::ReceivedMessage> messages) { in AsPullResponse() 84 std::vector<google::pubsub::v1::ReceivedMessage> GenerateOrderKeyMessages( in GenerateOrderKeyMessages() 86 std::vector<google::pubsub::v1::ReceivedMessage> result; in GenerateOrderKeyMessages() 89 google::pubsub::v1::ReceivedMessage m; in GenerateOrderKeyMessages() 136 std::vector<google::pubsub::v1::ReceivedMessage> received; in TEST() 137 auto handler = [&received](google::pubsub::v1::ReceivedMessage m) { in TEST() [all …]
|
/dports/audio/faust/faust-2.37.3/architecture/osclib/oscpack/tests/ |
H A D | OscUnitTests.cpp | 128 ReceivedMessage m( ReceivedPacket(buffer, sizeof(s)-1) ); in test1() 133 ReceivedMessage::const_iterator i = m.ArgumentsBegin(); in test1() 167 ReceivedMessage m( ReceivedPacket(buffer, sizeof(s)-1) ); in test1() 196 ReceivedMessage m( p );\ 275 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) );\ 289 ReceivedMessage m( *b.ElementsBegin() );\ 302 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) );\ 316 ReceivedMessage m( *b.ElementsBegin() );\ 334 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) ); in test3() 374 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) ); in test3() [all …]
|
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/oscpack_1_1_0/tests/ |
H A D | OscUnitTests.cpp | 128 ReceivedMessage m( ReceivedPacket(buffer, sizeof(s)-1) ); in test1() 133 ReceivedMessage::const_iterator i = m.ArgumentsBegin(); in test1() 167 ReceivedMessage m( ReceivedPacket(buffer, sizeof(s)-1) ); in test1() 196 ReceivedMessage m( p );\ 275 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) );\ 289 ReceivedMessage m( *b.ElementsBegin() );\ 302 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) );\ 316 ReceivedMessage m( *b.ElementsBegin() );\ 334 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) ); in test3() 374 ReceivedMessage m( ReceivedPacket(ps.Data(), ps.Size()) ); in test3() [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/internal/ |
H A D | subscription_message_queue_test.cc | 47 std::vector<google::pubsub::v1::ReceivedMessage> received; in TEST() 48 auto handler = [&received](google::pubsub::v1::ReceivedMessage m) { in TEST() 83 google::pubsub::v1::ReceivedMessage m0; in TEST() 84 google::pubsub::v1::ReceivedMessage m1; in TEST() 85 google::pubsub::v1::ReceivedMessage m2; in TEST()
|
/dports/net-im/ktp-common-internals/ktp-common-internals-21.12.3/otr-proxy/KTpProxy/ |
H A D | otr-proxy-channel-adaptee.cpp | 167 SIGNAL(messageReceived(const Tp::ReceivedMessage&)), in connectProxy() 168 SLOT(onMessageReceived(const Tp::ReceivedMessage&))); in connectProxy() 171 SIGNAL(pendingMessageRemoved(const Tp::ReceivedMessage&)), in connectProxy() 172 SLOT(onPendingMessageRemoved(const Tp::ReceivedMessage&))); in connectProxy() 177 for(const Tp::ReceivedMessage &m: chan->messageQueue()) { in connectProxy() 191 disconnect(chan.data(), SIGNAL(messageReceived(const Tp::ReceivedMessage&)), in disconnectProxy() 192 this, SLOT(onMessageReceived(const Tp::ReceivedMessage&))); in disconnectProxy() 194 disconnect(chan.data(), SIGNAL(pendingMessageRemoved(const Tp::ReceivedMessage&)), in disconnectProxy() 195 this, SLOT(onPendingMessageRemoved(const Tp::ReceivedMessage&))); in disconnectProxy() 284 QList<Tp::ReceivedMessage> toAcknowledge; in acknowledgePendingMessages() [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/dom/serviceworkers/ |
H A D | ServiceWorkerContainer.h | 132 struct ReceivedMessage; 137 void EnqueueReceivedMessageDispatch(RefPtr<ReceivedMessage> aMessage); 142 void DispatchMessage(RefPtr<ReceivedMessage> aMessage); 148 ReceivedMessage& aMessage, 166 nsTArray<RefPtr<ReceivedMessage>> mPendingMessages;
|
/dports/lang/spidermonkey78/firefox-78.9.0/dom/serviceworkers/ |
H A D | ServiceWorkerContainer.h | 130 struct ReceivedMessage; 135 void EnqueueReceivedMessageDispatch(RefPtr<ReceivedMessage> aMessage); 140 void DispatchMessage(RefPtr<ReceivedMessage> aMessage); 146 ReceivedMessage& aMessage, 164 nsTArray<RefPtr<ReceivedMessage>> mPendingMessages;
|
/dports/www/firefox/firefox-99.0/dom/serviceworkers/ |
H A D | ServiceWorkerContainer.h | 132 struct ReceivedMessage; 137 void EnqueueReceivedMessageDispatch(RefPtr<ReceivedMessage> aMessage); 142 void DispatchMessage(RefPtr<ReceivedMessage> aMessage); 148 ReceivedMessage& aMessage, 166 nsTArray<RefPtr<ReceivedMessage>> mPendingMessages;
|
/dports/mail/thunderbird/thunderbird-91.8.0/dom/serviceworkers/ |
H A D | ServiceWorkerContainer.h | 132 struct ReceivedMessage; 137 void EnqueueReceivedMessageDispatch(RefPtr<ReceivedMessage> aMessage); 142 void DispatchMessage(RefPtr<ReceivedMessage> aMessage); 148 ReceivedMessage& aMessage, 166 nsTArray<RefPtr<ReceivedMessage>> mPendingMessages;
|
/dports/net-im/telepathy-qt/telepathy-qt-0.9.8/tests/dbus/ |
H A D | text-chan.cpp | 47 void onMessageReceived(const Tp::ReceivedMessage &); 48 void onMessageRemoved(const Tp::ReceivedMessage &); 77 QList<ReceivedMessage> received; 78 QList<ReceivedMessage> removed; 84 void TestTextChan::onMessageReceived(const ReceivedMessage &message) in onMessageReceived() 91 void TestTextChan::onMessageRemoved(const ReceivedMessage &message) in onMessageRemoved() 248 SIGNAL(messageReceived(const Tp::ReceivedMessage &)), in commonTest() 249 SLOT(onMessageReceived(const Tp::ReceivedMessage &)))); in commonTest() 253 SLOT(onMessageRemoved(const Tp::ReceivedMessage &)))); in commonTest() 372 ReceivedMessage r(received.at(0)); in commonTest() [all …]
|