#include <wintirpc.h>
#include <reentrant.h>
#include <sys/types.h>
#include <assert.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <rpc/rpc.h>
#include "rpc_com.h"

Include dependency graph for svc.c:

Classes
struct	svc_callout

Macros
#define	RQCRED_SIZE 400 /* this size is excessive */

#define	SVC_VERSQUIET 0x0001 /* keep quiet about vers mismatch */

#define	version_keepquiet(xp) ((u_long)(xp)->xp_p3 & SVC_VERSQUIET)

#define	max(a, b) (a > b ? a : b)

Functions
static struct svc_callout *	svc_find (rpcprog_t, rpcvers_t, struct svc_callout *, char )

static void	__xprt_do_unregister (SVCXPRT *xprt, bool_t dolock)

void	xprt_register (SVCXPRT *xprt)

void	xprt_unregister (SVCXPRT *xprt)

void	__xprt_unregister_unlocked (SVCXPRT *xprt)

bool_t	svc_reg (SVCXPRT xprt, const rpcprog_t prog, const rpcvers_t vers, void dispatch, const struct netconfig *nconf)

void	svc_unreg (rpcprog_t prog, const rpcvers_t vers) const

bool_t	svc_sendreply (SVCXPRT xprt, xdrproc_t xdr_results, void xdr_location)

void	svcerr_noproc (SVCXPRT *xprt)

void	svcerr_decode (SVCXPRT *xprt)

void	svcerr_systemerr (SVCXPRT *xprt)

void	svcerr_auth (SVCXPRT *xprt, enum auth_stat why)

void	svcerr_weakauth (SVCXPRT *xprt)

void	svcerr_noprog (SVCXPRT *xprt)

void	svcerr_progvers (SVCXPRT *xprt, rpcvers_t low_vers, rpcvers_t high_vers)

void	svc_getreq (int rdfds)

void	svc_getreqset (fd_set *readfds)

void	svc_getreq_common (SOCKET fd)

void	svc_getreq_poll (struct pollfd *pfdp, int pollretval)

bool_t	rpc_control (int what, void *arg)

Variables
static struct svc_callout *	svc_head

rwlock_t	svc_lock

rwlock_t	svc_fd_lock

Macro Definition Documentation

#define max	(	a,
		b
	)	(a > b ? a : b)

Definition at line 63 of file svc.c.

