| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/igm/sockjs-go/sockjs/ |
| H A D | buffer.go | 7 type messageBuffer struct { struct
8 popCh chan string
9 closeCh chan struct{}
10 once sync.Once // for b.close()
20 func (b *messageBuffer) push(messages ...string) error {
32 func (b *messageBuffer) pop() (string, error) {
41 func (b *messageBuffer) close() { b.once.Do(func() { close(b.closeCh) }) }
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/igm/sockjs-go/v3/sockjs/ |
| H A D | buffer.go | 10 type messageBuffer struct { struct
11 popCh chan string
12 closeCh chan struct{}
13 once sync.Once // for b.close()
23 func (b *messageBuffer) push(messages ...string) error {
35 func (b *messageBuffer) pop(ctx context.Context) (string, error) {
46 func (b *messageBuffer) close() { b.once.Do(func() { close(b.closeCh) }) }
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/angle/third_party/VK-GL-CTS/src/execserver/ |
| H A D | xsTestDriver.cpp | 84 bool TestDriver::poll (ByteBuffer& messageBuffer) in poll()
182 bool TestDriver::pollLogFile (ByteBuffer& messageBuffer) in pollLogFile()
187 bool TestDriver::pollInfo (ByteBuffer& messageBuffer) in pollInfo()
192 bool TestDriver::pollBuffer (ByteBuffer& messageBuffer, MessageType msgType) in pollBuffer()
227 bool TestDriver::writeMessage (ByteBuffer& messageBuffer, const Message& message) in writeMessage()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Dispatcher/ |
| H A D | IMessageFilterTable.cs | 14 bool GetMatchingValue(MessageBuffer messageBuffer, out TFilterData value); in GetMatchingValue()
18 bool GetMatchingValues(MessageBuffer messageBuffer, ICollection<TFilterData> results); in GetMatchingValues()
23 bool GetMatchingFilter(MessageBuffer messageBuffer, out MessageFilter filter); in GetMatchingFilter()
25 bool GetMatchingFilters(MessageBuffer messageBuffer, ICollection<MessageFilter> results); in GetMatchingFilters()
|
| H A D | AndMessageFilterTable.cs | 167 FilterDataPair InnerMatch(MessageBuffer messageBuffer) in InnerMatch()
219 void InnerMatch(MessageBuffer messageBuffer, ICollection<MessageFilter> results) in InnerMatch()
233 void InnerMatchData(MessageBuffer messageBuffer, ICollection<FilterData> results) in InnerMatchData()
301 public bool GetMatchingValue(MessageBuffer messageBuffer, out FilterData data) in GetMatchingValue()
338 public bool GetMatchingFilter(MessageBuffer messageBuffer, out MessageFilter filter) in GetMatchingFilter()
374 … public bool GetMatchingFilters(MessageBuffer messageBuffer, ICollection<MessageFilter> results) in GetMatchingFilters()
408 public bool GetMatchingValues(MessageBuffer messageBuffer, ICollection<FilterData> results) in GetMatchingValues()
|
| H A D | ActionMessageFilterTable.cs | 278 public bool GetMatchingValue(MessageBuffer messageBuffer, out TFilterData data) in GetMatchingValue()
317 public bool GetMatchingFilter(MessageBuffer messageBuffer, out MessageFilter filter) in GetMatchingFilter()
353 … public bool GetMatchingFilters(MessageBuffer messageBuffer, ICollection<MessageFilter> results) in GetMatchingFilters()
395 public bool GetMatchingValues(MessageBuffer messageBuffer, ICollection<TFilterData> results) in GetMatchingValues()
|
| H A D | MatchAllMessageFilter.cs | 19 public override bool Match(MessageBuffer messageBuffer) in Match()
|
| H A D | MatchNoneMessageFilter.cs | 19 public override bool Match(MessageBuffer messageBuffer) in Match()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.ServiceModel/System.ServiceModel.Dispatcher/ |
| H A D | IMessageFilterTable.cs | 44 bool GetMatchingFilter (MessageBuffer messageBuffer, out MessageFilter filter); in GetMatchingFilter()
47 bool GetMatchingFilters (MessageBuffer messageBuffer, ICollection<MessageFilter> results); in GetMatchingFilters()
50 bool GetMatchingValue (MessageBuffer messageBuffer, out TFilterData value); in GetMatchingValue()
53 bool GetMatchingValues (MessageBuffer messageBuffer, ICollection<TFilterData> results); in GetMatchingValues()
|
| H A D | XPathMessageFilterTable.cs | 145 public bool GetMatchingFilter (MessageBuffer messageBuffer, out MessageFilter filter) in GetMatchingFilter()
165 public bool GetMatchingFilters (MessageBuffer messageBuffer, ICollection<MessageFilter> results) in GetMatchingFilters()
185 public bool GetMatchingValue (MessageBuffer messageBuffer, out TFilterData data) in GetMatchingValue()
205 public bool GetMatchingValues (MessageBuffer messageBuffer, ICollection<TFilterData> results) in GetMatchingValues()
|
| H A D | MatchAllMessageFilter.cs | 47 public override bool Match (MessageBuffer messageBuffer) in Match()
|
| H A D | MatchNoneMessageFilter.cs | 47 public override bool Match (MessageBuffer messageBuffer) in Match()
|
| /dports/games/scorched3d/scorched/src/common/tank/ |
| H A D | TankShotHistory.cpp | 129 static char messageBuffer[255]; in getRotationString() local
140 static char messageBuffer[255]; in getElevationString() local
151 static char messageBuffer[255]; in getPowerString() local
|
| /dports/databases/db18/db-18.1.40/util/db_gui/ |
| H A D | MessageBuffer.java | 23 private final BlockingQueue<String> messageBuffer; field in MessageBuffer
32 BlockingQueue<String> messageBuffer) { in MessageBuffer()
|
| /dports/devel/raknet/raknet-3.9.2_10,1/Source/ |
| H A D | SocketLayer.cpp | 96 LPVOID messageBuffer; in Connect() local
153 LPVOID messageBuffer; in SetDoNotFragment() local
238 LPVOID messageBuffer; in SetSocketOptions() local
348 LPVOID messageBuffer; in CreateBoundSocket() local
413 LPVOID messageBuffer; in CreateBoundSocket() local
1016 LPVOID messageBuffer; in SendTo() local
1057 LPVOID messageBuffer; in SendToTTL() local
1075 LPVOID messageBuffer; in SendToTTL() local
1203 LPVOID messageBuffer; in GetMyIP_Win32() local
1219 LPVOID messageBuffer; in GetMyIP_Win32() local
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ |
| H A D | MessageMetadataResult.java | 39 MessageMetadataResult(int messageLength, ByteBuffer messageBuffer, Message message) { in MessageMetadataResult()
113 private final ByteBuffer messageBuffer; field in MessageMetadataResult
|
| /dports/databases/arrow/apache-arrow-6.0.1/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ |
| H A D | MessageMetadataResult.java | 39 MessageMetadataResult(int messageLength, ByteBuffer messageBuffer, Message message) { in MessageMetadataResult()
113 private final ByteBuffer messageBuffer; field in MessageMetadataResult
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ |
| H A D | MessageMetadataResult.java | 39 MessageMetadataResult(int messageLength, ByteBuffer messageBuffer, Message message) { in MessageMetadataResult()
113 private final ByteBuffer messageBuffer; field in MessageMetadataResult
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Routing/System/ServiceModel/Dispatcher/ |
| H A D | StrictAndMessageFilter.cs | 94 public bool GetMatchingFilter(MessageBuffer messageBuffer, out MessageFilter filter) in GetMatchingFilter()
104 … public bool GetMatchingFilters(MessageBuffer messageBuffer, ICollection<MessageFilter> results) in GetMatchingFilters()
144 public bool GetMatchingValue(MessageBuffer messageBuffer, out TFilterData value) in GetMatchingValue()
176 … public bool GetMatchingValues(MessageBuffer messageBuffer, ICollection<TFilterData> results) in GetMatchingValues()
|
| /dports/math/vtk8/VTK-8.2.0/ThirdParty/vtkm/vtk-m/vtkm/exec/testing/ |
| H A D | UnitTestCellEdgeFace.cxx | 55 char messageBuffer[256]; in DoTest() local
144 char messageBuffer[256]; in DoTest() local
193 char messageBuffer[256]; in DoTest() local
|
| H A D | UnitTestParametricCoordinates.cxx | 71 char messageBuffer[256]; in CompareCoordinates() local
98 char messageBuffer[256]; in TestPCoordsSpecial() local
137 char messageBuffer[256]; in TestPCoordsSample() local
197 char messageBuffer[256]; in MakePointWCoords() local
|
| /dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/src/ableton/discovery/ |
| H A D | tst_UdpMessenger.cpp | 80 const auto messageBuffer = iface.sentMessages[0].first; variable
129 const auto messageBuffer = iface.sentMessages[1].first; variable
197 const auto messageBuffer = iface.sentMessages[1].first; variable
|
| /dports/audio/csound/csound-6.15.0/Opcodes/websockets/ |
| H A D | WebSocketOpcode.c | 67 unsigned char *messageBuffer; member
370 void *messageBuffer, struct lws *websocket) in WebSocketOpcode_writeOnce()
381 void *messageBuffer, struct lws *websocket) in WebSocketOpcode_writeFragments()
411 void *messageBuffer, struct lws *websocket) in WebSocketOpcode_writeMessage()
425 void *messageBuffer) in WebSocketOpcode_handleServerWritable()
555 void *messageBuffer = in Websocket_callback() local
|
| /dports/games/0ad/0ad-0.0.23b-alpha/build/premake/premake5/src/host/ |
| H A D | os_remove.c | 33 LPWSTR messageBuffer = NULL; in os_remove() local
|
| /dports/devel/premake5/premake-5.0.0-alpha16-src/src/host/ |
| H A D | os_remove.c | 33 LPWSTR messageBuffer = NULL; in os_remove() local
|