distribute-cache.c File Reference

#include "magick/studio.h"
#include "magick/cache.h"
#include "magick/cache-private.h"
#include "magick/distribute-cache.h"
#include "magick/distribute-cache-private.h"
#include "magick/exception.h"
#include "magick/exception-private.h"
#include "magick/geometry.h"
#include "magick/image.h"
#include "magick/image-private.h"
#include "magick/list.h"
#include "magick/locale_.h"
#include "magick/memory_.h"
#include "magick/nt-base-private.h"
#include "magick/policy.h"
#include "magick/random_.h"
#include "magick/registry.h"
#include "magick/splay-tree.h"
#include "magick/string_.h"
#include "magick/string-private.h"
#include "magick/version.h"
#include "magick/version-private.h"

Include dependency graph for distribute-cache.c:

Defines
#define	CLOSE_SOCKET(socket)
#define	HANDLER_RETURN_TYPE   void *
#define	HANDLER_RETURN_VALUE   (void *) NULL
#define	SOCKET_TYPE   int
#define	LENGTH_TYPE   size_t
#define	send(file, buffer, length, flags)   0
#define	recv(file, buffer, length, flags)   0
#define	DPCHostname   "127.0.0.1"
#define	DPCPendingConnections   10
#define	DPCPort   6668
#define	DPCSessionKeyLength   8
#define	MSG_NOSIGNAL   0
Functions
static MagickOffsetType	dpc_read (int file, const MagickSizeType length, unsigned char *magick_restrict message)
static int	ConnectPixelCacheServer (const char *hostname, const int port, size_t *session_key, ExceptionInfo *exception)
static char *	GetHostname (int *port, ExceptionInfo *exception)
MagickPrivate DistributeCacheInfo *	AcquireDistributeCacheInfo (ExceptionInfo *exception)
MagickPrivate DistributeCacheInfo *	DestroyDistributeCacheInfo (DistributeCacheInfo *server_info)
static MagickBooleanType	DestroyDistributeCache (SplayTreeInfo *registry, const size_t session_key)
static MagickOffsetType	dpc_send (int file, const MagickSizeType length, const unsigned char *magick_restrict message)
static MagickBooleanType	OpenDistributeCache (SplayTreeInfo *registry, int file, const size_t session_key, ExceptionInfo *exception)
static MagickBooleanType	ReadDistributeCacheIndexes (SplayTreeInfo *registry, int file, const size_t session_key, ExceptionInfo *exception)
static MagickBooleanType	ReadDistributeCachePixels (SplayTreeInfo *registry, int file, const size_t session_key, ExceptionInfo *exception)
static void *	RelinquishImageRegistry (void *image)
static MagickBooleanType	WriteDistributeCacheIndexes (SplayTreeInfo *registry, int file, const size_t session_key, ExceptionInfo *exception)
static MagickBooleanType	WriteDistributeCachePixels (SplayTreeInfo *registry, int file, const size_t session_key, ExceptionInfo *exception)
static HANDLER_RETURN_TYPE	DistributePixelCacheClient (void *socket)
MagickExport void	DistributePixelCacheServer (const int port, ExceptionInfo *exception)
MagickPrivate int	GetDistributeCacheFile (const DistributeCacheInfo *server_info)
MagickPrivate const char *	GetDistributeCacheHostname (const DistributeCacheInfo *server_info)
MagickPrivate int	GetDistributeCachePort (const DistributeCacheInfo *server_info)
MagickPrivate MagickBooleanType	OpenDistributePixelCache (DistributeCacheInfo *server_info, Image *image)
MagickPrivate MagickOffsetType	ReadDistributePixelCacheIndexes (DistributeCacheInfo *server_info, const RectangleInfo *region, const MagickSizeType length, unsigned char *indexes)
MagickPrivate MagickOffsetType	ReadDistributePixelCachePixels (DistributeCacheInfo *server_info, const RectangleInfo *region, const MagickSizeType length, unsigned char *magick_restrict pixels)
MagickPrivate MagickBooleanType	RelinquishDistributePixelCache (DistributeCacheInfo *server_info)
MagickPrivate MagickOffsetType	WriteDistributePixelCacheIndexes (DistributeCacheInfo *server_info, const RectangleInfo *region, const MagickSizeType length, const unsigned char *indexes)
MagickPrivate MagickOffsetType	WriteDistributePixelCachePixels (DistributeCacheInfo *server_info, const RectangleInfo *region, const MagickSizeType length, const unsigned char *magick_restrict pixels)

