Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(496)

Side by Side Diff: runtime/vm/message.h

Issue 749373002: - Implement Isolate.ping. (Closed) Base URL: http://dart.googlecode.com/svn/branches/bleeding_edge/dart/
Patch Set: Created 6 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 #ifndef VM_MESSAGE_H_ 5 #ifndef VM_MESSAGE_H_
6 #define VM_MESSAGE_H_ 6 #define VM_MESSAGE_H_
7 7
8 #include "platform/assert.h" 8 #include "platform/assert.h"
9 #include "vm/globals.h" 9 #include "vm/globals.h"
10 10
(...skipping 12 matching lines...) Expand all
23 kFirstPriority = 0, 23 kFirstPriority = 0,
24 kNumPriorities = 2, 24 kNumPriorities = 2,
25 } Priority; 25 } Priority;
26 26
27 // Values defining the type of OOB messages. OOB messages can only be 27 // Values defining the type of OOB messages. OOB messages can only be
28 // fixed length arrays where the first element is a Smi with one of the 28 // fixed length arrays where the first element is a Smi with one of the
29 // valid values below. 29 // valid values below.
30 typedef enum { 30 typedef enum {
31 kIllegalOOB = 0, 31 kIllegalOOB = 0,
32 kServiceOOBMsg = 1, 32 kServiceOOBMsg = 1,
33 kIsolateLibOOBMsg = 2 33 kIsolateLibOOBMsg = 2,
34 kDelayedIsolateLibOOBMsg = 3,
34 } OOBMsgTag; 35 } OOBMsgTag;
35 36
36 // A port number which is never used. 37 // A port number which is never used.
37 static const Dart_Port kIllegalPort = 0; 38 static const Dart_Port kIllegalPort = 0;
38 39
39 // A new message to be sent between two isolates. The data handed to this 40 // A new message to be sent between two isolates. The data handed to this
40 // message will be disposed by calling free() once the message object is 41 // message will be disposed by calling free() once the message object is
41 // being destructed (after delivery or when the receiving port is closed). 42 // being destructed (after delivery or when the receiving port is closed).
42 Message(Dart_Port dest_port, 43 Message(Dart_Port dest_port,
43 uint8_t* data, 44 uint8_t* data,
44 intptr_t len, 45 intptr_t len,
45 Priority priority, 46 Priority priority,
46 Dart_Port delivery_failure_port = kIllegalPort) 47 Dart_Port delivery_failure_port = kIllegalPort)
47 : next_(NULL), 48 : next_(NULL),
48 dest_port_(dest_port), 49 dest_port_(dest_port),
49 delivery_failure_port_(delivery_failure_port), 50 delivery_failure_port_(delivery_failure_port),
50 data_(data), 51 data_(data),
51 len_(len), 52 len_(len),
52 priority_(priority) { 53 priority_(priority) {
53 ASSERT(dest_port != kIllegalPort);
54 ASSERT((priority == kNormalPriority) || 54 ASSERT((priority == kNormalPriority) ||
55 (delivery_failure_port == kIllegalPort)); 55 (delivery_failure_port == kIllegalPort));
56 } 56 }
57 ~Message() { 57 ~Message() {
58 ASSERT(delivery_failure_port_ == kIllegalPort); 58 ASSERT(delivery_failure_port_ == kIllegalPort);
59 free(data_); 59 free(data_);
60 } 60 }
61 61
62 Dart_Port dest_port() const { return dest_port_; } 62 Dart_Port dest_port() const { return dest_port_; }
63 uint8_t* data() const { return data_; } 63 uint8_t* data() const { return data_; }
(...skipping 16 matching lines...) Expand all
80 80
81 DISALLOW_COPY_AND_ASSIGN(Message); 81 DISALLOW_COPY_AND_ASSIGN(Message);
82 }; 82 };
83 83
84 // There is a message queue per isolate. 84 // There is a message queue per isolate.
85 class MessageQueue { 85 class MessageQueue {
86 public: 86 public:
87 MessageQueue(); 87 MessageQueue();
88 ~MessageQueue(); 88 ~MessageQueue();
89 89
90 void Enqueue(Message* msg); 90 void Enqueue(Message* msg, bool before_events);
91 91
92 // Gets the next message from the message queue or NULL if no 92 // Gets the next message from the message queue or NULL if no
93 // message is available. This function will not block. 93 // message is available. This function will not block.
94 Message* Dequeue(); 94 Message* Dequeue();
95 95
96 bool IsEmpty() { return head_ == NULL; } 96 bool IsEmpty() { return head_ == NULL; }
97 97
98 // Clear all messages from the message queue. 98 // Clear all messages from the message queue.
99 void Clear(); 99 void Clear();
100 100
101 private: 101 private:
102 Message* head_; 102 Message* head_;
103 Message* tail_; 103 Message* tail_;
104 104
105 DISALLOW_COPY_AND_ASSIGN(MessageQueue); 105 DISALLOW_COPY_AND_ASSIGN(MessageQueue);
106 }; 106 };
107 107
108 } // namespace dart 108 } // namespace dart
109 109
110 #endif // VM_MESSAGE_H_ 110 #endif // VM_MESSAGE_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698