view release on metacpan or  search on metacpan

Client.xs  view on Meta::CPAN

#*
#***********************************************************************************

CassSsl*
ssl_new(void)
	CODE:
		RETVAL = cass_ssl_new();
	OUTPUT:
		RETVAL

void
ssl_free(cass, ssl)
	Database::Cassandra::Client cass;
	CassSsl *ssl;
	
	CODE:
		cass_ssl_free(ssl);

CassError
ssl_add_trusted_cert(cass, ssl, tcert_string)
	Database::Cassandra::Client cass;
	CassSsl *ssl;
	SV *tcert_string;
	
	PREINIT:
		STRLEN len;
	CODE:
		char *tcert_string_c = SvPV( tcert_string, len );
		CassString tcert_string_str = {tcert_string_c, (cass_size_t)len};
		
		RETVAL = cass_ssl_add_trusted_cert(ssl, tcert_string_str);
	OUTPUT:
		RETVAL

void
ssl_set_verify_flags(cass, ssl, flags)
	Database::Cassandra::Client cass;
	CassSsl *ssl;
	int flags;
	
	CODE:
		cass_ssl_set_verify_flags(ssl, flags);

CassError
ssl_set_cert(cass, ssl, cert)
	Database::Cassandra::Client cass;
	CassSsl *ssl;
	SV *cert;
	
	PREINIT:
		STRLEN len;
	CODE:
		char *cert_c = SvPV( cert, len );
		CassString cert_str = {cert_c, (cass_size_t)len};
		
		RETVAL = cass_ssl_set_cert(ssl, cert_str);
	OUTPUT:
		RETVAL

CassError
ssl_set_private_key(cass, ssl, key, password)
	Database::Cassandra::Client cass;
	CassSsl *ssl;
	SV *key;
	const char* password;
	
	PREINIT:
		STRLEN len;
	CODE:
		char *key_c = SvPV( key, len );
		CassString key_str = {key_c, (cass_size_t)len};
		
		RETVAL = cass_ssl_set_private_key(ssl, key_str, password);
	OUTPUT:
		RETVAL

#***********************************************************************************
#*
#* Future
#*
#***********************************************************************************

void
future_free(cass, future)
	Database::Cassandra::Client cass;
	CassFuture *future;
	
	CODE:
		cass_future_free(future);

CassError
future_set_callback(cass, future, callback, data = &PL_sv_undef)
	Database::Cassandra::Client cass;
	CassFuture *future;
	SV *callback;
	SV *data;
	
	CODE:
		SV *sub = newSVsv(callback);
		
		callback_data_t *calldata = malloc(sizeof(callback_data_t));
		
		calldata->callback     = (void *)sub;
		calldata->callback_arg = (void *)data;
		calldata->cass         = cass;
		
		if(cass->perl_int == NULL)
			cass->perl_int = Perl_get_context();
		
		RETVAL = cass_future_set_callback(future, base_callback_future, (void *)calldata);
	OUTPUT:
		RETVAL

SV*
future_ready(cass, future)
	Database::Cassandra::Client cass;
	CassFuture *future;
	
	CODE:
		RETVAL = newSViv( (int)cass_future_ready(future) );
	OUTPUT:
		RETVAL

SV*
future_wait(cass, future)
	Database::Cassandra::Client cass;
	CassFuture *future;
	
	CODE:
		cass_future_wait(future);
		RETVAL = newSViv(0);
	OUTPUT:
		RETVAL