fork.c File Reference

#include <errno.h>
#include <fcntl.h>
#include <inttypes.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/param.h>
#include <sys/socket.h>
#include <unistd.h>
#include <bstrlib.h>
#include <atalk/adouble.h>
#include <atalk/afp.h>
#include <atalk/asp.h>
#include <atalk/cnid.h>
#include <atalk/dsi.h>
#include <atalk/globals.h>
#include <atalk/logger.h>
#include <atalk/netatalk_conf.h>
#include <atalk/util.h>
#include "ad_cache.h"
#include "dircache.h"
#include "desktop.h"
#include "directory.h"
#include "file.h"
#include "fork.h"
#include "virtual_icon.h"
#include "volume.h"

Macros
#define	ENDBIT(a)   ((a) & 0x80)
#define	UNLOCKBIT(a)   ((a) & 0x01)

Functions
static int	materialize_virtual_icon (struct ofork *ofork)
	Materialize a virtual Icon fork into a real file on disk.
static int	getforkparams (const AFPObj *obj, struct ofork *ofork, uint16_t bitmap, char *buf, size_t *buflen)
static off_t	get_off_t (char **ibuf, int is64)
static int	set_off_t (off_t offset, char *rbuf, int is64)
static int	is_neg (int is64, off_t val)
static int	sum_neg (int is64, off_t offset, off_t reqcount)
static int	fork_setmode (const AFPObj *obj, struct adouble *adp, int eid, int access, int ofrefnum)
int	afp_openfork (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
static void	rfork_invalidate_for_ofork (const struct vol *vol, struct ofork *ofork)
	Invalidate cached rfork data for a file identified by its open fork.
int	afp_setforkparams (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
static int	byte_lock (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen, int is64)
int	afp_bytelock (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	afp_bytelock_ext (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
static int	read_file (const struct ofork *ofork, int eid, off_t offset, char *rbuf, size_t *rbuflen)
	Read *rbuflen bytes from fork at offset.
static int	rfork_cache_serve_from_buf (DSI *dsi, struct dir *cached_entry, char *ibuf, off_t offset, off_t reqcount, int err, size_t *rbuflen)
	Serve resource fork data from Tier 2 cache via DSI framing.
static int	read_fork (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen, int is64)
int	afp_read (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	afp_read_ext (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	afp_flush (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	afp_flushfork (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	afp_syncfork (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	flushfork (struct ofork *ofork)
int	afp_closefork (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
static ssize_t	write_file (struct ofork *ofork, int eid, off_t offset, char *rbuf, size_t rbuflen)
static int	write_fork (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen, int is64)
int	afp_write (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	afp_write_ext (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)
int	afp_getforkparams (AFPObj *obj, char *ibuf, size_t ibuflen, char *rbuf, size_t *rbuflen)

Macro Definition Documentation

ENDBIT

#define ENDBIT

(

a

)

((a) & 0x80)

UNLOCKBIT

#define UNLOCKBIT

(

a

)

((a) & 0x01)

Function Documentation

afp_bytelock()

int afp_bytelock	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_bytelock_ext()

int afp_bytelock_ext	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_closefork()

int afp_closefork	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_flush()

int afp_flush	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_flushfork()

int afp_flushfork	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_getforkparams()

int afp_getforkparams	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_openfork()

int afp_openfork	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_read()

int afp_read	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_read_ext()

int afp_read_ext	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_setforkparams()

int afp_setforkparams	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_syncfork()

int afp_syncfork	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

Bug:

There is a lot to tell about fsync, fdatasync, F_FULLFSYNC. fsync(2) on OSX is implemented differently than on other platforms.

See also

http://mirror.linux.org.au/pub/linux.conf.au/2007/video/talks/278.pdf

afp_write()

int afp_write	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

afp_write_ext()

int afp_write_ext	(	AFPObj *	obj,
		char *	ibuf,
		size_t	ibuflen,
		char *	rbuf,
		size_t *	rbuflen
	)

byte_lock()

static int byte_lock ( AFPObj *  obj, char *  ibuf, size_t  ibuflen, char *  rbuf, size_t *  rbuflen, int  is64  )

static

flushfork()

int flushfork

(

struct ofork *

ofork

)

fork_setmode()

static int fork_setmode ( const AFPObj *  obj, struct adouble *  adp, int  eid, int  access, int  ofrefnum  )

static

get_off_t()

static off_t get_off_t ( char **  ibuf, int  is64  )

static

getforkparams()

static int getforkparams ( const AFPObj *  obj, struct ofork *  ofork, uint16_t  bitmap, char *  buf, size_t *  buflen  )

static

is_neg()

static int is_neg ( int  is64, off_t  val  )

static

materialize_virtual_icon()

static int materialize_virtual_icon ( struct ofork *  ofork )

static

Materialize a virtual Icon fork into a real file on disk.

Creates the physical Icon file, seeds its resource fork with the virtual icon data, sets FinderInfo, and re-opens the fork through ad_open so the ofork has real file descriptors for writing.

Returns

AFP_OK on success, or an AFP error code

read_file()

static int read_file ( const struct ofork *  ofork, int  eid, off_t  offset, char *  rbuf, size_t *  rbuflen  )

static

Read *rbuflen bytes from fork at offset.

Parameters

[in]	ofork	fork handle
[in]	eid	data fork or resource fork entry id
[in]	offset	offset
[in]	rbuf	data buffer
[in,out]	rbuflen	in: number of bytes to read, out: bytes read

Returns

AFP status code

read_fork()

static int read_fork ( AFPObj *  obj, char *  ibuf, size_t  ibuflen, char *  rbuf, size_t *  rbuflen, int  is64  )

static

rfork_cache_serve_from_buf()

static int rfork_cache_serve_from_buf ( DSI *  dsi, struct dir *  cached_entry, char *  ibuf, off_t  offset, off_t  reqcount, int  err, size_t *  rbuflen  )

static

Serve resource fork data from Tier 2 cache via DSI framing.

Shared helper for cache-hit and just-populated cache paths in read_fork(). Handles dsi_readinit/dsi_read/dsi_readdone loop and LRU promotion.

Parameters

[in]	dsi	DSI connection
[in]	cached_entry	dir entry with populated dcache_rfork_buf
[in]	ibuf	DSI write buffer (repurposed from command buffer)
[in]	offset	Starting byte offset in the rfork
[in]	reqcount	Requested byte count
[in]	err	AFP error code (AFPERR_EOF or AFP_OK)
[out]	rbuflen	Output: bytes remaining (set by dsi_read)

Returns

0 on success (goto afp_read_done), -1 on DSI error (goto afp_read_exit)

rfork_invalidate_for_ofork()

static void rfork_invalidate_for_ofork ( const struct vol *  vol, struct ofork *  ofork  )

static

Invalidate cached rfork data for a file identified by its open fork.

Looks up the file's dircache entry via parent DID + name, and invalidates the AD cache (Tier 1 + Tier 2). Used after rfork writes and truncations.

set_off_t()

static int set_off_t ( off_t  offset, char *  rbuf, int  is64  )

static

sum_neg()

static int sum_neg ( int  is64, off_t  offset, off_t  reqcount  )

static

write_file()

static ssize_t write_file ( struct ofork *  ofork, int  eid, off_t  offset, char *  rbuf, size_t  rbuflen  )

static

write_fork()

static int write_fork ( AFPObj *  obj, char *  ibuf, size_t  ibuflen, char *  rbuf, size_t *  rbuflen, int  is64  )

static