| /dports/sysutils/synergy/synergy-core-1.14.0.4-stable/src/gui/src/ |
| H A D | ServerMessage.cpp | 20 ServerMessage::ServerMessage(const QString& message) : in ServerMessage() function in ServerMessage
27 bool ServerMessage::isNewClientMessage() const in isNewClientMessage()
32 bool ServerMessage::isExitMessage() const in isExitMessage()
37 bool ServerMessage::isConnectedMessage() const in isConnectedMessage()
42 bool ServerMessage::isDisconnectedMessage() const in isDisconnectedMessage()
47 const QString& ServerMessage::getClientName() const in getClientName()
52 QString ServerMessage::parseClientName(const QString& line) const in parseClientName()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/audioipc/server/src/ |
| H A D | lib.rs | 91 type Request = ServerMessage;
116 ServerMessage::ClientConnect => panic!("already connected"), in process_msg()
118 ServerMessage::ClientDisconnect => { in process_msg()
126 ServerMessage::ContextGetMaxChannelCount => context in process_msg()
131 ServerMessage::ContextGetMinLatency(ref params) => { in process_msg()
148 ServerMessage::ContextGetPreferredSampleRate => context in process_msg()
153 ServerMessage::ContextGetPreferredChannelLayout => context in process_msg()
169 ServerMessage::StreamDestroy(stm_tok) => { in process_msg()
174 ServerMessage::StreamStart(stm_tok) => self.streams[stm_tok] in process_msg()
179 ServerMessage::StreamStop(stm_tok) => self.streams[stm_tok] in process_msg()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/audioipc2-server/src/ |
| H A D | server.rs | 226 type ServerMessage = DeviceCollectionReq; typedef
233 type ServerMessage = CallbackReq; typedef
414 type ServerMessage = ServerMessage; typedef
418 if let ServerMessage::ClientConnect(pid) = req { in process()
471 msg: &ServerMessage, in process_msg() argument
474 ServerMessage::ClientConnect(_) => { in process_msg()
480 ServerMessage::ClientDisconnect => { in process_msg()
486 ServerMessage::ContextGetBackendId => { in process_msg()
490 ServerMessage::ContextGetMaxChannelCount => context in process_msg()
533 ServerMessage::StreamCreate(ref params) => self in process_msg()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/audioipc-server/src/ |
| H A D | server.rs | 365 type Request = ServerMessage;
374 if let ServerMessage::ClientConnect(pid) = req { in process()
422 msg: &ServerMessage, in process_msg() argument
425 ServerMessage::ClientConnect(_) => { in process_msg()
431 ServerMessage::ClientDisconnect => { in process_msg()
437 ServerMessage::ContextGetBackendId => { in process_msg()
441 ServerMessage::ContextGetMaxChannelCount => context in process_msg()
446 ServerMessage::ContextGetMinLatency(ref params) => { in process_msg()
484 ServerMessage::StreamCreate(ref params) => self in process_msg()
488 ServerMessage::StreamInit(stm_tok, ref params) => self in process_msg()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/audioipc-server/src/ |
| H A D | server.rs | 365 type Request = ServerMessage;
374 if let ServerMessage::ClientConnect(pid) = req { in process()
422 msg: &ServerMessage, in process_msg() argument
425 ServerMessage::ClientConnect(_) => { in process_msg()
431 ServerMessage::ClientDisconnect => { in process_msg()
437 ServerMessage::ContextGetBackendId => { in process_msg()
441 ServerMessage::ContextGetMaxChannelCount => context in process_msg()
446 ServerMessage::ContextGetMinLatency(ref params) => { in process_msg()
484 ServerMessage::StreamCreate(ref params) => self in process_msg()
488 ServerMessage::StreamInit(stm_tok, ref params) => self in process_msg()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/media/audioipc/server/src/ |
| H A D | server.rs | 385 type Request = ServerMessage;
394 if let ServerMessage::ClientConnect(pid) = req { in process()
439 msg: &ServerMessage, in process_msg() argument
442 ServerMessage::ClientConnect(_) => { in process_msg()
448 ServerMessage::ClientDisconnect => { in process_msg()
454 ServerMessage::ContextGetBackendId => { in process_msg()
458 ServerMessage::ContextGetMaxChannelCount => context in process_msg()
463 ServerMessage::ContextGetMinLatency(ref params) => { in process_msg()
480 ServerMessage::ContextGetPreferredSampleRate => context in process_msg()
501 ServerMessage::StreamInit(ref params) => self in process_msg()
[all …]
|
| /dports/net-p2p/py-nicotine-plus/nicotine-plus-3.2.0/pynicotine/ |
| H A D | slskmessages.py | 314 class ServerMessage(SlskMessage): class
318 class Login(ServerMessage):
372 class SetWaitPort(ServerMessage):
403 class AddUser(ServerMessage):
444 class RemoveUser(ServerMessage):
512 class JoinRoom(ServerMessage):
582 class LeaveRoom(ServerMessage):
745 class SetStatus(ServerMessage):
865 class Relogged(ServerMessage):
1051 class RoomAdded(ServerMessage):
[all …]
|
| /dports/games/cockatrice/Cockatrice-2021-01-26-Release-2.8.0/common/ |
| H A D | server_abstractuserinterface.cpp | 17 void Server_AbstractUserInterface::sendProtocolItemByType(ServerMessage::MessageType type, in sendProtocolItemByType()
21 case ServerMessage::RESPONSE: in sendProtocolItemByType()
24 case ServerMessage::SESSION_EVENT: in sendProtocolItemByType()
27 case ServerMessage::GAME_EVENT_CONTAINER: in sendProtocolItemByType()
30 case ServerMessage::ROOM_EVENT: in sendProtocolItemByType()
48 … const QList<QPair<ServerMessage::MessageType, ::google::protobuf::Message *>> &preResponseQueue = in sendResponseContainer()
65 … const QList<QPair<ServerMessage::MessageType, ::google::protobuf::Message *>> &postResponseQueue = in sendResponseContainer()
|
| H A D | server_response_containers.h | 89 …QList<QPair<ServerMessage::MessageType, ::google::protobuf::Message *>> preResponseQueue, postResp…
107 void enqueuePreResponseItem(ServerMessage::MessageType type, ::google::protobuf::Message *item) in enqueuePreResponseItem()
111 void enqueuePostResponseItem(ServerMessage::MessageType type, ::google::protobuf::Message *item) in enqueuePostResponseItem()
115 …const QList<QPair<ServerMessage::MessageType, ::google::protobuf::Message *>> &getPreResponseQueue… in getPreResponseQueue()
119 …const QList<QPair<ServerMessage::MessageType, ::google::protobuf::Message *>> &getPostResponseQueu… in getPostResponseQueue()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/audioipc-server/src/ |
| H A D | server.rs | 363 type Request = ServerMessage;
370 if let ServerMessage::ClientConnect(pid) = req { in process()
419 msg: &ServerMessage, in process_msg() argument
422 ServerMessage::ClientConnect(_) => { in process_msg()
428 ServerMessage::ClientDisconnect => { in process_msg()
434 ServerMessage::ContextGetBackendId => { in process_msg()
438 ServerMessage::ContextGetMaxChannelCount => context in process_msg()
443 ServerMessage::ContextGetMinLatency(ref params) => { in process_msg()
481 ServerMessage::StreamCreate(ref params) => self in process_msg()
485 ServerMessage::StreamInit(stm_tok, ref params) => self in process_msg()
[all …]
|
| /dports/editors/kak-lsp/kak-lsp-11.1.0/src/ |
| H A D | language_server_transport.rs | 14 pub to_lang_server: Worker<ServerMessage, Void>,
15 pub from_lang_server: Worker<Void, ServerMessage>,
118 sender: &Sender<ServerMessage>, in reader_loop() argument
155 if sender.send(ServerMessage::Response(output)).is_err() { in reader_loop()
163 if sender.send(ServerMessage::Request(msg)).is_err() { in reader_loop()
171 fn writer_loop(mut writer: impl Write, receiver: &Receiver<ServerMessage>) -> io::Result<()> { in writer_loop()
174 ServerMessage::Request(request) => serde_json::to_string(&request), in writer_loop()
175 ServerMessage::Response(response) => serde_json::to_string(&response), in writer_loop()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/audioipc2-client/src/ |
| H A D | context.rs | 17 ServerMessage,
32 type ServerMessage = ServerMessage; typedef
43 rpc: rpccore::Proxy<ServerMessage, ClientMessage>,
59 pub fn rpc(&self) -> rpccore::Proxy<ServerMessage, ClientMessage> { in rpc() argument
70 fn promote_thread(rpc: &rpccore::Proxy<ServerMessage, ClientMessage>) { in promote_thread() argument
75 rpc.call(ServerMessage::PromoteThreadToRealTime(bytes)); in promote_thread()
84 fn promote_thread(_rpc: &rpccore::Proxy<ServerMessage, ClientMessage>) { in promote_thread() argument
110 rpc: &rpccore::Proxy<ServerMessage, ClientMessage>, in promote_and_register_thread() argument
129 type ServerMessage = DeviceCollectionReq; typedef
132 fn process(&mut self, req: Self::ServerMessage) -> Self::ClientMessage { in process()
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/src/signaling/ |
| H A D | testclient_test.go | 120 func checkMessageType(message *ServerMessage, expectedType string) error { argument
451 func (c *TestClient) RunUntilMessage(ctx context.Context) (message *ServerMessage, err error) {
455 var m ServerMessage
465 func (c *TestClient) RunUntilHello(ctx context.Context) (message *ServerMessage, err error) {
508 func checkMessageRoomId(message *ServerMessage, roomId string) error { argument
529 func (c *TestClient) checkMessageJoined(message *ServerMessage, hello *HelloServerMessage) error {
591 func checkMessageRoomlistUpdate(message *ServerMessage) (*RoomEventServerMessage, error) { argument
631 func checkMessageParticipantsInCall(message *ServerMessage) (*RoomEventServerMessage, error) { argument
643 func checkMessageParticipantFlags(message *ServerMessage) (*RoomFlagsServerMessage, error) { argument
655 func checkMessageRoomMessage(message *ServerMessage) (*RoomEventMessage, error) { argument
[all …]
|
| H A D | room.go | 333 func (r *Room) publish(message *ServerMessage) {
347 message := &ServerMessage{
368 message := &ServerMessage{
395 message := &ServerMessage{
524 message := &ServerMessage{
543 message := &ServerMessage{
558 func (r *Room) getParticipantsUpdateMessage(users []map[string]interface{}) *ServerMessage {
561 message := &ServerMessage{
604 message := &ServerMessage{
682 msg := &ServerMessage{
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/audioipc2/src/ |
| H A D | rpccore.rs | 30 type ServerMessage; typedef
38 type ServerMessage; typedef
41 fn process(&mut self, req: Self::ServerMessage) -> Self::ClientMessage; in process()
130 messages: ProxyReceiver<C::ServerMessage, C::ClientMessage>,
136 type Out = C::ServerMessage;
175 ) -> (ClientHandler<C>, Proxy<C::ServerMessage, C::ClientMessage>) { in make_client() argument
202 type In = S::ServerMessage;
|
| /dports/games/cockatrice/Cockatrice-2021-01-26-Release-2.8.0/cockatrice/src/ |
| H A D | localclient.cpp | 12 …connect(lsi, SIGNAL(itemToClient(const ServerMessage &)), this, SLOT(itemFromServer(const ServerMe… in LocalClient()
33 void LocalClient::itemFromServer(const ServerMessage &item) in itemFromServer()
|
| H A D | abstractclient.cpp | 61 void AbstractClient::processProtocolItem(const ServerMessage &item) in processProtocolItem()
64 case ServerMessage::RESPONSE: { in processProtocolItem()
77 case ServerMessage::SESSION_EVENT: { in processProtocolItem()
124 case ServerMessage::GAME_EVENT_CONTAINER: { in processProtocolItem()
128 case ServerMessage::ROOM_EVENT: { in processProtocolItem()
|
| /dports/devel/allegro5/allegro5-5.2.7.0/examples/ |
| H A D | ex_enet_server.c | 45 static ServerMessage create_join_message(int player_id) in create_join_message()
47 ServerMessage msg_out; in create_join_message()
59 ServerMessage msg_out; in send_receive()
149 ServerMessage msg; in update_players()
156 sizeof(ServerMessage), in update_players()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/actix-server-1.0.3/src/ |
| H A D | service.rs | 17 pub(crate) enum ServerMessage { enum
42 Request = (Option<CounterGuard>, ServerMessage),
66 type Request = (Option<CounterGuard>, ServerMessage);
75 fn call(&mut self, (guard, req): (Option<CounterGuard>, ServerMessage)) -> Self::Future { in call()
77 ServerMessage::Connect(stream) => { in call()
|
| /dports/editors/helix/helix-0.5.0/helix-lsp/src/ |
| H A D | transport.rs | 32 enum ServerMessage { enum
87 ) -> Result<ServerMessage> { in recv_server_message() argument
131 let output: serde_json::Result<ServerMessage> = serde_json::from_str(msg); in recv_server_message()
192 msg: ServerMessage, in process_server_message() argument
195 ServerMessage::Output(output) => self.process_request_response(output).await?, in process_server_message()
196 ServerMessage::Call(call) => { in process_server_message()
315 … let notification = ServerMessage::Call(jsonrpc::Call::Notification(jsonrpc::Notification { in send()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/audioipc-client/src/ |
| H A D | context.rs | 18 ServerMessage,
38 type Request = ServerMessage;
51 rpc: rpc::ClientProxy<ServerMessage, ClientMessage>,
67 pub fn rpc(&self) -> rpc::ClientProxy<ServerMessage, ClientMessage> { in rpc() argument
78 fn promote_thread(rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>) { in promote_thread() argument
83 rpc.call(ServerMessage::PromoteThreadToRealTime(bytes)); in promote_thread()
92 fn promote_thread(_rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>) { in promote_thread() argument
118 rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>, in promote_and_register_thread() argument
188 tx_rpc: &mpsc::Sender<rpc::ClientProxy<ServerMessage, ClientMessage>>, in init() argument
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/audioipc-client/src/ |
| H A D | context.rs | 19 ServerMessage,
39 type Request = ServerMessage;
54 rpc: rpc::ClientProxy<ServerMessage, ClientMessage>,
70 pub fn rpc(&self) -> rpc::ClientProxy<ServerMessage, ClientMessage> { in rpc() argument
81 fn promote_thread(rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>) { in promote_thread() argument
86 rpc.call(ServerMessage::PromoteThreadToRealTime(bytes)); in promote_thread()
95 fn promote_thread(_rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>) { in promote_thread() argument
121 rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>, in promote_and_register_thread() argument
191 tx_rpc: &mpsc::Sender<rpc::ClientProxy<ServerMessage, ClientMessage>>, in init() argument
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/rust/audioipc-client/src/ |
| H A D | context.rs | 19 ServerMessage,
39 type Request = ServerMessage;
54 rpc: rpc::ClientProxy<ServerMessage, ClientMessage>,
70 pub fn rpc(&self) -> rpc::ClientProxy<ServerMessage, ClientMessage> { in rpc() argument
81 fn promote_thread(rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>) { in promote_thread() argument
86 rpc.call(ServerMessage::PromoteThreadToRealTime(bytes)); in promote_thread()
95 fn promote_thread(_rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>) { in promote_thread() argument
121 rpc: &rpc::ClientProxy<ServerMessage, ClientMessage>, in promote_and_register_thread() argument
191 tx_rpc: &mpsc::Sender<rpc::ClientProxy<ServerMessage, ClientMessage>>, in init() argument
|
| /dports/security/sudo/sudo-1.9.8p2/lib/logsrv/ |
| H A D | log_server.pb-c.c | 588 ServerMessage *
594 return (ServerMessage *) in server_message__unpack()
1607 offsetof(ServerMessage, type_case),
1608 offsetof(ServerMessage, u.hello),
1619 offsetof(ServerMessage, type_case),
1631 offsetof(ServerMessage, type_case),
1632 offsetof(ServerMessage, u.log_id),
1643 offsetof(ServerMessage, type_case),
1644 offsetof(ServerMessage, u.error),
1656 offsetof(ServerMessage, u.abort),
[all …]
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/ |
| H A D | ClientSinkBridge.h | 41 ServerMessage,
48 ServerMessage,
62 void push(ServerMessage&& value);
|