ServerDescription.c
No OneTemporary
Actions

Authored By

Unknown

Size

9 KB

Referenced Files

None

Subscribers

None

ServerDescription.c
View Options

	/*
	* Copyright 2021-present MongoDB, Inc.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	#include "bson/bson.h"
	#include "mongoc/mongoc.h"

	#include <php.h>
	#include <zend_smart_str.h>
	#include <ext/standard/php_var.h>
	#include <Zend/zend_interfaces.h>

	#include "php_phongo.h"
	#include "phongo_error.h"

	#include "MongoDB/ServerDescription.h"
	#include "ServerDescription_arginfo.h"

	zend_class_entry* php_phongo_serverdescription_ce;

	php_phongo_server_description_type_map_t
	php_phongo_server_description_type_map[PHONGO_SERVER_DESCRIPTION_TYPES] = {
	{ PHONGO_SERVER_UNKNOWN, PHONGO_SERVER_TYPE_UNKNOWN },
	{ PHONGO_SERVER_STANDALONE, PHONGO_SERVER_TYPE_STANDALONE },
	{ PHONGO_SERVER_MONGOS, PHONGO_SERVER_TYPE_MONGOS },
	{ PHONGO_SERVER_POSSIBLE_PRIMARY, PHONGO_SERVER_TYPE_POSSIBLE_PRIMARY },
	{ PHONGO_SERVER_RS_PRIMARY, PHONGO_SERVER_TYPE_RS_PRIMARY },
	{ PHONGO_SERVER_RS_SECONDARY, PHONGO_SERVER_TYPE_RS_SECONDARY },
	{ PHONGO_SERVER_RS_ARBITER, PHONGO_SERVER_TYPE_RS_ARBITER },
	{ PHONGO_SERVER_RS_OTHER, PHONGO_SERVER_TYPE_RS_OTHER },
	{ PHONGO_SERVER_RS_GHOST, PHONGO_SERVER_TYPE_RS_GHOST },
	{ PHONGO_SERVER_LOAD_BALANCER, PHONGO_SERVER_TYPE_LOAD_BALANCER },
	};

	PHONGO_DISABLED_CONSTRUCTOR(MongoDB_Driver_ServerDescription)

	/* Returns the most recent "hello" response */
	static PHP_METHOD(MongoDB_Driver_ServerDescription, getHelloResponse)
	{
	php_phongo_serverdescription_t* intern;
	const bson_t* helloResponse;
	php_phongo_bson_state state;

	intern = Z_SERVERDESCRIPTION_OBJ_P(getThis());

	PHONGO_PARSE_PARAMETERS_NONE();

	/* Note: the hello response will be empty for load balancers since they are
	* not monitored. Unlike Server::getInfo(), we do not attempt to fetch the
	* corresponding handshake description, as that would require holding a
	* reference to the libmongoc client (and likely a Manager object) on the
	* ServerDescription and TopologyDescription classes. */
	helloResponse = mongoc_server_description_hello_response(intern->server_description);

	PHONGO_BSON_INIT_DEBUG_STATE(state);

	if (!php_phongo_bson_to_zval_ex(helloResponse, &state)) {
	/* Exception should already have been thrown */
	zval_ptr_dtor(&state.zchild);
	return;
	}

	RETURN_ZVAL(&state.zchild, 0, 1);
	}

	/* Returns the server's hostname */
	static PHP_METHOD(MongoDB_Driver_ServerDescription, getHost)
	{
	php_phongo_serverdescription_t* intern;

	intern = Z_SERVERDESCRIPTION_OBJ_P(getThis());

	PHONGO_PARSE_PARAMETERS_NONE();

	RETVAL_STRING(mongoc_server_description_host(intern->server_description)->host);
	}

	/* Returns the server's last update time, in microseconds */
	static PHP_METHOD(MongoDB_Driver_ServerDescription, getLastUpdateTime)
	{
	php_phongo_serverdescription_t* intern;
	int64_t last_update_time;

	intern = Z_SERVERDESCRIPTION_OBJ_P(getThis());

	PHONGO_PARSE_PARAMETERS_NONE();

	last_update_time = mongoc_server_description_last_update_time(intern->server_description);

	#if SIZEOF_ZEND_LONG == 4
	if (last_update_time > INT32_MAX \|\| last_update_time < INT32_MIN) {
	zend_error(E_WARNING, "Truncating 64-bit value for lastUpdateTime");
	}
	#endif

	RETVAL_LONG(last_update_time);
	}

	/* Returns the server's port */
	static PHP_METHOD(MongoDB_Driver_ServerDescription, getPort)
	{
	php_phongo_serverdescription_t* intern;

	intern = Z_SERVERDESCRIPTION_OBJ_P(getThis());

	PHONGO_PARSE_PARAMETERS_NONE();

	RETVAL_LONG(mongoc_server_description_host(intern->server_description)->port);
	}

	/* Returns the server's round trip time, in milliseconds */
	static PHP_METHOD(MongoDB_Driver_ServerDescription, getRoundTripTime)
	{
	php_phongo_serverdescription_t* intern;

	intern = Z_SERVERDESCRIPTION_OBJ_P(getThis());

	PHONGO_PARSE_PARAMETERS_NONE();

	/* TODO: Use MONGOC_RTT_UNSET once it is added to libmongoc's public API (CDRIVER-4176) */
	if (mongoc_server_description_round_trip_time(intern->server_description) == -1) {
	RETVAL_NULL();
	} else {
	RETVAL_LONG(mongoc_server_description_round_trip_time(intern->server_description));
	}
	}

	/* Returns the server's node type */
	static PHP_METHOD(MongoDB_Driver_ServerDescription, getType)
	{
	php_phongo_serverdescription_t* intern;

	intern = Z_SERVERDESCRIPTION_OBJ_P(getThis());

	PHONGO_PARSE_PARAMETERS_NONE();

	RETVAL_STRING(mongoc_server_description_type(intern->server_description));
	}

	/* MongoDB\Driver\ServerDescription object handlers */
	static zend_object_handlers php_phongo_handler_serverdescription;

	static void php_phongo_serverdescription_free_object(zend_object* object)
	{
	php_phongo_serverdescription_t* intern = Z_OBJ_SERVERDESCRIPTION(object);

	zend_object_std_dtor(&intern->std);

	if (intern->properties) {
	zend_hash_destroy(intern->properties);
	FREE_HASHTABLE(intern->properties);
	}

	if (intern->server_description) {
	mongoc_server_description_destroy(intern->server_description);
	}
	}

	static zend_object* php_phongo_serverdescription_create_object(zend_class_entry* class_type)
	{
	php_phongo_serverdescription_t* intern = zend_object_alloc(sizeof(php_phongo_serverdescription_t), class_type);

	zend_object_std_init(&intern->std, class_type);
	object_properties_init(&intern->std, class_type);

	intern->std.handlers = &php_phongo_handler_serverdescription;

	return &intern->std;
	}

	HashTable* php_phongo_serverdescription_get_properties_hash(zend_object* object, bool is_debug)
	{
	php_phongo_serverdescription_t* intern = NULL;
	HashTable* props;

	intern = Z_OBJ_SERVERDESCRIPTION(object);

	PHONGO_GET_PROPERTY_HASH_INIT_PROPS(is_debug, intern, props, 6);

	if (!intern->server_description) {
	return props;
	}

	{
	zval host, port, type;
	mongoc_host_list_t* host_list = mongoc_server_description_host(intern->server_description);

	ZVAL_STRING(&host, host_list->host);
	zend_hash_str_update(props, "host", sizeof("host") - 1, &host);

	ZVAL_LONG(&port, host_list->port);
	zend_hash_str_update(props, "port", sizeof("port") - 1, &port);

	ZVAL_STRING(&type, mongoc_server_description_type(intern->server_description));
	zend_hash_str_update(props, "type", sizeof("type") - 1, &type);
	}

	{
	const bson_t* hello_response = mongoc_server_description_hello_response(intern->server_description);
	php_phongo_bson_state state;

	PHONGO_BSON_INIT_DEBUG_STATE(state);

	if (!php_phongo_bson_to_zval_ex(hello_response, &state)) {
	zval_ptr_dtor(&state.zchild);
	goto done;
	}
	zend_hash_str_update(props, "hello_response", sizeof("hello_response") - 1, &state.zchild);
	}

	{
	int64_t last_update_time;
	zval z_last_update_time;

	last_update_time = mongoc_server_description_last_update_time(intern->server_description);

	#if SIZEOF_ZEND_LONG == 4
	if (last_update_time > INT32_MAX \|\| last_update_time < INT32_MIN) {
	ZVAL_INT64_STRING(&z_last_update_time, last_update_time);
	} else {
	ZVAL_LONG(&z_last_update_time, last_update_time);
	}
	#else
	ZVAL_LONG(&z_last_update_time, last_update_time);
	#endif

	zend_hash_str_update(props, "last_update_time", sizeof("last_update_time") - 1, &z_last_update_time);
	}

	{
	zval round_trip_time;

	/* TODO: Use MONGOC_RTT_UNSET once it is added to libmongoc's public API (CDRIVER-4176) */
	if (mongoc_server_description_round_trip_time(intern->server_description) == -1) {
	ZVAL_NULL(&round_trip_time);
	} else {
	ZVAL_LONG(&round_trip_time, mongoc_server_description_round_trip_time(intern->server_description));
	}

	zend_hash_str_update(props, "round_trip_time", sizeof("round_trip_time") - 1, &round_trip_time);
	}

	done:
	return props;
	}

	static HashTable* php_phongo_serverdescription_get_debug_info(zend_object* object, int* is_temp)
	{
	*is_temp = 1;
	return php_phongo_serverdescription_get_properties_hash(object, true);
	}

	static HashTable* php_phongo_serverdescription_get_properties(zend_object* object)
	{
	return php_phongo_serverdescription_get_properties_hash(object, false);
	}

	void php_phongo_serverdescription_init_ce(INIT_FUNC_ARGS)
	{
	php_phongo_serverdescription_ce = register_class_MongoDB_Driver_ServerDescription();
	php_phongo_serverdescription_ce->create_object = php_phongo_serverdescription_create_object;

	memcpy(&php_phongo_handler_serverdescription, phongo_get_std_object_handlers(), sizeof(zend_object_handlers));
	php_phongo_handler_serverdescription.get_debug_info = php_phongo_serverdescription_get_debug_info;
	php_phongo_handler_serverdescription.get_properties = php_phongo_serverdescription_get_properties;
	php_phongo_handler_serverdescription.free_obj = php_phongo_serverdescription_free_object;
	php_phongo_handler_serverdescription.offset = XtOffsetOf(php_phongo_serverdescription_t, std);
	}

	void phongo_serverdescription_init_ex(zval* return_value, mongoc_server_description_t* server_description, bool copy)
	{
	php_phongo_serverdescription_t* intern;

	object_init_ex(return_value, php_phongo_serverdescription_ce);

	intern = Z_SERVERDESCRIPTION_OBJ_P(return_value);
	intern->server_description = copy ? mongoc_server_description_new_copy(server_description) : server_description;
	}

	php_phongo_server_description_type_t php_phongo_server_description_type(mongoc_server_description_t* sd)
	{
	const char* name = mongoc_server_description_type(sd);
	int i;

	for (i = 0; i < PHONGO_SERVER_DESCRIPTION_TYPES; i++) {
	if (!strcmp(name, php_phongo_server_description_type_map[i].name)) {
	return php_phongo_server_description_type_map[i].type;
	}
	}

	return PHONGO_SERVER_UNKNOWN;
	}

File Metadata

Mime Type: text/x-c
Expires: Sun, Nov 15, 7:17 AM (1 d, 22 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 152146
Default Alt Text: ServerDescription.c (9 KB)

ServerDescription.cNo OneTemporaryActions

ServerDescription.cView Options

File Metadata

Event Timeline

ServerDescription.c
No OneTemporary
Actions

ServerDescription.c
View Options