+++ /dev/null
-/* $Id$
- * CORBA/ORBit server side of File object, ran by sandbox_child()
- * Copyright (C) 2003 Jan Kratochvil <project-captive@jankratochvil.net>
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; exactly version 2 of June 1991 is required
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
- */
-
-
-#include "config.h"
-
-#include "server-File.h" /* self */
-#include "sandbox.h"
-#include <glib/gmessages.h>
-#include "captive/macros.h"
-#include "split.h"
-#include "FileInfo.h"
-
-
-static void impl_Captive_File_fini(impl_POA_Captive_File *servant,CORBA_Environment *ev);
-static void impl_Captive_File_read(impl_POA_Captive_File *servant,Captive_Bytes **buffer,
- const Captive_GnomeVFSFileSize num_bytes,CORBA_Environment *ev);
-static void impl_Captive_File_write(impl_POA_Captive_File *servant,
- const Captive_Bytes *buffer,Captive_GnomeVFSFileSize *bytes_written_return,CORBA_Environment *ev);
-static void impl_Captive_File_seek(impl_POA_Captive_File *servant,
- const Captive_GnomeVFSSeekPosition whence,const Captive_GnomeVFSFileOffset offset,CORBA_Environment *ev);
-static void impl_Captive_File_tell
- (impl_POA_Captive_File *servant,Captive_GnomeVFSFileOffset *offset_return,CORBA_Environment *ev);
-static void impl_Captive_File_remove(impl_POA_Captive_File *servant,CORBA_Environment *ev);
-static void impl_Captive_File_file_info_get
- (impl_POA_Captive_File *servant,Captive_GnomeVFSFileInfo **file_info,CORBA_Environment *ev);
-static void impl_Captive_File_file_info_set(impl_POA_Captive_File *servant,
- const Captive_GnomeVFSFileInfo *file_info,const Captive_GnomeVFSSetFileInfoMask mask,CORBA_Environment *ev);
-static void impl_Captive_File_truncate
- (impl_POA_Captive_File *servant,const Captive_GnomeVFSFileSize file_size,CORBA_Environment *ev);
-static void impl_Captive_File_move
- (impl_POA_Captive_File *servant,const CORBA_char *pathname_new,const CORBA_boolean force_replace,CORBA_Environment *ev);
-static void impl_Captive_File_shutdown(impl_POA_Captive_File *servant,CORBA_Environment *ev);
-
-
-static PortableServer_ServantBase__epv impl_Captive_File_base_epv={
- NULL, /* _private data */
- (gpointer)&impl_Captive_File_fini, /* finalize routine */
- NULL, /* default_POA routine */
- };
-static POA_Captive_File__epv impl_Captive_File_epv={
- NULL, /* _private */
- (gpointer)&impl_Captive_File_read,
- (gpointer)&impl_Captive_File_write,
- (gpointer)&impl_Captive_File_seek,
- (gpointer)&impl_Captive_File_tell,
- (gpointer)&impl_Captive_File_remove,
- (gpointer)&impl_Captive_File_file_info_get,
- (gpointer)&impl_Captive_File_file_info_set,
- (gpointer)&impl_Captive_File_truncate,
- (gpointer)&impl_Captive_File_move,
- (gpointer)&impl_Captive_File_shutdown,
- };
-static POA_Captive_File__vepv impl_Captive_File_vepv={
- &impl_Captive_File_base_epv,
- &impl_Captive_File_epv,
- };
-
-
-Captive_File impl_Captive_File__create(PortableServer_POA poa,CORBA_Environment *ev)
-{
-Captive_File retval;
-impl_POA_Captive_File *newservant;
-PortableServer_ObjectId *objid;
-
- captive_new0(newservant); /* FIXME: leak */
- newservant->servant.vepv=&impl_Captive_File_vepv;
- newservant->poa=poa;
- newservant->captive_file_object=NULL;
- POA_Captive_File__init((PortableServer_Servant)newservant,ev);
- objid=PortableServer_POA_activate_object(poa,newservant,ev);
- CORBA_free(objid);
- retval=PortableServer_POA_servant_to_reference(poa,newservant,ev);
-
- return retval;
-}
-
-
-static void impl_Captive_File_fini(impl_POA_Captive_File *servant,CORBA_Environment *ev)
-{
- if (servant->captive_file_object) {
- g_object_unref(servant->captive_file_object);
- servant->captive_file_object=NULL;
- }
-}
-
-
-static void impl_Captive_File__destroy(impl_POA_Captive_File *servant,CORBA_Environment *ev)
-{
-PortableServer_ObjectId *objid;
-
- objid=PortableServer_POA_servant_to_id(servant->poa,servant,ev);
- PortableServer_POA_deactivate_object(servant->poa,objid,ev);
- CORBA_free(objid);
- impl_Captive_File_fini(servant,ev);
- g_free(servant);
-}
-
-
-Captive_File impl_Captive_Vfs_file_new_open
- (impl_POA_Captive_Vfs *servant,const CORBA_char *pathname,const Captive_GnomeVFSOpenMode mode,CORBA_Environment *ev)
-{
-Captive_File retval;
-impl_POA_Captive_File *retval_servant;
-GnomeVFSResult errvfsresult;
-
- g_return_val_if_fail(servant->captive_vfs_object!=NULL,NULL); /* not yet initialized? */
-
- retval=impl_Captive_File__create(servant->poa,ev);
- if (ev->_major!=CORBA_NO_EXCEPTION)
- return NULL;
-
- retval_servant=PortableServer_POA_reference_to_servant(servant->poa,retval,ev);
- if (ev->_major!=CORBA_NO_EXCEPTION)
- return NULL; /* 'retval' leak */
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_new_open(&retval_servant->captive_file_object,
- servant->captive_vfs_object,pathname,mode))) {
- impl_Captive_File__destroy(retval_servant,ev);
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return NULL;
- }
-
- return retval;
-}
-
-
-Captive_File impl_Captive_Vfs_file_new_create(impl_POA_Captive_Vfs *servant,const CORBA_char *pathname,
- const Captive_GnomeVFSOpenMode mode,const CORBA_boolean exclusive,const CORBA_unsigned_long perm,CORBA_Environment *ev)
-{
-Captive_File retval;
-impl_POA_Captive_File *retval_servant;
-GnomeVFSResult errvfsresult;
-
- g_return_val_if_fail(servant->captive_vfs_object!=NULL,NULL); /* not yet initialized? */
-
- retval=impl_Captive_File__create(servant->poa,ev);
- if (ev->_major!=CORBA_NO_EXCEPTION)
- return NULL;
-
- retval_servant=PortableServer_POA_reference_to_servant(servant->poa,retval,ev);
- if (ev->_major!=CORBA_NO_EXCEPTION)
- return NULL; /* 'retval' leak */
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_new_create(&retval_servant->captive_file_object,
- servant->captive_vfs_object,pathname,mode,exclusive,perm))) {
- impl_Captive_File__destroy(retval_servant,ev);
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return NULL;
- }
-
- return retval;
-}
-
-
-static void impl_Captive_File_read(impl_POA_Captive_File *servant,Captive_Bytes **buffer_corba_return,
- const Captive_GnomeVFSFileSize num_bytes,CORBA_Environment *ev)
-{
-Captive_Bytes *buffer_corba;
-GnomeVFSFileSize bytes_read;
-GnomeVFSResult errvfsresult;
-
- buffer_corba=Captive_Bytes__alloc();
- buffer_corba->_maximum=num_bytes;
- buffer_corba->_length=0;
- buffer_corba->_buffer=Captive_Bytes_allocbuf(buffer_corba->_maximum);
- buffer_corba->_release=TRUE;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_read(servant->captive_file_object,
- buffer_corba->_buffer,num_bytes,&bytes_read))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- Captive_Bytes__freekids(buffer_corba,NULL/* 'd'; meaning? */);
- CORBA_free(buffer_corba);
- return;
- }
-
- buffer_corba->_length=bytes_read;
- *buffer_corba_return=buffer_corba;
-}
-
-
-static void impl_Captive_File_write(impl_POA_Captive_File *servant,
- const Captive_Bytes *buffer_corba,Captive_GnomeVFSFileSize *bytes_written_return,CORBA_Environment *ev)
-{
-GnomeVFSFileSize bytes_written;
-GnomeVFSResult errvfsresult;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_write(servant->captive_file_object,
- buffer_corba->_buffer,buffer_corba->_length,&bytes_written))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-
- *bytes_written_return=bytes_written;
-}
-
-
-static void impl_Captive_File_seek(impl_POA_Captive_File *servant,
- const Captive_GnomeVFSSeekPosition whence,const Captive_GnomeVFSFileOffset offset,CORBA_Environment *ev)
-{
-GnomeVFSResult errvfsresult;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_seek(servant->captive_file_object,whence,offset))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-}
-
-
-static void impl_Captive_File_tell
- (impl_POA_Captive_File *servant,Captive_GnomeVFSFileOffset *offset_return,CORBA_Environment *ev)
-{
-GnomeVFSFileOffset offset_captive;
-GnomeVFSResult errvfsresult;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_tell(servant->captive_file_object,&offset_captive))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-
- *offset_return=offset_captive;
-}
-
-
-static void impl_Captive_File_remove(impl_POA_Captive_File *servant,CORBA_Environment *ev)
-{
-GnomeVFSResult errvfsresult;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_remove(servant->captive_file_object))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-}
-
-
-static void impl_Captive_File_file_info_get
- (impl_POA_Captive_File *servant,Captive_GnomeVFSFileInfo **file_info_corba_return,CORBA_Environment *ev)
-{
-GnomeVFSFileInfo file_info_captive;
-GnomeVFSResult errvfsresult;
-Captive_GnomeVFSFileInfo *file_info_corba;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_file_info_get(servant->captive_file_object,&file_info_captive))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-
- file_info_corba=Captive_GnomeVFSFileInfo__alloc();
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_sandbox_file_info_captive_to_corba(
- file_info_corba,&file_info_captive))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- Captive_GnomeVFSFileInfo__freekids(file_info_corba,NULL/* 'd'; meaning? */);
- CORBA_free(file_info_corba);
- return;
- }
-
- *file_info_corba_return=file_info_corba;
-}
-
-
-static void impl_Captive_File_file_info_set(impl_POA_Captive_File *servant,
- const Captive_GnomeVFSFileInfo *file_info_corba,const Captive_GnomeVFSSetFileInfoMask mask,CORBA_Environment *ev)
-{
-GnomeVFSFileInfo file_info_captive;
-GnomeVFSResult errvfsresult;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_sandbox_file_info_corba_to_captive(
- &file_info_captive,file_info_corba))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_file_info_set(servant->captive_file_object,&file_info_captive,mask))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-}
-
-
-static void impl_Captive_File_truncate
- (impl_POA_Captive_File *servant,const Captive_GnomeVFSFileSize file_size,CORBA_Environment *ev)
-{
-GnomeVFSResult errvfsresult;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_truncate(servant->captive_file_object,file_size))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-}
-
-
-static void impl_Captive_File_move
- (impl_POA_Captive_File *servant,const CORBA_char *pathname_new,const CORBA_boolean force_replace,CORBA_Environment *ev)
-{
-GnomeVFSResult errvfsresult;
-
- if (GNOME_VFS_OK!=(errvfsresult=captive_file_move(servant->captive_file_object,pathname_new,force_replace))) {
- captive_sandbox_child_GnomeVFSResultException_throw(ev,errvfsresult);
- return;
- }
-}
-
-
-static gboolean impl_Captive_File_shutdown_idle(impl_POA_Captive_File *servant /* data */)
-{
- impl_Captive_File__destroy(servant,&captive_corba_ev);
- g_assert(validate_CORBA_Environment(&captive_corba_ev));
-
- return FALSE; /* remove me */
-}
-
-static void impl_Captive_File_shutdown(impl_POA_Captive_File *servant,CORBA_Environment *ev)
-{
-GSource *source;
-
- /* Shutdown 'servant->captive_file_object' synchronously as it may
- * flush its buffers needed to be transferred to our parent.
- */
- impl_Captive_File_fini(servant,&captive_corba_ev);
- g_assert(validate_CORBA_Environment(&captive_corba_ev));
-
- /* Do not call impl_Captive_File__destroy() directly as we would fail
- * to finish this CORBA method call properly.
- * Do not call g_idle_add_full() as it would miss linc main loop.
- * FIXME: STATUS_SHARING_VIOLATION error during batch processing.
- * - probably exclusive access to be changed to shareable one
- */
- source=g_idle_source_new ();
- g_source_set_priority(source,G_PRIORITY_LOW);
- g_source_set_callback(
- source, /* source */
- (GSourceFunc)impl_Captive_File_shutdown_idle, /* func */
- servant, /* data */
- NULL); /* notify */
- g_source_attach(source,
- g_main_loop_get_context(linc_main_get_loop())); /* context; NULL means 'default context' */
- g_source_unref(source);
-}
git://git.jankratochvil.net / captive.git / blobdiff