Referenced by __ext4_ext_check(), basic_filebuf< _CharT, _Traits >::_M_allocate_buffers(), _M_append_sum(), _M_append_sum_pos(), vector< CTestInfo >::_M_compute_next_size(), __BVECTOR_QUALIFIED::_M_fill_insert(), _Deque_base< _Tp, _Alloc >::_M_initialize_map(), deque< _Tp, >::_M_reallocate_map(), basic_filebuf< _CharT, _Traits >::_M_setup_codecvt(), _mesa_get_format_max_bits(), _mesa_max_buffer_index(), _mesa_pack_rgba_span_float(), _mesa_scale_and_bias_depth_uint(), _readex_expect_async(), _S_apply_to_pieces(), _Stl_expand_array(), _Strftime(), _tnl_draw_prims(), _tpopen(), AbbrevStr(), ACTION_RecurseSearchDirectory(), action_RegDeleteTreeA(), add_chunk(), add_dir_child(), add_func_desc(), add_index(), add_line_to_buffer(), add_name(), add_option(), add_var_desc(), KeyTranslator::AddGlobalDef(), AddRun(), adns__findlabel_start(), adns__update_expires(), af_glyph_hints_align_strong_points(), af_latin_hints_link_segments(), alloc_user_entry(), append_data(), arc2polybezier(), arial_enum_proc(), arial_enum_procw(), Array_indexOf(), ata_check_unit(), ata_send_ioctl(), AtaSetTransferMode(), AVIFILE_ReadBlock(), balance_data_chunk(), bdf_cmap_char_index(), bdf_cmap_char_next(), bezier_deviation_squared(), bitmap_info_size(), BlpDeviceCompare(), Brush(), calc_thumb_dimensions(), Mapdesc::calcPartialVelocity(), calculate_dds_file_size(), calculate_dds_surface_size(), CalculateBitmapSize(), CBDropDown(), CC_PaintLumBar(), CC_RGBtoHSL(), CdRomDeviceControlDispatch(), CdRomInitDevice(), CdRomPickDvdRegion(), NumPutGetTest::check_get_float(), check_height_font_enumproc(), check_ilhead_data(), check_index_bounds(), check_keywords(), check_output_buffer_space(), check_with_margin(), CheckListWndProc(), ChildWndProc(), choose_font(), ClassInterpretSenseInfo(), ClassSendDeviceIoControlSynchronous(), clean_space_cache_chunk(), ClipOrCenterRectToMonitor(), CmpInitializeHive(), CmpOpenHiveFiles(), co_IntGetScrollBarInfo(), co_IntSetScrollInfo(), co_WinPosGetMinMaxInfo(), codeview_add_type(), color_key_arbfp(), ColorRGBToHLS(), ColorsProc(), CombineRgn(), COMBOEX_ReSize(), CompBattGetBatteryInformation(), CompositeMonikerMarshalImpl_UnmarshalInterface(), compress2(), ComputeCompatibleFormat(), CUiWindow< CStatusBar >::ComputeContentBounds(), CUiSplitPanel::ComputeContentBounds(), CUiMeasure::ComputeMeasure(), CUiBox::ComputeMinimalSize(), CUiSplitPanel::ComputeMinimalSize(), ConCfgReadUserSettings(), ConDrvReadConsole(), ConDrvSetConsoleCursorInfo(), ConioGetIntersection(), ConioGetUnion(), ConioWriteConsole(), CONSOLE_SCREEN_BUFFER_Initialize(), ConSrvApplyUserSettings(), ConSrvReadUserSettings(), ConSrvTermReadStream(), cp2range(), cpu_blitter_clear(), create_child_window(), create_taskdialog_template(), CreateProcessInternalW(), CRYPT_AsnDecodeMaximum(), CRYPT_AsnDecodeSequence(), CRYPT_LMhash(), ctrl_container_resize(), ctrl_resize(), CURSORICON_GetCursorDataFromBMI(), customctrl_resize(), d3d8_device_prepare_index_buffer(), d3d8_device_prepare_vertex_buffer(), d3d9_device_prepare_index_buffer(), d3d9_device_prepare_vertex_buffer(), d3d_device_prepare_index_buffer(), d3d_device_prepare_vertex_buffer(), d3d_execute_buffer_SetExecuteData(), d3drm_array_reserve(), d3dx9_base_effect_get_int(), d3dx9_base_effect_set_vector(), D3DXCheckTextureRequirements(), D3DXCheckVolumeTextureRequirements(), D3DXSHRotateZ(), DATETIME_IncreaseField(), ddraw_find_decl(), ddraw_surface_create(), DECLARE_INTERFACE_(), DefWndDoSizeMove(), DefWndHandleWindowPosChanging(), DefWndStartSizeMove(), KeyTranslator::DeleteAllDefs(), DequeueFreeTransferPacket(), device_clear_render_targets(), device_get_fvf_declaration(), devinst_RegDeleteTreeW(), DIALOG_NEW_DlgProc(), DIB_BitmapInfoSize(), DispatchEx_GetDispID(), DispatchEx_InvokeEx(), DispCallFunc(), TMapLoader::Display(), Display_OnVScroll(), do_write_file(), dotest_spi_iconhorizontalspacing(), dotest_spi_iconverticalspacing(), DPA_CreateEx(), DPA_DeletePtr(), DPA_Grow(), draw_chunk_bar_V(), DrawTextFromClipboard(), CImgAreaWindow::drawZoomFrame(), DrvLineTo(), DSA_Create(), EDIT_AdjustFormatRect(), EDIT_BuildLineDefs_ML(), EDIT_ConfinePoint(), EDIT_EM_LineScroll_internal(), EDIT_EM_Scroll(), EDIT_GetLineRect(), EDIT_PaintLine(), EDIT_WM_Copy(), EDIT_WM_Paint(), EMFDRV_ArcChordPie(), EMFDRV_ExtTextOut(), EMFDRV_LineTo(), EMFDRV_UpdateBBox(), EngLineTo(), enum_font_data_proc(), enum_fullname_data_proc(), enum_ms_shell_dlg2_proc(), enum_ms_shell_dlg_proc(), Erase(), expr_common_type(), ext4_ext_max_entries(), Fast486FpuAdd(), fdi_Zipinflate_codes(), FILEDLG95_LOOKIN_Init(), fill_ip4routetable(), FillTMEx(), FilterInstanceSetup(), find_arb_pshader(), find_arb_vshader(), find_builtin_prop(), find_entry_by_id(), find_entry_by_name(), find_glsl_pshader(), find_glsl_vshader(), find_html_symbol(), find_new_dup_stripes(), find_pe_resource(), FindFonts(), FindMUIEntriesOfPage(), FindMUIErrorEntries(), FindMUIStringEntries(), NumPutGetTest::fix_float_long(), FloatDown(), flush_partial_stripe(), format_insert(), format_string(), FormatMessageA(), FormatMessageW(), FrLdrHeapAllocateEx(), FsdSetFsLabelInformation(), GdipCreateLineBrushFromRect(), GdipGetPathWorldBounds(), get_builtin_func(), get_builtin_id(), get_constants_desc(), get_dir_last_child(), get_escaped_string(), get_geoinfo_dataptr(), get_nextvalue(), get_olemisc_value(), get_points_bounds(), get_pointsize_minmax(), get_selection_rect(), get_superblock_size(), get_table_size(), get_tag_desc(), get_target_info(), get_vertical_line_count(), CMenuBand::GetBandInfo(), GetClipboardDataDimensions(), GetDeviceData(), CSysPagerWnd::GetSize(), GraphCtrl_InvalidateCtrl(), GreGradientFill(), grow_output_buffer(), GuiConsoleHandleScroll(), GuiConsoleUpdateSelection(), guiProgress(), gxv_kern_subtable_fmt3_validate(), gz_comp(), gz_load(), handle_readdir(), hash_table_destroy(), HEADER_ChangeItemOrder(), HEXEDIT_Update(), HistoryRecallHistory(), HLPFILE_Uncompress_Phrases40(), IAVIStream_fnWrite(), ICSeqCompressFrameStart(), IdeSendCommand(), IFileDialog2_fnSetFileTypeIndex(), III_dequantize_sample(), IKsPin_PrepareStreamHeader(), image_list_init(), ImageList_Create(), IMAGELIST_InternalExpandBitmaps(), ImageList_Merge(), IncreaseMftSize(), inflate_table(), TConfig::init_aliases(), init_argb_conversion_info(), InitD3D9ResourceManager(), CACLCustomMRU::Initialize(), InitializeContextEx(), InitializePool(), InitMetrics(), __BVECTOR_QUALIFIED::insert(), InstallEngineTiming_GetInstallProgress(), IntCalculateThumb(), IntEngGradientFillRect(), IntEngLineTo(), IntEngPolyline(), IntersectRect(), IntGdiLineTo(), IntGdiPolygon(), IntHideMousePointer(), IntMapWindowPoints(), IntRectangle(), IntRoundRect(), IntScrollDrawSizeGrip(), IntScrollGetScrollBarRect(), IntShowMousePointer(), IoGetDeviceInterfaces(), IPropertyStorage_fnWriteMultiple(), is_comctl32_class(), is_cp_event(), iterator_frameditems_absolute(), KeSetTimeIncrement(), layout_merge_segments(), layout_recall_merge(), LayoutProc(), LineInputRecallHistory(), CUSBQueue::LinkInterruptQueueHead(), LISTBOX_FindFileStrPos(), LISTBOX_FindStringPos(), LISTBOX_GetMaxTopIndex(), LISTBOX_MoveCaret(), LISTBOX_SetTopItem(), LISTBOX_WindowProc(), ListBoxWndProc_common(), LISTVIEW_AddGroupSelection(), LISTVIEW_CalculateItemHeight(), LISTVIEW_CalculateItemWidth(), LISTVIEW_GetAreaRect(), LISTVIEW_GetCountPerColumn(), LISTVIEW_GetCountPerRow(), LISTVIEW_GetItemMetrics(), LISTVIEW_MarqueeHighlight(), LISTVIEW_Notify(), LISTVIEW_RedrawItems(), LISTVIEW_SetColumnWidth(), LISTVIEW_SetGroupSelection(), LISTVIEW_SetItemCount(), LISTVIEW_UpdateHScroll(), LISTVIEW_UpdateSize(), LISTVIEW_UpdateVScroll(), load_cube_texture_from_dds(), load_texture_from_dds(), load_volume_texture_from_dds(), LoadIniFile(), log_file(), TMapLoader::LookForPart(), KeyTranslator::LookOnGlobal(), lookup_assembly(), lookup_style_tbl(), MACRO_CreateButton(), MainWndProc(), MapWindowPoints(), Math_max(), MaxTest::max1(), MaxTest::max2(), ME_BeginRow(), ME_DrawParaDecoration(), ME_DrawParagraph(), ME_DrawTableBorders(), ME_HandleMessage(), ME_InsertRowStart(), ME_PostSetScrollRangeVisibility(), ME_ProtectPartialTableDeletion(), ME_RunOfsFromCharOfs(), ME_ScrollAbs(), ME_StreamOutRTF(), ME_WmCreate(), ME_WrapMarkedParagraphs(), ME_WrapTextParagraph(), measure_ranges_callback(), memcpy_max(), memp_init(), MENU_CalcItemSize(), MENU_DrawMenuItem(), MENU_MenuBarCalcSize(), MENU_PopupMenuCalcSize(), MenuInit(), MessageBoxTimeoutIndirectW(), METAFILE_AllocateRecord(), METAFILE_GraphicsDeleted(), MFDRV_WriteRecord(), MiEnablePagingOfDriver(), MiFindInitializationCode(), MiInitializeMemoryEvents(), MiLocateKernelSections(), AlgTest::min_max(), MiTrimMemoryConsumer(), MiWriteProtectSystemImage(), mixerGetControlDetailsA(), MmAdjustWorkingSetSize(), MmArmInitSystem(), mmioAdvance(), MmMapViewOfSection(), SelectionModel::ModifyDestRect(), ModifyStatus(), MONTHCAL_SetMaxSelCount(), MONTHCAL_UpdateSize(), move_across_subvols(), mru_RegDeleteTreeA(), MSI_IterateRecords(), MsiEnumComponentCostsW(), MUIDefaultKeyboardLayout(), MUIGetGeoID(), MUIGetLayoutsList(), myRegDeleteTreeA(), myRegDeleteTreeW(), NdrFullPointerQueryRefId(), near_match(), nearest_texel_location(), NEtoSW(), notify_measureitem(), NtGdiEllipse(), NtGdiGetBoundsRect(), NtGdiPolyPolyDraw(), NumPutGetTest::num_put_float(), NWtoSE(), ObpAllocateObject(), on_wm_initdialog(), CAttributesDialog::OnEdit1(), CAttributesDialog::OnEdit2(), OnLink(), CMainWindow::OnLink(), CUiSplitPanel::OnParentSize(), OnScroll(), CGridView::OnVScroll(), OnVScroll(), OptionsProc(), strstreambuf::overflow(), package_RegDeleteTreeW(), PAGER_PositionChildWnd(), paraformat_proc(), parse_ctab_constant_type(), parse_encoding_name(), parse_vertex_colors(), ParseMinMaxQuantifier(), patch_offset_get_filepatches(), patch_offset_get_files(), patch_offset_modify_db(), PATH_CreatePath(), pattern_fork(), pbuf_memfind(), pcf_cmap_char_index(), pcf_cmap_char_next(), pfr_cmap_char_index(), pfr_cmap_char_next(), pfr_face_init(), pfr_lookup_bitmap_data(), poll_isset(), POLYGONFILL_FillScanLineWinding(), POLYGONFILL_MakeEdge(), POLYGONFILL_UpdateScanline(), pool_alloc(), pqDelete(), prepare_raid5_write(), prepare_raid6_write(), PROGRESS_Draw(), PropertyHandler_Level(), protect_superblocks(), ps_dimension_add_t1stem(), ArcTessellator::pwl(), query_reg_path(), QuerySizeFix(), CUSBQueue::QueueHeadInterruptCompletion(), quirk_apple_glsl_constants(), quirk_r200_constants(), ranges_add(), ranges_shift(), RawMountVolume(), read_data_raid5(), read_data_raid6(), read_file(), read_reply(), readerinput_grow(), REBAR_CalcHorzBand(), REBAR_CalcVertBand(), REBAR_LayoutRow(), REBAR_NCCalcSize(), REBAR_SetBandsHeight(), REBAR_ShrinkBandsLTR(), REBAR_ShrinkBandsRTL(), REBAR_SizeChildrenToHeight(), REBAR_ValidateBand(), RECTL_bClipRectBySize(), RECTL_bIntersectRect(), RECTL_bUnionRect(), RecycleBin5_Create(), RegDeleteTreeW(), REGION_CropRegion(), REGION_IntersectO(), REGION_RegionOp(), REGION_SetPolyPolygonRgn(), REGION_UnionRegion(), remove_target_tasks(), Replace(), basic_string< _CharT, _Traits, _Alloc >::reserve(), reserve(), resize_9x(), resize_table(), ResizeTextConsole(), ResizeWnd(), round_child_height(), RpnpEvaluateStack(), RQueryServiceConfig2A(), RQueryServiceConfig2W(), RtlIsTextUnicode(), RtlpClassifyChars(), RtlpCollapsePath(), s_mp_add(), s_mp_sub(), scan_revoke_records(), ScmDeleteRegKey(), ScmSetFailureActions(), SCROLL_GetThumbVal(), scrollbar_test_default(), scrub_chunk(), scrub_chunk_raid56_stripe_run(), scrub_extent(), scrub_extent_raid10(), SdbpGetLongPathName(), set_avg(), set_bumpmat_arbfp(), set_constants(), set_rename_information(), SEtoNW(), SelectionModel::SetSrcAndDestRectFromPoints(), SETUP_CreateInterfaceList(), shader_arb_load_constants_f(), shader_arb_select(), shader_arb_update_float_pixel_constants(), shader_arb_update_float_vertex_constants(), shader_find_free_input_register(), shader_glsl_alloc(), shader_glsl_generate_patch_constant_setup(), shader_glsl_generate_transform_feedback_varyings(), shader_glsl_load_constants(), shader_glsl_pointsize_uniform(), shader_reg_maps_add_tgsm(), shader_set_limits(), SHQueryValueExA(), SHQueryValueExW(), SOFTWARE_GdipDrawThinPath(), source_new(), space_list_add2(), SpiFixupValues(), SpiGetSet(), stabs_find_ref(), StackDropProc(), Defragment::Start(), start_balance(), state_arb_specularenable(), state_pscale(), state_psizemin_arb(), state_psizemin_ext(), state_psizemin_w(), state_texfactor_arbfp(), state_tss_constant_arbfp(), STATUSBAR_ComputeHeight(), STATUSBAR_DrawSizeGrip(), STATUSBAR_SetMinHeight(), sti_compar(), StorageImpl_StreamSetSize(), store_user_dirid(), strstreambuf::strstreambuf(), SubstituteVars(), KeyTranslator::SwitchTo(), SWtoNE(), symt_new_array(), SYSLINK_WrapLine(), system(), T1_Get_Kerning(), TAB_SetItemBounds(), taskdialog_init_button(), tcp_current_ssthresh(), tcp_initialize_rcv_mss(), tcp_moderate_sndbuf(), tcp_recalc_ssthresh(), tcp_select_initial_window(), Subdivider::tessellate(), test_basic_video(), test_boundsrect(), test_CreateIcon(), test_float_limits(), test_format_rect(), test_GetPwrDiskSpindownRange(), test_GetSystemMetrics(), test_GetSystemPreferredUILanguages(), test_GetUserPreferredUILanguages(), test_hotspot(), test_hv_scroll_2(), test_integral_limits(), test_integral_limits_base(), test_marshal_LPSAFEARRAY(), test_mbs_help(), test_not_full(), test_PBM_STEPIT(), test_pen_thickness(), test_rasenum(), test_scroll(), test_scroll_messages(), test_setpos(), test_SHQueryValueEx(), test_SPI_SETNONCLIENTMETRICS(), test_tab(), TestEventConcurrent(), TestEventsGeneration(), TestLockBytes_SetSize(), TestSynchronizeExecution(), tex_bumpenvlum_arbfp(), TEXTMODE_BUFFER_Initialize(), textrange_setend(), texture_apply_base_level(), texture_init(), TIME_SetEventInternal(), TOOLBAR_DrawButton(), TOOLBAR_GetIdealSize(), TOOLBAR_GetImageListCount(), TOOLBAR_LButtonDown(), TOOLBAR_MeasureButton(), TOOLBAR_SetButtonSize(), TOOLTIPS_CalcTipSize(), TOOLTIPS_Show(), TRACKBAR_SetRangeMax(), TransactedSnapshotImpl_StreamWriteAt(), transform_color(), TREEVIEW_Command(), TREEVIEW_EditLabel(), TREEVIEW_EnsureVisible(), TREEVIEW_UpdateDispInfo(), TREEVIEW_UpdateScrollBars(), TREEVIEW_VScroll(), triangle(), TRIO_ARGS2(), TRIO_ARGS5(), tt_face_get_kerning(), type_buffer_alignment(), UDFAddXSpaceBitmap(), UDFCompleteMount(), UDFEjectReqWaiter(), UDFGetDiskInfo(), UDFGetFreeSpace(), UDFLoadLogicalVolInt(), UDFQueryFsFullSizeInfo(), UDFQueryFsSizeInfo(), UDFReadAndProcessFullToc(), UDFReadDiscTrackInfo(), UDFReadEntityID_Domain(), UDFRelocateSector(), UDFRemapPacket(), UDFUnmapRange(), UDFUpdateLogicalVol(), UDFUpdateLogicalVolInt(), UDFUpdateVolIdent(), UDFUseStandard(), UDFVerifyXSpaceBitmap(), UmaMgrInitialize(), uncompress2(), UniataAhciDetect(), UniataAhciSetupCmdPtr(), UniataQueueRequest(), UnionRect(), update_min_band_height(), update_preview_sizes(), update_table_size(), UpdateScrollbox(), UpdateSelection(), CStartButton::UpdateSize(), UpdateWindowScrollState(), USB2_AllocateTimeForEndpoint(), UsbAudioGetDataRanges(), USBPORT_UpdateAllocatedBwTt(), USBSTOR_FdoHandleDeviceRelations(), UserClipCursor(), usp10_array_reserve(), UXTHEME_LoadImage(), validate_indices(), VARIANT_FormatNumber(), VARIANT_UserMarshal(), VerQueryValueW(), vfatMakeFullName(), VGADDI_ComputePointerRect(), VGADDI_IntersectRect(), VGADDIIntersectRect(), VgaMarkForUpdate(), vgaNEtoSW(), vgaNWtoSE(), vgaSEtoNW(), vgaSWtoNE(), VidBiosScrollWindow(), volumetexture_init(), walk_parameter_dep(), warp_check(), WCacheInit__(), weld_dec3n(), weld_float16_2(), weld_float16_4(), weld_float2(), weld_float3(), weld_float4(), weld_short2(), weld_short4(), weld_ubyte4(), weld_udec3(), weld_ushort2n(), weld_ushort4n(), whilePaintingL(), WhoamiGroups(), WhoamiPrintTable(), wined3d_array_reserve(), wined3d_cs_st_require_space(), wined3d_device_update_texture(), wined3d_get_device_caps(), wined3d_sampler_desc_from_sampler_states(), wined3d_swapchain_desc_from_present_parameters(), wined3d_texture_get_level_depth(), wined3d_texture_get_level_height(), wined3d_texture_get_level_pow2_height(), wined3d_texture_get_level_pow2_width(), wined3d_texture_get_level_width(), wined3d_texture_init(), WINHELP_ButtonBoxWndProc(), WINHELP_GetPopupWindowInfo(), WinPosFixupFlags(), WinPosGetMinMaxInfo(), WinPrev_OnDraw(), WndProc(), wnetInit(), write_file2(), write_new_procformatstring_type(), x86_64_find_runtime_function(), xbuf_resize(), xHalExamineMBR(), xHalIoReadPartitionTable(), xHalIoSetPartitionInformation(), xHalIoWritePartitionTable(), xmlParseNmtoken(), xmlParseStringName(), xmlSaveUri(), xmlSplitQName(), xprt_register(), xsltGetProfileInformation(), xsltNumberFormat(), xsltSaveProfiling(), and zoomTo().