---

Define Documentation

#define CLOSE_SOCKET

(

socket

)

Referenced by ConnectPixelCacheServer(), DestroyDistributeCacheInfo(), DistributePixelCacheClient(), and DistributePixelCacheServer().

#define DPCHostname   "127.0.0.1"

Referenced by GetHostname().

#define DPCPendingConnections   10

Referenced by DistributePixelCacheServer().

#define DPCPort   6668

Referenced by GetHostname().

#define DPCSessionKeyLength   8

Referenced by DistributePixelCacheClient().

#define HANDLER_RETURN_TYPE   void *

#define HANDLER_RETURN_VALUE   (void *) NULL

Referenced by DistributePixelCacheClient().

#define LENGTH_TYPE   size_t

Referenced by dpc_read(), and dpc_send().

#define MSG_NOSIGNAL   0

Referenced by dpc_send().

#define recv	(	file,
		buffer,
		length,
		flags		)	0

Referenced by ConnectPixelCacheServer(), and dpc_read().

#define send	(	file,
		buffer,
		length,
		flags		)	0

Referenced by dpc_send().

#define SOCKET_TYPE   int

Referenced by ConnectPixelCacheServer(), DistributePixelCacheClient(), and DistributePixelCacheServer().

---

Function Documentation

MagickPrivate DistributeCacheInfo* AcquireDistributeCacheInfo

(

ExceptionInfo *

exception

)

References AcquireQuantumMemory(), ConnectPixelCacheServer(), CopyMagickString(), _DistributeCacheInfo::debug, DestroyDistributeCacheInfo(), DestroyString(), _DistributeCacheInfo::file, GetHostname(), _DistributeCacheInfo::hostname, IsEventLogging(), MagickCoreSignature, MaxTextExtent, _DistributeCacheInfo::port, ResourceLimitFatalError, _DistributeCacheInfo::session_key, _DistributeCacheInfo::signature, and ThrowFatalException.

static int ConnectPixelCacheServer	(	const char *	hostname,
		const int	port,
		size_t *	session_key,
		ExceptionInfo *	exception
	)			[static]

References AcquireStringInfo(), CacheError, CLOSE_SOCKET, DestroyString(), DestroyStringInfo(), FormatLocaleString(), GetMagickCoreSignature(), GetMagickModule, GetPolicyValue(), GetStringInfoDatum(), magick_unreferenced, MagickFalse, MagickTrue, MaxTextExtent, MissingDelegateError, recv, SOCKET_TYPE, and ThrowMagickException().

Referenced by AcquireDistributeCacheInfo().

static MagickBooleanType DestroyDistributeCache	(	SplayTreeInfo *	registry,
		const size_t	session_key
	)			[static]

References DeleteNodeFromSplayTree().

Referenced by DistributePixelCacheClient().

MagickPrivate DistributeCacheInfo* DestroyDistributeCacheInfo

(

DistributeCacheInfo *

server_info

)

References CLOSE_SOCKET, _DistributeCacheInfo::file, MagickCoreSignature, RelinquishMagickMemory(), and _DistributeCacheInfo::signature.

Referenced by AcquireDistributeCacheInfo(), DestroyPixelCache(), and OpenPixelCache().

static HANDLER_RETURN_TYPE DistributePixelCacheClient

(

void *

socket

)

[static]

References AcquireExceptionInfo(), AcquireRandomInfo(), CacheFatalError, CLOSE_SOCKET, CopyMagickString(), DestroyDistributeCache(), DestroyExceptionInfo(), DestroyRandomInfo(), DestroySplayTree(), DestroyString(), DestroyStringInfo(), dpc_read(), dpc_send(), DPCSessionKeyLength, GetMagickCoreSignature(), GetPolicyValue(), GetRandomKey(), GetStringInfoDatum(), HANDLER_RETURN_VALUE, MagickFalse, MaxTextExtent, NewSplayTree(), OpenDistributeCache(), random_info, ReadDistributeCacheIndexes(), ReadDistributeCachePixels(), registry, RelinquishImageRegistry(), SOCKET_TYPE, ThrowFatalException, WriteDistributeCacheIndexes(), and WriteDistributeCachePixels().

