Home
last modified time | relevance | path

Searched refs:ReceivedMessage (Results 1 – 25 of 922) sorted by relevance

12345678910>>...37

/dports/net-im/telepathy-qt/telepathy-qt-0.9.8/TelepathyQt/
H A Dmessage.cpp523 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 Dmessage.h85 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 Dtext-channel.h38 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 Dsimple-text-observer.cpp81 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 Dreceived_message.go18 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 Dreceived_message.go18 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 Dreceived_message.go18 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 Dsession_test.cc41 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 Dchannel-adapter.cpp33 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 Dutils.cpp29 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 Dutils.h32 … 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 Dfilter.go38 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 Dmessage.go58 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 Dfilter.go40 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 Dmessage.go61 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 Dsubscription_message_queue_test.cc37 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 DOscUnitTests.cpp128 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 DOscUnitTests.cpp128 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 Dsubscription_message_queue_test.cc47 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 Dotr-proxy-channel-adaptee.cpp167 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 DServiceWorkerContainer.h132 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 DServiceWorkerContainer.h130 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 DServiceWorkerContainer.h132 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 DServiceWorkerContainer.h132 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 Dtext-chan.cpp47 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 …]

12345678910>>...37