#define RQCRED_SIZE 400 /* this size is excessive */

Definition at line 57 of file svc.c.

Referenced by svc_getreq_common().

#define SVC_VERSQUIET 0x0001 /* keep quiet about vers mismatch */

Definition at line 59 of file svc.c.

#define version_keepquiet ( xp ) ((u_long)(xp)->xp_p3 & SVC_VERSQUIET)

Definition at line 60 of file svc.c.

Function Documentation

static void __xprt_do_unregister	(	SVCXPRT *	xprt,
		bool_t	dolock
	)

static

Definition at line 143 of file svc.c.

Referenced by __xprt_unregister_unlocked(), and xprt_unregister().

 {
   SOCKET sock;
 
   assert (xprt != NULL);
 
   sock = xprt->xp_fd;
 
 #ifndef _WIN32
   if (dolock)
     rwlock_wrlock (&svc_fd_lock);
   if ((sock < FD_SETSIZE) && (__svc_xports[sock] == xprt)) {
     __svc_xports[sock] = NULL;
     FD_CLR (sock, &svc_fdset);
     if (sock >= svc_maxfd) {
       for (svc_maxfd--; svc_maxfd >= 0; svc_maxfd--)
         if (__svc_xports[svc_maxfd])
           break;
     }
   }
   if (dolock)
     rwlock_unlock (&svc_fd_lock);
 #else
   fprintf(stderr, "%s: Yikes!  Figure out __svc_xports[] issue!!\n", __FUNCTION__);
 #endif
 }

