Skip to content

Commit 624d801

Browse files
tanlisutanlisu
committed
PHPC-1893: Implement ServerClosedEvent class
1 parent 3d5e12c commit 624d801

19 files changed

+279
-2
lines changed

‎config.m4

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -174,6 +174,7 @@ if test "$PHP_MONGODB" != "no"; then
174174
src/MongoDB/Monitoring/SDAMSubscriber.c \
175175
src/MongoDB/Monitoring/Subscriber.c \
176176
src/MongoDB/Monitoring/ServerChangedEvent.c \
177+
src/MongoDB/Monitoring/ServerClosedEvent.c \
177178
src/MongoDB/Monitoring/ServerOpeningEvent.c \
178179
src/MongoDB/Monitoring/TopologyChangedEvent.c \
179180
src/MongoDB/Monitoring/TopologyOpeningEvent.c \

‎config.w32

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ if (PHP_MONGODB != "no") {
122122
MONGODB_ADD_SOURCES("/src/BSON", "Binary.c BinaryInterface.c DBPointer.c Decimal128.c Decimal128Interface.c Int64.c Javascript.c JavascriptInterface.c MaxKey.c MaxKeyInterface.c MinKey.c MinKeyInterface.c ObjectId.c ObjectIdInterface.c Persistable.c Regex.c RegexInterface.c Serializable.c Symbol.c Timestamp.c TimestampInterface.c Type.c Undefined.c Unserializable.c UTCDateTime.c UTCDateTimeInterface.c functions.c");
123123
MONGODB_ADD_SOURCES("/src/MongoDB", "BulkWrite.c ClientEncryption.c Command.c Cursor.c CursorId.c CursorInterface.c Manager.c Query.c ReadConcern.c ReadPreference.c Server.c ServerApi.c ServerDescription.c Session.c TopologyDescription.c WriteConcern.c WriteConcernError.c WriteError.c WriteResult.c");
124124
MONGODB_ADD_SOURCES("/src/MongoDB/Exception", "AuthenticationException.c BulkWriteException.c CommandException.c ConnectionException.c ConnectionTimeoutException.c EncryptionException.c Exception.c ExecutionTimeoutException.c InvalidArgumentException.c LogicException.c RuntimeException.c ServerException.c SSLConnectionException.c UnexpectedValueException.c WriteException.c");
125-
MONGODB_ADD_SOURCES("/src/MongoDB/Monitoring", "CommandFailedEvent.c CommandStartedEvent.c CommandSubscriber.c CommandSucceededEvent.c SDAMSubscriber.c Subscriber.c ServerChangedEvent.c ServerOpeningEvent.c TopologyChangedEvent.c TopologyOpeningEvent.c functions.c");
125+
MONGODB_ADD_SOURCES("/src/MongoDB/Monitoring", "CommandFailedEvent.c CommandStartedEvent.c CommandSubscriber.c CommandSucceededEvent.c SDAMSubscriber.c Subscriber.c ServerChangedEvent.c ServerClosedEvent.c ServerOpeningEvent.c TopologyChangedEvent.c TopologyOpeningEvent.c functions.c");
126126
MONGODB_ADD_SOURCES("/src/libmongoc/src/common", PHP_MONGODB_COMMON_SOURCES);
127127
MONGODB_ADD_SOURCES("/src/libmongoc/src/libbson/src/bson", PHP_MONGODB_BSON_SOURCES);
128128
MONGODB_ADD_SOURCES("/src/libmongoc/src/libbson/src/jsonsl", PHP_MONGODB_JSONSL_SOURCES);

‎php_phongo.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3858,6 +3858,7 @@ PHP_MINIT_FUNCTION(mongodb)
38583858
php_phongo_commandsucceededevent_init_ce(INIT_FUNC_ARGS_PASSTHRU);
38593859
php_phongo_sdamsubscriber_init_ce(INIT_FUNC_ARGS_PASSTHRU);
38603860
php_phongo_serverchangedevent_init_ce(INIT_FUNC_ARGS_PASSTHRU);
3861+
php_phongo_serverclosedevent_init_ce(INIT_FUNC_ARGS_PASSTHRU);
38613862
php_phongo_serveropeningevent_init_ce(INIT_FUNC_ARGS_PASSTHRU);
38623863
php_phongo_topologychangedevent_init_ce(INIT_FUNC_ARGS_PASSTHRU);
38633864
php_phongo_topologyopeningevent_init_ce(INIT_FUNC_ARGS_PASSTHRU);

‎php_phongo_classes.h

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -163,6 +163,10 @@ static inline php_phongo_serverchangedevent_t* php_serverchangedevent_fetch_obje
163163
{
164164
return (php_phongo_serverchangedevent_t*) ((char*) obj - XtOffsetOf(php_phongo_serverchangedevent_t, std));
165165
}
166+
static inline php_phongo_serverclosedevent_t* php_serverclosedevent_fetch_object(zend_object* obj)
167+
{
168+
return (php_phongo_serverclosedevent_t*) ((char*) obj - XtOffsetOf(php_phongo_serverclosedevent_t, std));
169+
}
166170
static inline php_phongo_serveropeningevent_t* php_serveropeningevent_fetch_object(zend_object* obj)
167171
{
168172
return (php_phongo_serveropeningevent_t*) ((char*) obj - XtOffsetOf(php_phongo_serveropeningevent_t, std));
@@ -211,6 +215,7 @@ static inline php_phongo_topologyopeningevent_t* php_topologyopeningevent_fetch_
211215
#define Z_COMMANDSTARTEDEVENT_OBJ_P(zv) (php_commandstartedevent_fetch_object(Z_OBJ_P(zv)))
212216
#define Z_COMMANDSUCCEEDEDEVENT_OBJ_P(zv) (php_commandsucceededevent_fetch_object(Z_OBJ_P(zv)))
213217
#define Z_SERVERCHANGEDEVENT_OBJ_P(zv) (php_serverchangedevent_fetch_object(Z_OBJ_P(zv)))
218+
#define Z_SERVERCLOSEDEVENT_OBJ_P(zv) (php_serverclosedevent_fetch_object(Z_OBJ_P(zv)))
214219
#define Z_SERVEROPENINGEVENT_OBJ_P(zv) (php_serveropeningevent_fetch_object(Z_OBJ_P(zv)))
215220
#define Z_TOPOLOGYCHANGEDEVENT_OBJ_P(zv) (php_topologychangedevent_fetch_object(Z_OBJ_P(zv)))
216221
#define Z_TOPOLOGYOPENINGEVENT_OBJ_P(zv) (php_topologyopeningevent_fetch_object(Z_OBJ_P(zv)))
@@ -250,6 +255,7 @@ static inline php_phongo_topologyopeningevent_t* php_topologyopeningevent_fetch_
250255
#define Z_OBJ_COMMANDSTARTEDEVENT(zo) (php_commandstartedevent_fetch_object(zo))
251256
#define Z_OBJ_COMMANDSUCCEEDEDEVENT(zo) (php_commandsucceededevent_fetch_object(zo))
252257
#define Z_OBJ_SERVERCHANGEDEVENT(zo) (php_serverchangedevent_fetch_object(zo))
258+
#define Z_OBJ_SERVERCLOSEDEVENT(zo) (php_serverclosedevent_fetch_object(zo))
253259
#define Z_OBJ_SERVEROPENINGEVENT(zo) (php_serveropeningevent_fetch_object(zo))
254260
#define Z_OBJ_TOPOLOGYCHANGEDEVENT(zo) (php_topologychangedevent_fetch_object(zo))
255261
#define Z_OBJ_TOPOLOGYOPENINGEVENT(zo) (php_topologyopeningevent_fetch_object(zo))
@@ -326,6 +332,7 @@ extern zend_class_entry* php_phongo_commandsucceededevent_ce;
326332
extern zend_class_entry* php_phongo_sdamsubscriber_ce;
327333
extern zend_class_entry* php_phongo_subscriber_ce;
328334
extern zend_class_entry* php_phongo_serverchangedevent_ce;
335+
extern zend_class_entry* php_phongo_serverclosedevent_ce;
329336
extern zend_class_entry* php_phongo_serveropeningevent_ce;
330337
extern zend_class_entry* php_phongo_topologychangedevent_ce;
331338
extern zend_class_entry* php_phongo_topologyopeningevent_ce;
@@ -402,6 +409,7 @@ extern void php_phongo_commandsucceededevent_init_ce(INIT_FUNC_ARGS);
402409
extern void php_phongo_sdamsubscriber_init_ce(INIT_FUNC_ARGS);
403410
extern void php_phongo_subscriber_init_ce(INIT_FUNC_ARGS);
404411
extern void php_phongo_serverchangedevent_init_ce(INIT_FUNC_ARGS);
412+
extern void php_phongo_serverclosedevent_init_ce(INIT_FUNC_ARGS);
405413
extern void php_phongo_serveropeningevent_init_ce(INIT_FUNC_ARGS);
406414
extern void php_phongo_topologychangedevent_init_ce(INIT_FUNC_ARGS);
407415
extern void php_phongo_topologyopeningevent_init_ce(INIT_FUNC_ARGS);

‎php_phongo_structs.h

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -293,6 +293,13 @@ typedef struct {
293293
zend_object std;
294294
} php_phongo_serverchangedevent_t;
295295

296+
typedef struct {
297+
bson_oid_t topology_id;
298+
char host[BSON_HOST_NAME_MAX + 1];
299+
uint16_t port;
300+
zend_object std;
301+
} php_phongo_serverclosedevent_t;
302+
296303
typedef struct {
297304
bson_oid_t topology_id;
298305
char host[BSON_HOST_NAME_MAX + 1];

‎src/MongoDB/Monitoring/ServerClosedEvent.c

Lines changed: 154 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,154 @@
1+
/*
2+
* Copyright 2021-present MongoDB, Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
#include <php.h>
18+
#include <Zend/zend_interfaces.h>
19+
20+
#ifdef HAVE_CONFIG_H
21+
#include "config.h"
22+
#endif
23+
24+
#include "phongo_compat.h"
25+
#include "php_phongo.h"
26+
27+
zend_class_entry* php_phongo_serverclosedevent_ce;
28+
29+
/* {{{ proto string ServerClosedEvent::getHost()
30+
Returns this event's host */
31+
static PHP_METHOD(ServerClosedEvent, getHost)
32+
{
33+
php_phongo_serverclosedevent_t* intern = Z_SERVERCLOSEDEVENT_OBJ_P(getThis());
34+
35+
PHONGO_PARSE_PARAMETERS_NONE();
36+
37+
RETVAL_STRING(intern->host);
38+
} /* }}} */
39+
40+
/* {{{ proto integer ServerClosedEvent::getPort()
41+
Returns this event's port */
42+
static PHP_METHOD(ServerClosedEvent, getPort)
43+
{
44+
php_phongo_serverclosedevent_t* intern = Z_SERVERCLOSEDEVENT_OBJ_P(getThis());
45+
46+
PHONGO_PARSE_PARAMETERS_NONE();
47+
48+
RETVAL_LONG(intern->port);
49+
} /* }}} */
50+
51+
/* {{{ proto MongoDB\BSON\ObjectId ServerClosedEvent::getTopologyId()
52+
Returns this event's topology id */
53+
static PHP_METHOD(ServerClosedEvent, getTopologyId)
54+
{
55+
php_phongo_objectid_t* topology_id;
56+
php_phongo_serverclosedevent_t* intern = Z_SERVERCLOSEDEVENT_OBJ_P(getThis());
57+
58+
PHONGO_PARSE_PARAMETERS_NONE();
59+
60+
object_init_ex(return_value, php_phongo_objectid_ce);
61+
62+
topology_id = Z_OBJECTID_OBJ_P(return_value);
63+
bson_oid_to_string(&intern->topology_id, topology_id->oid);
64+
topology_id->initialized = true;
65+
} /* }}} */
66+
67+
/* {{{ MongoDB\Driver\Monitoring\ServerClosedEvent function entries */
68+
ZEND_BEGIN_ARG_INFO_EX(ai_ServerClosedEvent_void, 0, 0, 0)
69+
ZEND_END_ARG_INFO()
70+
71+
static zend_function_entry php_phongo_serverclosedevent_me[] = {
72+
/* clang-format off */
73+
ZEND_NAMED_ME(__construct, PHP_FN(MongoDB_disabled___construct), ai_ServerClosedEvent_void, ZEND_ACC_PRIVATE | ZEND_ACC_FINAL)
74+
PHP_ME(ServerClosedEvent, getHost, ai_ServerClosedEvent_void, ZEND_ACC_PUBLIC | ZEND_ACC_FINAL)
75+
PHP_ME(ServerClosedEvent, getPort, ai_ServerClosedEvent_void, ZEND_ACC_PUBLIC | ZEND_ACC_FINAL)
76+
PHP_ME(ServerClosedEvent, getTopologyId, ai_ServerClosedEvent_void, ZEND_ACC_PUBLIC | ZEND_ACC_FINAL)
77+
ZEND_NAMED_ME(__wakeup, PHP_FN(MongoDB_disabled___wakeup), ai_ServerClosedEvent_void, ZEND_ACC_PUBLIC | ZEND_ACC_FINAL)
78+
PHP_FE_END
79+
/* clang-format on */
80+
};
81+
/* }}} */
82+
83+
/* {{{ MongoDB\Driver\Monitoring\ServerClosedEvent object handlers */
84+
static zend_object_handlers php_phongo_handler_serverclosedevent;
85+
86+
static void php_phongo_serverclosedevent_free_object(zend_object* object) /* {{{ */
87+
{
88+
php_phongo_serverclosedevent_t* intern = Z_OBJ_SERVERCLOSEDEVENT(object);
89+
90+
zend_object_std_dtor(&intern->std);
91+
} /* }}} */
92+
93+
static zend_object* php_phongo_serverclosedevent_create_object(zend_class_entry* class_type) /* {{{ */
94+
{
95+
php_phongo_serverclosedevent_t* intern = NULL;
96+
97+
intern = PHONGO_ALLOC_OBJECT_T(php_phongo_serverclosedevent_t, class_type);
98+
99+
zend_object_std_init(&intern->std, class_type);
100+
object_properties_init(&intern->std, class_type);
101+
102+
intern->std.handlers = &php_phongo_handler_serverclosedevent;
103+
104+
return &intern->std;
105+
} /* }}} */
106+
107+
static HashTable* php_phongo_serverclosedevent_get_debug_info(phongo_compat_object_handler_type* object, int* is_temp) /* {{{ */
108+
{
109+
php_phongo_serverclosedevent_t* intern;
110+
zval retval = ZVAL_STATIC_INIT;
111+
char topology_id[25];
112+
113+
intern = Z_OBJ_SERVERCLOSEDEVENT(PHONGO_COMPAT_GET_OBJ(object));
114+
*is_temp = 1;
115+
array_init_size(&retval, 3);
116+
117+
ADD_ASSOC_STRING(&retval, "host", intern->host);
118+
ADD_ASSOC_LONG_EX(&retval, "port", intern->port);
119+
120+
bson_oid_to_string(&intern->topology_id, topology_id);
121+
ADD_ASSOC_STRING(&retval, "topologyId", topology_id);
122+
123+
return Z_ARRVAL(retval);
124+
} /* }}} */
125+
/* }}} */
126+
127+
void php_phongo_serverclosedevent_init_ce(INIT_FUNC_ARGS) /* {{{ */
128+
{
129+
zend_class_entry ce;
130+
(void) type;
131+
(void) module_number;
132+
133+
INIT_NS_CLASS_ENTRY(ce, "MongoDB\\Driver\\Monitoring", "ServerClosedEvent", php_phongo_serverclosedevent_me);
134+
php_phongo_serverclosedevent_ce = zend_register_internal_class(&ce);
135+
php_phongo_serverclosedevent_ce->create_object = php_phongo_serverclosedevent_create_object;
136+
PHONGO_CE_FINAL(php_phongo_serverclosedevent_ce);
137+
PHONGO_CE_DISABLE_SERIALIZATION(php_phongo_serverclosedevent_ce);
138+
139+
memcpy(&php_phongo_handler_serverclosedevent, phongo_get_std_object_handlers(), sizeof(zend_object_handlers));
140+
php_phongo_handler_serverclosedevent.get_debug_info = php_phongo_serverclosedevent_get_debug_info;
141+
php_phongo_handler_serverclosedevent.free_obj = php_phongo_serverclosedevent_free_object;
142+
php_phongo_handler_serverclosedevent.offset = XtOffsetOf(php_phongo_serverclosedevent_t, std);
143+
144+
return;
145+
} /* }}} */
146+
147+
/*
148+
* Local variables:
149+
* tab-width: 4
150+
* c-basic-offset: 4
151+
* End:
152+
* vim600: noet sw=4 ts=4 fdm=marker
153+
* vim<600: noet sw=4 ts=4
154+
*/

‎src/phongo_apm.c

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -297,6 +297,39 @@ static void phongo_apm_server_changed(const mongoc_apm_server_changed_t* event)
297297
FREE_HASHTABLE(subscribers);
298298
}
299299

300+
static void phongo_apm_server_closed(const mongoc_apm_server_closed_t* event)
301+
{
302+
mongoc_client_t* client;
303+
HashTable* subscribers;
304+
php_phongo_serverclosedevent_t* p_event;
305+
zval z_event;
306+
const mongoc_host_list_t* host_list;
307+
308+
client = mongoc_apm_server_closed_get_context(event);
309+
subscribers = phongo_apm_get_subscribers_to_notify(php_phongo_sdamsubscriber_ce, client);
310+
311+
/* Return early if there are no APM subscribers to notify */
312+
if (zend_hash_num_elements(subscribers) == 0) {
313+
goto cleanup;
314+
}
315+
316+
object_init_ex(&z_event, php_phongo_serverclosedevent_ce);
317+
p_event = Z_SERVERCLOSEDEVENT_OBJ_P(&z_event);
318+
319+
host_list = mongoc_apm_server_closed_get_host(event);
320+
memcpy(&p_event->host, &host_list->host, BSON_HOST_NAME_MAX + 1);
321+
p_event->port = host_list->port;
322+
323+
mongoc_apm_server_closed_get_topology_id(event, &p_event->topology_id);
324+
325+
phongo_apm_dispatch_event(subscribers, "serverClosed", &z_event);
326+
zval_ptr_dtor(&z_event);
327+
328+
cleanup:
329+
zend_hash_destroy(subscribers);
330+
FREE_HASHTABLE(subscribers);
331+
}
332+
300333
static void phongo_apm_server_opening(const mongoc_apm_server_opening_t* event)
301334
{
302335
mongoc_client_t* client;
@@ -401,6 +434,7 @@ bool phongo_apm_set_callbacks(mongoc_client_t* client)
401434
mongoc_apm_set_command_succeeded_cb(callbacks, phongo_apm_command_succeeded);
402435
mongoc_apm_set_command_failed_cb(callbacks, phongo_apm_command_failed);
403436
mongoc_apm_set_server_changed_cb(callbacks, phongo_apm_server_changed);
437+
mongoc_apm_set_server_closed_cb(callbacks, phongo_apm_server_closed);
404438
mongoc_apm_set_server_opening_cb(callbacks, phongo_apm_server_opening);
405439
mongoc_apm_set_topology_changed_cb(callbacks, phongo_apm_topology_changed);
406440
mongoc_apm_set_topology_opening_cb(callbacks, phongo_apm_topology_opening);

‎tests/apm/monitoring-serverChanged-001.phpt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,8 @@ class MySubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
2727
echo "- getPreviousDescription() returns a ServerDescription: ", ($event->getPreviousDescription() instanceof MongoDB\Driver\ServerDescription) ? 'yes' : 'no', "\n";
2828
}
2929

30+
public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event) {}
31+
3032
public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event) {}
3133

