Home
last modified time | relevance | path

Searched refs:message_expiry (Results 1 – 4 of 4) sorted by relevance

/dports/net/mosquitto/mosquitto-2.0.13/src/
H A Dloop.c73 …ingle_publish(struct mosquitto *context, struct mosquitto_message_v5 *msg, uint32_t message_expiry) in single_publish() argument
99 if(db__message_store(context, stored, message_expiry, 0, mosq_mo_broker)) return 1; in single_publish()
110 static void read_message_expiry_interval(mosquitto_property **proplist, uint32_t *message_expiry) in read_message_expiry_interval() argument
114 *message_expiry = 0; in read_message_expiry_interval()
121 *message_expiry = p->value.i32; in read_message_expiry_interval()
140 uint32_t message_expiry; in queue_plugin_msgs() local
145 read_message_expiry_interval(&msg->properties, &message_expiry); in queue_plugin_msgs()
150 single_publish(context, msg, message_expiry); in queue_plugin_msgs()
153 …t8_t)msg->qos, (uint32_t)msg->payloadlen, msg->payload, msg->retain, message_expiry, &msg->propert… in queue_plugin_msgs()
/dports/irc/srvx/srvx-1.3.1/src/
H A Dmod-memoserv.c114 int message_expiry; member
173 if ((now - memo->sent) > memoserv_conf.message_expiry) { in do_expire()
185 if (memoserv_conf.message_expiry) { in expire_memos()
187 timeq_add(now + memoserv_conf.message_expiry, expire_memos, NULL); in expire_memos()
355 if (!memoserv_conf.message_expiry) { in MODCMD_FUNC()
360 intervalString(interval, memoserv_conf.message_expiry, user->handle_info); in MODCMD_FUNC()
361 reply("MSMSG_EXPIRY", interval, memoserv_conf.message_expiry); in MODCMD_FUNC()
458 memoserv_conf.message_expiry = str ? ParseInterval(str) : 60*24*30; in memoserv_conf_read()
605 if (memoserv_conf.message_expiry) in memoserv_init()
606 timeq_add(now + memoserv_conf.message_expiry, expire_memos, NULL); in memoserv_init()
/dports/sysutils/pxp-agent/pxp-agent-1.15.16/acceptance/lib/pxp-agent/
H A Dtest_helper.rb175 message_expiry = 10 # Seconds for the PCP message to be considered failed
177 message.expires(message_expiry)
322 message_expiry = 10 # Seconds for the PCP message to be considered failed
323 message.expires(message_expiry)
/dports/irc/srvx/srvx-1.3.1/
H A Dsrvx.conf.example292 "message_expiry" "30d"; // age when messages are deleted; set