Home
last modified time | relevance | path

Searched refs:msg_dict (Results 1 – 25 of 52) sorted by relevance

123

/dports/net-mgmt/py-napalm-logs/napalm-logs-0.9.0/napalm_logs/
H A Dserver.py157 msg_dict = {}
180 msg_dict = {}
185 msg_dict['message'] = msg_dict['message'].strip()
188 if 'pri' in msg_dict:
189 msg_dict['facility'] = int(int(msg_dict['pri']) / 8)
190 msg_dict['severity'] = int(int(msg_dict['pri']) - (msg_dict['facility'] * 8))
191 return msg_dict
206 if msg_dict:
213 msg_dict = {'message': msg}
214 ret.append((None, msg_dict))
[all …]
H A Ddevice.py140 def _parse(self, msg_dict): argument
152 if match_on not in msg_dict:
155 if message['tag'] != msg_dict[match_on]:
287 host = msg_dict.get('host')
288 prefix_id = msg_dict.pop('__prefix_id__')
289 if 'timestamp' in msg_dict:
296 facility = msg_dict.get('facility')
297 severity = msg_dict.get('severity')
299 kwargs = self._parse(msg_dict)
307 'message_details': msg_dict,
[all …]
/dports/net-p2p/bitcoin/bitcoin-22.0/contrib/message-capture/
H A Dmessage-capture-parser.py117 msg_dict = {}
119 msg_dict["time"] = time
131 msg_dict["msgtype"] = msgtype_tmp
133 msg_dict["msgtype"] = "UNREADABLE"
134 msg_dict["body"] = msg_ser.read().hex()
136 messages.append(msg_dict)
142 msg_dict["msgtype"] = msgtype.decode()
151 msg_dict["body"] = msg_ser.read().hex()
153 messages.append(msg_dict)
159 msg_dict["body"] = to_jsonable(msg)
[all …]
/dports/net-p2p/bitcoin-daemon/bitcoin-22.0/contrib/message-capture/
H A Dmessage-capture-parser.py117 msg_dict = {}
119 msg_dict["time"] = time
131 msg_dict["msgtype"] = msgtype_tmp
133 msg_dict["msgtype"] = "UNREADABLE"
134 msg_dict["body"] = msg_ser.read().hex()
136 messages.append(msg_dict)
142 msg_dict["msgtype"] = msgtype.decode()
151 msg_dict["body"] = msg_ser.read().hex()
153 messages.append(msg_dict)
159 msg_dict["body"] = to_jsonable(msg)
[all …]
/dports/net-p2p/bitcoin-utils/bitcoin-22.0/contrib/message-capture/
H A Dmessage-capture-parser.py117 msg_dict = {}
119 msg_dict["time"] = time
131 msg_dict["msgtype"] = msgtype_tmp
133 msg_dict["msgtype"] = "UNREADABLE"
134 msg_dict["body"] = msg_ser.read().hex()
136 messages.append(msg_dict)
142 msg_dict["msgtype"] = msgtype.decode()
151 msg_dict["body"] = msg_ser.read().hex()
153 messages.append(msg_dict)
159 msg_dict["body"] = to_jsonable(msg)
[all …]
/dports/devel/py-pystorm/pystorm-3.1.4/test/pystorm/serializers/
H A Dtest_json_serializer.py23 msg_dict = {'hello': "world",}
24 self.instance.input_stream = StringIO(self.instance.serialize_dict(msg_dict))
25 assert self.instance.read_message() == msg_dict
33 msg_dict = {'hello': "world",}
36 self.instance.send_message(msg_dict)
50 msg_dict = {'hello': b'\xfc\x89'}
52 self.instance.send_message(msg_dict)
53 log_mock.assert_called_with('Failed to send message: %r', msg_dict)
H A Dtest_msgpack_serializer.py31 msg_dict = {b'hello': b"world",}
32 self.instance.input_stream = BytesIO(msgpack.packb(msg_dict))
33 assert self.instance.read_message() == msg_dict
43 msg_dict = {'hello': "world"}
44 expected_output = msgpack.packb(msg_dict)
45 self.instance.send_message(msg_dict)
/dports/devel/py-spyder-kernels/spyder-kernels-2.2.1/spyder_kernels/comms/
H A Dcommbase.py241 msg_dict = {
308 msg_dict = msg['content']['data']
325 msg_dict['content']['call_name'],
326 msg_dict['content']['call_id'])
328 msg_dict['content']['is_error'] = True
334 msg_dict, buffer)
340 msg_dict = msg['content']
341 self.on_incoming_call(msg_dict)
344 msg_dict['call_name'],
350 msg_dict['call_name'], msg_dict['call_id'])
[all …]
/dports/finance/odoo/odoo-19d77c2a03335eb95a686bd69a1b56b38e87d609/odoo/addons/mail/models/
H A Dmail_thread_cc.py22 def message_new(self, msg_dict, custom_values=None): argument
26 'email_cc': ", ".join(self._mail_cc_sanitized_raw_dict(msg_dict.get('cc')).values()),
29 return super(MailCCMixin, self).message_new(msg_dict, cc_values)
31 def message_update(self, msg_dict, update_vals=None): argument
36 new_cc = self._mail_cc_sanitized_raw_dict(msg_dict.get('cc'))
42 return super(MailCCMixin, self).message_update(msg_dict, cc_values)
H A Dmail_thread.py1135 msg_dict.pop('attachments', None)
1140 msg_dict.get('email_from'), msg_dict.get('to'), msg_dict.get('message_id'))
1401 msg_dict = {'message_type': 'email'}
1408 msg_dict['message_id'] = message_id.strip()
1418 msg_dict['from'] = msg_dict['email_from'] # compatibility for message_new
1432 msg_dict['to'] = ','.join(set(formatted_email
1440 msg_dict['partner_ids'] = partner_ids
1464 if msg_dict['in_reply_to']:
1470 msg_dict['parent_id'] = parent_ids.id
1474 msg_dict.update(self._message_parse_extract_bounce(message, msg_dict))
[all …]
/dports/mail/py-mailnag/mailnag-2.2.0/Mailnag/daemon/
H A Dmails.py112 def _get_header(self, msg_dict): argument
117 content = self._get_header_field(msg_dict, 'From')
133 content = self._get_header_field(msg_dict, 'Subject')
140 content = self._get_header_field(msg_dict, 'Date')
152 msgid = self._get_header_field(msg_dict, 'Message-ID')
159 def _get_header_field(self, msg_dict, key): argument
160 if key in msg_dict:
161 value = msg_dict[key]
162 elif key.lower() in msg_dict:
163 value = msg_dict[key.lower()]
/dports/devel/py-pystorm/pystorm-3.1.4/pystorm/serializers/
H A Dserializer.py28 def send_message(self, msg_dict): argument
33 self.output_stream.write(self.serialize_dict(msg_dict))
38 log.exception('Failed to send message: %r', msg_dict)
40 def serialize_dict(self, msg_dict): argument
H A Dmsgpack_serializer.py70 def serialize_dict(self, msg_dict): argument
75 return msgpack.packb(msg_dict)
H A Djson_serializer.py91 def serialize_dict(self, msg_dict): argument
93 serialized = json.dumps(msg_dict, namedtuple_as_object=False)
/dports/net-im/py-matrix-synapse/synapse-1.50.2/tests/replication/slave/storage/
H A Dtest_events.py106 msg_dict = msg.get_dict()
107 msg_dict["content"] = {}
108 msg_dict["unsigned"]["redacted_by"] = redaction.event_id
109 msg_dict["unsigned"]["redacted_because"] = redaction
111 msg_dict, internal_metadata_dict=msg.internal_metadata.get_dict()
128 msg_dict = msg.get_dict()
129 msg_dict["content"] = {}
130 msg_dict["unsigned"]["redacted_by"] = redaction.event_id
131 msg_dict["unsigned"]["redacted_because"] = redaction
133 msg_dict, internal_metadata_dict=msg.internal_metadata.get_dict()
/dports/dns/getdns/getdns-1.5.2/src/
H A Dconvert.c616 if (!wire || !*wire || !wire_len || !msg_dict) in _getdns_wire2msg_dict_scan()
717 *msg_dict = result; in _getdns_wire2msg_dict_scan()
891 return _getdns_reply_dict2wire(msg_dict, gbuf, 0); in _getdns_msg_dict2wire_buf()
907 msg_dict, buf_spc, &buf_len); in getdns_msg_dict2wire()
972 const getdns_dict *msg_dict, char **str) in getdns_msg_dict2str() argument
977 msg_dict, buf_spc, &buf_len); in getdns_msg_dict2str()
1028 if (!msg_dict || !str || !*str || !str_len) in getdns_msg_dict2str_scan()
1032 r = _getdns_msg_dict2wire_buf(msg_dict, &gbuf); in getdns_msg_dict2str_scan()
1039 r = _getdns_msg_dict2wire_buf(msg_dict, &gbuf); in getdns_msg_dict2str_scan()
1043 GETDNS_FREE(msg_dict->mf, buf); in getdns_msg_dict2str_scan()
[all …]
/dports/misc/py-cinder/cinder-12.0.10/cinder/scheduler/
H A Dbase_filter.py69 msg_dict = {"vol_id": rspec.get("volume_id", ""),
73 msg_dict)
74 msg_dict["str_results"] = ', '.join(
80 msg_dict)
/dports/finance/odoo/odoo-19d77c2a03335eb95a686bd69a1b56b38e87d609/odoo/addons/mass_mailing/models/
H A Dmail_thread.py67 def message_new(self, msg_dict, custom_values=None): argument
75 thread_references = msg_dict.get('references', '') or msg_dict.get('in_reply_to', '')
87 return super(MailThread, self).message_new(msg_dict, custom_values=defaults)
/dports/net-mgmt/py-napalm-logs/napalm-logs-0.9.0/napalm_logs/config/nxos/
H A DUSER_LOGIN.py56 def emit(msg_dict): argument
77 log.debug(msg_dict)
79 extracted = napalm_logs.utils.extract(_RGX, msg_dict['message'], _RGX_PARTS)
/dports/dns/getdns/getdns-1.5.2/src/getdns/
H A Dgetdns_extra.h2017 const getdns_dict *msg_dict, uint8_t **wire, size_t *wire_sz);
2034 const getdns_dict *msg_dict, uint8_t *wire, size_t *wire_sz);
2055 const getdns_dict *msg_dict, uint8_t **wire, int *wire_sz);
2068 const uint8_t *wire, size_t wire_sz, getdns_dict **msg_dict);
2081 const uint8_t *wire, size_t *wire_sz, getdns_dict **msg_dict);
2097 const uint8_t **wire, size_t *wire_sz, getdns_dict **msg_dict);
2109 const getdns_dict *msg_dict, char **str);
2126 const getdns_dict *msg_dict, char *str, size_t *str_len);
2147 const getdns_dict *msg_dict, char **str, int *str_len);
/dports/security/py-cybox/python-cybox-2.1.0.21/cybox/test/objects/
H A Demail_message_test.py266 msg_dict = {'header': {
273 msg_obj = EmailMessage.object_from_dict(msg_dict)
280 msg_dict['header']['from'])
282 msg_dict['header']['to'][0])
284 msg_dict['header']['subject'])
286 msg_dict['raw_body'])
/dports/security/py-trezor/trezor-0.13.0/src/trezorlib/
H A Dprotobuf.py357 msg_dict: Dict[str, Any] = {}
361 msg_dict[field.name] = []
363 msg_dict[field.name] = field.default
407 msg_dict[field.name].extend(fvalues)
411 msg_dict[field.name] = fvalues[0]
414 if field.required and field.name not in msg_dict:
416 return msg_type(**msg_dict)
/dports/misc/py-cinder/cinder-12.0.10/cinder/api/middleware/
H A Dfault.py62 msg_dict = dict(url=req.url, status=status)
63 LOG.info("%(url)s returned with HTTP %(status)d", msg_dict)
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/google-endpoints/apitools/base/py/
H A Dextra_types_test.py144 msg_dict = {
148 self.assertEqual(msg_dict, json.loads(encoding.MessageToJson(msg)))
150 msg, encoding.JsonToMessage(DateMsg, json.dumps(msg_dict)))
/dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/third_party/apitools/apitools/base/py/
H A Dextra_types_test.py155 msg_dict = {
159 self.assertEqual(msg_dict, json.loads(encoding.MessageToJson(msg)))
161 msg, encoding.JsonToMessage(DateMsg, json.dumps(msg_dict)))

123