3234
public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event) {}

‎tests/apm/monitoring-serverClosed-001.phpt

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,50 @@
1+
--TEST--
2+
MongoDB\Driver\Monitoring\ServerClosedEvent
3+
--SKIPIF--
4+
<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
5+
<?php skip_if_not_live(); ?>
6+
--FILE--
7+
<?php
8+
require_once __DIR__ . "/../utils/basic.inc";
9+
10+
$m = create_test_manager();
11+
12+
class MySubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
13+
{
14+
private $serverClosed = false;
15+
16+
public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event) {}
17+
18+
public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event)
19+
{
20+
if ($this->serverClosed) {
21+
return;
22+
}
23+
24+
$this->serverClosed = true;
25+
echo "- getHost() returns a string: ", is_string($event->getHost()) ? 'yes' : 'no', "\n";
26+
echo "- getPort() returns an integer: ", is_integer($event->getPort()) ? 'yes' : 'no', "\n";
27+
echo "- getTopologyId() returns an ObjectId: ", ($event->getTopologyId() instanceof MongoDB\BSON\ObjectId) ? 'yes' : 'no', "\n";
28+
}
29+
30+
public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event) {}
31+
32+
public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event) {}
33+
34+
public function topologyOpening(MongoDB\Driver\Monitoring\TopologyOpeningEvent $event) {}
35+
}
36+
37+
$subscriber = new MySubscriber;
38+
MongoDB\Driver\Monitoring\addSubscriber($subscriber);
39+
40+
$command = new MongoDB\Driver\Command(['ping' => 1]);
41+
$m->executeCommand(DATABASE_NAME, $command);
42+
43+
?>
44+
===DONE===
45+
<?php exit(0); ?>
46+
--EXPECT--
47+
- getHost() returns a string: yes
48+
- getPort() returns an integer: yes
49+
- getTopologyId() returns an ObjectId: yes
50+
===DONE===