void __xprt_unregister_unlocked ( SVCXPRT * xprt )

Definition at line 134 of file svc.c.

Referenced by __svc_clean_idle().

 {
   __xprt_do_unregister (xprt, FALSE);
 }

bool_t rpc_control	(	int	what,
		void *	arg
	)

Definition at line 784 of file svc.c.

 {
   int val;
 
   switch (what)
     {
     case RPC_SVC_CONNMAXREC_SET:
       val = *(int *) arg;
       if (val <= 0)
     return FALSE;
       __svc_maxrec = val;
       return TRUE;
     case RPC_SVC_CONNMAXREC_GET:
       *(int *) arg = __svc_maxrec;
       return TRUE;
     default:
       break;
     }
   return FALSE;
 }

static struct svc_callout * svc_find	(	rpcprog_t	prog,
		rpcvers_t	vers,
		struct svc_callout **	prev,
		char *	netid
	)

static

Definition at line 370 of file svc.c.

Referenced by svc_reg(), and svc_unreg().

 {
   struct svc_callout *s, *p;
 
   assert (prev != NULL);
 
   p = NULL;
   for (s = svc_head; s != NULL; s = s->sc_next)
     {
       if (((s->sc_prog == prog) && (s->sc_vers == vers)) &&
       ((netid == NULL) || (s->sc_netid == NULL) ||
        (strcmp (netid, s->sc_netid) == 0)))
     break;
       p = s;
     }
   *prev = p;
   return (s);
 }

