Line data Source code
1 : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : /*************************************************************************
3 : *
4 : * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
5 : *
6 : * Copyright 2000, 2010 Oracle and/or its affiliates.
7 : *
8 : * OpenOffice.org - a multi-platform office productivity suite
9 : *
10 : * This file is part of OpenOffice.org.
11 : *
12 : * OpenOffice.org is free software: you can redistribute it and/or modify
13 : * it under the terms of the GNU Lesser General Public License version 3
14 : * only, as published by the Free Software Foundation.
15 : *
16 : * OpenOffice.org is distributed in the hope that it will be useful,
17 : * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 : * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 : * GNU Lesser General Public License version 3 for more details
20 : * (a copy is included in the LICENSE file that accompanied this code).
21 : *
22 : * You should have received a copy of the GNU Lesser General Public License
23 : * version 3 along with OpenOffice.org. If not, see
24 : * <http://www.openoffice.org/license.html>
25 : * for a copy of the LGPLv3 License.
26 : *
27 : ************************************************************************/
28 :
29 : #ifdef UNIX
30 : #include <sys/stat.h>
31 : #include <sys/socket.h>
32 : #include <sys/types.h>
33 : #include <arpa/inet.h>
34 : #include <netinet/in.h>
35 : #endif //end of UNIX
36 :
37 : #ifdef WNT
38 : #ifdef _MSC_VER
39 : #pragma once
40 : #pragma warning (push,1)
41 : #pragma warning (disable:4668)
42 : #endif
43 : #define WIN32_LEAN_AND_MEAN
44 : #include <windows.h>
45 : #include <winsock2.h>
46 : #include <malloc.h>
47 : #include <memory.h>
48 : #include <tchar.h>
49 : #ifdef _MSC_VER
50 : #pragma warning (pop)
51 : #endif
52 : #endif //end of WNT
53 :
54 : #include <unistd.h>
55 : #include <stdio.h>
56 : #include <stdlib.h>
57 : #include <errno.h>
58 : #include "boost/scoped_array.hpp"
59 :
60 : #include "ns_debug.hxx"
61 : #include "so_msg.hxx"
62 : #include "so_instance.hxx"
63 : #include "so_env.hxx"
64 :
65 : #include "nsp_func.hxx"
66 :
67 : #include "sal/main.h"
68 : #include <sal/macros.h>
69 :
70 : #include "rtl/process.h"
71 : #include "rtl/bootstrap.hxx"
72 : #include "rtl/string.hxx"
73 : #include "rtl/ustrbuf.hxx"
74 :
75 : #include "osl/security.hxx"
76 : #include "osl/thread.hxx"
77 :
78 : #include "cppuhelper/bootstrap.hxx"
79 :
80 :
81 :
82 : #include "com/sun/star/uno/XComponentContext.hpp"
83 : #include "com/sun/star/lang/XMultiServiceFactory.hpp"
84 : #include "com/sun/star/bridge/UnoUrlResolver.hpp"
85 : #include "com/sun/star/bridge/XUnoUrlResolver.hpp"
86 :
87 : #define OUSTR(x) ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM(x) )
88 :
89 : using namespace ::rtl;
90 : using namespace ::osl;
91 : using namespace ::cppu;
92 : using namespace ::com::sun::star;
93 : using namespace ::com::sun::star::uno;
94 :
95 :
96 : #define MAX_NODE_NUM 1024
97 :
98 : SoPluginInstance* lpInstance[MAX_NODE_NUM];
99 :
100 : static NSP_PIPE_FD la_read_fd = 0;
101 : static char const * progdir = NULL;
102 :
103 :
104 0 : long int NSP_ReadFromPipe(NSP_PIPE_FD fp, void* buf, unsigned long int len)
105 : {
106 0 : unsigned long int len_unix = 0, len_wnt = 0;
107 :
108 0 : len_unix = NSP_Read_Pipe(fp, buf, len, &len_wnt);
109 : #ifdef UNIX
110 : (void)len_wnt;
111 0 : return len_unix;
112 : #endif //end of UNIX
113 : #ifdef WNT
114 : (void)len_unix;
115 : return len_wnt;
116 : #endif //end of WNT
117 :
118 : }
119 :
120 0 : int find_free_node()
121 : {
122 0 : for(int i=0; i<MAX_NODE_NUM; i++)
123 : {
124 0 : if(NULL == lpInstance[i])
125 0 : return i;
126 : }
127 0 : return -1;
128 : }
129 :
130 0 : int find_cur_node(long cur_id)
131 : {
132 0 : for(int i=0; i<MAX_NODE_NUM; i++)
133 : {
134 0 : if(lpInstance[i] == NULL)
135 0 : continue;
136 0 : if(cur_id == lpInstance[i]->GetParent())
137 0 : return i;
138 : }
139 0 : return -1;
140 : }
141 :
142 0 : sal_Bool dump_plugin_message(PLUGIN_MSG* pMsg)
143 : {
144 0 : if (!pMsg)
145 0 : return sal_False;
146 : debug_fprintf(NSP_LOG_APPEND, "NSPlugin Message: msg_id:%d; instance_id:%d;wnd_id:%d;wnd_x:%d;wnd_y:%d;wnd_w:%d;wnd_h:%d; url:%s\n",
147 : pMsg->msg_id, pMsg->instance_id, pMsg->wnd_id,
148 0 : pMsg->wnd_x, pMsg->wnd_y, pMsg->wnd_w, pMsg->wnd_h, pMsg->url);
149 0 : return sal_True;
150 : }
151 :
152 0 : int Set_Window(PLUGIN_MSG* pMsg)
153 : {
154 0 : dump_plugin_message(pMsg);
155 : int cur_no;
156 0 : if( -1 == (cur_no = find_cur_node(pMsg->instance_id)))
157 0 : return -1;
158 0 : if(lpInstance[cur_no]->SetWindow(pMsg->wnd_id,
159 0 : pMsg->wnd_x, pMsg->wnd_y, pMsg->wnd_w, pMsg->wnd_h))
160 0 : return 0;
161 : else
162 0 : return -1;
163 : }
164 :
165 0 : int Set_URL(PLUGIN_MSG* pMsg)
166 : {
167 0 : dump_plugin_message(pMsg);
168 : int cur_no;
169 0 : if( -1 == (cur_no = find_cur_node(pMsg->instance_id)))
170 0 : return -1;
171 0 : if(lpInstance[cur_no]->SetURL(pMsg->url))
172 0 : return 0;
173 : else
174 0 : return -1;
175 : }
176 :
177 0 : int New_Instance(PLUGIN_MSG* pMsg, Reference< lang::XMultiServiceFactory > xMSF)
178 : {
179 0 : dump_plugin_message(pMsg);
180 : int free_no;
181 0 : if( -1 == (free_no = find_free_node()))
182 0 : return -1;
183 0 : lpInstance[free_no] = new SoPluginInstance(pMsg->instance_id, xMSF);
184 0 : return 0;
185 : }
186 :
187 0 : int Destroy(PLUGIN_MSG* pMsg)
188 : {
189 0 : dump_plugin_message(pMsg);
190 : int cur_no;
191 0 : if( -1 == (cur_no = find_cur_node(pMsg->instance_id)))
192 0 : return -1;
193 0 : if(lpInstance[cur_no] != NULL)
194 : {
195 0 : lpInstance[cur_no]->Destroy();
196 0 : debug_fprintf(NSP_LOG_APPEND, "print by Nsplugin, begin delete.\n");
197 0 : delete(lpInstance[cur_no]);
198 0 : lpInstance[cur_no] = NULL;
199 : }
200 0 : return 0;
201 : }
202 :
203 0 : int Print(PLUGIN_MSG* pMsg)
204 : {
205 0 : dump_plugin_message(pMsg);
206 : int cur_no;
207 0 : if( -1 == (cur_no = find_cur_node(pMsg->instance_id)))
208 0 : return -1;
209 0 : if(lpInstance[cur_no] != NULL)
210 : {
211 0 : lpInstance[cur_no]->Print();
212 : }
213 0 : return 0;
214 : }
215 :
216 0 : int Shutdown()
217 : {
218 0 : for(int cur_no=0; cur_no<MAX_NODE_NUM; cur_no++)
219 : {
220 0 : if(lpInstance[cur_no] == NULL)
221 0 : continue;
222 0 : lpInstance[cur_no]->Destroy();
223 0 : debug_fprintf(NSP_LOG_APPEND, "print by Nsplugin, begin delete.\n");
224 0 : delete(lpInstance[cur_no]);
225 0 : lpInstance[cur_no] = NULL;
226 : }
227 0 : return -1;
228 : }
229 :
230 0 : int dispatchMsg(PLUGIN_MSG* pMsg, Reference< lang::XMultiServiceFactory > xMSF)
231 : {
232 0 : switch(pMsg->msg_id)
233 : {
234 : case SO_SET_WINDOW:
235 0 : return Set_Window(pMsg);
236 : case SO_NEW_INSTANCE:
237 0 : if(xMSF.is())
238 0 : return New_Instance(pMsg, xMSF);
239 : case SO_SET_URL:
240 0 : return Set_URL(pMsg);
241 : case SO_DESTROY:
242 0 : return Destroy(pMsg);
243 : case SO_SHUTDOWN:
244 0 : Shutdown();
245 0 : return -1;
246 : case SO_PRINT:
247 0 : Print(pMsg);
248 0 : return 0;
249 : default:
250 0 : return -1;
251 : }
252 : }
253 :
254 0 : Reference< lang::XMultiServiceFactory > SAL_CALL start_office(NSP_PIPE_FD read_fd)
255 : {
256 0 : Reference< XComponentContext > xRemoteContext;
257 :
258 : try
259 : {
260 0 : OUString aOfficePath;
261 :
262 : #ifdef UNIX
263 : boost::scoped_array< char > exepath(
264 0 : new char[( progdir ? strlen( progdir ) : 0 ) + RTL_CONSTASCII_LENGTH( "/soffice" ) + 1] );
265 0 : if ( progdir )
266 0 : sprintf( exepath.get(), "%s/soffice", progdir );
267 : else
268 0 : sprintf( exepath.get(), "soffice" );
269 0 : if (!rtl_convertStringToUString(
270 0 : &aOfficePath.pData, exepath.get(), strlen(exepath.get()), osl_getThreadTextEncoding(),
271 : (RTL_TEXTTOUNICODE_FLAGS_UNDEFINED_ERROR |
272 : RTL_TEXTTOUNICODE_FLAGS_MBUNDEFINED_ERROR |
273 0 : RTL_TEXTTOUNICODE_FLAGS_INVALID_ERROR)))
274 : {
275 0 : debug_fprintf(NSP_LOG_APPEND,"bad characters in soffice installation path!\n");
276 0 : return Reference< lang::XMultiServiceFactory >(NULL);
277 : }
278 : #endif //end of UNIX
279 : #ifdef WNT
280 : char sPath[NPP_PATH_MAX];
281 : sPath[0] = 0;
282 :
283 : // The quotes will be added in osl_executeProcess
284 : sprintf(sPath, "%s", findSofficeExecutable() );
285 : if (!rtl_convertStringToUString(
286 : &aOfficePath.pData, sPath, strlen(sPath), osl_getThreadTextEncoding(),
287 : (RTL_TEXTTOUNICODE_FLAGS_UNDEFINED_ERROR |
288 : RTL_TEXTTOUNICODE_FLAGS_MBUNDEFINED_ERROR |
289 : RTL_TEXTTOUNICODE_FLAGS_INVALID_ERROR)))
290 : {
291 : debug_fprintf(NSP_LOG_APPEND,"bad characters in soffice installation path!\n");
292 : return Reference< lang::XMultiServiceFactory >(NULL);
293 : }
294 : #endif //end of WNT
295 :
296 : // create default local component context
297 : Reference< XComponentContext > xLocalContext(
298 0 : defaultBootstrap_InitialComponentContext() );
299 0 : if ( !xLocalContext.is() )
300 : {
301 0 : debug_fprintf(NSP_LOG_APPEND,"no local component context!\n");
302 0 : return Reference< lang::XMultiServiceFactory >(NULL);
303 : }
304 :
305 : // env string
306 0 : ::rtl::OUStringBuffer buf;
307 0 : OUString aPath, aPluginPipeName;
308 :
309 0 : if(!Bootstrap::get(OUSTR("BRAND_BASE_DIR"), aPath))
310 : {
311 0 : debug_fprintf(NSP_LOG_APPEND,"failed to get BRAND_BASE_DIR!\n");
312 0 : return Reference< lang::XMultiServiceFactory >(NULL);
313 : }
314 :
315 0 : aPluginPipeName = ::rtl::OUString::valueOf( aPath.hashCode() );
316 :
317 : // accept string
318 : OSL_ASSERT( buf.getLength() == 0 );
319 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "--accept=pipe,name=" ) );
320 0 : buf.append( aPluginPipeName ); //user installation path as pipe name
321 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( ";urp;" ) );
322 0 : OUString sConnectStartString( buf.makeStringAndClear() );
323 :
324 : // arguments
325 : OUString args [] = {
326 : OUSTR( "--nologo" ),
327 : OUSTR( "--nodefault" ),
328 : OUSTR( "--nolockcheck" ),
329 : sConnectStartString,
330 0 : };
331 :
332 : // create a URL resolver
333 : Reference< bridge::XUnoUrlResolver > xUrlResolver(
334 0 : bridge::UnoUrlResolver::create( xLocalContext ) );
335 :
336 : // connection string
337 : OSL_ASSERT( buf.getLength() == 0 );
338 0 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM( "uno:pipe,name=" ) );
339 0 : buf.append( aPluginPipeName );
340 : buf.appendAscii( RTL_CONSTASCII_STRINGPARAM(
341 0 : ";urp;StarOffice.ComponentContext" ) );
342 0 : OUString sConnectString( buf.makeStringAndClear() );
343 :
344 : try
345 : {
346 : // try to connect to office, no need to start instance again if office already started
347 : xRemoteContext.set(
348 0 : xUrlResolver->resolve( sConnectString ), UNO_QUERY_THROW );
349 0 : debug_fprintf(NSP_LOG_APPEND, "Staroffice already start\n");
350 0 : return Reference< lang::XMultiServiceFactory >(xRemoteContext->getServiceManager(), UNO_QUERY);
351 : }
352 0 : catch ( const connection::NoConnectException & )
353 : {
354 : }
355 :
356 : // start office process
357 : #ifdef UNIX
358 : // a temporary solution
359 : // in future the process should be started using the osl_executeProcess call
360 0 : int nChildPID = fork();
361 0 : if( ! nChildPID ) // child process
362 : {
363 0 : NSP_Close_Pipe(read_fd);
364 : execl( "/bin/sh",
365 : "/bin/sh",
366 0 : ::rtl::OUStringToOString( aOfficePath, osl_getThreadTextEncoding() ).getStr(),
367 0 : ::rtl::OUStringToOString( args[0], osl_getThreadTextEncoding() ).getStr(),
368 0 : ::rtl::OUStringToOString( args[1], osl_getThreadTextEncoding() ).getStr(),
369 0 : ::rtl::OUStringToOString( args[2], osl_getThreadTextEncoding() ).getStr(),
370 0 : ::rtl::OUStringToOString( args[3], osl_getThreadTextEncoding() ).getStr(),
371 0 : NULL);
372 0 : _exit(255);
373 : }
374 : #else
375 : (void) read_fd; /* avoid warning about unused parameter */
376 : Security sec;
377 : oslProcess hProcess = 0;
378 : rtl_uString * ar_args [] = {
379 : args[ 0 ].pData,
380 : args[ 1 ].pData,
381 : args[ 2 ].pData,
382 : args[ 3 ].pData,
383 : };
384 :
385 : oslProcessError rc = osl_executeProcess(
386 : aOfficePath.pData,
387 : ar_args,
388 : SAL_N_ELEMENTS( ar_args ),
389 : osl_Process_DETACHED,
390 : sec.getHandle(),
391 : 0, // => current working dir
392 : 0,
393 : 0, // => no env vars
394 : &hProcess );
395 : switch ( rc )
396 : {
397 : case osl_Process_E_None:
398 : osl_freeProcessHandle( hProcess );
399 : break;
400 : default:
401 : debug_fprintf(NSP_LOG_APPEND, "unmapped error!\n");
402 : return Reference< lang::XMultiServiceFactory >(NULL);
403 : }
404 : #endif
405 :
406 : // wait until office is started
407 0 : for ( int i = 0; i < 240 /* stop the connection after 240 * 500ms */; ++i )
408 : {
409 : try
410 : {
411 : // try to connect to office
412 : xRemoteContext.set(
413 0 : xUrlResolver->resolve( sConnectString ), UNO_QUERY_THROW );
414 0 : return Reference< lang::XMultiServiceFactory >(xRemoteContext->getServiceManager(), UNO_QUERY);
415 : }
416 0 : catch ( const connection::NoConnectException & )
417 : {
418 : // wait 500 ms, then try to connect again
419 0 : TimeValue tv = { 0 /* secs */, 500000000 /* nanosecs */ };
420 0 : ::osl::Thread::wait( tv );
421 : }
422 : }
423 0 : debug_fprintf(NSP_LOG_APPEND, "Failed to connect to Staroffice in 2 minutes\n");
424 0 : return Reference< lang::XMultiServiceFactory >(NULL);
425 : }
426 0 : catch (const Exception & e)
427 : {
428 0 : debug_fprintf(NSP_LOG_APPEND, "unexpected UNO exception caught: ");
429 0 : debug_fprintf(NSP_LOG_APPEND, (sal_Char *)e.Message.getStr());
430 0 : return Reference< lang::XMultiServiceFactory >(NULL);
431 0 : }
432 :
433 : }
434 :
435 :
436 0 : SAL_IMPLEMENT_MAIN_WITH_ARGS(argc, argv)
437 : {
438 : // Sleep(20*1000);
439 0 : debug_fprintf(NSP_LOG_APPEND, "start of main\n");
440 0 : memset(lpInstance, 0, sizeof(lpInstance));
441 :
442 : // MessageBox( NULL, "nsplugin has been started", "Info", MB_OK );
443 :
444 : NSP_PIPE_FD fd_pipe[2];
445 : int iPipe[2];
446 0 : if(argc < 3)
447 : {
448 0 : debug_fprintf(NSP_LOG_APPEND, "print by nsplugin, command error; too little argument to start plugin exec\n");
449 0 : return EXIT_FAILURE;
450 : }
451 0 : iPipe[0] = atoi(argv[1]);
452 0 : iPipe[1] = atoi(argv[2]);
453 :
454 : // fd_pipe[0]: read, fd_pipe[0]: write
455 0 : fd_pipe[0] = (NSP_PIPE_FD) iPipe[0] ;
456 0 : fd_pipe[1] = (NSP_PIPE_FD) iPipe[1] ;
457 0 : NSP_Close_Pipe(fd_pipe[1]);
458 :
459 0 : if(iPipe[0] < 0)
460 : {
461 0 : debug_fprintf(NSP_LOG_APPEND, "print by nsplugin, command error: bad read file id:%s \n", iPipe[0]);
462 0 : return 0;
463 : }
464 0 : la_read_fd = fd_pipe[0];
465 :
466 : // the program path is provided only on unix, on windows the registry entry is used
467 0 : if ( argc > 4 )
468 0 : progdir = argv[4];
469 :
470 0 : Reference< lang::XMultiServiceFactory > xFactory = start_office(la_read_fd);
471 0 : if(!xFactory.is())
472 : {
473 0 : NSP_Close_Pipe(la_read_fd);
474 0 : return -1;
475 : }
476 : PLUGIN_MSG nMsg;
477 : int len;
478 0 : while(1)
479 : {
480 0 : memset(&nMsg, 0, sizeof(PLUGIN_MSG));
481 0 : len = NSP_ReadFromPipe(la_read_fd, (char*)&nMsg, sizeof(PLUGIN_MSG));
482 0 : if(len != sizeof(PLUGIN_MSG))
483 0 : break;
484 0 : debug_fprintf(NSP_LOG_APPEND, "Read message from pipe type %d \n", nMsg.msg_id);
485 0 : if(-1 == dispatchMsg(&nMsg, xFactory))
486 : {
487 0 : debug_fprintf(NSP_LOG_APPEND, "plugin will shutdown\n");
488 0 : break;
489 : }
490 : }
491 0 : NSP_Close_Pipe(la_read_fd);
492 0 : _exit(0);
493 : #ifndef _MSC_VER
494 0 : return EXIT_SUCCESS; // avoid warnings
495 : #endif
496 : }
497 :
498 : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