‎tests/apm/monitoring-serverOpening-001.phpt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@ class MySubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
1515

1616
public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event) {}
1717

18+
public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event) {}
19+
1820
public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event)
1921
{
2022
if ($this->serverOpened) {

‎tests/apm/monitoring-topologyChanged-001.phpt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@ class MySubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
1515

1616
public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event) {}
1717

18+
public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event) {}
19+
1820
public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event) {}
1921

2022
public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event)

‎tests/apm/monitoring-topologyOpening-001.phpt

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,9 @@ $m = create_test_manager();
1212
class MySubscriber implements MongoDB\Driver\Monitoring\SDAMSubscriber
1313
{
1414
public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event) {}
15-
15+
16+
public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event) {}
17+
1618
public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event) {}
1719

1820
public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event) {}

‎tests/topologyDescription/topologyDescription-debug-001.phpt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,8 @@ class TopologyDescriptionProvider implements MongoDB\Driver\Monitoring\SDAMSubsc
1313

1414
public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event) {}
1515

16+
public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event) {}
17+
1618
public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event) {}
1719

1820
public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event)

‎tests/topologyDescription/topologyDescription-getServers-001.phpt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,8 @@ class TopologyDescriptionProvider implements MongoDB\Driver\Monitoring\SDAMSubsc
1313

1414
public function serverChanged(MongoDB\Driver\Monitoring\ServerChangedEvent $event) {}
1515

16+
public function serverClosed(MongoDB\Driver\Monitoring\ServerClosedEvent $event) {}
17+
1618
public function serverOpening(MongoDB\Driver\Monitoring\ServerOpeningEvent $event) {}
1719

1820
public function topologyChanged(MongoDB\Driver\Monitoring\TopologyChangedEvent $event)

0 commit comments

Comments
 (0)