void svc_getreq ( int rdfds )

Definition at line 604 of file svc.c.

 {
   fd_set readfds;
 
   FD_ZERO (&readfds);
   //XXX Windows!! readfds.fds_bits[0] = rdfds;
   svc_getreqset (&readfds);
 }

void svc_getreq_common ( SOCKET fd )

Definition at line 641 of file svc.c.

Referenced by clnt_raw_call(), svc_getreq_poll(), and svc_getreqset().

 {
   SVCXPRT *xprt;
   struct svc_req r;
   struct rpc_msg msg;
   int prog_found;
   rpcvers_t low_vers;
   rpcvers_t high_vers;
   enum xprt_stat stat;
   char cred_area[2 * MAX_AUTH_BYTES + RQCRED_SIZE];
 
   msg.rm_call.cb_cred.oa_base = cred_area;
   msg.rm_call.cb_verf.oa_base = &(cred_area[MAX_AUTH_BYTES]);
   r.rq_clntcred = &(cred_area[2 * MAX_AUTH_BYTES]);
 
   rwlock_rdlock (&svc_fd_lock);
   xprt = __svc_xports[fd];
   rwlock_unlock (&svc_fd_lock);
   if (xprt == NULL)
     /* But do we control sock? */
     return;
   /* now receive msgs from xprtprt (support batch calls) */
   do
     {
       if (SVC_RECV (xprt, &msg))
     {
 
       /* now find the exported program and call it */
       struct svc_callout *s;
       enum auth_stat why;
 
       r.rq_xprt = xprt;
       r.rq_prog = msg.rm_call.cb_prog;
       r.rq_vers = msg.rm_call.cb_vers;
       r.rq_proc = msg.rm_call.cb_proc;
       r.rq_cred = msg.rm_call.cb_cred;
       /* first authenticate the message */
       if ((why = _authenticate (&r, &msg)) != AUTH_OK)
         {
           svcerr_auth (xprt, why);
           goto call_done;
         }
       /* now match message with a registered service */
       prog_found = FALSE;
       low_vers = (rpcvers_t) - 1L;
       high_vers = (rpcvers_t) 0L;
       for (s = svc_head; s != NULL; s = s->sc_next)
         {
           if (s->sc_prog == r.rq_prog)
         {
           if (s->sc_vers == r.rq_vers)
             {
               (*s->sc_dispatch) (&r, xprt);
               goto call_done;
             }       /* found correct version */
           prog_found = TRUE;
           if (s->sc_vers < low_vers)
             low_vers = s->sc_vers;
           if (s->sc_vers > high_vers)
             high_vers = s->sc_vers;
         }       /* found correct program */
         }
       /*
        * if we got here, the program or version
        * is not served ...
        */
       if (prog_found)
         svcerr_progvers (xprt, low_vers, high_vers);
       else
         svcerr_noprog (xprt);
       /* Fall through to ... */
     }
       /*
        * Check if the xprt has been disconnected in a
        * recursive call in the service dispatch routine.
        * If so, then break.
        */
       rwlock_rdlock (&svc_fd_lock);
       
       if (xprt != __svc_xports[fd])
     {
       rwlock_unlock (&svc_fd_lock);
       break;
     }
       rwlock_unlock (&svc_fd_lock);
     call_done:
       if ((stat = SVC_STAT (xprt)) == XPRT_DIED)
     {
       SVC_DESTROY (xprt);
       break;
     }
     else if ((xprt->xp_auth != NULL) 
 #ifdef HAVE_LIBGSSAPI
         && (xprt->xp_auth->svc_ah_ops != &svc_auth_gss_ops)
 #endif
     ) {
       xprt->xp_auth = NULL;
     }
     }
   while (stat == XPRT_MOREREQS);
 }