Referenced by DistributePixelCacheServer().

MagickExport void DistributePixelCacheServer	(	const int	port,
		ExceptionInfo *	exception
	)

References CacheFatalError, CLOSE_SOCKET, DistributePixelCacheClient(), DPCPendingConnections, FormatLocaleString(), magick_unreferenced, MagickCoreSignature, MagickFalse, MaxTextExtent, MissingDelegateError, pthread_attr_init, pthread_create, _ExceptionInfo::signature, SOCKET_TYPE, and ThrowFatalException.

static MagickOffsetType dpc_read	(	int	file,
		const MagickSizeType	length,
		unsigned char *magick_restrict	message
	)			[inline, static]

References LENGTH_TYPE, magick_unreferenced, MagickMin, and recv.

Referenced by DistributePixelCacheClient(), OpenDistributeCache(), OpenDistributePixelCache(), ReadDistributeCacheIndexes(), ReadDistributeCachePixels(), ReadDistributePixelCacheIndexes(), ReadDistributePixelCachePixels(), RelinquishDistributePixelCache(), WriteDistributeCacheIndexes(), and WriteDistributeCachePixels().

static MagickOffsetType dpc_send	(	int	file,
		const MagickSizeType	length,
		const unsigned char *magick_restrict	message
	)			[inline, static]

References LENGTH_TYPE, magick_unreferenced, MagickMin, MSG_NOSIGNAL, and send.

Referenced by DistributePixelCacheClient(), OpenDistributePixelCache(), ReadDistributeCacheIndexes(), ReadDistributeCachePixels(), ReadDistributePixelCacheIndexes(), ReadDistributePixelCachePixels(), RelinquishDistributePixelCache(), WriteDistributePixelCacheIndexes(), and WriteDistributePixelCachePixels().

MagickPrivate int GetDistributeCacheFile

(

const DistributeCacheInfo *

server_info

)

References _DistributeCacheInfo::file, MagickCoreSignature, and _DistributeCacheInfo::signature.

MagickPrivate const char* GetDistributeCacheHostname

(

const DistributeCacheInfo *

server_info

)

References _DistributeCacheInfo::hostname, MagickCoreSignature, and _DistributeCacheInfo::signature.

Referenced by OpenPixelCache().

MagickPrivate int GetDistributeCachePort

(

const DistributeCacheInfo *

server_info

)

References MagickCoreSignature, _DistributeCacheInfo::port, and _DistributeCacheInfo::signature.

Referenced by OpenPixelCache().

static char* GetHostname	(	int *	port,
		ExceptionInfo *	exception
	)			[static]

References AcquireString(), DestroyString(), DPCHostname, DPCPort, GetImageRegistry(), RelinquishMagickMemory(), StringRegistryType, StringToArgv(), StringToLong(), and SubstituteString().

Referenced by AcquireDistributeCacheInfo().

static MagickBooleanType OpenDistributeCache	(	SplayTreeInfo *	registry,
		int	file,
		const size_t	session_key,
		ExceptionInfo *	exception
	)			[static]

References AcquireImage(), AddValueToSplayTree(), _Image::channels, _Image::colorspace, _Image::columns, dpc_read(), MagickFalse, MaxTextExtent, _Image::rows, _Image::storage_class, and SyncImagePixelCache().

Referenced by DistributePixelCacheClient().

MagickPrivate MagickBooleanType OpenDistributePixelCache	(	DistributeCacheInfo *	server_info,
		Image *	image
	)

References _Image::channels, _Image::colorspace, _Image::columns, dpc_read(), dpc_send(), _DistributeCacheInfo::file, MagickCoreSignature, MagickFalse, MagickTrue, MaxTextExtent, _Image::rows, _DistributeCacheInfo::session_key, _Image::signature, _DistributeCacheInfo::signature, and _Image::storage_class.

static MagickBooleanType ReadDistributeCacheIndexes	(	SplayTreeInfo *	registry,
		int	file,
		const size_t	session_key,
		ExceptionInfo *	exception
	)			[static]

