1129fa3d1SAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
3129fa3d1SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
4129fa3d1SAndrew Rist * or more contributor license agreements. See the NOTICE file
5129fa3d1SAndrew Rist * distributed with this work for additional information
6129fa3d1SAndrew Rist * regarding copyright ownership. The ASF licenses this file
7129fa3d1SAndrew Rist * to you under the Apache License, Version 2.0 (the
8129fa3d1SAndrew Rist * "License"); you may not use this file except in compliance
9129fa3d1SAndrew Rist * with the License. You may obtain a copy of the License at
10129fa3d1SAndrew Rist *
11129fa3d1SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
12129fa3d1SAndrew Rist *
13129fa3d1SAndrew Rist * Unless required by applicable law or agreed to in writing,
14129fa3d1SAndrew Rist * software distributed under the License is distributed on an
15129fa3d1SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16129fa3d1SAndrew Rist * KIND, either express or implied. See the License for the
17129fa3d1SAndrew Rist * specific language governing permissions and limitations
18129fa3d1SAndrew Rist * under the License.
19129fa3d1SAndrew Rist *
20129fa3d1SAndrew Rist *************************************************************/
21129fa3d1SAndrew Rist
22129fa3d1SAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_cppu.hxx"
26cdf0e10cSrcweir #include <stdio.h>
27*0618ff6bSPedro Giffuni #include <string.h>
28cdf0e10cSrcweir
29cdf0e10cSrcweir #include <list>
30cdf0e10cSrcweir
31cdf0e10cSrcweir #include <osl/mutex.hxx>
32cdf0e10cSrcweir #include <osl/thread.h>
33cdf0e10cSrcweir #include <osl/diagnose.h>
34cdf0e10cSrcweir
35cdf0e10cSrcweir #include <rtl/process.h>
36cdf0e10cSrcweir #include <rtl/byteseq.hxx>
37cdf0e10cSrcweir
38cdf0e10cSrcweir #include <uno/threadpool.h>
39cdf0e10cSrcweir
40cdf0e10cSrcweir #include "current.hxx"
41cdf0e10cSrcweir
42cdf0e10cSrcweir
43cdf0e10cSrcweir using namespace ::std;
44cdf0e10cSrcweir using namespace ::osl;
45cdf0e10cSrcweir using namespace ::rtl;
46cdf0e10cSrcweir using namespace ::cppu;
47cdf0e10cSrcweir
48cdf0e10cSrcweir
createLocalId(sal_Sequence ** ppThreadId)49cdf0e10cSrcweir static inline void createLocalId( sal_Sequence **ppThreadId )
50cdf0e10cSrcweir {
51*0618ff6bSPedro Giffuni rtl_byte_sequence_constructNoDefault( ppThreadId , sizeof(oslThreadIdentifier) + 16 );
52cdf0e10cSrcweir
53*0618ff6bSPedro Giffuni oslThreadIdentifier hIdent = osl_getThreadIdentifier(0);
54*0618ff6bSPedro Giffuni memcpy((*ppThreadId)->elements, &hIdent, sizeof(oslThreadIdentifier));
55*0618ff6bSPedro Giffuni
56*0618ff6bSPedro Giffuni rtl_getGlobalProcessId( (sal_uInt8 * ) &( (*ppThreadId)->elements[sizeof(oslThreadIdentifier)]) );
57cdf0e10cSrcweir }
58cdf0e10cSrcweir
59cdf0e10cSrcweir
60cdf0e10cSrcweir extern "C" void SAL_CALL
uno_getIdOfCurrentThread(sal_Sequence ** ppThreadId)61cdf0e10cSrcweir uno_getIdOfCurrentThread( sal_Sequence **ppThreadId )
62cdf0e10cSrcweir SAL_THROW_EXTERN_C()
63cdf0e10cSrcweir {
64cdf0e10cSrcweir IdContainer * p = getIdContainer();
65cdf0e10cSrcweir if( ! p->bInit )
66cdf0e10cSrcweir {
67cdf0e10cSrcweir // first time, that the thread enters the bridge
68cdf0e10cSrcweir createLocalId( ppThreadId );
69cdf0e10cSrcweir
70cdf0e10cSrcweir // TODO
71cdf0e10cSrcweir // note : this is a leak !
72cdf0e10cSrcweir p->pLocalThreadId = *ppThreadId;
73cdf0e10cSrcweir p->pCurrentId = *ppThreadId;
74cdf0e10cSrcweir p->nRefCountOfCurrentId = 1;
75cdf0e10cSrcweir rtl_byte_sequence_acquire( p->pLocalThreadId );
76cdf0e10cSrcweir rtl_byte_sequence_acquire( p->pCurrentId );
77cdf0e10cSrcweir p->bInit = sal_True;
78cdf0e10cSrcweir }
79cdf0e10cSrcweir else
80cdf0e10cSrcweir {
81cdf0e10cSrcweir p->nRefCountOfCurrentId ++;
82cdf0e10cSrcweir if( *ppThreadId )
83cdf0e10cSrcweir {
84cdf0e10cSrcweir rtl_byte_sequence_release( *ppThreadId );
85cdf0e10cSrcweir }
86cdf0e10cSrcweir *ppThreadId = p->pCurrentId;
87cdf0e10cSrcweir rtl_byte_sequence_acquire( *ppThreadId );
88cdf0e10cSrcweir }
89cdf0e10cSrcweir }
90cdf0e10cSrcweir
91cdf0e10cSrcweir
uno_releaseIdFromCurrentThread()92cdf0e10cSrcweir extern "C" void SAL_CALL uno_releaseIdFromCurrentThread()
93cdf0e10cSrcweir SAL_THROW_EXTERN_C()
94cdf0e10cSrcweir {
95cdf0e10cSrcweir IdContainer *p = getIdContainer();
96cdf0e10cSrcweir OSL_ASSERT( p );
97cdf0e10cSrcweir OSL_ASSERT( p->nRefCountOfCurrentId );
98cdf0e10cSrcweir
99cdf0e10cSrcweir p->nRefCountOfCurrentId --;
100cdf0e10cSrcweir if( ! p->nRefCountOfCurrentId && (p->pLocalThreadId != p->pCurrentId) )
101cdf0e10cSrcweir {
102cdf0e10cSrcweir rtl_byte_sequence_assign( &(p->pCurrentId) , p->pLocalThreadId );
103cdf0e10cSrcweir }
104cdf0e10cSrcweir }
105cdf0e10cSrcweir
uno_bindIdToCurrentThread(sal_Sequence * pThreadId)106cdf0e10cSrcweir extern "C" sal_Bool SAL_CALL uno_bindIdToCurrentThread( sal_Sequence *pThreadId )
107cdf0e10cSrcweir SAL_THROW_EXTERN_C()
108cdf0e10cSrcweir {
109cdf0e10cSrcweir IdContainer *p = getIdContainer();
110cdf0e10cSrcweir if( ! p->bInit )
111cdf0e10cSrcweir {
112cdf0e10cSrcweir p->pLocalThreadId = 0;
113cdf0e10cSrcweir createLocalId( &(p->pLocalThreadId) );
114cdf0e10cSrcweir p->nRefCountOfCurrentId = 1;
115cdf0e10cSrcweir p->pCurrentId = pThreadId;
116cdf0e10cSrcweir rtl_byte_sequence_acquire( p->pCurrentId );
117cdf0e10cSrcweir p->bInit = sal_True;
118cdf0e10cSrcweir }
119cdf0e10cSrcweir else
120cdf0e10cSrcweir {
121cdf0e10cSrcweir OSL_ASSERT( 0 == p->nRefCountOfCurrentId );
122cdf0e10cSrcweir if( 0 == p->nRefCountOfCurrentId )
123cdf0e10cSrcweir {
124cdf0e10cSrcweir rtl_byte_sequence_assign(&( p->pCurrentId ), pThreadId );
125cdf0e10cSrcweir p->nRefCountOfCurrentId ++;
126cdf0e10cSrcweir }
127cdf0e10cSrcweir else
128cdf0e10cSrcweir {
129cdf0e10cSrcweir return sal_False;
130cdf0e10cSrcweir }
131cdf0e10cSrcweir
132cdf0e10cSrcweir }
133cdf0e10cSrcweir return sal_True;
134cdf0e10cSrcweir }
135