void svc_getreq_poll	(	struct pollfd *	pfdp,
		int	pollretval
	)

Definition at line 745 of file svc.c.

 {
   int i;
   int fds_found;
 
   for (i = fds_found = 0; fds_found < pollretval; i++)
     {
       struct pollfd *p = &pfdp[i];
 
       if (p->revents)
     {
       /* fd has input waiting */
       fds_found++;
       /*
        *      We assume that this function is only called
        *      via someone _select()ing from svc_fdset or
        *      _poll()ing from svc_pollset[].  Thus it's safe
        *      to handle the POLLNVAL event by simply turning
        *      the corresponding bit off in svc_fdset.  The
        *      svc_pollset[] array is derived from svc_fdset
        *      and so will also be updated eventually.
        *
        *      XXX Should we do an xprt_unregister() instead?
        */
       if (p->revents & POLLNVAL)
         {
           rwlock_wrlock (&svc_fd_lock);
           FD_CLR (p->fd, &svc_fdset);
           rwlock_unlock (&svc_fd_lock);
         }
       else
         svc_getreq_common (p->fd);
     }
     }
 }

void svc_getreqset ( fd_set * readfds )

Definition at line 615 of file svc.c.

Referenced by svc_getreq(), and svc_run().

 {
 #ifndef _WIN32
   int bit, fd;
   fd_mask mask, *maskp;
   int sock;
 
   assert (readfds != NULL);
 
   maskp = readfds->fds_bits;
   for (sock = 0; sock < FD_SETSIZE; sock += NFDBITS)
     {
       for (mask = *maskp++; (bit = ffs (mask)) != 0; mask ^= (1 << (bit - 1)))
     {
       /* sock has input waiting */
       fd = sock + bit - 1;
       svc_getreq_common (fd);
     }
     }
 #else
     fprintf(stderr, "%s: Yikes!\n", __FUNCTION__);
 #endif
 }