References dpc_read(), dpc_send(), GetValueFromSplayTree(), GetVirtualIndexQueue(), GetVirtualPixels(), _RectangleInfo::height, MagickFalse, MagickTrue, MaxTextExtent, _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.

Referenced by DistributePixelCacheClient().

static MagickBooleanType ReadDistributeCachePixels	(	SplayTreeInfo *	registry,
		int	file,
		const size_t	session_key,
		ExceptionInfo *	exception
	)			[static]

References dpc_read(), dpc_send(), GetValueFromSplayTree(), GetVirtualPixels(), _RectangleInfo::height, MagickFalse, MagickTrue, MaxTextExtent, _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.

Referenced by DistributePixelCacheClient().

MagickPrivate MagickOffsetType ReadDistributePixelCacheIndexes	(	DistributeCacheInfo *	server_info,
		const RectangleInfo *	region,
		const MagickSizeType	length,
		unsigned char *	indexes
	)

References dpc_read(), dpc_send(), _DistributeCacheInfo::file, _RectangleInfo::height, MagickCoreSignature, MaxTextExtent, _DistributeCacheInfo::session_key, _DistributeCacheInfo::signature, _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.

MagickPrivate MagickOffsetType ReadDistributePixelCachePixels	(	DistributeCacheInfo *	server_info,
		const RectangleInfo *	region,
		const MagickSizeType	length,
		unsigned char *magick_restrict	pixels
	)

References dpc_read(), dpc_send(), _DistributeCacheInfo::file, _RectangleInfo::height, MagickCoreSignature, MaxTextExtent, _DistributeCacheInfo::session_key, _DistributeCacheInfo::signature, _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.

MagickPrivate MagickBooleanType RelinquishDistributePixelCache

(

DistributeCacheInfo *

server_info

)

References dpc_read(), dpc_send(), _DistributeCacheInfo::file, MagickCoreSignature, MagickFalse, MagickTrue, MaxTextExtent, _DistributeCacheInfo::session_key, and _DistributeCacheInfo::signature.

Referenced by RelinquishPixelCachePixels().

static void* RelinquishImageRegistry

(

void *

image

)

[static]

References DestroyImageList().

Referenced by DistributePixelCacheClient().

static MagickBooleanType WriteDistributeCacheIndexes	(	SplayTreeInfo *	registry,
		int	file,
		const size_t	session_key,
		ExceptionInfo *	exception
	)			[static]

References dpc_read(), GetAuthenticIndexQueue(), GetAuthenticPixels(), GetValueFromSplayTree(), _RectangleInfo::height, MagickFalse, MaxTextExtent, SyncAuthenticPixels(), _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.

Referenced by DistributePixelCacheClient().

static MagickBooleanType WriteDistributeCachePixels	(	SplayTreeInfo *	registry,
		int	file,
		const size_t	session_key,
		ExceptionInfo *	exception
	)			[static]

References dpc_read(), GetAuthenticPixels(), GetValueFromSplayTree(), _RectangleInfo::height, MagickFalse, MaxTextExtent, SyncAuthenticPixels(), _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.

Referenced by DistributePixelCacheClient().

MagickPrivate MagickOffsetType WriteDistributePixelCacheIndexes	(	DistributeCacheInfo *	server_info,
		const RectangleInfo *	region,
		const MagickSizeType	length,
		const unsigned char *	indexes
	)

References dpc_send(), _DistributeCacheInfo::file, _RectangleInfo::height, MagickCoreSignature, MaxTextExtent, _DistributeCacheInfo::session_key, _DistributeCacheInfo::signature, _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.

MagickPrivate MagickOffsetType WriteDistributePixelCachePixels	(	DistributeCacheInfo *	server_info,
		const RectangleInfo *	region,
		const MagickSizeType	length,
		const unsigned char *magick_restrict	pixels
	)

References dpc_send(), _DistributeCacheInfo::file, _RectangleInfo::height, MagickCoreSignature, MaxTextExtent, _DistributeCacheInfo::session_key, _DistributeCacheInfo::signature, _RectangleInfo::width, _RectangleInfo::x, and _RectangleInfo::y.