bool_t svc_reg	(	SVCXPRT *	xprt,
		const rpcprog_t	prog,
		const rpcvers_t	vers,
		void *	dispatch,
		const struct netconfig *	nconf
	)

Definition at line 178 of file svc.c.

Referenced by rpc_reg(), svc_create(), and svc_tp_create().

 {
   bool_t dummy;
   struct svc_callout *prev;
   struct svc_callout *s;
   struct netconfig *tnconf;
   char *netid = NULL;
   int flag = 0;
 
 /* VARIABLES PROTECTED BY svc_lock: s, prev, svc_head */
   if (xprt->xp_netid)
     {
       netid = strdup (xprt->xp_netid);
       flag = 1;
     }
   else if (nconf && nconf->nc_netid)
     {
       netid = strdup (nconf->nc_netid);
       flag = 1;
     }
   else if ((tnconf = __rpcgettp (xprt->xp_fd)) != NULL)
     {
       netid = strdup (tnconf->nc_netid);
       flag = 1;
       freenetconfigent (tnconf);
     }               /* must have been created with svc_raw_create */
   if ((netid == NULL) && (flag == 1))
     {
       return (FALSE);
     }
 
   rwlock_wrlock (&svc_lock);
   if ((s = svc_find (prog, vers, &prev, netid)) != NULL)
     {
       if (netid)
     free (netid);
       if (s->sc_dispatch == dispatch)
     goto rpcb_it;       /* he is registering another xptr */
       rwlock_unlock (&svc_lock);
       return (FALSE);
     }
   s = mem_alloc (sizeof (struct svc_callout));
   if (s == NULL)
     {
       if (netid)
     free (netid);
       rwlock_unlock (&svc_lock);
       return (FALSE);
     }
 
   s->sc_prog = prog;
   s->sc_vers = vers;
   s->sc_dispatch = dispatch;
   s->sc_netid = netid;
   s->sc_next = svc_head;
   svc_head = s;
 
   if ((xprt->xp_netid == NULL) && (flag == 1) && netid)
     ((SVCXPRT *) xprt)->xp_netid = strdup (netid);
 
 rpcb_it:
   rwlock_unlock (&svc_lock);
   /* now register the information with the local binder service */
   if (nconf)
     {
       /*LINTED const castaway */
       dummy = rpcb_set (prog, vers, (struct netconfig *) nconf,
             &((SVCXPRT *) xprt)->xp_ltaddr);
       return (dummy);
     }
   return (TRUE);
 }

bool_t svc_sendreply	(	SVCXPRT *	xprt,
		xdrproc_t	xdr_results,
		void *	xdr_location
	)

Definition at line 399 of file svc.c.

Referenced by _svcauth_gss(), and universal().

 {
   struct rpc_msg rply;
 
   assert (xprt != NULL);
 
   rply.rm_direction = REPLY;
   rply.rm_reply.rp_stat = MSG_ACCEPTED;
   rply.acpted_rply.ar_verf = xprt->xp_verf;
   rply.acpted_rply.ar_stat = SUCCESS;
   rply.acpted_rply.ar_results.where = xdr_location;
   rply.acpted_rply.ar_results.proc = xdr_results;
   return (SVC_REPLY (xprt, &rply));
 }

void svc_unreg	(	rpcprog_t	prog,
		const rpcvers_t	vers
	)		const

Definition at line 260 of file svc.c.

 {
   struct svc_callout *prev;
   struct svc_callout *s;
 
   /* unregister the information anyway */
   (void) rpcb_unset (prog, vers, NULL);
   rwlock_wrlock (&svc_lock);
   while ((s = svc_find (prog, vers, &prev, NULL)) != NULL)
     {
       if (prev == NULL)
     {
       svc_head = s->sc_next;
     }
       else
     {
       prev->sc_next = s->sc_next;
     }
       s->sc_next = NULL;
       if (s->sc_netid)
     mem_free (s->sc_netid, sizeof (s->sc_netid) + 1);
       mem_free (s, sizeof (struct svc_callout));
     }
   rwlock_unlock (&svc_lock);
 }

void svcerr_auth	(	SVCXPRT *	xprt,
		enum auth_stat	why
	)

Definition at line 517 of file svc.c.

Referenced by svc_getreq_common(), and svcerr_weakauth().

 {
   struct rpc_msg rply;
 
   assert (xprt != NULL);
 
   rply.rm_direction = REPLY;
   rply.rm_reply.rp_stat = MSG_DENIED;
   rply.rjcted_rply.rj_stat = AUTH_ERROR;
   rply.rjcted_rply.rj_why = why;
   SVC_REPLY (xprt, &rply);
 }

void svcerr_decode ( SVCXPRT * xprt )

Definition at line 439 of file svc.c.

Referenced by universal().

 {
   struct rpc_msg rply;
 
   assert (xprt != NULL);
 
   rply.rm_direction = REPLY;
   rply.rm_reply.rp_stat = MSG_ACCEPTED;
   rply.acpted_rply.ar_verf = xprt->xp_verf;
   rply.acpted_rply.ar_stat = GARBAGE_ARGS;
   SVC_REPLY (xprt, &rply);
 }

void svcerr_noproc ( SVCXPRT * xprt )

Definition at line 421 of file svc.c.

 {
   struct rpc_msg rply;
 
   assert (xprt != NULL);
 
   rply.rm_direction = REPLY;
   rply.rm_reply.rp_stat = MSG_ACCEPTED;
   rply.acpted_rply.ar_verf = xprt->xp_verf;
   rply.acpted_rply.ar_stat = PROC_UNAVAIL;
   SVC_REPLY (xprt, &rply);
 }

void svcerr_noprog ( SVCXPRT * xprt )

Definition at line 549 of file svc.c.

Referenced by svc_getreq_common().

 {
   struct rpc_msg rply;
 
   assert (xprt != NULL);
 
   rply.rm_direction = REPLY;
   rply.rm_reply.rp_stat = MSG_ACCEPTED;
   rply.acpted_rply.ar_verf = xprt->xp_verf;
   rply.acpted_rply.ar_stat = PROG_UNAVAIL;
   SVC_REPLY (xprt, &rply);
 }

void svcerr_progvers	(	SVCXPRT *	xprt,
		rpcvers_t	low_vers,
		rpcvers_t	high_vers
	)

Definition at line 567 of file svc.c.

Referenced by svc_getreq_common().

 {
   struct rpc_msg rply;
 
   assert (xprt != NULL);
 
   rply.rm_direction = REPLY;
   rply.rm_reply.rp_stat = MSG_ACCEPTED;
   rply.acpted_rply.ar_verf = xprt->xp_verf;
   rply.acpted_rply.ar_stat = PROG_MISMATCH;
   rply.acpted_rply.ar_vers.low = (u_int32_t) low_vers;
   rply.acpted_rply.ar_vers.high = (u_int32_t) high_vers;
   SVC_REPLY (xprt, &rply);
 }

void svcerr_systemerr ( SVCXPRT * xprt )

Definition at line 457 of file svc.c.

 {
   struct rpc_msg rply;
 
   assert (xprt != NULL);
 
   rply.rm_direction = REPLY;
   rply.rm_reply.rp_stat = MSG_ACCEPTED;
   rply.acpted_rply.ar_verf = xprt->xp_verf;
   rply.acpted_rply.ar_stat = SYSTEM_ERR;
   SVC_REPLY (xprt, &rply);
 }

void svcerr_weakauth ( SVCXPRT * xprt )

Definition at line 536 of file svc.c.

 {
 
   assert (xprt != NULL);
 
   svcerr_auth (xprt, AUTH_TOOWEAK);
 }

void xprt_register ( SVCXPRT * xprt )

Definition at line 97 of file svc.c.

Referenced by makefd_xprt(), svc_dg_create(), svc_raw_create(), and svc_vc_create().

 {
   SOCKET sock;
 
   assert (xprt != NULL);
 
   sock = xprt->xp_fd;
 
   rwlock_wrlock (&svc_fd_lock);
   if (__svc_xports == NULL) {
       __svc_xports = (SVCXPRT **) mem_alloc (FD_SETSIZE * sizeof (SVCXPRT *));
       if (__svc_xports == NULL) {
         // XXX Give an error indication?
         return;
       }
       memset (__svc_xports, 0, FD_SETSIZE * sizeof (SVCXPRT *));
   }
 #ifndef _WIN32
   if (sock < FD_SETSIZE) {
     __svc_xports[sock] = xprt;
     FD_SET (sock, &svc_fdset);
     svc_maxfd = max (svc_maxfd, sock);
   }
 #else
   fprintf(stderr, "%s: Yikes!  Figure out __svc_xports[] issue!!\n", __FUNCTION__);
 #endif
   rwlock_unlock (&svc_fd_lock);
 }

void xprt_unregister ( SVCXPRT * xprt )

Definition at line 128 of file svc.c.

Referenced by svc_dg_destroy(), and svc_vc_destroy().

 {
   __xprt_do_unregister (xprt, TRUE);
 }

Variable Documentation

rwlock_t svc_fd_lock

Definition at line 22 of file mt_misc.c.

struct svc_callout * svc_head

static

Referenced by svc_find(), svc_getreq_common(), svc_reg(), and svc_unreg().

rwlock_t svc_lock

Definition at line 19 of file mt_misc.c.

Classes

Macros

Functions

Variables

Macro Definition Documentation

Function Documentation

Variable Documentation